tunnel

package
v1.27.0 Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2026 License: MPL-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LifecycleTerminalProtocolVersion  uint32 = 1
	LifecycleTerminalMaxFrame                = 32 << 10
	LifecycleTerminalHandshakeTimeout        = 5 * time.Second
	LifecycleTerminalExitAckTimeout          = 30 * time.Second
)
View Source 
const (
	Tunnel_Ping_FullMethodName                  = "/tunnel.Tunnel/Ping"
	Tunnel_Log_FullMethodName                   = "/tunnel.Tunnel/Log"
	Tunnel_Status_FullMethodName                = "/tunnel.Tunnel/Status"
	Tunnel_AppendSetupLogs_FullMethodName       = "/tunnel.Tunnel/AppendSetupLogs"
	Tunnel_SendResult_FullMethodName            = "/tunnel.Tunnel/SendResult"
	Tunnel_DockerCredentials_FullMethodName     = "/tunnel.Tunnel/DockerCredentials"
	Tunnel_GitCredentials_FullMethodName        = "/tunnel.Tunnel/GitCredentials"
	Tunnel_GitHubCredentials_FullMethodName     = "/tunnel.Tunnel/GitHubCredentials"
	Tunnel_GitSSHSignature_FullMethodName       = "/tunnel.Tunnel/GitSSHSignature"
	Tunnel_GitUser_FullMethodName               = "/tunnel.Tunnel/GitUser"
	Tunnel_DevsyConfig_FullMethodName           = "/tunnel.Tunnel/DevsyConfig"
	Tunnel_GPGPublicKeys_FullMethodName         = "/tunnel.Tunnel/GPGPublicKeys"
	Tunnel_KubeConfig_FullMethodName            = "/tunnel.Tunnel/KubeConfig"
	Tunnel_Secrets_FullMethodName               = "/tunnel.Tunnel/Secrets"
	Tunnel_ForwardPort_FullMethodName           = "/tunnel.Tunnel/ForwardPort"
	Tunnel_StopForwardPort_FullMethodName       = "/tunnel.Tunnel/StopForwardPort"
	Tunnel_StreamWorkspace_FullMethodName       = "/tunnel.Tunnel/StreamWorkspace"
	Tunnel_StreamMount_FullMethodName           = "/tunnel.Tunnel/StreamMount"
	Tunnel_StreamSnapshotVolumes_FullMethodName = "/tunnel.Tunnel/StreamSnapshotVolumes"
	Tunnel_LifecycleTerminal_FullMethodName     = "/tunnel.Tunnel/LifecycleTerminal"
)

Variables

View Source 
var (
	LogLevel_name = map[int32]string{
		0: "DEBUG",
		1: "INFO",
		2: "DONE",
		3: "WARNING",
		4: "ERROR",
	}
	LogLevel_value = map[string]int32{
		"DEBUG":   0,
		"INFO":    1,
		"DONE":    2,
		"WARNING": 3,
		"ERROR":   4,
	}
)

Enum value maps for LogLevel.

View Source 
var (
	SetupLogResult_name = map[int32]string{
		0: "SETUP_LOG_RESULT_UNSPECIFIED",
		1: "SETUP_LOG_RESULT_ACCEPTED",
		2: "SETUP_LOG_RESULT_RETENTION_GAP",
		3: "SETUP_LOG_RESULT_REJECTED_INVALID",
	}
	SetupLogResult_value = map[string]int32{
		"SETUP_LOG_RESULT_UNSPECIFIED":      0,
		"SETUP_LOG_RESULT_ACCEPTED":         1,
		"SETUP_LOG_RESULT_RETENTION_GAP":    2,
		"SETUP_LOG_RESULT_REJECTED_INVALID": 3,
	}
)

Enum value maps for SetupLogResult.

View Source 
var File_tunnel_proto protoreflect.FileDescriptor
View Source 
var Tunnel_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tunnel.Tunnel",
	HandlerType: (*TunnelServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Tunnel_Ping_Handler,
		},
		{
			MethodName: "Log",
			Handler:    _Tunnel_Log_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Tunnel_Status_Handler,
		},
		{
			MethodName: "AppendSetupLogs",
			Handler:    _Tunnel_AppendSetupLogs_Handler,
		},
		{
			MethodName: "SendResult",
			Handler:    _Tunnel_SendResult_Handler,
		},
		{
			MethodName: "DockerCredentials",
			Handler:    _Tunnel_DockerCredentials_Handler,
		},
		{
			MethodName: "GitCredentials",
			Handler:    _Tunnel_GitCredentials_Handler,
		},
		{
			MethodName: "GitHubCredentials",
			Handler:    _Tunnel_GitHubCredentials_Handler,
		},
		{
			MethodName: "GitSSHSignature",
			Handler:    _Tunnel_GitSSHSignature_Handler,
		},
		{
			MethodName: "GitUser",
			Handler:    _Tunnel_GitUser_Handler,
		},
		{
			MethodName: "DevsyConfig",
			Handler:    _Tunnel_DevsyConfig_Handler,
		},
		{
			MethodName: "GPGPublicKeys",
			Handler:    _Tunnel_GPGPublicKeys_Handler,
		},
		{
			MethodName: "KubeConfig",
			Handler:    _Tunnel_KubeConfig_Handler,
		},
		{
			MethodName: "Secrets",
			Handler:    _Tunnel_Secrets_Handler,
		},
		{
			MethodName: "ForwardPort",
			Handler:    _Tunnel_ForwardPort_Handler,
		},
		{
			MethodName: "StopForwardPort",
			Handler:    _Tunnel_StopForwardPort_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamWorkspace",
			Handler:       _Tunnel_StreamWorkspace_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamMount",
			Handler:       _Tunnel_StreamMount_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamSnapshotVolumes",
			Handler:       _Tunnel_StreamSnapshotVolumes_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "LifecycleTerminal",
			Handler:       _Tunnel_LifecycleTerminal_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "tunnel.proto",
}

Tunnel_ServiceDesc is the grpc.ServiceDesc for Tunnel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTunnelServer 

func RegisterTunnelServer(s grpc.ServiceRegistrar, srv TunnelServer)

Types

type AppendSetupLogsRequest added in v1.27.0 

