pb

package
v0.7.2 Latest Latest
Warning

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

Go to latest
Published: Feb 10, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Egg_Spawn_FullMethodName   = "/egg.Egg/Spawn"
	Egg_List_FullMethodName    = "/egg.Egg/List"
	Egg_Kill_FullMethodName    = "/egg.Egg/Kill"
	Egg_Resize_FullMethodName  = "/egg.Egg/Resize"
	Egg_Session_FullMethodName = "/egg.Egg/Session"
	Egg_Version_FullMethodName = "/egg.Egg/Version"
)

Variables

View Source
var Egg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "egg.Egg",
	HandlerType: (*EggServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Spawn",
			Handler:    _Egg_Spawn_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Egg_List_Handler,
		},
		{
			MethodName: "Kill",
			Handler:    _Egg_Kill_Handler,
		},
		{
			MethodName: "Resize",
			Handler:    _Egg_Resize_Handler,
		},
		{
			MethodName: "Version",
			Handler:    _Egg_Version_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 {
	Spawn(ctx context.Context, in *SpawnRequest, opts ...grpc.CallOption) (*SpawnResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	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)
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, 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 {
	Spawn(context.Context, *SpawnRequest) (*SpawnResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Kill(context.Context, *KillRequest) (*KillResponse, error)
	Resize(context.Context, *ResizeRequest) (*ResizeResponse, error)
	Session(grpc.BidiStreamingServer[SessionMsg, SessionMsg]) error
	Version(context.Context, *VersionRequest) (*VersionResponse, 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 ListRequest

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

func (*ListRequest) Descriptor deprecated

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect

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

func (*ListRequest) Reset

func (x *ListRequest) Reset()

func (*ListRequest) String

func (x *ListRequest) String() string

type ListResponse

type ListResponse struct {
	Sessions []*SessionInfo `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetSessions

func (x *ListResponse) GetSessions() []*SessionInfo

func (*ListResponse) ProtoMessage

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect

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

func (*ListResponse) Reset

func (x *ListResponse) Reset()

func (*ListResponse) String

func (x *ListResponse) String() string

type Mount

type Mount struct {
	Source   string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Target   string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	ReadOnly bool   `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	// contains filtered or unexported fields
}

func (*Mount) Descriptor deprecated

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

Deprecated: Use Mount.ProtoReflect.Descriptor instead.

func (*Mount) GetReadOnly

func (x *Mount) GetReadOnly() bool

func (*Mount) GetSource

func (x *Mount) GetSource() string

func (*Mount) GetTarget

func (x *Mount) GetTarget() string

func (*Mount) ProtoMessage

func (*Mount) ProtoMessage()

func (*Mount) ProtoReflect

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

func (*Mount) Reset

func (x *Mount) Reset()

func (*Mount) String

func (x *Mount) 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 ResourceLimits

type ResourceLimits struct {
	CpuSeconds  uint32 `protobuf:"varint,1,opt,name=cpu_seconds,json=cpuSeconds,proto3" json:"cpu_seconds,omitempty"`    // RLIMIT_CPU (0 = no limit)
	MemoryBytes uint64 `protobuf:"varint,2,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"` // RLIMIT_AS (0 = no limit)
	MaxFds      uint32 `protobuf:"varint,3,opt,name=max_fds,json=maxFds,proto3" json:"max_fds,omitempty"`                // RLIMIT_NOFILE (0 = no limit)
	MaxPids     uint32 `protobuf:"varint,4,opt,name=max_pids,json=maxPids,proto3" json:"max_pids,omitempty"`             // cgroup pids.max (0 = no limit)
	// contains filtered or unexported fields
}

func (*ResourceLimits) Descriptor deprecated

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

Deprecated: Use ResourceLimits.ProtoReflect.Descriptor instead.

func (*ResourceLimits) GetCpuSeconds

func (x *ResourceLimits) GetCpuSeconds() uint32

func (*ResourceLimits) GetMaxFds

func (x *ResourceLimits) GetMaxFds() uint32

func (*ResourceLimits) GetMaxPids

func (x *ResourceLimits) GetMaxPids() uint32

func (*ResourceLimits) GetMemoryBytes

func (x *ResourceLimits) GetMemoryBytes() uint64

func (*ResourceLimits) ProtoMessage

func (*ResourceLimits) ProtoMessage()

func (*ResourceLimits) ProtoReflect

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

func (*ResourceLimits) Reset

func (x *ResourceLimits) Reset()

func (*ResourceLimits) String

func (x *ResourceLimits) String() string

type SessionInfo

type SessionInfo struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Pid       int32  `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	Agent     string `protobuf:"bytes,3,opt,name=agent,proto3" json:"agent,omitempty"`
	Cwd       string `protobuf:"bytes,4,opt,name=cwd,proto3" json:"cwd,omitempty"`
	StartedAt string `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	Isolation string `protobuf:"bytes,6,opt,name=isolation,proto3" json:"isolation,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionInfo) Descriptor deprecated

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

Deprecated: Use SessionInfo.ProtoReflect.Descriptor instead.

func (*SessionInfo) GetAgent

func (x *SessionInfo) GetAgent() string

func (*SessionInfo) GetCwd

func (x *SessionInfo) GetCwd() string

func (*SessionInfo) GetIsolation

func (x *SessionInfo) GetIsolation() string

func (*SessionInfo) GetPid

func (x *SessionInfo) GetPid() int32

func (*SessionInfo) GetSessionId

func (x *SessionInfo) GetSessionId() string

func (*SessionInfo) GetStartedAt

func (x *SessionInfo) GetStartedAt() string

func (*SessionInfo) ProtoMessage

func (*SessionInfo) ProtoMessage()

func (*SessionInfo) ProtoReflect

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

func (*SessionInfo) Reset

func (x *SessionInfo) Reset()

func (*SessionInfo) String

func (x *SessionInfo) 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 SpawnRequest

type SpawnRequest 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"`
	Cwd            string            `protobuf:"bytes,3,opt,name=cwd,proto3" json:"cwd,omitempty"`
	Rows           uint32            `protobuf:"varint,4,opt,name=rows,proto3" json:"rows,omitempty"`
	Cols           uint32            `protobuf:"varint,5,opt,name=cols,proto3" json:"cols,omitempty"`
	Isolation      string            `protobuf:"bytes,6,opt,name=isolation,proto3" json:"isolation,omitempty"`
	Env            map[string]string `` /* 133-byte string literal not displayed */
	Mounts         []*Mount          `protobuf:"bytes,8,rep,name=mounts,proto3" json:"mounts,omitempty"`
	TimeoutSeconds uint32            `protobuf:"varint,9,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	ResourceLimits *ResourceLimits   `protobuf:"bytes,10,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"`
	Skill          string            `protobuf:"bytes,11,opt,name=skill,proto3" json:"skill,omitempty"` // skill name for logging/tracking
	Metadata       map[string]string ``                                                                 // arbitrary key-value pairs
	/* 144-byte string literal not displayed */
	Shell string `protobuf:"bytes,13,opt,name=shell,proto3" json:"shell,omitempty"` // override shell (default: agent decides)
	// contains filtered or unexported fields
}

func (*SpawnRequest) Descriptor deprecated

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

Deprecated: Use SpawnRequest.ProtoReflect.Descriptor instead.

func (*SpawnRequest) GetAgent

func (x *SpawnRequest) GetAgent() string

func (*SpawnRequest) GetCols

func (x *SpawnRequest) GetCols() uint32

func (*SpawnRequest) GetCwd

func (x *SpawnRequest) GetCwd() string

func (*SpawnRequest) GetEnv

func (x *SpawnRequest) GetEnv() map[string]string

func (*SpawnRequest) GetIsolation

func (x *SpawnRequest) GetIsolation() string

func (*SpawnRequest) GetMetadata

func (x *SpawnRequest) GetMetadata() map[string]string

func (*SpawnRequest) GetMounts

func (x *SpawnRequest) GetMounts() []*Mount

func (*SpawnRequest) GetResourceLimits

func (x *SpawnRequest) GetResourceLimits() *ResourceLimits

func (*SpawnRequest) GetRows

func (x *SpawnRequest) GetRows() uint32

func (*SpawnRequest) GetSessionId

func (x *SpawnRequest) GetSessionId() string

func (*SpawnRequest) GetShell

func (x *SpawnRequest) GetShell() string

func (*SpawnRequest) GetSkill

func (x *SpawnRequest) GetSkill() string

func (*SpawnRequest) GetTimeoutSeconds

func (x *SpawnRequest) GetTimeoutSeconds() uint32

func (*SpawnRequest) ProtoMessage

func (*SpawnRequest) ProtoMessage()

func (*SpawnRequest) ProtoReflect

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

func (*SpawnRequest) Reset

func (x *SpawnRequest) Reset()

func (*SpawnRequest) String

func (x *SpawnRequest) String() string

type SpawnResponse

type SpawnResponse struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Pid       int32  `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*SpawnResponse) Descriptor deprecated

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

Deprecated: Use SpawnResponse.ProtoReflect.Descriptor instead.

func (*SpawnResponse) GetPid

func (x *SpawnResponse) GetPid() int32

func (*SpawnResponse) GetSessionId

func (x *SpawnResponse) GetSessionId() string

func (*SpawnResponse) ProtoMessage

func (*SpawnResponse) ProtoMessage()

func (*SpawnResponse) ProtoReflect

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

func (*SpawnResponse) Reset

func (x *SpawnResponse) Reset()

func (*SpawnResponse) String

func (x *SpawnResponse) 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) List

func (UnimplementedEggServer) Resize

func (UnimplementedEggServer) Session

func (UnimplementedEggServer) Spawn

func (UnimplementedEggServer) Version

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.

type VersionRequest

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

func (*VersionRequest) Descriptor deprecated

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

Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.

func (*VersionRequest) ProtoMessage

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) ProtoReflect

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

func (*VersionRequest) Reset

func (x *VersionRequest) Reset()

func (*VersionRequest) String

func (x *VersionRequest) String() string

type VersionResponse

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

func (*VersionResponse) Descriptor deprecated

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetVersion

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect

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

func (*VersionResponse) Reset

func (x *VersionResponse) Reset()

func (*VersionResponse) String

func (x *VersionResponse) String() string

Jump to

Keyboard shortcuts

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