session

package
v0.17.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 20, 2025 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const InstrumentationLibrary = "dagger.io/engine.session"

Variables

View Source 
var (
	ErrInvalidLengthGit        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGit          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGit = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthH2C        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowH2C          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupH2C = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPrompt        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrompt          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrompt = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTerminal        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTerminal          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTerminal = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ErrorInfo_ErrorType_name = map[int32]string{
	0: "UNKNOWN",
	1: "INVALID_REQUEST",
	2: "NO_GIT",
	3: "TIMEOUT",
	4: "CREDENTIAL_RETRIEVAL_FAILED",
	5: "CONFIG_RETRIEVAL_FAILED",
}
View Source 
var ErrorInfo_ErrorType_value = map[string]int32{
	"UNKNOWN":                     0,
	"INVALID_REQUEST":             1,
	"NO_GIT":                      2,
	"TIMEOUT":                     3,
	"CREDENTIAL_RETRIEVAL_FAILED": 4,
	"CONFIG_RETRIEVAL_FAILED":     5,
}

Functions

func RegisterGitServer added in v0.17.0 

func RegisterGitServer(s *grpc.Server, srv GitServer)

func RegisterPromptServer added in v0.17.0 

func RegisterPromptServer(s *grpc.Server, srv PromptServer)

func RegisterTerminalServer added in v0.12.0 

func RegisterTerminalServer(s *grpc.Server, srv TerminalServer)

func RegisterTunnelListenerServer 

func RegisterTunnelListenerServer(s *grpc.Server, srv TunnelListenerServer)

Types

type BoolRequest added in v0.17.0 

type BoolRequest struct {
	// the prompt to display to the user
	Prompt string `protobuf:"bytes,1,opt,name=prompt,proto3" json:"prompt,omitempty"`
	// if provided, the prompt will be persisted and not reprompted
	PersistentKey string `protobuf:"bytes,2,opt,name=persistentKey,proto3" json:"persistentKey,omitempty"`
	// the default value to return if the user doesn't respond
	Default bool `protobuf:"varint,3,opt,name=default,proto3" json:"default,omitempty"`
}

func (*BoolRequest) Descriptor added in v0.17.0 

func (*BoolRequest) Descriptor() ([]byte, []int)

func (*BoolRequest) Equal added in v0.17.0 

func (this *BoolRequest) Equal(that interface{}) bool

func (*BoolRequest) GetDefault added in v0.17.0 

func (m *BoolRequest) GetDefault() bool

func (*BoolRequest) GetPersistentKey added in v0.17.0 

func (m *BoolRequest) GetPersistentKey() string

func (*BoolRequest) GetPrompt added in v0.17.0 

func (m *BoolRequest) GetPrompt() string

func (*BoolRequest) GoString added in v0.17.0 

func (this *BoolRequest) GoString() string

func (*BoolRequest) Marshal added in v0.17.0 

func (m *BoolRequest) Marshal() (dAtA []byte, err error)

func (*BoolRequest) MarshalTo added in v0.17.0 

func (m *BoolRequest) MarshalTo(dAtA []byte) (int, error)

func (*BoolRequest) MarshalToSizedBuffer added in v0.17.0 

func (m *BoolRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BoolRequest) ProtoMessage added in v0.17.0 

func (*BoolRequest) ProtoMessage()

func (*BoolRequest) Reset added in v0.17.0 

func (m *BoolRequest) Reset()

func (*BoolRequest) Size added in v0.17.0 

func (m *BoolRequest) Size() (n int)

func (*BoolRequest) String added in v0.17.0 

func (this *BoolRequest) String() string

func (*BoolRequest) Unmarshal added in v0.17.0 

func (m *BoolRequest) Unmarshal(dAtA []byte) error

func (*BoolRequest) XXX_DiscardUnknown added in v0.17.0 

func (m *BoolRequest) XXX_DiscardUnknown()

func (*BoolRequest) XXX_Marshal added in v0.17.0 

func (m *BoolRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BoolRequest) XXX_Merge added in v0.17.0 

func (m *BoolRequest) XXX_Merge(src proto.Message)

func (*BoolRequest) XXX_Size added in v0.17.0 

func (m *BoolRequest) XXX_Size() int

func (*BoolRequest) XXX_Unmarshal added in v0.17.0 

func (m *BoolRequest) XXX_Unmarshal(b []byte) error

type BoolResponse added in v0.17.0 

type BoolResponse struct {
	// the response from the user
	Response bool `protobuf:"varint,1,opt,name=response,proto3" json:"response,omitempty"`
}

func (*BoolResponse) Descriptor added in v0.17.0 

func (*BoolResponse) Descriptor() ([]byte, []int)

func (*BoolResponse) Equal added in v0.17.0 

func (this *BoolResponse) Equal(that interface{}) bool

func (*BoolResponse) GetResponse added in v0.17.0 

func (m *BoolResponse) GetResponse() bool

func (*BoolResponse) GoString added in v0.17.0 

func (this *BoolResponse) GoString() string

func (*BoolResponse) Marshal added in v0.17.0 

func (m *BoolResponse) Marshal() (dAtA []byte, err error)

func (*BoolResponse) MarshalTo added in v0.17.0 

func (m *BoolResponse) MarshalTo(dAtA []byte) (int, error)

func (*BoolResponse) MarshalToSizedBuffer added in v0.17.0 

func (m *BoolResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BoolResponse) ProtoMessage added in v0.17.0 

func (*BoolResponse) ProtoMessage()

func (*BoolResponse) Reset added in v0.17.0 

func (m *BoolResponse) Reset()

func (*BoolResponse) Size added in v0.17.0 

func (m *BoolResponse) Size() (n int)

func (*BoolResponse) String added in v0.17.0 

func (this *BoolResponse) String() string

func (*BoolResponse) Unmarshal added in v0.17.0 

func (m *BoolResponse) Unmarshal(dAtA []byte) error

func (*BoolResponse) XXX_DiscardUnknown added in v0.17.0 

func (m *BoolResponse) XXX_DiscardUnknown()

func (*BoolResponse) XXX_Marshal added in v0.17.0 

func (m *BoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BoolResponse) XXX_Merge added in v0.17.0 

func (m *BoolResponse) XXX_Merge(src proto.Message)

func (*BoolResponse) XXX_Size added in v0.17.0 

func (m *BoolResponse) XXX_Size() int

func (*BoolResponse) XXX_Unmarshal added in v0.17.0 

func (m *BoolResponse) XXX_Unmarshal(b []byte) error

type CredentialInfo added in v0.14.0 

type CredentialInfo struct {
	Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Host     string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
}

func (*CredentialInfo) Descriptor added in v0.14.0 

func (*CredentialInfo) Descriptor() ([]byte, []int)

func (*CredentialInfo) Equal added in v0.14.0 

func (this *CredentialInfo) Equal(that interface{}) bool

func (*CredentialInfo) GetHost added in v0.14.0 

func (m *CredentialInfo) GetHost() string

func (*CredentialInfo) GetPassword added in v0.14.0 

func (m *CredentialInfo) GetPassword() string

func (*CredentialInfo) GetProtocol added in v0.14.0 

func (m *CredentialInfo) GetProtocol() string

func (*CredentialInfo) GetUsername added in v0.14.0 

func (m *CredentialInfo) GetUsername() string

func (*CredentialInfo) GoString added in v0.14.0 

func (this *CredentialInfo) GoString() string

func (*CredentialInfo) Marshal added in v0.14.0 

func (m *CredentialInfo) Marshal() (dAtA []byte, err error)

func (*CredentialInfo) MarshalTo added in v0.14.0 

func (m *CredentialInfo) MarshalTo(dAtA []byte) (int, error)

func (*CredentialInfo) MarshalToSizedBuffer added in v0.14.0 

func (m *CredentialInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CredentialInfo) ProtoMessage added in v0.14.0 

func (*CredentialInfo) ProtoMessage()

func (*CredentialInfo) Reset added in v0.14.0 

func (m *CredentialInfo) Reset()

func (*CredentialInfo) Size added in v0.14.0 

func (m *CredentialInfo) Size() (n int)

func (*CredentialInfo) String added in v0.14.0 

func (this *CredentialInfo) String() string

func (*CredentialInfo) Unmarshal added in v0.14.0 

func (m *CredentialInfo) Unmarshal(dAtA []byte) error

func (*CredentialInfo) XXX_DiscardUnknown added in v0.14.0 

func (m *CredentialInfo) XXX_DiscardUnknown()

func (*CredentialInfo) XXX_Marshal added in v0.14.0 

func (m *CredentialInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CredentialInfo) XXX_Merge added in v0.14.0 

func (m *CredentialInfo) XXX_Merge(src proto.Message)

func (*CredentialInfo) XXX_Size added in v0.14.0 

func (m *CredentialInfo) XXX_Size() int

func (*CredentialInfo) XXX_Unmarshal added in v0.14.0 

func (m *CredentialInfo) XXX_Unmarshal(b []byte) error

type ErrorInfo added in v0.14.0 

type ErrorInfo struct {
	Type    ErrorInfo_ErrorType `protobuf:"varint,1,opt,name=type,proto3,enum=ErrorInfo_ErrorType" json:"type,omitempty"`
	Message string              `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*ErrorInfo) Descriptor added in v0.14.0 

func (*ErrorInfo) Descriptor() ([]byte, []int)

func (*ErrorInfo) Equal added in v0.14.0 

func (this *ErrorInfo) Equal(that interface{}) bool

func (*ErrorInfo) GetMessage added in v0.14.0 

func (m *ErrorInfo) GetMessage() string

func (*ErrorInfo) GetType added in v0.14.0 

func (m *ErrorInfo) GetType() ErrorInfo_ErrorType

func (*ErrorInfo) GoString added in v0.14.0 

func (this *ErrorInfo) GoString() string

func (*ErrorInfo) Marshal added in v0.14.0 

func (m *ErrorInfo) Marshal() (dAtA []byte, err error)

func (*ErrorInfo) MarshalTo added in v0.14.0 

func (m *ErrorInfo) MarshalTo(dAtA []byte) (int, error)

func (*ErrorInfo) MarshalToSizedBuffer added in v0.14.0 

func (m *ErrorInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ErrorInfo) ProtoMessage added in v0.14.0 

func (*ErrorInfo) ProtoMessage()

func (*ErrorInfo) Reset added in v0.14.0 

func (m *ErrorInfo) Reset()

func (*ErrorInfo) Size added in v0.14.0 

func (m *ErrorInfo) Size() (n int)

func (*ErrorInfo) String added in v0.14.0 

func (this *ErrorInfo) String() string

func (*ErrorInfo) Unmarshal added in v0.14.0 

func (m *ErrorInfo) Unmarshal(dAtA []byte) error

func (*ErrorInfo) XXX_DiscardUnknown added in v0.14.0 

func (m *ErrorInfo) XXX_DiscardUnknown()

func (*ErrorInfo) XXX_Marshal added in v0.14.0 

func (m *ErrorInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorInfo) XXX_Merge added in v0.14.0 

func (m *ErrorInfo) XXX_Merge(src proto.Message)

func (*ErrorInfo) XXX_Size added in v0.14.0 

func (m *ErrorInfo) XXX_Size() int

func (*ErrorInfo) XXX_Unmarshal added in v0.14.0 

func (m *ErrorInfo) XXX_Unmarshal(b []byte) error

type ErrorInfo_ErrorType added in v0.14.0 

type ErrorInfo_ErrorType int32
const (
	UNKNOWN                     ErrorInfo_ErrorType = 0
	INVALID_REQUEST             ErrorInfo_ErrorType = 1
	NO_GIT                      ErrorInfo_ErrorType = 2
	TIMEOUT                     ErrorInfo_ErrorType = 3
	CREDENTIAL_RETRIEVAL_FAILED ErrorInfo_ErrorType = 4
	CONFIG_RETRIEVAL_FAILED     ErrorInfo_ErrorType = 5
)

func (ErrorInfo_ErrorType) EnumDescriptor added in v0.14.0 

func (ErrorInfo_ErrorType) EnumDescriptor() ([]byte, []int)

func (ErrorInfo_ErrorType) String added in v0.14.0 

func (x ErrorInfo_ErrorType) String() string

type GitAttachable added in v0.17.0 

type GitAttachable struct {
	UnimplementedGitServer
	// contains filtered or unexported fields
}

func NewGitAttachable added in v0.17.0 

func NewGitAttachable(rootCtx context.Context) GitAttachable

func (GitAttachable) GetConfig added in v0.17.0 

func (s GitAttachable) GetConfig(ctx context.Context, req *GitConfigRequest) (*GitConfigResponse, error)

GetConfig retrieves Git config using the local Git config system. The function has a timeout of 30 seconds and ensures thread-safe execution.

It follows Git's config protocol and error handling: - If Git fails to list config: CONFIG_RETRIEVAL_FAILED - If the command times out: TIMEOUT - If Git is not installed: NO_GIT - If the request is invalid: INVALID_REQUEST

func (GitAttachable) GetCredential added in v0.17.0 

func (s GitAttachable) GetCredential(ctx context.Context, req *GitCredentialRequest) (*GitCredentialResponse, error)

GetCredential retrieves Git credentials for the given request using the local Git credential system. The function has a timeout of 30 seconds and ensures thread-safe execution.

It follows Git's credential helper protocol and error handling: - If Git can't find or execute a helper: CREDENTIAL_RETRIEVAL_FAILED - If a helper returns invalid format or no credentials: Git handles it as a failure (CREDENTIAL_RETRIEVAL_FAILED) - If the command times out: TIMEOUT - If Git is not installed: NO_GIT - If the request is invalid: INVALID_REQUEST

func (GitAttachable) Register added in v0.17.0 

func (s GitAttachable) Register(srv *grpc.Server)

type GitClient added in v0.17.0 

type GitClient interface {
	GetCredential(ctx context.Context, in *GitCredentialRequest, opts ...grpc.CallOption) (*GitCredentialResponse, error)
	GetConfig(ctx context.Context, in *GitConfigRequest, opts ...grpc.CallOption) (*GitConfigResponse, error)
}

GitClient is the client API for Git service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGitClient added in v0.17.0 

func NewGitClient(cc *grpc.ClientConn) GitClient

type GitConfig added in v0.17.0 

type GitConfig struct {
	Entries []*GitConfigEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
}

func (*GitConfig) Descriptor added in v0.17.0 

func (*GitConfig) Descriptor() ([]byte, []int)

func (*GitConfig) Equal added in v0.17.0 

func (this *GitConfig) Equal(that interface{}) bool

func (*GitConfig) GetEntries added in v0.17.0 

func (m *GitConfig) GetEntries() []*GitConfigEntry

func (*GitConfig) GoString added in v0.17.0 

func (this *GitConfig) GoString() string

func (*GitConfig) Marshal added in v0.17.0 

func (m *GitConfig) Marshal() (dAtA []byte, err error)

func (*GitConfig) MarshalTo added in v0.17.0 

func (m *GitConfig) MarshalTo(dAtA []byte) (int, error)

func (*GitConfig) MarshalToSizedBuffer added in v0.17.0 

func (m *GitConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitConfig) ProtoMessage added in v0.17.0 

func (*GitConfig) ProtoMessage()

func (*GitConfig) Reset added in v0.17.0 

func (m *GitConfig) Reset()

func (*GitConfig) Size added in v0.17.0 

func (m *GitConfig) Size() (n int)

func (*GitConfig) String added in v0.17.0 

func (this *GitConfig) String() string

func (*GitConfig) Unmarshal added in v0.17.0 

func (m *GitConfig) Unmarshal(dAtA []byte) error

func (*GitConfig) XXX_DiscardUnknown added in v0.17.0 

func (m *GitConfig) XXX_DiscardUnknown()

func (*GitConfig) XXX_Marshal added in v0.17.0 

func (m *GitConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GitConfig) XXX_Merge added in v0.17.0 

func (m *GitConfig) XXX_Merge(src proto.Message)

func (*GitConfig) XXX_Size added in v0.17.0 

func (m *GitConfig) XXX_Size() int

func (*GitConfig) XXX_Unmarshal added in v0.17.0 

func (m *GitConfig) XXX_Unmarshal(b []byte) error

type GitConfigEntry added in v0.17.0 

type GitConfigEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*GitConfigEntry) Descriptor added in v0.17.0 

func (*GitConfigEntry) Descriptor() ([]byte, []int)

func (*GitConfigEntry) Equal added in v0.17.0 

func (this *GitConfigEntry) Equal(that interface{}) bool

func (*GitConfigEntry) GetKey added in v0.17.0 

func (m *GitConfigEntry) GetKey() string

func (*GitConfigEntry) GetValue added in v0.17.0 

func (m *GitConfigEntry) GetValue() string

func (*GitConfigEntry) GoString added in v0.17.0 

func (this *GitConfigEntry) GoString() string

func (*GitConfigEntry) Marshal added in v0.17.0 

func (m *GitConfigEntry) Marshal() (dAtA []byte, err error)

func (*GitConfigEntry) MarshalTo added in v0.17.0 

func (m *GitConfigEntry) MarshalTo(dAtA []byte) (int, error)

func (*GitConfigEntry) MarshalToSizedBuffer added in v0.17.0 

func (m *GitConfigEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitConfigEntry) ProtoMessage added in v0.17.0 

func (*GitConfigEntry) ProtoMessage()

func (*GitConfigEntry) Reset added in v0.17.0 

func (m *GitConfigEntry) Reset()

func (*GitConfigEntry) Size added in v0.17.0 

func (m *GitConfigEntry) Size() (n int)

func (*GitConfigEntry) String added in v0.17.0 

func (this *GitConfigEntry) String() string

func (*GitConfigEntry) Unmarshal added in v0.17.0 

func (m *GitConfigEntry) Unmarshal(dAtA []byte) error

func (*GitConfigEntry) XXX_DiscardUnknown added in v0.17.0 

func (m *GitConfigEntry) XXX_DiscardUnknown()

func (*GitConfigEntry) XXX_Marshal added in v0.17.0 

func (m *GitConfigEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GitConfigEntry) XXX_Merge added in v0.17.0 

func (m *GitConfigEntry) XXX_Merge(src proto.Message)

func (*GitConfigEntry) XXX_Size added in v0.17.0 

func (m *GitConfigEntry) XXX_Size() int

func (*GitConfigEntry) XXX_Unmarshal added in v0.17.0 

func (m *GitConfigEntry) XXX_Unmarshal(b []byte) error

type GitConfigRequest added in v0.17.0 

type GitConfigRequest struct {
}

func (*GitConfigRequest) Descriptor added in v0.17.0 

func (*GitConfigRequest) Descriptor() ([]byte, []int)

func (*GitConfigRequest) Equal added in v0.17.0 

func (this *GitConfigRequest) Equal(that interface{}) bool

func (*GitConfigRequest) GoString added in v0.17.0 

func (this *GitConfigRequest) GoString() string

func (*GitConfigRequest) Marshal added in v0.17.0 

func (m *GitConfigRequest) Marshal() (dAtA []byte, err error)

func (*GitConfigRequest) MarshalTo added in v0.17.0 

func (m *GitConfigRequest) MarshalTo(dAtA []byte) (int, error)

func (*GitConfigRequest) MarshalToSizedBuffer added in v0.17.0 

func (m *GitConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitConfigRequest) ProtoMessage added in v0.17.0 

func (*GitConfigRequest) ProtoMessage()

func (*GitConfigRequest) Reset added in v0.17.0 

func (m *GitConfigRequest) Reset()

func (*GitConfigRequest) Size added in v0.17.0 

func (m *GitConfigRequest) Size() (n int)

func (*GitConfigRequest) String added in v0.17.0 

func (this *GitConfigRequest) String() string

func (*GitConfigRequest) Unmarshal added in v0.17.0 

func (m *GitConfigRequest) Unmarshal(dAtA []byte) error

func (*GitConfigRequest) XXX_DiscardUnknown added in v0.17.0 

func (m *GitConfigRequest) XXX_DiscardUnknown()

func (*GitConfigRequest) XXX_Marshal added in v0.17.0 

func (m *GitConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GitConfigRequest) XXX_Merge added in v0.17.0 

func (m *GitConfigRequest) XXX_Merge(src proto.Message)

func (*GitConfigRequest) XXX_Size added in v0.17.0 

func (m *GitConfigRequest) XXX_Size() int

func (*GitConfigRequest) XXX_Unmarshal added in v0.17.0 

func (m *GitConfigRequest) XXX_Unmarshal(b []byte) error

type GitConfigResponse added in v0.17.0 

type GitConfigResponse struct {
	// Types that are valid to be assigned to Result:
	//
	//	*GitConfigResponse_Config
	//	*GitConfigResponse_Error
	Result isGitConfigResponse_Result `protobuf_oneof:"result"`
}

func (*GitConfigResponse) Descriptor added in v0.17.0 

func (*GitConfigResponse) Descriptor() ([]byte, []int)

func (*GitConfigResponse) Equal added in v0.17.0 

func (this *GitConfigResponse) Equal(that interface{}) bool

func (*GitConfigResponse) GetConfig added in v0.17.0 

func (m *GitConfigResponse) GetConfig() *GitConfig

func (*GitConfigResponse) GetError added in v0.17.0 

func (m *GitConfigResponse) GetError() *ErrorInfo

func (*GitConfigResponse) GetResult added in v0.17.0 

func (m *GitConfigResponse) GetResult() isGitConfigResponse_Result

func (*GitConfigResponse) GoString added in v0.17.0 

func (this *GitConfigResponse) GoString() string

func (*GitConfigResponse) Marshal added in v0.17.0 

func (m *GitConfigResponse) Marshal() (dAtA []byte, err error)

func (*GitConfigResponse) MarshalTo added in v0.17.0 

func (m *GitConfigResponse) MarshalTo(dAtA []byte) (int, error)

func (*GitConfigResponse) MarshalToSizedBuffer added in v0.17.0 

func (m *GitConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitConfigResponse) ProtoMessage added in v0.17.0 

func (*GitConfigResponse) ProtoMessage()

func (*GitConfigResponse) Reset added in v0.17.0 

func (m *GitConfigResponse) Reset()

func (*GitConfigResponse) Size added in v0.17.0 

func (m *GitConfigResponse) Size() (n int)

func (*GitConfigResponse) String added in v0.17.0 

func (this *GitConfigResponse) String() string

func (*GitConfigResponse) Unmarshal added in v0.17.0 

func (m *GitConfigResponse) Unmarshal(dAtA []byte) error

func (*GitConfigResponse) XXX_DiscardUnknown added in v0.17.0 

func (m *GitConfigResponse) XXX_DiscardUnknown()

func (*GitConfigResponse) XXX_Marshal added in v0.17.0 

func (m *GitConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GitConfigResponse) XXX_Merge added in v0.17.0 

func (m *GitConfigResponse) XXX_Merge(src proto.Message)

func (*GitConfigResponse) XXX_OneofWrappers added in v0.17.0 

func (*GitConfigResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GitConfigResponse) XXX_Size added in v0.17.0 

func (m *GitConfigResponse) XXX_Size() int

func (*GitConfigResponse) XXX_Unmarshal added in v0.17.0 

func (m *GitConfigResponse) XXX_Unmarshal(b []byte) error

type GitConfigResponse_Config added in v0.17.0 

type GitConfigResponse_Config struct {
	Config *GitConfig `protobuf:"bytes,1,opt,name=config,proto3,oneof" json:"config,omitempty"`
}

func (*GitConfigResponse_Config) Equal added in v0.17.0 

func (this *GitConfigResponse_Config) Equal(that interface{}) bool

func (*GitConfigResponse_Config) GoString added in v0.17.0 

func (this *GitConfigResponse_Config) GoString() string

func (*GitConfigResponse_Config) MarshalTo added in v0.17.0 

func (m *GitConfigResponse_Config) MarshalTo(dAtA []byte) (int, error)

func (*GitConfigResponse_Config) MarshalToSizedBuffer added in v0.17.0 

func (m *GitConfigResponse_Config) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitConfigResponse_Config) Size added in v0.17.0 

func (m *GitConfigResponse_Config) Size() (n int)

func (*GitConfigResponse_Config) String added in v0.17.0 

func (this *GitConfigResponse_Config) String() string

type GitConfigResponse_Error added in v0.17.0 

type GitConfigResponse_Error struct {
	Error *ErrorInfo `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
}

func (*GitConfigResponse_Error) Equal added in v0.17.0 

func (this *GitConfigResponse_Error) Equal(that interface{}) bool

func (*GitConfigResponse_Error) GoString added in v0.17.0 

func (this *GitConfigResponse_Error) GoString() string

func (*GitConfigResponse_Error) MarshalTo added in v0.17.0 

func (m *GitConfigResponse_Error) MarshalTo(dAtA []byte) (int, error)

func (*GitConfigResponse_Error) MarshalToSizedBuffer added in v0.17.0 

func (m *GitConfigResponse_Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitConfigResponse_Error) Size added in v0.17.0 

func (m *GitConfigResponse_Error) Size() (n int)

func (*GitConfigResponse_Error) String added in v0.17.0 

func (this *GitConfigResponse_Error) String() string

type GitCredentialRequest added in v0.14.0 

type GitCredentialRequest struct {
	Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Host     string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Path     string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
}

func (*GitCredentialRequest) Descriptor added in v0.14.0 

func (*GitCredentialRequest) Descriptor() ([]byte, []int)

func (*GitCredentialRequest) Equal added in v0.14.0 

func (this *GitCredentialRequest) Equal(that interface{}) bool

func (*GitCredentialRequest) GetHost added in v0.14.0 

func (m *GitCredentialRequest) GetHost() string

func (*GitCredentialRequest) GetPath added in v0.14.0 

func (m *GitCredentialRequest) GetPath() string

func (*GitCredentialRequest) GetProtocol added in v0.14.0 

func (m *GitCredentialRequest) GetProtocol() string

func (*GitCredentialRequest) GoString added in v0.14.0 

func (this *GitCredentialRequest) GoString() string

func (*GitCredentialRequest) Marshal added in v0.14.0 

func (m *GitCredentialRequest) Marshal() (dAtA []byte, err error)

func (*GitCredentialRequest) MarshalTo added in v0.14.0 

func (m *GitCredentialRequest) MarshalTo(dAtA []byte) (int, error)

func (*GitCredentialRequest) MarshalToSizedBuffer added in v0.14.0 

func (m *GitCredentialRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitCredentialRequest) ProtoMessage added in v0.14.0 

func (*GitCredentialRequest) ProtoMessage()

func (*GitCredentialRequest) Reset added in v0.14.0 

func (m *GitCredentialRequest) Reset()

func (*GitCredentialRequest) Size added in v0.14.0 

func (m *GitCredentialRequest) Size() (n int)

func (*GitCredentialRequest) String added in v0.14.0 

func (this *GitCredentialRequest) String() string

func (*GitCredentialRequest) Unmarshal added in v0.14.0 

func (m *GitCredentialRequest) Unmarshal(dAtA []byte) error

func (*GitCredentialRequest) XXX_DiscardUnknown added in v0.14.0 

func (m *GitCredentialRequest) XXX_DiscardUnknown()

func (*GitCredentialRequest) XXX_Marshal added in v0.14.0 

func (m *GitCredentialRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GitCredentialRequest) XXX_Merge added in v0.14.0 

func (m *GitCredentialRequest) XXX_Merge(src proto.Message)

func (*GitCredentialRequest) XXX_Size added in v0.14.0 

func (m *GitCredentialRequest) XXX_Size() int

func (*GitCredentialRequest) XXX_Unmarshal added in v0.14.0 

func (m *GitCredentialRequest) XXX_Unmarshal(b []byte) error

type GitCredentialResponse added in v0.14.0 

type GitCredentialResponse struct {
	// Types that are valid to be assigned to Result:
	//	*GitCredentialResponse_Credential
	//	*GitCredentialResponse_Error
	Result isGitCredentialResponse_Result `protobuf_oneof:"result"`
}

func (*GitCredentialResponse) Descriptor added in v0.14.0 

func (*GitCredentialResponse) Descriptor() ([]byte, []int)

func (*GitCredentialResponse) Equal added in v0.14.0 

func (this *GitCredentialResponse) Equal(that interface{}) bool

func (*GitCredentialResponse) GetCredential added in v0.14.0 

func (m *GitCredentialResponse) GetCredential() *CredentialInfo

func (*GitCredentialResponse) GetError added in v0.14.0 

func (m *GitCredentialResponse) GetError() *ErrorInfo

func (*GitCredentialResponse) GetResult added in v0.14.0 

func (m *GitCredentialResponse) GetResult() isGitCredentialResponse_Result

func (*GitCredentialResponse) GoString added in v0.14.0 

func (this *GitCredentialResponse) GoString() string

func (*GitCredentialResponse) Marshal added in v0.14.0 

func (m *GitCredentialResponse) Marshal() (dAtA []byte, err error)

func (*GitCredentialResponse) MarshalTo added in v0.14.0 

func (m *GitCredentialResponse) MarshalTo(dAtA []byte) (int, error)

func (*GitCredentialResponse) MarshalToSizedBuffer added in v0.14.0 

func (m *GitCredentialResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitCredentialResponse) ProtoMessage added in v0.14.0 

func (*GitCredentialResponse) ProtoMessage()

func (*GitCredentialResponse) Reset added in v0.14.0 

func (m *GitCredentialResponse) Reset()

func (*GitCredentialResponse) Size added in v0.14.0 

func (m *GitCredentialResponse) Size() (n int)

func (*GitCredentialResponse) String added in v0.14.0 

func (this *GitCredentialResponse) String() string

func (*GitCredentialResponse) Unmarshal added in v0.14.0 

func (m *GitCredentialResponse) Unmarshal(dAtA []byte) error

func (*GitCredentialResponse) XXX_DiscardUnknown added in v0.14.0 

func (m *GitCredentialResponse) XXX_DiscardUnknown()

func (*GitCredentialResponse) XXX_Marshal added in v0.14.0 

func (m *GitCredentialResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GitCredentialResponse) XXX_Merge added in v0.14.0 

func (m *GitCredentialResponse) XXX_Merge(src proto.Message)

func (*GitCredentialResponse) XXX_OneofWrappers added in v0.14.0 

func (*GitCredentialResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GitCredentialResponse) XXX_Size added in v0.14.0 

func (m *GitCredentialResponse) XXX_Size() int

func (*GitCredentialResponse) XXX_Unmarshal added in v0.14.0 

func (m *GitCredentialResponse) XXX_Unmarshal(b []byte) error

type GitCredentialResponse_Credential added in v0.14.0 

type GitCredentialResponse_Credential struct {
	Credential *CredentialInfo `protobuf:"bytes,1,opt,name=credential,proto3,oneof" json:"credential,omitempty"`
}

func (*GitCredentialResponse_Credential) Equal added in v0.14.0 

func (this *GitCredentialResponse_Credential) Equal(that interface{}) bool

func (*GitCredentialResponse_Credential) GoString added in v0.14.0 

func (this *GitCredentialResponse_Credential) GoString() string

func (*GitCredentialResponse_Credential) MarshalTo added in v0.14.0 

func (m *GitCredentialResponse_Credential) MarshalTo(dAtA []byte) (int, error)

func (*GitCredentialResponse_Credential) MarshalToSizedBuffer added in v0.14.0 

func (m *GitCredentialResponse_Credential) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitCredentialResponse_Credential) Size added in v0.14.0 