type AppendSetupLogsRequest struct {
	SchemaVersion uint32   `protobuf:"varint,1,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	RunId         string   `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	ProducerId    string   `protobuf:"bytes,3,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"`
	FirstSequence uint64   `protobuf:"varint,4,opt,name=first_sequence,json=firstSequence,proto3" json:"first_sequence,omitempty"`
	LastSequence  uint64   `protobuf:"varint,5,opt,name=last_sequence,json=lastSequence,proto3" json:"last_sequence,omitempty"`
	Records       [][]byte `protobuf:"bytes,6,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

AppendSetupLogsRequest carries one contiguous batch of a producer's records. Each record is a JSON encoded workspacelogs.Record. The encoded request is capped at 256 KiB.

func (*AppendSetupLogsRequest) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use AppendSetupLogsRequest.ProtoReflect.Descriptor instead.

func (*AppendSetupLogsRequest) GetFirstSequence added in v1.27.0 

func (x *AppendSetupLogsRequest) GetFirstSequence() uint64

func (*AppendSetupLogsRequest) GetLastSequence added in v1.27.0 

func (x *AppendSetupLogsRequest) GetLastSequence() uint64

func (*AppendSetupLogsRequest) GetProducerId added in v1.27.0 

func (x *AppendSetupLogsRequest) GetProducerId() string

func (*AppendSetupLogsRequest) GetRecords added in v1.27.0 

func (x *AppendSetupLogsRequest) GetRecords() [][]byte

func (*AppendSetupLogsRequest) GetRunId added in v1.27.0 

func (x *AppendSetupLogsRequest) GetRunId() string

func (*AppendSetupLogsRequest) GetSchemaVersion added in v1.27.0 

func (x *AppendSetupLogsRequest) GetSchemaVersion() uint32

func (*AppendSetupLogsRequest) ProtoMessage added in v1.27.0 

func (*AppendSetupLogsRequest) ProtoMessage()

func (*AppendSetupLogsRequest) ProtoReflect added in v1.27.0 

func (x *AppendSetupLogsRequest) ProtoReflect() protoreflect.Message

func (*AppendSetupLogsRequest) Reset added in v1.27.0 

func (x *AppendSetupLogsRequest) Reset()

func (*AppendSetupLogsRequest) String added in v1.27.0 

func (x *AppendSetupLogsRequest) String() string

type AppendSetupLogsResponse added in v1.27.0 

type AppendSetupLogsResponse struct {

	// Highest contiguous sequence persisted for the producer.
	AcceptedSequence uint64         `protobuf:"varint,1,opt,name=accepted_sequence,json=acceptedSequence,proto3" json:"accepted_sequence,omitempty"`
	Result           SetupLogResult `protobuf:"varint,2,opt,name=result,proto3,enum=tunnel.SetupLogResult" json:"result,omitempty"`
	// Sequences the receiver will never hold, set for RETENTION_GAP.
	GapFirstSequence uint64 `protobuf:"varint,3,opt,name=gap_first_sequence,json=gapFirstSequence,proto3" json:"gap_first_sequence,omitempty"`
	GapLastSequence  uint64 `protobuf:"varint,4,opt,name=gap_last_sequence,json=gapLastSequence,proto3" json:"gap_last_sequence,omitempty"`
	Detail           string `protobuf:"bytes,5,opt,name=detail,proto3" json:"detail,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendSetupLogsResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use AppendSetupLogsResponse.ProtoReflect.Descriptor instead.

func (*AppendSetupLogsResponse) GetAcceptedSequence added in v1.27.0 

func (x *AppendSetupLogsResponse) GetAcceptedSequence() uint64

func (*AppendSetupLogsResponse) GetDetail added in v1.27.0 

func (x *AppendSetupLogsResponse) GetDetail() string

func (*AppendSetupLogsResponse) GetGapFirstSequence added in v1.27.0 

func (x *AppendSetupLogsResponse) GetGapFirstSequence() uint64

func (*AppendSetupLogsResponse) GetGapLastSequence added in v1.27.0 

func (x *AppendSetupLogsResponse) GetGapLastSequence() uint64

func (*AppendSetupLogsResponse) GetResult added in v1.27.0 

func (x *AppendSetupLogsResponse) GetResult() SetupLogResult

func (*AppendSetupLogsResponse) ProtoMessage added in v1.27.0 

func (*AppendSetupLogsResponse) ProtoMessage()

func (*AppendSetupLogsResponse) ProtoReflect added in v1.27.0 

func (x *AppendSetupLogsResponse) ProtoReflect() protoreflect.Message

func (*AppendSetupLogsResponse) Reset added in v1.27.0 

func (x *AppendSetupLogsResponse) Reset()

func (*AppendSetupLogsResponse) String added in v1.27.0 

func (x *AppendSetupLogsResponse) String() string

type Chunk 

type Chunk struct {
	Content []byte `protobuf:"bytes,1,opt,name=Content,proto3" json:"Content,omitempty"`
	// contains filtered or unexported fields
}

func (*Chunk) Descriptor deprecated 

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

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetContent 

func (x *Chunk) GetContent() []byte

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect 

func (x *Chunk) ProtoReflect() protoreflect.Message

func (*Chunk) Reset 

func (x *Chunk) Reset()

func (*Chunk) String 

func (x *Chunk) String() string

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type ForwardPortRequest 

type ForwardPortRequest struct {
	Port string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardPortRequest) Descriptor deprecated 

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

Deprecated: Use ForwardPortRequest.ProtoReflect.Descriptor instead.

func (*ForwardPortRequest) GetPort 

func (x *ForwardPortRequest) GetPort() string

func (*ForwardPortRequest) ProtoMessage 

func (*ForwardPortRequest) ProtoMessage()

func (*ForwardPortRequest) ProtoReflect 

func (x *ForwardPortRequest) ProtoReflect() protoreflect.Message

func (*ForwardPortRequest) Reset 

func (x *ForwardPortRequest) Reset()

func (*ForwardPortRequest) String 

func (x *ForwardPortRequest) String() string

type ForwardPortResponse 

type ForwardPortResponse struct {
	// contains filtered or unexported fields
}

func (*ForwardPortResponse) Descriptor deprecated 

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

Deprecated: Use ForwardPortResponse.ProtoReflect.Descriptor instead.

func (*ForwardPortResponse) ProtoMessage 

func (*ForwardPortResponse) ProtoMessage()

func (*ForwardPortResponse) ProtoReflect 

func (x *ForwardPortResponse) ProtoReflect() protoreflect.Message

func (*ForwardPortResponse) Reset 

func (x *ForwardPortResponse) Reset()

func (*ForwardPortResponse) String 

func (x *ForwardPortResponse) String() string

type LifecycleTerminalBegin added in v1.27.0 

type LifecycleTerminalBegin struct {
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	Phase        string `protobuf:"bytes,2,opt,name=phase,proto3" json:"phase,omitempty"`
	Index        uint32 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Key          string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalBegin) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalBegin.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalBegin) GetIndex added in v1.27.0 

func (x *LifecycleTerminalBegin) GetIndex() uint32

func (*LifecycleTerminalBegin) GetInvocationId added in v1.27.0 

func (x *LifecycleTerminalBegin) GetInvocationId() string

func (*LifecycleTerminalBegin) GetKey added in v1.27.0 

