Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterEggServer(s grpc.ServiceRegistrar, srv EggServer)
- type EggClient
- type EggServer
- type Egg_SessionClient
- type Egg_SessionServer
- type KillRequest
- type KillResponse
- type Resize
- type ResizeRequest
- func (*ResizeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResizeRequest) GetCols() uint32
- func (x *ResizeRequest) GetRows() uint32
- func (x *ResizeRequest) GetSessionId() string
- func (*ResizeRequest) ProtoMessage()
- func (x *ResizeRequest) ProtoReflect() protoreflect.Message
- func (x *ResizeRequest) Reset()
- func (x *ResizeRequest) String() string
- type ResizeResponse
- type SessionMsg
- func (*SessionMsg) Descriptor() ([]byte, []int)deprecated
- func (x *SessionMsg) GetAttach() bool
- func (x *SessionMsg) GetDetach() bool
- func (x *SessionMsg) GetExitCode() int32
- func (x *SessionMsg) GetInput() []byte
- func (x *SessionMsg) GetOutput() []byte
- func (x *SessionMsg) GetPayload() isSessionMsg_Payload
- func (x *SessionMsg) GetResize() *Resize
- func (x *SessionMsg) GetSessionId() string
- func (*SessionMsg) ProtoMessage()
- func (x *SessionMsg) ProtoReflect() protoreflect.Message
- func (x *SessionMsg) Reset()
- func (x *SessionMsg) String() string
- type SessionMsg_Attach
- type SessionMsg_Detach
- type SessionMsg_ExitCode
- type SessionMsg_Input
- type SessionMsg_Output
- type SessionMsg_Resize
- type StatusRequest
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusResponse) GetAgent() string
- func (x *StatusResponse) GetBufferBytes() int64
- func (x *StatusResponse) GetIdleSeconds() int64
- func (x *StatusResponse) GetReaders() int32
- func (x *StatusResponse) GetRenderedConfig() string
- func (x *StatusResponse) GetSessionId() string
- func (x *StatusResponse) GetTotalTrimmed() int64
- func (x *StatusResponse) GetTotalWritten() int64
- func (x *StatusResponse) GetUptimeSeconds() int64
- func (*StatusResponse) ProtoMessage()
- func (x *StatusResponse) ProtoReflect() protoreflect.Message
- func (x *StatusResponse) Reset()
- func (x *StatusResponse) String() string
- type UnimplementedEggServer
- func (UnimplementedEggServer) Kill(context.Context, *KillRequest) (*KillResponse, error)
- func (UnimplementedEggServer) Resize(context.Context, *ResizeRequest) (*ResizeResponse, error)
- func (UnimplementedEggServer) Session(grpc.BidiStreamingServer[SessionMsg, SessionMsg]) error
- func (UnimplementedEggServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
- type UnsafeEggServer
Constants ¶
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 ¶
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)
var File_egg_proto protoreflect.FileDescriptor
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) ProtoMessage ¶
func (*Resize) ProtoMessage()
func (*Resize) ProtoReflect ¶
func (x *Resize) ProtoReflect() protoreflect.Message
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) 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.