func (m *GitCredentialResponse_Credential) Size() (n int)

func (*GitCredentialResponse_Credential) String added in v0.14.0 

func (this *GitCredentialResponse_Credential) String() string

type GitCredentialResponse_Error added in v0.14.0 

type GitCredentialResponse_Error struct {
	Error *ErrorInfo `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
}

func (*GitCredentialResponse_Error) Equal added in v0.14.0 

func (this *GitCredentialResponse_Error) Equal(that interface{}) bool

func (*GitCredentialResponse_Error) GoString added in v0.14.0 

func (this *GitCredentialResponse_Error) GoString() string

func (*GitCredentialResponse_Error) MarshalTo added in v0.14.0 

func (m *GitCredentialResponse_Error) MarshalTo(dAtA []byte) (int, error)

func (*GitCredentialResponse_Error) MarshalToSizedBuffer added in v0.14.0 

func (m *GitCredentialResponse_Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GitCredentialResponse_Error) Size added in v0.14.0 

func (m *GitCredentialResponse_Error) Size() (n int)

func (*GitCredentialResponse_Error) String added in v0.14.0 

func (this *GitCredentialResponse_Error) String() string

type GitServer added in v0.17.0 

type GitServer interface {
	GetCredential(context.Context, *GitCredentialRequest) (*GitCredentialResponse, error)
	GetConfig(context.Context, *GitConfigRequest) (*GitConfigResponse, error)
}

GitServer is the server API for Git service.

type ListenRequest 

type ListenRequest struct {
	Addr     string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	ConnId   string `protobuf:"bytes,3,opt,name=connId,proto3" json:"connId,omitempty"`
	Data     []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Close    bool   `protobuf:"varint,5,opt,name=close,proto3" json:"close,omitempty"`
}

func (*ListenRequest) Descriptor 

func (*ListenRequest) Descriptor() ([]byte, []int)

func (*ListenRequest) Equal 

func (this *ListenRequest) Equal(that interface{}) bool

func (*ListenRequest) GetAddr 

func (m *ListenRequest) GetAddr() string

func (*ListenRequest) GetClose 

func (m *ListenRequest) GetClose() bool

func (*ListenRequest) GetConnId 

func (m *ListenRequest) GetConnId() string

func (*ListenRequest) GetData 

func (m *ListenRequest) GetData() []byte

func (*ListenRequest) GetProtocol 

func (m *ListenRequest) GetProtocol() string

func (*ListenRequest) GoString 

func (this *ListenRequest) GoString() string

func (*ListenRequest) Marshal 

func (m *ListenRequest) Marshal() (dAtA []byte, err error)

func (*ListenRequest) MarshalTo 

func (m *ListenRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListenRequest) MarshalToSizedBuffer 

func (m *ListenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) Size 

func (m *ListenRequest) Size() (n int)

func (*ListenRequest) String 

func (this *ListenRequest) String() string

func (*ListenRequest) Unmarshal 

func (m *ListenRequest) Unmarshal(dAtA []byte) error

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

func (m *ListenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenRequest) XXX_Merge 

func (m *ListenRequest) XXX_Merge(src proto.Message)

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

func (m *ListenRequest) XXX_Unmarshal(b []byte) error

type ListenResponse 

type ListenResponse struct {
	Addr   string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	ConnId string `protobuf:"bytes,2,opt,name=connId,proto3" json:"connId,omitempty"`
	Data   []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Close  bool   `protobuf:"varint,4,opt,name=close,proto3" json:"close,omitempty"`
}

func (*ListenResponse) Descriptor 

func (*ListenResponse) Descriptor() ([]byte, []int)

func (*ListenResponse) Equal 

func (this *ListenResponse) Equal(that interface{}) bool

func (*ListenResponse) GetAddr 

func (m *ListenResponse) GetAddr() string

func (*ListenResponse) GetClose 

func (m *ListenResponse) GetClose() bool

func (*ListenResponse) GetConnId 

func (m *ListenResponse) GetConnId() string

func (*ListenResponse) GetData 

func (m *ListenResponse) GetData() []byte

func (*ListenResponse) GoString 

func (this *ListenResponse) GoString() string

func (*ListenResponse) Marshal 

func (m *ListenResponse) Marshal() (dAtA []byte, err error)

func (*ListenResponse) MarshalTo 

func (m *ListenResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListenResponse) MarshalToSizedBuffer 

func (m *ListenResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) Reset 

func (m *ListenResponse) Reset()

func (*ListenResponse) Size 

func (m *ListenResponse) Size() (n int)

func (*ListenResponse) String 

func (this *ListenResponse) String() string

func (*ListenResponse) Unmarshal 

func (m *ListenResponse) Unmarshal(dAtA []byte) error

func (*ListenResponse) XXX_DiscardUnknown 

func (m *ListenResponse) XXX_DiscardUnknown()

func (*ListenResponse) XXX_Marshal 

func (m *ListenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenResponse) XXX_Merge 

func (m *ListenResponse) XXX_Merge(src proto.Message)

func (*ListenResponse) XXX_Size 

func (m *ListenResponse) XXX_Size() int

func (*ListenResponse) XXX_Unmarshal 

func (m *ListenResponse) XXX_Unmarshal(b []byte) error

type PromptAttachable added in v0.17.0 

type PromptAttachable struct {
	UnimplementedPromptServer
	// contains filtered or unexported fields
}

func NewPromptAttachable added in v0.17.0 

func NewPromptAttachable(promptHandler PromptHandler) PromptAttachable

func (PromptAttachable) PromptBool added in v0.17.0 

func (p PromptAttachable) PromptBool(ctx context.Context, req *BoolRequest) (*BoolResponse, error)

right now this is hardcoded to allow llm prompts, but could easily be extended to other prompt use cases

func (PromptAttachable) Register added in v0.17.0 

func (p PromptAttachable) Register(srv *grpc.Server)

type PromptClient added in v0.17.0 

type PromptClient interface {
	PromptBool(ctx context.Context, in *BoolRequest, opts ...grpc.CallOption) (*BoolResponse, error)
}

PromptClient is the client API for Prompt service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPromptClient added in v0.17.0 

func NewPromptClient(cc *grpc.ClientConn) PromptClient

type PromptHandler added in v0.17.0 

type PromptHandler interface {
	HandlePrompt(ctx context.Context, prompt string, dest any) error
}

type PromptResponses added in v0.17.0 

type PromptResponses struct {
	// only keyed like this for json marshalling forwards-compatibility
	Responses map[string]struct{} `json:"responses"`
}

PromptResponses manages the list of LLM modules that the user has allowed

type PromptServer added in v0.17.0 

type PromptServer interface {
	PromptBool(context.Context, *BoolRequest) (*BoolResponse, error)
}

PromptServer is the server API for Prompt service.

type Resize added in v0.12.0 

type Resize struct {
	Width  int32 `protobuf:"varint,1,opt,name=Width,proto3" json:"Width,omitempty"`
	Height int32 `protobuf:"varint,2,opt,name=Height,proto3" json:"Height,omitempty"`
}

func (*Resize) Descriptor added in v0.12.0 

func (*Resize) Descriptor() ([]byte, []int)

func (*Resize) Equal added in v0.12.0 

func (this *Resize) Equal(that interface{}) bool

func (*Resize) GetHeight added in v0.12.0 

func (m *Resize) GetHeight() int32

func (*Resize) GetWidth added in v0.12.0 

func (m *Resize) GetWidth() int32

func (*Resize) GoString added in v0.12.0 

func (this *Resize) GoString() string

func (*Resize) Marshal added in v0.12.0 

func (m *Resize) Marshal() (dAtA []byte, err error)

func (*Resize) MarshalTo added in v0.12.0 

func (m *Resize) MarshalTo(dAtA []byte) (int, error)

func (*Resize) MarshalToSizedBuffer added in v0.12.0 

func (m *Resize) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Resize) ProtoMessage added in v0.12.0 

func (*Resize) ProtoMessage()

func (*Resize) Reset added in v0.12.0 

func (m *Resize) Reset()

func (*Resize) Size added in v0.12.0 

func (m *Resize) Size() (n int)

func (*Resize) String added in v0.12.0 

func (this *Resize) String() string

func (*Resize) Unmarshal added in v0.12.0 

func (m *Resize) Unmarshal(dAtA []byte) error

func (*Resize) XXX_DiscardUnknown added in v0.12.0 

func (m *Resize) XXX_DiscardUnknown()

func (*Resize) XXX_Marshal added in v0.12.0 

func (m *Resize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Resize) XXX_Merge added in v0.12.0 

func (m *Resize) XXX_Merge(src proto.Message)

func (*Resize) XXX_Size added in v0.12.0 

func (m *Resize) XXX_Size() int

func (*Resize) XXX_Unmarshal added in v0.12.0 

func (m *Resize) XXX_Unmarshal(b []byte) error

type SessionRequest added in v0.12.0 

type SessionRequest struct {
	// Types that are valid to be assigned to Msg:
	//	*SessionRequest_Stdout
	//	*SessionRequest_Stderr
	//	*SessionRequest_Exit
	Msg isSessionRequest_Msg `protobuf_oneof:"msg"`
}

func (*SessionRequest) Descriptor added in v0.12.0 

func (*SessionRequest) Descriptor() ([]byte, []int)

func (*SessionRequest) Equal added in v0.12.0 

func (this *SessionRequest) Equal(that interface{}) bool

func (*SessionRequest) GetExit added in v0.12.0 

func (m *SessionRequest) GetExit() int32

func (*SessionRequest) GetMsg added in v0.12.0 

func (m *SessionRequest) GetMsg() isSessionRequest_Msg

func (*SessionRequest) GetStderr added in v0.12.0 

func (m *SessionRequest) GetStderr() []byte

func (*SessionRequest) GetStdout added in v0.12.0 

func (m *SessionRequest) GetStdout() []byte

func (*SessionRequest) GoString added in v0.12.0 

func (this *SessionRequest) GoString() string

func (*SessionRequest) Marshal added in v0.12.0 

func (m *SessionRequest) Marshal() (dAtA []byte, err error)

func (*SessionRequest) MarshalTo added in v0.12.0 

func (m *SessionRequest) MarshalTo(dAtA []byte) (int, error)

func (*SessionRequest) MarshalToSizedBuffer added in v0.12.0 

func (m *SessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRequest) ProtoMessage added in v0.12.0 

func (*SessionRequest) ProtoMessage()

func (*SessionRequest) Reset added in v0.12.0 

func (m *SessionRequest) Reset()

func (*SessionRequest) Size added in v0.12.0 

func (m *SessionRequest) Size() (n int)

func (*SessionRequest) String added in v0.12.0 

func (this *SessionRequest) String() string

func (*SessionRequest) Unmarshal added in v0.12.0 

func (m *SessionRequest) Unmarshal(dAtA []byte) error

func (*SessionRequest) XXX_DiscardUnknown added in v0.12.0 

func (m *SessionRequest) XXX_DiscardUnknown()

func (*SessionRequest) XXX_Marshal added in v0.12.0 

func (m *SessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionRequest) XXX_Merge added in v0.12.0 

func (m *SessionRequest) XXX_Merge(src proto.Message)

func (*SessionRequest) XXX_OneofWrappers added in v0.12.0 

func (*SessionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SessionRequest) XXX_Size added in v0.12.0 

func (m *SessionRequest) XXX_Size() int

func (*SessionRequest) XXX_Unmarshal added in v0.12.0 

func (m *SessionRequest) XXX_Unmarshal(b []byte) error

type SessionRequest_Exit added in v0.12.0 

type SessionRequest_Exit struct {
	Exit int32 `protobuf:"varint,3,opt,name=exit,proto3,oneof" json:"exit,omitempty"`
}

func (*SessionRequest_Exit) Equal added in v0.12.0 

func (this *SessionRequest_Exit) Equal(that interface{}) bool

func (*SessionRequest_Exit) GoString added in v0.12.0 

func (this *SessionRequest_Exit) GoString() string

func (*SessionRequest_Exit) MarshalTo added in v0.12.0 

func (m *SessionRequest_Exit) MarshalTo(dAtA []byte) (int, error)

func (*SessionRequest_Exit) MarshalToSizedBuffer added in v0.12.0 

func (m *SessionRequest_Exit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRequest_Exit) Size added in v0.12.0 

func (m *SessionRequest_Exit) Size() (n int)

func (*SessionRequest_Exit) String added in v0.12.0 

func (this *SessionRequest_Exit) String() string

type SessionRequest_Stderr added in v0.12.0 

type SessionRequest_Stderr struct {
	Stderr []byte `protobuf:"bytes,2,opt,name=stderr,proto3,oneof" json:"stderr,omitempty"`
}

func (*SessionRequest_Stderr) Equal added in v0.12.0 

func (this *SessionRequest_Stderr) Equal(that interface{}) bool

func (*SessionRequest_Stderr) GoString added in v0.12.0 

func (this *SessionRequest_Stderr) GoString() string

func (*SessionRequest_Stderr) MarshalTo added in v0.12.0 

func (m *SessionRequest_Stderr) MarshalTo(dAtA []byte) (int, error)

func (*SessionRequest_Stderr) MarshalToSizedBuffer added in v0.12.0 

func (m *SessionRequest_Stderr) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRequest_Stderr) Size added in v0.12.0 

func (m *SessionRequest_Stderr) Size() (n int)

func (*SessionRequest_Stderr) String added in v0.12.0 

func (this *SessionRequest_Stderr) String() string

type SessionRequest_Stdout added in v0.12.0 

type SessionRequest_Stdout struct {
	Stdout []byte `protobuf:"bytes,1,opt,name=stdout,proto3,oneof" json:"stdout,omitempty"`
}

func (*SessionRequest_Stdout) Equal added in v0.12.0 

func (this *SessionRequest_Stdout) Equal(that interface{}) bool

func (*SessionRequest_Stdout) GoString added in v0.12.0 

func (this *SessionRequest_Stdout) GoString() string

func (*SessionRequest_Stdout) MarshalTo added in v0.12.0 

func (m *SessionRequest_Stdout) MarshalTo(dAtA []byte) (int, error)

func (*SessionRequest_Stdout) MarshalToSizedBuffer added in v0.12.0 

func (m *SessionRequest_Stdout) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRequest_Stdout) Size added in v0.12.0 

func (m *SessionRequest_Stdout) Size() (n int)

func (*SessionRequest_Stdout) String added in v0.12.0 

func (this *SessionRequest_Stdout) String() string

type SessionResponse added in v0.12.0 

type SessionResponse struct {
	// Types that are valid to be assigned to Msg:
	//	*SessionResponse_Stdin
	//	*SessionResponse_Resize
	Msg isSessionResponse_Msg `protobuf_oneof:"msg"`
}

func (*SessionResponse) Descriptor added in v0.12.0 

func (*SessionResponse) Descriptor() ([]byte, []int)

func (*SessionResponse) Equal added in v0.12.0 

func (this *SessionResponse) Equal(that interface{}) bool

func (*SessionResponse) GetMsg added in v0.12.0 

func (m *SessionResponse) GetMsg() isSessionResponse_Msg

func (*SessionResponse) GetResize added in v0.12.0 

func (m *SessionResponse) GetResize() *Resize

func (*SessionResponse) GetStdin added in v0.12.0 

func (m *SessionResponse) GetStdin() []byte

func (*SessionResponse) GoString added in v0.12.0 

func (this *SessionResponse) GoString() string

func (*SessionResponse) Marshal added in v0.12.0 

func (m *SessionResponse) Marshal() (dAtA []byte, err error)

func (*SessionResponse) MarshalTo added in v0.12.0 

func (m *SessionResponse) MarshalTo(dAtA []byte) (int, error)

func (*SessionResponse) MarshalToSizedBuffer added in v0.12.0 

func (m *SessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionResponse) ProtoMessage added in v0.12.0 

func (*SessionResponse) ProtoMessage()

func (*SessionResponse) Reset added in v0.12.0 

func (m *SessionResponse) Reset()

func (*SessionResponse) Size added in v0.12.0 

func (m *SessionResponse) Size() (n int)

func (*SessionResponse) String added in v0.12.0 

func (this *SessionResponse) String() string

func (*SessionResponse) Unmarshal added in v0.12.0 

func (m *SessionResponse) Unmarshal(dAtA []byte) error

func (*SessionResponse) XXX_DiscardUnknown added in v0.12.0 

func (m *SessionResponse) XXX_DiscardUnknown()

func (*SessionResponse) XXX_Marshal added in v0.12.0 

func (m *SessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionResponse) XXX_Merge added in v0.12.0 

func (m *SessionResponse) XXX_Merge(src proto.Message)

func (*SessionResponse) XXX_OneofWrappers added in v0.12.0 

func (*SessionResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SessionResponse) XXX_Size added in v0.12.0 

func (m *SessionResponse) XXX_Size() int

func (*SessionResponse) XXX_Unmarshal added in v0.12.0 

func (m *SessionResponse) XXX_Unmarshal(b []byte) error

type SessionResponse_Resize added in v0.12.0 

type SessionResponse_Resize struct {
	Resize *Resize `protobuf:"bytes,2,opt,name=resize,proto3,oneof" json:"resize,omitempty"`
}

func (*SessionResponse_Resize) Equal added in v0.12.0 

func (this *SessionResponse_Resize) Equal(that interface{}) bool

func (*SessionResponse_Resize) GoString added in v0.12.0 

func (this *SessionResponse_Resize) GoString() string

func (*SessionResponse_Resize) MarshalTo added in v0.12.0 

func (m *SessionResponse_Resize) MarshalTo(dAtA []byte) (int, error)

func (*SessionResponse_Resize) MarshalToSizedBuffer added in v0.12.0 

func (m *SessionResponse_Resize) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionResponse_Resize) Size added in v0.12.0 

func (m *SessionResponse_Resize) Size() (n int)

func (*SessionResponse_Resize) String added in v0.12.0 

func (this *SessionResponse_Resize) String() string

type SessionResponse_Stdin added in v0.12.0 

type SessionResponse_Stdin struct {
	Stdin []byte `protobuf:"bytes,1,opt,name=stdin,proto3,oneof" json:"stdin,omitempty"`
}

func (*SessionResponse_Stdin) Equal added in v0.12.0 

func (this *SessionResponse_Stdin) Equal(that interface{}) bool

func (*SessionResponse_Stdin) GoString added in v0.12.0 

func (this *SessionResponse_Stdin) GoString() string

func (*SessionResponse_Stdin) MarshalTo added in v0.12.0 

func (m *SessionResponse_Stdin) MarshalTo(dAtA []byte) (int, error)

func (*SessionResponse_Stdin) MarshalToSizedBuffer added in v0.12.0 

func (m *SessionResponse_Stdin) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionResponse_Stdin) Size added in v0.12.0 

func (m *SessionResponse_Stdin) Size() (n int)

func (*SessionResponse_Stdin) String added in v0.12.0 

func (this *SessionResponse_Stdin) String() string

type TerminalAttachable added in v0.12.0 

type TerminalAttachable struct {
	UnimplementedTerminalServer
	// contains filtered or unexported fields
}

func NewTerminalAttachable added in v0.12.0 

func NewTerminalAttachable(
	rootCtx context.Context,
	withTerminal WithTerminalFunc,
) TerminalAttachable

func (TerminalAttachable) Register added in v0.12.0 

func (s TerminalAttachable) Register(srv *grpc.Server)

func (TerminalAttachable) Session added in v0.12.0 

func (s TerminalAttachable) Session(srv Terminal_SessionServer) error

type TerminalClient added in v0.12.0 

type TerminalClient interface {
	Session(ctx context.Context, opts ...grpc.CallOption) (Terminal_SessionClient, error)
}

TerminalClient is the client API for Terminal service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTerminalClient added in v0.12.0 

func NewTerminalClient(cc *grpc.ClientConn) TerminalClient

type TerminalServer added in v0.12.0 

type TerminalServer interface {
	Session(Terminal_SessionServer) error
}

TerminalServer is the server API for Terminal service.

type Terminal_SessionClient added in v0.12.0 

type Terminal_SessionClient interface {
	Send(*SessionRequest) error
	Recv() (*SessionResponse, error)
	grpc.ClientStream
}

type Terminal_SessionServer added in v0.12.0 

type Terminal_SessionServer interface {
	Send(*SessionResponse) error
	Recv() (*SessionRequest, error)
	grpc.ServerStream
}

type TunnelListenerAttachable 

type TunnelListenerAttachable struct {
	UnimplementedTunnelListenerServer
	// contains filtered or unexported fields
}

func NewTunnelListenerAttachable 

func NewTunnelListenerAttachable(rootCtx context.Context) TunnelListenerAttachable

func (TunnelListenerAttachable) Listen 

func (s TunnelListenerAttachable) Listen(srv TunnelListener_ListenServer) error

func (TunnelListenerAttachable) Register 

func (s TunnelListenerAttachable) Register(srv *grpc.Server)

type TunnelListenerClient 

type TunnelListenerClient interface {
	Listen(ctx context.Context, opts ...grpc.CallOption) (TunnelListener_ListenClient, error)
}

TunnelListenerClient is the client API for TunnelListener service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTunnelListenerClient 

func NewTunnelListenerClient(cc *grpc.ClientConn) TunnelListenerClient

type TunnelListenerServer 

type TunnelListenerServer interface {
	Listen(TunnelListener_ListenServer) error
}

TunnelListenerServer is the server API for TunnelListener service.

type TunnelListener_ListenClient 

type TunnelListener_ListenClient interface {
	Send(*ListenRequest) error
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type TunnelListener_ListenServer 

type TunnelListener_ListenServer interface {
	Send(*ListenResponse) error
	Recv() (*ListenRequest, error)
	grpc.ServerStream
}

type UnimplementedGitServer added in v0.17.0 

type UnimplementedGitServer struct {
}

UnimplementedGitServer can be embedded to have forward compatible implementations.

func (*UnimplementedGitServer) GetConfig added in v0.17.0 

func (*UnimplementedGitServer) GetConfig(ctx context.Context, req *GitConfigRequest) (*GitConfigResponse, error)

func (*UnimplementedGitServer) GetCredential added in v0.17.0 

func (*UnimplementedGitServer) GetCredential(ctx context.Context, req *GitCredentialRequest) (*GitCredentialResponse, error)

type UnimplementedPromptServer added in v0.17.0 

type UnimplementedPromptServer struct {
}

UnimplementedPromptServer can be embedded to have forward compatible implementations.

func (*UnimplementedPromptServer) PromptBool added in v0.17.0 

func (*UnimplementedPromptServer) PromptBool(ctx context.Context, req *BoolRequest) (*BoolResponse, error)

type UnimplementedTerminalServer added in v0.12.0 

type UnimplementedTerminalServer struct {
}

UnimplementedTerminalServer can be embedded to have forward compatible implementations.

func (*UnimplementedTerminalServer) Session added in v0.12.0 

func (*UnimplementedTerminalServer) Session(srv Terminal_SessionServer) error

type UnimplementedTunnelListenerServer 

type UnimplementedTunnelListenerServer struct {
}

UnimplementedTunnelListenerServer can be embedded to have forward compatible implementations.

func (*UnimplementedTunnelListenerServer) Listen 

func (*UnimplementedTunnelListenerServer) Listen(srv TunnelListener_ListenServer) error

type WithTerminalFunc added in v0.12.0 

type WithTerminalFunc func(func(stdin io.Reader, stdout, stderr io.Writer) error) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