func (x *LifecycleTerminalBegin) GetKey() string

func (*LifecycleTerminalBegin) GetPhase added in v1.27.0 

func (x *LifecycleTerminalBegin) GetPhase() string

func (*LifecycleTerminalBegin) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalBegin) ProtoMessage()

func (*LifecycleTerminalBegin) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalBegin) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalBegin) Reset added in v1.27.0 

func (x *LifecycleTerminalBegin) Reset()

func (*LifecycleTerminalBegin) String added in v1.27.0 

func (x *LifecycleTerminalBegin) String() string

type LifecycleTerminalBeginAck added in v1.27.0 

type LifecycleTerminalBeginAck struct {
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	Rows         uint32 `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	Columns      uint32 `protobuf:"varint,3,opt,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalBeginAck) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalBeginAck.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalBeginAck) GetColumns added in v1.27.0 

func (x *LifecycleTerminalBeginAck) GetColumns() uint32

func (*LifecycleTerminalBeginAck) GetInvocationId added in v1.27.0 

func (x *LifecycleTerminalBeginAck) GetInvocationId() string

func (*LifecycleTerminalBeginAck) GetRows added in v1.27.0 

func (x *LifecycleTerminalBeginAck) GetRows() uint32

func (*LifecycleTerminalBeginAck) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalBeginAck) ProtoMessage()

func (*LifecycleTerminalBeginAck) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalBeginAck) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalBeginAck) Reset added in v1.27.0 

func (x *LifecycleTerminalBeginAck) Reset()

func (*LifecycleTerminalBeginAck) String added in v1.27.0 

func (x *LifecycleTerminalBeginAck) String() string

type LifecycleTerminalCancel added in v1.27.0 

type LifecycleTerminalCancel struct {
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalCancel) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalCancel.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalCancel) GetInvocationId added in v1.27.0 

func (x *LifecycleTerminalCancel) GetInvocationId() string

func (*LifecycleTerminalCancel) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalCancel) ProtoMessage()

func (*LifecycleTerminalCancel) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalCancel) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalCancel) Reset added in v1.27.0 

func (x *LifecycleTerminalCancel) Reset()

func (*LifecycleTerminalCancel) String added in v1.27.0 

func (x *LifecycleTerminalCancel) String() string

type LifecycleTerminalComplete added in v1.27.0 

type LifecycleTerminalComplete struct {
	// contains filtered or unexported fields
}

func (*LifecycleTerminalComplete) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalComplete.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalComplete) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalComplete) ProtoMessage()

func (*LifecycleTerminalComplete) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalComplete) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalComplete) Reset added in v1.27.0 

func (x *LifecycleTerminalComplete) Reset()

func (*LifecycleTerminalComplete) String added in v1.27.0 

func (x *LifecycleTerminalComplete) String() string

type LifecycleTerminalExit added in v1.27.0 

type LifecycleTerminalExit struct {
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	ExitCode     int32  `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Signal       string `protobuf:"bytes,3,opt,name=signal,proto3" json:"signal,omitempty"`
	StartError   string `protobuf:"bytes,4,opt,name=start_error,json=startError,proto3" json:"start_error,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalExit) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalExit.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalExit) GetExitCode added in v1.27.0 

func (x *LifecycleTerminalExit) GetExitCode() int32

func (*LifecycleTerminalExit) GetInvocationId added in v1.27.0 

func (x *LifecycleTerminalExit) GetInvocationId() string

func (*LifecycleTerminalExit) GetSignal added in v1.27.0 

func (x *LifecycleTerminalExit) GetSignal() string

func (*LifecycleTerminalExit) GetStartError added in v1.27.0 

func (x *LifecycleTerminalExit) GetStartError() string

func (*LifecycleTerminalExit) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalExit) ProtoMessage()

func (*LifecycleTerminalExit) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalExit) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalExit) Reset added in v1.27.0 

func (x *LifecycleTerminalExit) Reset()

func (*LifecycleTerminalExit) String added in v1.27.0 

func (x *LifecycleTerminalExit) String() string

type LifecycleTerminalExitAck added in v1.27.0 

type LifecycleTerminalExitAck struct {
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalExitAck) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalExitAck.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalExitAck) GetInvocationId added in v1.27.0 

func (x *LifecycleTerminalExitAck) GetInvocationId() string

func (*LifecycleTerminalExitAck) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalExitAck) ProtoMessage()

func (*LifecycleTerminalExitAck) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalExitAck) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalExitAck) Reset added in v1.27.0 

func (x *LifecycleTerminalExitAck) Reset()

func (*LifecycleTerminalExitAck) String added in v1.27.0 

func (x *LifecycleTerminalExitAck) String() string

type LifecycleTerminalInput added in v1.27.0 

type LifecycleTerminalInput struct {
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	Data         []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalInput) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalInput.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalInput) GetData added in v1.27.0 

func (x *LifecycleTerminalInput) GetData() []byte

func (*LifecycleTerminalInput) GetInvocationId added in v1.27.0 

func (x *LifecycleTerminalInput) GetInvocationId() string

func (*LifecycleTerminalInput) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalInput) ProtoMessage()

func (*LifecycleTerminalInput) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalInput) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalInput) Reset added in v1.27.0 

func (x *LifecycleTerminalInput) Reset()

func (*LifecycleTerminalInput) String added in v1.27.0 

func (x *LifecycleTerminalInput) String() string

type LifecycleTerminalOpen added in v1.27.0 

type LifecycleTerminalOpen struct {
	ProtocolVersion uint32 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	WorkspaceUid    string `protobuf:"bytes,2,opt,name=workspace_uid,json=workspaceUid,proto3" json:"workspace_uid,omitempty"`
	Context         string `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	Nonce           string `protobuf:"bytes,4,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalOpen) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalOpen.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalOpen) GetContext added in v1.27.0 

func (x *LifecycleTerminalOpen) GetContext() string

func (*LifecycleTerminalOpen) GetNonce added in v1.27.0 

func (x *LifecycleTerminalOpen) GetNonce() string

func (*LifecycleTerminalOpen) GetProtocolVersion added in v1.27.0 

func (x *LifecycleTerminalOpen) GetProtocolVersion() uint32

func (*LifecycleTerminalOpen) GetWorkspaceUid added in v1.27.0 

func (x *LifecycleTerminalOpen) GetWorkspaceUid() string

func (*LifecycleTerminalOpen) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalOpen) ProtoMessage()

func (*LifecycleTerminalOpen) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalOpen) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalOpen) Reset added in v1.27.0 

func (x *LifecycleTerminalOpen) Reset()

func (*LifecycleTerminalOpen) String added in v1.27.0 

func (x *LifecycleTerminalOpen) String() string

type LifecycleTerminalOutput added in v1.27.0 

