pb

package
v0.149.4 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Egg_Kill_FullMethodName    = "/egg.Egg/Kill"
	Egg_Resize_FullMethodName  = "/egg.Egg/Resize"
	Egg_Session_FullMethodName = "/egg.Egg/Session"
	Egg_Status_FullMethodName  = "/egg.Egg/Status"
)

Variables

View Source 
var Egg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "egg.Egg",
	HandlerType: (*EggServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Kill",
			Handler:    _Egg_Kill_Handler,
		},
		{
			MethodName: "Resize",
			Handler:    _Egg_Resize_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Egg_Status_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Session",
			Handler:       _Egg_Session_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "egg.proto",
}

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

View Source 
var File_egg_proto protoreflect.FileDescriptor

Functions

func RegisterEggServer 

func RegisterEggServer(s grpc.ServiceRegistrar, srv EggServer)

Types

type AttachOptions added in v0.148.0 

type AttachOptions struct {
	ReadOnly       bool   `protobuf:"varint,1,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	Takeover       bool   `protobuf:"varint,2,opt,name=takeover,proto3" json:"takeover,omitempty"`
	Claim          bool   `protobuf:"varint,3,opt,name=claim,proto3" json:"claim,omitempty"`
	Owner          string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`
	Rows           uint32 `protobuf:"varint,5,opt,name=rows,proto3" json:"rows,omitempty"`
	Cols           uint32 `protobuf:"varint,6,opt,name=cols,proto3" json:"cols,omitempty"`
	NativeTerminal bool   `protobuf:"varint,7,opt,name=native_terminal,json=nativeTerminal,proto3" json:"native_terminal,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachOptions) Descriptor deprecated added in v0.148.0 

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

Deprecated: Use AttachOptions.ProtoReflect.Descriptor instead.

func (*AttachOptions) GetClaim added in v0.148.0 

func (x *AttachOptions) GetClaim() bool

func (*AttachOptions) GetCols added in v0.148.0 

func (x *AttachOptions) GetCols() uint32

func (*AttachOptions) GetNativeTerminal added in v0.149.4 

func (x *AttachOptions) GetNativeTerminal() bool

func (*AttachOptions) GetOwner added in v0.148.0 

func (x *AttachOptions) GetOwner() string

func (*AttachOptions) GetReadOnly added in v0.148.0 

func (x *AttachOptions) GetReadOnly() bool

func (*AttachOptions) GetRows added in v0.148.0 

func (x *AttachOptions) GetRows() uint32

func (*AttachOptions) GetTakeover added in v0.148.0 

func (x *AttachOptions) GetTakeover() bool

func (*AttachOptions) ProtoMessage added in v0.148.0 

func (*AttachOptions) ProtoMessage()

func (*AttachOptions) ProtoReflect added in v0.148.0 

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

func (*AttachOptions) Reset added in v0.148.0 

func (x *AttachOptions) Reset()

func (*AttachOptions) String added in v0.148.0 

func (x *AttachOptions) String() string

type AttachmentInfo added in v0.148.0 

type AttachmentInfo struct {
	AttachmentId    string `protobuf:"bytes,1,opt,name=attachment_id,json=attachmentId,proto3" json:"attachment_id,omitempty"`
	WriterId        string `protobuf:"bytes,2,opt,name=writer_id,json=writerId,proto3" json:"writer_id,omitempty"`
	WriterOwner     string `protobuf:"bytes,3,opt,name=writer_owner,json=writerOwner,proto3" json:"writer_owner,omitempty"`
	InputEpoch      uint64 `protobuf:"varint,4,opt,name=input_epoch,json=inputEpoch,proto3" json:"input_epoch,omitempty"`
	AttachmentToken string `protobuf:"bytes,5,opt,name=attachment_token,json=attachmentToken,proto3" json:"attachment_token,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachmentInfo) Descriptor deprecated added in v0.148.0 

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

Deprecated: Use AttachmentInfo.ProtoReflect.Descriptor instead.

func (*AttachmentInfo) GetAttachmentId added in v0.148.0 

func (x *AttachmentInfo) GetAttachmentId() string

func (*AttachmentInfo) GetAttachmentToken added in v0.148.0 

func (x *AttachmentInfo) GetAttachmentToken() string

func (*AttachmentInfo) GetInputEpoch added in v0.148.0 

func (x *AttachmentInfo) GetInputEpoch() uint64

func (*AttachmentInfo) GetWriterId added in v0.148.0 

func (x *AttachmentInfo) GetWriterId() string

func (*AttachmentInfo) GetWriterOwner added in v0.148.0 

func (x *AttachmentInfo) GetWriterOwner() string

func (*AttachmentInfo) ProtoMessage added in v0.148.0 

func (*AttachmentInfo) ProtoMessage()

func (*AttachmentInfo) ProtoReflect added in v0.148.0 

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

func (*AttachmentInfo) Reset added in v0.148.0 

func (x *AttachmentInfo) Reset()

func (*AttachmentInfo) String added in v0.148.0 

func (x *AttachmentInfo) String() string

type EggClient 

type EggClient interface {
	Kill(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*KillResponse, error)
	Resize(ctx context.Context, in *ResizeRequest, opts ...grpc.CallOption) (*ResizeResponse, error)
	Session(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SessionMsg, SessionMsg], error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

EggClient is the client API for Egg 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 NewEggClient 

func NewEggClient(cc grpc.ClientConnInterface) EggClient

type EggServer 

type EggServer interface {
	Kill(context.Context, *KillRequest) (*KillResponse, error)
	Resize(context.Context, *ResizeRequest) (*ResizeResponse, error)
	Session(grpc.BidiStreamingServer[SessionMsg, SessionMsg]) error
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

EggServer is the server API for Egg service. All implementations must embed UnimplementedEggServer for forward compatibility.

type Egg_SessionClient 

type Egg_SessionClient = grpc.BidiStreamingClient[SessionMsg, SessionMsg]

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

type Egg_SessionServer 

type Egg_SessionServer = grpc.BidiStreamingServer[SessionMsg, SessionMsg]

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

type KillRequest 

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

func (*KillRequest) Descriptor deprecated 

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

Deprecated: Use KillRequest.ProtoReflect.Descriptor instead.

func (*KillRequest) GetSessionId 

func (x *KillRequest) GetSessionId() string

func (*KillRequest) ProtoMessage 

func (*KillRequest) ProtoMessage()

func (*KillRequest) ProtoReflect 

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

func (*KillRequest) Reset 

func (x *KillRequest) Reset()

func (*KillRequest) String 

func (x *KillRequest) String() string

type KillResponse 

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

func (*KillResponse) Descriptor deprecated 

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

Deprecated: Use KillResponse.ProtoReflect.Descriptor instead.

func (*KillResponse) ProtoMessage 

func (*KillResponse) ProtoMessage()

func (*KillResponse) ProtoReflect 

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

func (*KillResponse) Reset 

func (x *KillResponse) Reset()

func (*KillResponse) String 

func (x *KillResponse) String() string

type Resize 

type Resize struct {
	Rows uint32 `protobuf:"varint,1,opt,name=rows,proto3" json:"rows,omitempty"`
	Cols uint32 `protobuf:"varint,2,opt,name=cols,proto3" json:"cols,omitempty"`
	// contains filtered or unexported fields
}

func (*Resize) Descriptor deprecated 

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

Deprecated: Use Resize.ProtoReflect.Descriptor instead.

func (*Resize) GetCols 

func (x *Resize) GetCols() uint32

func (*Resize) GetRows 

func (x *Resize) GetRows() uint32

func (*Resize) ProtoMessage 

func (*Resize) ProtoMessage()

func (*Resize) ProtoReflect 

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

func (*Resize) Reset 

func (x *Resize) Reset()

func (*Resize) String 

func (x *Resize) String() string

type ResizeRequest 

type ResizeRequest struct {
	SessionId       string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Rows            uint32 `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	Cols            uint32 `protobuf:"varint,3,opt,name=cols,proto3" json:"cols,omitempty"`
	AttachmentId    string `protobuf:"bytes,4,opt,name=attachment_id,json=attachmentId,proto3" json:"attachment_id,omitempty"`
	InputEpoch      uint64 `protobuf:"varint,5,opt,name=input_epoch,json=inputEpoch,proto3" json:"input_epoch,omitempty"`
	AttachmentToken string `protobuf:"bytes,6,opt,name=attachment_token,json=attachmentToken,proto3" json:"attachment_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ResizeRequest) Descriptor deprecated 

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

Deprecated: Use ResizeRequest.ProtoReflect.Descriptor instead.

func (*ResizeRequest) GetAttachmentId added in v0.148.0 

func (x *ResizeRequest) GetAttachmentId() string

func (*ResizeRequest) GetAttachmentToken added in v0.148.0 

func (x *ResizeRequest) GetAttachmentToken() string

func (*ResizeRequest) GetCols 

func (x *ResizeRequest) GetCols() uint32

func (*ResizeRequest) GetInputEpoch added in v0.148.0 

func (x *ResizeRequest) GetInputEpoch() uint64

func (*ResizeRequest) GetRows 

func (x *ResizeRequest) GetRows() uint32

func (*ResizeRequest) GetSessionId 

func (x *ResizeRequest) GetSessionId() string

func (*ResizeRequest) ProtoMessage 

func (*ResizeRequest) ProtoMessage()

func (*ResizeRequest) ProtoReflect 

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

func (*ResizeRequest) Reset 

func (x *ResizeRequest) Reset()

func (*ResizeRequest) String 

func (x *ResizeRequest) String() string

type ResizeResponse 

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

func (*ResizeResponse) Descriptor deprecated 

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

Deprecated: Use ResizeResponse.ProtoReflect.Descriptor instead.

func (*ResizeResponse) ProtoMessage 

func (*ResizeResponse) ProtoMessage()

func (*ResizeResponse) ProtoReflect 

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

func (*ResizeResponse) Reset 

func (x *ResizeResponse) Reset()

func (*ResizeResponse) String 

func (x *ResizeResponse) String() string

type SessionMsg 

type SessionMsg struct {
	SessionId      string          `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	AttachOptions  *AttachOptions  `protobuf:"bytes,8,opt,name=attach_options,json=attachOptions,proto3" json:"attach_options,omitempty"`
	AttachmentInfo *AttachmentInfo `protobuf:"bytes,9,opt,name=attachment_info,json=attachmentInfo,proto3" json:"attachment_info,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*SessionMsg_Output
	//	*SessionMsg_Input
	//	*SessionMsg_Resize
	//	*SessionMsg_ExitCode
	//	*SessionMsg_Attach
	//	*SessionMsg_Detach
	Payload isSessionMsg_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*SessionMsg) Descriptor deprecated 

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

Deprecated: Use SessionMsg.ProtoReflect.Descriptor instead.

func (*SessionMsg) GetAttach 

func (x *SessionMsg) GetAttach() bool

func (*SessionMsg) GetAttachOptions added in v0.148.0 

func (x *SessionMsg) GetAttachOptions() *AttachOptions

func (*SessionMsg) GetAttachmentInfo added in v0.148.0 

func (x *SessionMsg) GetAttachmentInfo() *AttachmentInfo

func (*SessionMsg) GetDetach 

func (x *SessionMsg) GetDetach() bool

func (*SessionMsg) GetExitCode 

func (x *SessionMsg) GetExitCode() int32

func (*SessionMsg) GetInput 

func (x *SessionMsg) GetInput() []byte

func (*SessionMsg) GetOutput 

func (x *SessionMsg) GetOutput() []byte

func (*SessionMsg) GetPayload 

func (x *SessionMsg) GetPayload() isSessionMsg_Payload

func (*SessionMsg) GetResize 

func (x *SessionMsg) GetResize() *Resize

func (*SessionMsg) GetSessionId 

func (x *SessionMsg) GetSessionId() string

func (*SessionMsg) ProtoMessage 

func (*SessionMsg) ProtoMessage()

func (*SessionMsg) ProtoReflect 

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

func (*SessionMsg) Reset 

func (x *SessionMsg) Reset()

func (*SessionMsg) String 

func (x *SessionMsg) String() string

type SessionMsg_Attach 

type SessionMsg_Attach struct {
	Attach bool `protobuf:"varint,6,opt,name=attach,proto3,oneof"`
}

type SessionMsg_Detach 

type SessionMsg_Detach struct {
	Detach bool `protobuf:"varint,7,opt,name=detach,proto3,oneof"`
}

type SessionMsg_ExitCode 

type SessionMsg_ExitCode struct {
	ExitCode int32 `protobuf:"varint,5,opt,name=exit_code,json=exitCode,proto3,oneof"`
}

type SessionMsg_Input 

type SessionMsg_Input struct {
	Input []byte `protobuf:"bytes,3,opt,name=input,proto3,oneof"`
}

type SessionMsg_Output 

type SessionMsg_Output struct {
	Output []byte `protobuf:"bytes,2,opt,name=output,proto3,oneof"`
}

type SessionMsg_Resize 

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

type StatusRequest added in v0.19.0 

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

func (*StatusRequest) Descriptor deprecated added in v0.19.0 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage added in v0.19.0 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect added in v0.19.0 

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

func (*StatusRequest) Reset added in v0.19.0 

func (x *StatusRequest) Reset()

func (*StatusRequest) String added in v0.19.0 

func (x *StatusRequest) String() string

type StatusResponse added in v0.19.0 

type StatusResponse struct {
	SessionId      string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Agent          string `protobuf:"bytes,2,opt,name=agent,proto3" json:"agent,omitempty"`
	BufferBytes    int64  `protobuf:"varint,3,opt,name=buffer_bytes,json=bufferBytes,proto3" json:"buffer_bytes,omitempty"`
	TotalWritten   int64  `protobuf:"varint,4,opt,name=total_written,json=totalWritten,proto3" json:"total_written,omitempty"`
	TotalTrimmed   int64  `protobuf:"varint,5,opt,name=total_trimmed,json=totalTrimmed,proto3" json:"total_trimmed,omitempty"`
	Readers        int32  `protobuf:"varint,6,opt,name=readers,proto3" json:"readers,omitempty"`
	UptimeSeconds  int64  `protobuf:"varint,7,opt,name=uptime_seconds,json=uptimeSeconds,proto3" json:"uptime_seconds,omitempty"`
	RenderedConfig string `protobuf:"bytes,8,opt,name=rendered_config,json=renderedConfig,proto3" json:"rendered_config,omitempty"`
	IdleSeconds    int64  `protobuf:"varint,9,opt,name=idle_seconds,json=idleSeconds,proto3" json:"idle_seconds,omitempty"`
	WriterId       string `protobuf:"bytes,10,opt,name=writer_id,json=writerId,proto3" json:"writer_id,omitempty"`
	WriterOwner    string `protobuf:"bytes,11,opt,name=writer_owner,json=writerOwner,proto3" json:"writer_owner,omitempty"`
	InputEpoch     uint64 `protobuf:"varint,12,opt,name=input_epoch,json=inputEpoch,proto3" json:"input_epoch,omitempty"`
	ProcessPid     int32  `protobuf:"varint,13,opt,name=process_pid,json=processPid,proto3" json:"process_pid,omitempty"`
	// Explicit discovery; an ignored AttachOptions field is not negotiation.
	NativeTerminal bool `protobuf:"varint,14,opt,name=native_terminal,json=nativeTerminal,proto3" json:"native_terminal,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated added in v0.19.0 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetAgent added in v0.19.0 

func (x *StatusResponse) GetAgent() string

func (*StatusResponse) GetBufferBytes added in v0.19.0 

func (x *StatusResponse) GetBufferBytes() int64

func (*StatusResponse) GetIdleSeconds added in v0.101.0 

func (x *StatusResponse) GetIdleSeconds() int64

func (*StatusResponse) GetInputEpoch added in v0.148.0 

func (x *StatusResponse) GetInputEpoch() uint64

func (*StatusResponse) GetNativeTerminal added in v0.149.4 

func (x *StatusResponse) GetNativeTerminal() bool

func (*StatusResponse) GetProcessPid added in v0.148.0 

func (x *StatusResponse) GetProcessPid() int32

func (*StatusResponse) GetReaders added in v0.19.0 

func (x *StatusResponse) GetReaders() int32

func (*StatusResponse) GetRenderedConfig added in v0.21.0 

func (x *StatusResponse) GetRenderedConfig() string

func (*StatusResponse) GetSessionId added in v0.19.0 

func (x *StatusResponse) GetSessionId() string

func (*StatusResponse) GetTotalTrimmed added in v0.19.0 

func (x *StatusResponse) GetTotalTrimmed() int64

func (*StatusResponse) GetTotalWritten added in v0.19.0 

func (x *StatusResponse) GetTotalWritten() int64

func (*StatusResponse) GetUptimeSeconds added in v0.19.0 

func (x *StatusResponse) GetUptimeSeconds() int64

func (*StatusResponse) GetWriterId added in v0.148.0 

func (x *StatusResponse) GetWriterId() string

func (*StatusResponse) GetWriterOwner added in v0.148.0 

func (x *StatusResponse) GetWriterOwner() string

func (*StatusResponse) ProtoMessage added in v0.19.0 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect added in v0.19.0 

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

func (*StatusResponse) Reset added in v0.19.0 

func (x *StatusResponse) Reset()

func (*StatusResponse) String added in v0.19.0 

func (x *StatusResponse) String() string

type UnimplementedEggServer 

type UnimplementedEggServer struct{}

UnimplementedEggServer 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 (UnimplementedEggServer) Kill 

func (UnimplementedEggServer) Kill(context.Context, *KillRequest) (*KillResponse, error)

func (UnimplementedEggServer) Resize 

func (UnimplementedEggServer) Resize(context.Context, *ResizeRequest) (*ResizeResponse, error)

func (UnimplementedEggServer) Session 

func (UnimplementedEggServer) Session(grpc.BidiStreamingServer[SessionMsg, SessionMsg]) error

func (UnimplementedEggServer) Status added in v0.19.0 

func (UnimplementedEggServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnsafeEggServer 

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

UnsafeEggServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EggServer 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.