tunnel

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
}

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
}

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

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

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

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

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
}

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
}

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

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

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
}

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

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
}

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
}

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
}

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
}

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
}

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

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

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

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

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

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
}

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
}

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

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

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

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

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

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

type LogLevel int32

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
}

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

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
}

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

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

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
}

type SetupLogResult int32

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

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
}

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

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
}

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
}

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

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

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

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 struct {
	ExitCode           int
	Signal, StartError string
}

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

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

type TerminalWindow struct {
	Term          string
	Rows, Columns uint16
}

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)
}

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
}

type Tunnel_LifecycleTerminalClient = grpc.BidiStreamingClient[LifecycleTerminalRequest, LifecycleTerminalResponse]

type Tunnel_LifecycleTerminalServer = grpc.BidiStreamingServer[LifecycleTerminalRequest, LifecycleTerminalResponse]

type Tunnel_StreamMountClient = grpc.ServerStreamingClient[Chunk]

type Tunnel_StreamMountServer = grpc.ServerStreamingServer[Chunk]

type Tunnel_StreamSnapshotVolumesClient = grpc.ServerStreamingClient[Chunk]

type Tunnel_StreamSnapshotVolumesServer = grpc.ServerStreamingServer[Chunk]

type Tunnel_StreamWorkspaceClient = grpc.ServerStreamingClient[Chunk]

type Tunnel_StreamWorkspaceServer = grpc.ServerStreamingServer[Chunk]

type UnimplementedTunnelServer struct{}

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