type LifecycleTerminalOutput struct {
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	Sequence     uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Data         []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalOutput) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalOutput.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalOutput) GetData added in v1.27.0 

func (x *LifecycleTerminalOutput) GetData() []byte

func (*LifecycleTerminalOutput) GetInvocationId added in v1.27.0 

func (x *LifecycleTerminalOutput) GetInvocationId() string

func (*LifecycleTerminalOutput) GetSequence added in v1.27.0 

func (x *LifecycleTerminalOutput) GetSequence() uint64

func (*LifecycleTerminalOutput) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalOutput) ProtoMessage()

func (*LifecycleTerminalOutput) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalOutput) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalOutput) Reset added in v1.27.0 

func (x *LifecycleTerminalOutput) Reset()

func (*LifecycleTerminalOutput) String added in v1.27.0 

func (x *LifecycleTerminalOutput) String() string

type LifecycleTerminalReady added in v1.27.0 

type LifecycleTerminalReady struct {
	ProtocolVersion uint32 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	Term            string `protobuf:"bytes,2,opt,name=term,proto3" json:"term,omitempty"`
	Rows            uint32 `protobuf:"varint,3,opt,name=rows,proto3" json:"rows,omitempty"`
	Columns         uint32 `protobuf:"varint,4,opt,name=columns,proto3" json:"columns,omitempty"`
	Input           bool   `protobuf:"varint,5,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalReady) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalReady.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalReady) GetColumns added in v1.27.0 

func (x *LifecycleTerminalReady) GetColumns() uint32

func (*LifecycleTerminalReady) GetInput added in v1.27.0 

func (x *LifecycleTerminalReady) GetInput() bool

func (*LifecycleTerminalReady) GetProtocolVersion added in v1.27.0 

func (x *LifecycleTerminalReady) GetProtocolVersion() uint32

func (*LifecycleTerminalReady) GetRows added in v1.27.0 

func (x *LifecycleTerminalReady) GetRows() uint32

func (*LifecycleTerminalReady) GetTerm added in v1.27.0 

func (x *LifecycleTerminalReady) GetTerm() string

func (*LifecycleTerminalReady) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalReady) ProtoMessage()

func (*LifecycleTerminalReady) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalReady) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalReady) Reset added in v1.27.0 

func (x *LifecycleTerminalReady) Reset()

func (*LifecycleTerminalReady) String added in v1.27.0 

func (x *LifecycleTerminalReady) String() string

type LifecycleTerminalRequest added in v1.27.0 

type LifecycleTerminalRequest struct {

	// Types that are valid to be assigned to Frame:
	//
	//	*LifecycleTerminalRequest_Open
	//	*LifecycleTerminalRequest_Begin
	//	*LifecycleTerminalRequest_Output
	//	*LifecycleTerminalRequest_Exit
	//	*LifecycleTerminalRequest_Complete
	Frame isLifecycleTerminalRequest_Frame `protobuf_oneof:"frame"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalRequest) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalRequest.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalRequest) GetBegin added in v1.27.0 

func (x *LifecycleTerminalRequest) GetBegin() *LifecycleTerminalBegin

func (*LifecycleTerminalRequest) GetComplete added in v1.27.0 

func (x *LifecycleTerminalRequest) GetComplete() *LifecycleTerminalComplete

func (*LifecycleTerminalRequest) GetExit added in v1.27.0 

func (x *LifecycleTerminalRequest) GetExit() *LifecycleTerminalExit

func (*LifecycleTerminalRequest) GetFrame added in v1.27.0 

func (x *LifecycleTerminalRequest) GetFrame() isLifecycleTerminalRequest_Frame

func (*LifecycleTerminalRequest) GetOpen added in v1.27.0 

func (x *LifecycleTerminalRequest) GetOpen() *LifecycleTerminalOpen

func (*LifecycleTerminalRequest) GetOutput added in v1.27.0 

func (x *LifecycleTerminalRequest) GetOutput() *LifecycleTerminalOutput

func (*LifecycleTerminalRequest) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalRequest) ProtoMessage()

func (*LifecycleTerminalRequest) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalRequest) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalRequest) Reset added in v1.27.0 

func (x *LifecycleTerminalRequest) Reset()

func (*LifecycleTerminalRequest) String added in v1.27.0 

func (x *LifecycleTerminalRequest) String() string

type LifecycleTerminalRequest_Begin added in v1.27.0 

type LifecycleTerminalRequest_Begin struct {
	Begin *LifecycleTerminalBegin `protobuf:"bytes,2,opt,name=begin,proto3,oneof"`
}

type LifecycleTerminalRequest_Complete added in v1.27.0 

type LifecycleTerminalRequest_Complete struct {
	Complete *LifecycleTerminalComplete `protobuf:"bytes,5,opt,name=complete,proto3,oneof"`
}

type LifecycleTerminalRequest_Exit added in v1.27.0 

type LifecycleTerminalRequest_Exit struct {
	Exit *LifecycleTerminalExit `protobuf:"bytes,4,opt,name=exit,proto3,oneof"`
}

type LifecycleTerminalRequest_Open added in v1.27.0 

type LifecycleTerminalRequest_Open struct {
	Open *LifecycleTerminalOpen `protobuf:"bytes,1,opt,name=open,proto3,oneof"`
}

type LifecycleTerminalRequest_Output added in v1.27.0 

type LifecycleTerminalRequest_Output struct {
	Output *LifecycleTerminalOutput `protobuf:"bytes,3,opt,name=output,proto3,oneof"`
}

type LifecycleTerminalResize added in v1.27.0 

type LifecycleTerminalResize struct {
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	Rows         uint32 `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	Columns      uint32 `protobuf:"varint,3,opt,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalResize) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalResize.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalResize) GetColumns added in v1.27.0 

func (x *LifecycleTerminalResize) GetColumns() uint32

func (*LifecycleTerminalResize) GetInvocationId added in v1.27.0 

func (x *LifecycleTerminalResize) GetInvocationId() string

func (*LifecycleTerminalResize) GetRows added in v1.27.0 

func (x *LifecycleTerminalResize) GetRows() uint32

func (*LifecycleTerminalResize) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalResize) ProtoMessage()

func (*LifecycleTerminalResize) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalResize) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalResize) Reset added in v1.27.0 

func (x *LifecycleTerminalResize) Reset()

func (*LifecycleTerminalResize) String added in v1.27.0 

func (x *LifecycleTerminalResize) String() string

type LifecycleTerminalResponse added in v1.27.0 

