pb

package
v0.139.0 Latest Latest
Warning

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

Go to latest
Published: Jun 21, 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)

Functions

func RegisterEggServer

func RegisterEggServer(s grpc.ServiceRegistrar, srv EggServer)

Types

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"`
	// contains filtered or unexported fields
}

func (*ResizeRequest) Descriptor deprecated

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

Deprecated: Use ResizeRequest.ProtoReflect.Descriptor instead.

func (*ResizeRequest) GetCols

func (x *ResizeRequest) GetCols() uint32

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"`
	// 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) 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"`
	// 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) 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) 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) Resize

func (UnimplementedEggServer) Session

func (UnimplementedEggServer) Status added in v0.19.0

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL