session

package
v0.18.0 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 2025 License: Apache-2.0 Imports: 31 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 (
	ErrInvalidLengthPipe        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPipe          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPipe = 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 RegisterPipeServer added in v0.18.0 

func RegisterPipeServer(s *grpc.Server, srv PipeServer)

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 Data added in v0.18.0 

type Data struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Data) Descriptor added in v0.18.0 

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

func (*Data) Equal added in v0.18.0 

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

func (*Data) GetData added in v0.18.0 

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

func (*Data) GoString added in v0.18.0 

func (this *Data) GoString() string

func (*Data) Marshal added in v0.18.0 

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

func (*Data) MarshalTo added in v0.18.0 

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

func (*Data) MarshalToSizedBuffer added in v0.18.0 

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

func (*Data) ProtoMessage added in v0.18.0 

func (*Data) ProtoMessage()

func (*Data) Reset added in v0.18.0 

func (m *Data) Reset()

func (*Data) Size added in v0.18.0 

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

func (*Data) String added in v0.18.0 

func (this *Data) String() string

func (*Data) Unmarshal added in v0.18.0 

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

func (*Data) XXX_DiscardUnknown added in v0.18.0 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal added in v0.18.0 

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

func (*Data) XXX_Merge added in v0.18.0 

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

func (*Data) XXX_Size added in v0.18.0 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal added in v0.18.0 

func (m *Data) 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 PipeAttachable added in v0.18.0 

type PipeAttachable struct {
	UnimplementedPipeServer
	// contains filtered or unexported fields
}

PipeAttachable implements the PipeServer interface generated by protoc.

func NewPipeAttachable added in v0.18.0 

func NewPipeAttachable(rootCtx context.Context, stdin io.Reader, stdout io.Writer) PipeAttachable

func (PipeAttachable) IO added in v0.18.0 

func (p PipeAttachable) IO(srv Pipe_IOServer) error

func (PipeAttachable) Register added in v0.18.0 

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

type PipeClient added in v0.18.0 

type PipeClient interface {
	IO(ctx context.Context, opts ...grpc.CallOption) (Pipe_IOClient, error)
}

PipeClient is the client API for Pipe service.

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

func NewPipeClient added in v0.18.0 

func NewPipeClient(cc *grpc.ClientConn) PipeClient

type PipeIO added in v0.18.0 

type PipeIO struct {
	GRPC interface {
		Send(*Data) error
		Recv() (*Data, error)
	}
	// contains filtered or unexported fields
}

PipeIO transforms a Pipe_IOServer or a Pipe_IOClient into an io.ReadWriter

func (*PipeIO) Close added in v0.18.0 

func (pio *PipeIO) Close() error

func (*PipeIO) Read added in v0.18.0 

func (pio *PipeIO) Read(p []byte) (n int, err error)

func (*PipeIO) Write added in v0.18.0 

func (pio *PipeIO) Write(p []byte) (n int, err error)

type PipeServer added in v0.18.0 

type PipeServer interface {
	IO(Pipe_IOServer) error
}

PipeServer is the server API for Pipe service.

type Pipe_IOClient added in v0.18.0 

type Pipe_IOClient interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc.ClientStream
}

type Pipe_IOServer added in v0.18.0 

type Pipe_IOServer interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc.ServerStream
}

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)

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 UnimplementedPipeServer added in v0.18.0 

type UnimplementedPipeServer struct {
}

UnimplementedPipeServer can be embedded to have forward compatible implementations.

func (*UnimplementedPipeServer) IO added in v0.18.0 

func (*UnimplementedPipeServer) IO(srv Pipe_IOServer) 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

Directories

Path Synopsis
Package ctxio provides context-aware io.ReadCloser and io.WriteCloser implementations that handle cancellations during blocking read/write operations.
 Package ctxio provides context-aware io.ReadCloser and io.WriteCloser implementations that handle cancellations during blocking read/write operations.

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 🇻🇳