type LifecycleTerminalResponse struct {

	// Types that are valid to be assigned to Frame:
	//
	//	*LifecycleTerminalResponse_Ready
	//	*LifecycleTerminalResponse_BeginAck
	//	*LifecycleTerminalResponse_Input
	//	*LifecycleTerminalResponse_Resize
	//	*LifecycleTerminalResponse_Cancel
	//	*LifecycleTerminalResponse_ExitAck
	Frame isLifecycleTerminalResponse_Frame `protobuf_oneof:"frame"`
	// contains filtered or unexported fields
}

func (*LifecycleTerminalResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use LifecycleTerminalResponse.ProtoReflect.Descriptor instead.

func (*LifecycleTerminalResponse) GetBeginAck added in v1.27.0 

func (x *LifecycleTerminalResponse) GetBeginAck() *LifecycleTerminalBeginAck

func (*LifecycleTerminalResponse) GetCancel added in v1.27.0 

func (x *LifecycleTerminalResponse) GetCancel() *LifecycleTerminalCancel

func (*LifecycleTerminalResponse) GetExitAck added in v1.27.0 

func (x *LifecycleTerminalResponse) GetExitAck() *LifecycleTerminalExitAck

func (*LifecycleTerminalResponse) GetFrame added in v1.27.0 

func (x *LifecycleTerminalResponse) GetFrame() isLifecycleTerminalResponse_Frame

func (*LifecycleTerminalResponse) GetInput added in v1.27.0 

func (x *LifecycleTerminalResponse) GetInput() *LifecycleTerminalInput

func (*LifecycleTerminalResponse) GetReady added in v1.27.0 

func (x *LifecycleTerminalResponse) GetReady() *LifecycleTerminalReady

func (*LifecycleTerminalResponse) GetResize added in v1.27.0 

func (x *LifecycleTerminalResponse) GetResize() *LifecycleTerminalResize

func (*LifecycleTerminalResponse) ProtoMessage added in v1.27.0 

func (*LifecycleTerminalResponse) ProtoMessage()

func (*LifecycleTerminalResponse) ProtoReflect added in v1.27.0 

func (x *LifecycleTerminalResponse) ProtoReflect() protoreflect.Message

func (*LifecycleTerminalResponse) Reset added in v1.27.0 

func (x *LifecycleTerminalResponse) Reset()

func (*LifecycleTerminalResponse) String added in v1.27.0 

func (x *LifecycleTerminalResponse) String() string

type LifecycleTerminalResponse_BeginAck added in v1.27.0 

type LifecycleTerminalResponse_BeginAck struct {
	BeginAck *LifecycleTerminalBeginAck `protobuf:"bytes,2,opt,name=begin_ack,json=beginAck,proto3,oneof"`
}

type LifecycleTerminalResponse_Cancel added in v1.27.0 

type LifecycleTerminalResponse_Cancel struct {
	Cancel *LifecycleTerminalCancel `protobuf:"bytes,5,opt,name=cancel,proto3,oneof"`
}

type LifecycleTerminalResponse_ExitAck added in v1.27.0 

type LifecycleTerminalResponse_ExitAck struct {
	ExitAck *LifecycleTerminalExitAck `protobuf:"bytes,6,opt,name=exit_ack,json=exitAck,proto3,oneof"`
}

type LifecycleTerminalResponse_Input added in v1.27.0 

type LifecycleTerminalResponse_Input struct {
	Input *LifecycleTerminalInput `protobuf:"bytes,3,opt,name=input,proto3,oneof"`
}

type LifecycleTerminalResponse_Ready added in v1.27.0 

type LifecycleTerminalResponse_Ready struct {
	Ready *LifecycleTerminalReady `protobuf:"bytes,1,opt,name=ready,proto3,oneof"`
}

type LifecycleTerminalResponse_Resize added in v1.27.0 

type LifecycleTerminalResponse_Resize struct {
	Resize *LifecycleTerminalResize `protobuf:"bytes,4,opt,name=resize,proto3,oneof"`
}

type LogLevel 

type LogLevel int32
const (
	LogLevel_DEBUG   LogLevel = 0
	LogLevel_INFO    LogLevel = 1
	LogLevel_DONE    LogLevel = 2
	LogLevel_WARNING LogLevel = 3
	LogLevel_ERROR   LogLevel = 4
)

func (LogLevel) Descriptor 

func (LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogLevel) Enum 

func (x LogLevel) Enum() *LogLevel

func (LogLevel) EnumDescriptor deprecated 

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

Deprecated: Use LogLevel.Descriptor instead.

func (LogLevel) Number 

func (x LogLevel) Number() protoreflect.EnumNumber

func (LogLevel) String 

func (x LogLevel) String() string

func (LogLevel) Type 

func (LogLevel) Type() protoreflect.EnumType

type LogMessage 

type LogMessage struct {
	LogLevel LogLevel `protobuf:"varint,1,opt,name=logLevel,proto3,enum=tunnel.LogLevel" json:"logLevel,omitempty"`
	Message  string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessage) Descriptor deprecated 

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

Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.

func (*LogMessage) GetLogLevel 

func (x *LogMessage) GetLogLevel() LogLevel

func (*LogMessage) GetMessage 

func (x *LogMessage) GetMessage() string

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) ProtoReflect 

func (x *LogMessage) ProtoReflect() protoreflect.Message

func (*LogMessage) Reset 

func (x *LogMessage) Reset()

func (*LogMessage) String 

func (x *LogMessage) String() string

type Message 

type Message struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetMessage 

func (x *Message) GetMessage() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type Secret added in v1.10.0 

type Secret struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Mount bool   `protobuf:"varint,3,opt,name=mount,proto3" json:"mount,omitempty"`
	// contains filtered or unexported fields
}

func (*Secret) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetMount added in v1.10.0 

func (x *Secret) GetMount() bool

func (*Secret) GetName added in v1.10.0 

func (x *Secret) GetName() string

func (*Secret) GetValue added in v1.10.0 

func (x *Secret) GetValue() string

func (*Secret) ProtoMessage added in v1.10.0 

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect added in v1.10.0 

func (x *Secret) ProtoReflect() protoreflect.Message

func (*Secret) Reset added in v1.10.0 

func (x *Secret) Reset()

func (*Secret) String added in v1.10.0 

func (x *Secret) String() string

type SecretsResponse added in v1.10.0 

type SecretsResponse struct {
	Secrets []*Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretsResponse) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use SecretsResponse.ProtoReflect.Descriptor instead.

func (*SecretsResponse) GetSecrets added in v1.10.0 

func (x *SecretsResponse) GetSecrets() []*Secret

func (*SecretsResponse) ProtoMessage added in v1.10.0 

func (*SecretsResponse) ProtoMessage()

func (*SecretsResponse) ProtoReflect added in v1.10.0 

func (x *SecretsResponse) ProtoReflect() protoreflect.Message

func (*SecretsResponse) Reset added in v1.10.0 

func (x *SecretsResponse) Reset()

func (*SecretsResponse) String added in v1.10.0 

func (x *SecretsResponse) String() string

type SetupLogForwarder added in v1.27.0 

type SetupLogForwarder struct {
	// contains filtered or unexported fields
}

SetupLogForwarder is the intermediate mode for the provider host. It sends the original records received from containers upstream with unchanged run, producer and sequence identity, and tracks the caller's acknowledged position separately from what its own store accepted.

func NewSetupLogForwarder added in v1.27.0 

func NewSetupLogForwarder(ctx context.Context, opts SetupLogForwarderOptions) *SetupLogForwarder

NewSetupLogForwarder returns a forwarder whose senders live until ctx ends or Close is called.

func (*SetupLogForwarder) Close added in v1.27.0 

func (f *SetupLogForwarder) Close()

Close stops every sender.

func (*SetupLogForwarder) Flush added in v1.27.0 

func (f *SetupLogForwarder) Flush(ctx context.Context) bool

Flush drains every producer upstream within one cleanup budget and reports whether the caller holds everything the provider holds. A failure at this hop is reported even though the provider's own store accepted the records.

func (*SetupLogForwarder) Notify added in v1.27.0 

func (f *SetupLogForwarder) Notify(producerID string, _ uint64)

Notify is the Sink's OnAccepted hook: records of producerID are now in the local store and can go upstream. It never blocks.

type SetupLogForwarderOptions added in v1.27.0 

type SetupLogForwarderOptions struct {
	Client TunnelClient
	Source SetupLogSource
	RunID  string
	Acks   *workspacelogs.AckStore
	// CleanupTimeout bounds one Flush across every producer.
	CleanupTimeout time.Duration
	CallTimeout    time.Duration
	PollInterval   time.Duration
}

SetupLogForwarderOptions configures a SetupLogForwarder.

type SetupLogResult added in v1.27.0 

type SetupLogResult int32
const (
	SetupLogResult_SETUP_LOG_RESULT_UNSPECIFIED      SetupLogResult = 0
	SetupLogResult_SETUP_LOG_RESULT_ACCEPTED         SetupLogResult = 1
	SetupLogResult_SETUP_LOG_RESULT_RETENTION_GAP    SetupLogResult = 2
	SetupLogResult_SETUP_LOG_RESULT_REJECTED_INVALID SetupLogResult = 3
)

func (SetupLogResult) Descriptor added in v1.27.0 

func (SetupLogResult) Descriptor() protoreflect.EnumDescriptor

func (SetupLogResult) Enum added in v1.27.0 

func (x SetupLogResult) Enum() *SetupLogResult

func (SetupLogResult) EnumDescriptor deprecated added in v1.27.0 

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

Deprecated: Use SetupLogResult.Descriptor instead.

func (SetupLogResult) Number added in v1.27.0 

func (x SetupLogResult) Number() protoreflect.EnumNumber

func (SetupLogResult) String added in v1.27.0 

func (x SetupLogResult) String() string

func (SetupLogResult) Type added in v1.27.0 

func (SetupLogResult) Type() protoreflect.EnumType

type SetupLogSender added in v1.27.0 

type SetupLogSender struct {
	// contains filtered or unexported fields
}

SetupLogSender mirrors one producer's records from a source store to the next host. Records stay in the source spool; the sender only remembers how far the peer has acknowledged, so a stalled peer never blocks the producer and never grows memory.

func NewSetupLogSender added in v1.27.0 

func NewSetupLogSender(ctx context.Context, opts SetupLogSenderOptions) *SetupLogSender

NewSetupLogSender starts the background worker. Call Close when done.

func (*SetupLogSender) Acked added in v1.27.0 

func (s *SetupLogSender) Acked() uint64

Acked returns the highest sequence the peer acknowledged.

func (*SetupLogSender) Close added in v1.27.0 

func (s *SetupLogSender) Close()

Close stops the background worker.

func (*SetupLogSender) Disabled added in v1.27.0 

func (s *SetupLogSender) Disabled() bool

Disabled reports that the peer cannot take records (older peer or rejected batch). The source spool is intact.

func (*SetupLogSender) Flush added in v1.27.0 

func (s *SetupLogSender) Flush(ctx context.Context) bool

Flush makes a bounded final drain. It always uses its own cleanup deadline, even when ctx is already canceled, and reports whether every retained record was acknowledged without gaps.

func (*SetupLogSender) Notify added in v1.27.0 

func (s *SetupLogSender) Notify()

Notify tells the sender new records are available. It never blocks; wake-ups coalesce into one.

type SetupLogSenderOptions added in v1.27.0 

type SetupLogSenderOptions struct {
	Client     TunnelClient
	Source     SetupLogSource
	RunID      string
	ProducerID string
	// Acks stores the acknowledged position so a restart resumes from it. When
	// nil the position lives in memory only.
	Acks *workspacelogs.AckStore
	// Hop names the position kept in Acks. Defaults to HopUpstream.
	Hop workspacelogs.Hop
	// CleanupTimeout bounds Flush. CallTimeout bounds one RPC.
	CleanupTimeout time.Duration
	CallTimeout    time.Duration
	PollInterval   time.Duration
}

SetupLogSenderOptions configures a SetupLogSender.

type SetupLogSource added in v1.27.0 

type SetupLogSource interface {
	ReadAfter(runID, producerID string, after uint64, maxBytes int) ([]workspacelogs.Record, error)
}

SetupLogSource supplies a producer's committed records. See workspacelogs.StoreSource.

type StatusError added in v1.20.0 

type StatusError struct {
	Code    string            `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Hint    string            `protobuf:"bytes,3,opt,name=hint,proto3" json:"hint,omitempty"`
	Context map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatusError) Descriptor deprecated added in v1.20.0 

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

Deprecated: Use StatusError.ProtoReflect.Descriptor instead.

func (*StatusError) GetCode added in v1.20.0 

func (x *StatusError) GetCode() string

func (*StatusError) GetContext added in v1.20.0 

func (x *StatusError) GetContext() map[string]string

func (*StatusError) GetHint added in v1.20.0 

func (x *StatusError) GetHint() string

func (*StatusError) GetMessage added in v1.20.0 

func (x *StatusError) GetMessage() string

func (*StatusError) ProtoMessage added in v1.20.0 

func (*StatusError) ProtoMessage()

func (*StatusError) ProtoReflect added in v1.20.0 

func (x *StatusError) ProtoReflect() protoreflect.Message

func (*StatusError) Reset added in v1.20.0 

func (x *StatusError) Reset()

func (*StatusError) String added in v1.20.0 

func (x *StatusError) String() string

type StatusUpdate added in v1.13.0 

type StatusUpdate struct {
	Phase             string       `protobuf:"bytes,1,opt,name=phase,proto3" json:"phase,omitempty"`
	Step              string       `protobuf:"bytes,2,opt,name=step,proto3" json:"step,omitempty"`
	State             string       `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	DurationMs        int64        `protobuf:"varint,4,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	OperationId       string       `protobuf:"bytes,5,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	ParentOperationId string       `protobuf:"bytes,6,opt,name=parent_operation_id,json=parentOperationId,proto3" json:"parent_operation_id,omitempty"`
	Error             *StatusError `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusUpdate) Descriptor deprecated added in v1.13.0 

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

Deprecated: Use StatusUpdate.ProtoReflect.Descriptor instead.

func (*StatusUpdate) GetDurationMs added in v1.20.0 

func (x *StatusUpdate) GetDurationMs() int64

func (*StatusUpdate) GetError added in v1.13.0 

func (x *StatusUpdate) GetError() *StatusError

func (*StatusUpdate) GetOperationId added in v1.20.0 

func (x *StatusUpdate) GetOperationId() string

func (*StatusUpdate) GetParentOperationId added in v1.20.0 

func (x *StatusUpdate) GetParentOperationId() string

func (*StatusUpdate) GetPhase added in v1.13.0 

func (x *StatusUpdate) GetPhase() string

func (*StatusUpdate) GetState added in v1.20.0 

func (x *StatusUpdate) GetState() string

func (*StatusUpdate) GetStep added in v1.13.0 

func (x *StatusUpdate) GetStep() string

func (*StatusUpdate) ProtoMessage added in v1.13.0 

func (*StatusUpdate) ProtoMessage()

func (*StatusUpdate) ProtoReflect added in v1.13.0 

func (x *StatusUpdate) ProtoReflect() protoreflect.Message

func (*StatusUpdate) Reset added in v1.13.0 

func (x *StatusUpdate) Reset()

func (*StatusUpdate) String added in v1.13.0 

func (x *StatusUpdate) String() string

type StopForwardPortRequest 

type StopForwardPortRequest struct {
	Port string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*StopForwardPortRequest) Descriptor deprecated 

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

Deprecated: Use StopForwardPortRequest.ProtoReflect.Descriptor instead.

func (*StopForwardPortRequest) GetPort 

func (x *StopForwardPortRequest) GetPort() string

func (*StopForwardPortRequest) ProtoMessage 

func (*StopForwardPortRequest) ProtoMessage()

func (*StopForwardPortRequest) ProtoReflect 

func (x *StopForwardPortRequest) ProtoReflect() protoreflect.Message

func (*StopForwardPortRequest) Reset 

func (x *StopForwardPortRequest) Reset()

func (*StopForwardPortRequest) String 

func (x *StopForwardPortRequest) String() string

type StopForwardPortResponse 

type StopForwardPortResponse struct {
	// contains filtered or unexported fields
}

func (*StopForwardPortResponse) Descriptor deprecated 

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

Deprecated: Use StopForwardPortResponse.ProtoReflect.Descriptor instead.

func (*StopForwardPortResponse) ProtoMessage 

func (*StopForwardPortResponse) ProtoMessage()

func (*StopForwardPortResponse) ProtoReflect 

func (x *StopForwardPortResponse) ProtoReflect() protoreflect.Message

func (*StopForwardPortResponse) Reset 

func (x *StopForwardPortResponse) Reset()

func (*StopForwardPortResponse) String 

func (x *StopForwardPortResponse) String() string

type StreamMountRequest 

type StreamMountRequest struct {
	Mount string `protobuf:"bytes,1,opt,name=mount,proto3" json:"mount,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamMountRequest) Descriptor deprecated 

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

Deprecated: Use StreamMountRequest.ProtoReflect.Descriptor instead.

func (*StreamMountRequest) GetMount 

func (x *StreamMountRequest) GetMount() string

func (*StreamMountRequest) ProtoMessage 

func (*StreamMountRequest) ProtoMessage()

func (*StreamMountRequest) ProtoReflect 

func (x *StreamMountRequest) ProtoReflect() protoreflect.Message

func (*StreamMountRequest) Reset 

func (x *StreamMountRequest) Reset()

func (*StreamMountRequest) String 

func (x *StreamMountRequest) String() string

type TerminalAttachment added in v1.27.0 

type TerminalAttachment interface {
	Window() TerminalWindow
	Output() io.Writer
	Abort()
	Input() io.ReadCloser
	Resizes() <-chan TerminalWindow
	Canceled() <-chan struct{}
	Exit(ctx context.Context, exit TerminalExit) error
}

type TerminalExit added in v1.27.0 

type TerminalExit struct {
	ExitCode           int
	Signal, StartError string
}

type TerminalInvocation added in v1.27.0 

type TerminalInvocation struct {
	ID, Phase, Key string
	Index          int
}

type TerminalSession added in v1.27.0 

type TerminalSession interface {
	Begin(ctx context.Context, inv TerminalInvocation) (TerminalAttachment, error)
	Close(ctx context.Context) error
}

type TerminalWindow added in v1.27.0 

type TerminalWindow struct {
	Term          string
	Rows, Columns uint16
}

type TunnelClient 

type TunnelClient interface {
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	Log(ctx context.Context, in *LogMessage, opts ...grpc.CallOption) (*Empty, error)
	Status(ctx context.Context, in *StatusUpdate, opts ...grpc.CallOption) (*Empty, error)
	AppendSetupLogs(ctx context.Context, in *AppendSetupLogsRequest, opts ...grpc.CallOption) (*AppendSetupLogsResponse, error)
	SendResult(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Empty, error)
	DockerCredentials(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	GitCredentials(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	GitHubCredentials(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Message, error)
	GitSSHSignature(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	GitUser(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Message, error)
	DevsyConfig(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	GPGPublicKeys(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	KubeConfig(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	Secrets(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SecretsResponse, error)
	ForwardPort(ctx context.Context, in *ForwardPortRequest, opts ...grpc.CallOption) (*ForwardPortResponse, error)
	StopForwardPort(ctx context.Context, in *StopForwardPortRequest, opts ...grpc.CallOption) (*StopForwardPortResponse, error)
	StreamWorkspace(ctx context.Context, in *Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Chunk], error)
	StreamMount(ctx context.Context, in *StreamMountRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Chunk], error)
	StreamSnapshotVolumes(ctx context.Context, in *Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Chunk], error)
	LifecycleTerminal(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[LifecycleTerminalRequest, LifecycleTerminalResponse], error)
}

TunnelClient is the client API for Tunnel service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTunnelClient 

func NewTunnelClient(cc grpc.ClientConnInterface) TunnelClient

type TunnelServer 

type TunnelServer interface {
	Ping(context.Context, *Empty) (*Empty, error)
	Log(context.Context, *LogMessage) (*Empty, error)
	Status(context.Context, *StatusUpdate) (*Empty, error)
	AppendSetupLogs(context.Context, *AppendSetupLogsRequest) (*AppendSetupLogsResponse, error)
	SendResult(context.Context, *Message) (*Empty, error)
	DockerCredentials(context.Context, *Message) (*Message, error)
	GitCredentials(context.Context, *Message) (*Message, error)
	GitHubCredentials(context.Context, *Empty) (*Message, error)
	GitSSHSignature(context.Context, *Message) (*Message, error)
	GitUser(context.Context, *Empty) (*Message, error)
	DevsyConfig(context.Context, *Message) (*Message, error)
	GPGPublicKeys(context.Context, *Message) (*Message, error)
	KubeConfig(context.Context, *Message) (*Message, error)
	Secrets(context.Context, *Empty) (*SecretsResponse, error)
	ForwardPort(context.Context, *ForwardPortRequest) (*ForwardPortResponse, error)
	StopForwardPort(context.Context, *StopForwardPortRequest) (*StopForwardPortResponse, error)
	StreamWorkspace(*Empty, grpc.ServerStreamingServer[Chunk]) error
	StreamMount(*StreamMountRequest, grpc.ServerStreamingServer[Chunk]) error
	StreamSnapshotVolumes(*Empty, grpc.ServerStreamingServer[Chunk]) error
	LifecycleTerminal(grpc.BidiStreamingServer[LifecycleTerminalRequest, LifecycleTerminalResponse]) error
	// contains filtered or unexported methods
}

TunnelServer is the server API for Tunnel service. All implementations must embed UnimplementedTunnelServer for forward compatibility.

type Tunnel_LifecycleTerminalClient added in v1.27.0 

type Tunnel_LifecycleTerminalClient = grpc.BidiStreamingClient[LifecycleTerminalRequest, LifecycleTerminalResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Tunnel_LifecycleTerminalServer added in v1.27.0 

type Tunnel_LifecycleTerminalServer = grpc.BidiStreamingServer[LifecycleTerminalRequest, LifecycleTerminalResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Tunnel_StreamMountClient 

type Tunnel_StreamMountClient = grpc.ServerStreamingClient[Chunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Tunnel_StreamMountServer 

type Tunnel_StreamMountServer = grpc.ServerStreamingServer[Chunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Tunnel_StreamSnapshotVolumesClient added in v1.14.0 

type Tunnel_StreamSnapshotVolumesClient = grpc.ServerStreamingClient[Chunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Tunnel_StreamSnapshotVolumesServer added in v1.14.0 

type Tunnel_StreamSnapshotVolumesServer = grpc.ServerStreamingServer[Chunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Tunnel_StreamWorkspaceClient 

type Tunnel_StreamWorkspaceClient = grpc.ServerStreamingClient[Chunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Tunnel_StreamWorkspaceServer 

type Tunnel_StreamWorkspaceServer = grpc.ServerStreamingServer[Chunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedTunnelServer 

type UnimplementedTunnelServer struct{}

UnimplementedTunnelServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTunnelServer) AppendSetupLogs added in v1.27.0 

func (UnimplementedTunnelServer) AppendSetupLogs(context.Context, *AppendSetupLogsRequest) (*AppendSetupLogsResponse, error)

func (UnimplementedTunnelServer) DevsyConfig 

func (UnimplementedTunnelServer) DevsyConfig(context.Context, *Message) (*Message, error)

func (UnimplementedTunnelServer) DockerCredentials 

func (UnimplementedTunnelServer) DockerCredentials(context.Context, *Message) (*Message, error)

func (UnimplementedTunnelServer) ForwardPort 

func (UnimplementedTunnelServer) ForwardPort(context.Context, *ForwardPortRequest) (*ForwardPortResponse, error)

func (UnimplementedTunnelServer) GPGPublicKeys 

func (UnimplementedTunnelServer) GPGPublicKeys(context.Context, *Message) (*Message, error)

func (UnimplementedTunnelServer) GitCredentials 

func (UnimplementedTunnelServer) GitCredentials(context.Context, *Message) (*Message, error)

func (UnimplementedTunnelServer) GitHubCredentials added in v1.25.0 

func (UnimplementedTunnelServer) GitHubCredentials(context.Context, *Empty) (*Message, error)

func (UnimplementedTunnelServer) GitSSHSignature 

func (UnimplementedTunnelServer) GitSSHSignature(context.Context, *Message) (*Message, error)

func (UnimplementedTunnelServer) GitUser 

func (UnimplementedTunnelServer) GitUser(context.Context, *Empty) (*Message, error)

func (UnimplementedTunnelServer) KubeConfig 

func (UnimplementedTunnelServer) KubeConfig(context.Context, *Message) (*Message, error)

func (UnimplementedTunnelServer) LifecycleTerminal added in v1.27.0 

func (UnimplementedTunnelServer) LifecycleTerminal(grpc.BidiStreamingServer[LifecycleTerminalRequest, LifecycleTerminalResponse]) error

func (UnimplementedTunnelServer) Log 

func (UnimplementedTunnelServer) Log(context.Context, *LogMessage) (*Empty, error)

func (UnimplementedTunnelServer) Ping 

func (UnimplementedTunnelServer) Ping(context.Context, *Empty) (*Empty, error)

func (UnimplementedTunnelServer) Secrets added in v1.10.0 

func (UnimplementedTunnelServer) Secrets(context.Context, *Empty) (*SecretsResponse, error)

func (UnimplementedTunnelServer) SendResult 

func (UnimplementedTunnelServer) SendResult(context.Context, *Message) (*Empty, error)

func (UnimplementedTunnelServer) Status added in v1.13.0 

func (UnimplementedTunnelServer) Status(context.Context, *StatusUpdate) (*Empty, error)

func (UnimplementedTunnelServer) StopForwardPort 

func (UnimplementedTunnelServer) StopForwardPort(context.Context, *StopForwardPortRequest) (*StopForwardPortResponse, error)

func (UnimplementedTunnelServer) StreamMount 

func (UnimplementedTunnelServer) StreamMount(*StreamMountRequest, grpc.ServerStreamingServer[Chunk]) error

func (UnimplementedTunnelServer) StreamSnapshotVolumes added in v1.14.0 

func (UnimplementedTunnelServer) StreamSnapshotVolumes(*Empty, grpc.ServerStreamingServer[Chunk]) error

func (UnimplementedTunnelServer) StreamWorkspace 

func (UnimplementedTunnelServer) StreamWorkspace(*Empty, grpc.ServerStreamingServer[Chunk]) error

type UnsafeTunnelServer 

type UnsafeTunnelServer interface {
	// contains filtered or unexported methods
}

UnsafeTunnelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TunnelServer will result in compilation errors.

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.