Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterExecPluginServer(s grpc.ServiceRegistrar, srv ExecPluginServer)
- type AttachSessionRequest
- func (*AttachSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AttachSessionRequest) GetId() string
- func (*AttachSessionRequest) ProtoMessage()
- func (x *AttachSessionRequest) ProtoReflect() protoreflect.Message
- func (x *AttachSessionRequest) Reset()
- func (x *AttachSessionRequest) String() string
- type AttachSessionResponse
- func (*AttachSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AttachSessionResponse) GetBuffer() []byte
- func (x *AttachSessionResponse) GetSession() *Session
- func (*AttachSessionResponse) ProtoMessage()
- func (x *AttachSessionResponse) ProtoReflect() protoreflect.Message
- func (x *AttachSessionResponse) Reset()
- func (x *AttachSessionResponse) String() string
- type CloseSessionRequest
- func (*CloseSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSessionRequest) GetId() string
- func (*CloseSessionRequest) ProtoMessage()
- func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
- func (x *CloseSessionRequest) Reset()
- func (x *CloseSessionRequest) String() string
- type CloseSessionResponse
- func (*CloseSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSessionResponse) GetError() string
- func (x *CloseSessionResponse) GetSuccess() bool
- func (*CloseSessionResponse) ProtoMessage()
- func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
- func (x *CloseSessionResponse) Reset()
- func (x *CloseSessionResponse) String() string
- type CreateSessionRequest
- func (*CreateSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSessionRequest) GetCommand() string
- func (x *CreateSessionRequest) GetId() string
- func (x *CreateSessionRequest) GetLabels() map[string]string
- func (x *CreateSessionRequest) GetParams() map[string]string
- func (x *CreateSessionRequest) GetTty() bool
- func (*CreateSessionRequest) ProtoMessage()
- func (x *CreateSessionRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSessionRequest) Reset()
- func (x *CreateSessionRequest) String() string
- type CreateSessionResponse
- func (*CreateSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSessionResponse) GetError() string
- func (x *CreateSessionResponse) GetSession() *Session
- func (x *CreateSessionResponse) GetSuccess() bool
- func (*CreateSessionResponse) ProtoMessage()
- func (x *CreateSessionResponse) ProtoReflect() protoreflect.Message
- func (x *CreateSessionResponse) Reset()
- func (x *CreateSessionResponse) String() string
- type ExecHandler
- func (*ExecHandler) Descriptor() ([]byte, []int)deprecated
- func (x *ExecHandler) GetDefaultCommand() []string
- func (x *ExecHandler) GetPlugin() string
- func (x *ExecHandler) GetResource() string
- func (x *ExecHandler) GetTargetBuilder() *common.ActionTargetBuilder
- func (*ExecHandler) ProtoMessage()
- func (x *ExecHandler) ProtoReflect() protoreflect.Message
- func (x *ExecHandler) Reset()
- func (x *ExecHandler) String() string
- type ExecPluginClient
- type ExecPluginServer
- type ExecPlugin_StreamClient
- type ExecPlugin_StreamServer
- type GetSessionRequest
- type GetSessionResponse
- func (*GetSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSessionResponse) GetError() string
- func (x *GetSessionResponse) GetSession() *Session
- func (x *GetSessionResponse) GetSuccess() bool
- func (*GetSessionResponse) ProtoMessage()
- func (x *GetSessionResponse) ProtoReflect() protoreflect.Message
- func (x *GetSessionResponse) Reset()
- func (x *GetSessionResponse) String() string
- type GetSupportedResourcesResponse
- func (*GetSupportedResourcesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSupportedResourcesResponse) GetHandlers() []*ExecHandler
- func (*GetSupportedResourcesResponse) ProtoMessage()
- func (x *GetSupportedResourcesResponse) ProtoReflect() protoreflect.Message
- func (x *GetSupportedResourcesResponse) Reset()
- func (x *GetSupportedResourcesResponse) String() string
- type ListSessionsResponse
- func (*ListSessionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSessionsResponse) GetError() string
- func (x *ListSessionsResponse) GetSessions() []*Session
- func (x *ListSessionsResponse) GetSuccess() bool
- func (*ListSessionsResponse) ProtoMessage()
- func (x *ListSessionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListSessionsResponse) Reset()
- func (x *ListSessionsResponse) String() string
- type ResizeSessionRequest
- func (*ResizeSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResizeSessionRequest) GetCols() int32
- func (x *ResizeSessionRequest) GetId() string
- func (x *ResizeSessionRequest) GetRows() int32
- func (*ResizeSessionRequest) ProtoMessage()
- func (x *ResizeSessionRequest) ProtoReflect() protoreflect.Message
- func (x *ResizeSessionRequest) Reset()
- func (x *ResizeSessionRequest) String() string
- type ResizeSessionResponse
- func (*ResizeSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ResizeSessionResponse) GetError() string
- func (x *ResizeSessionResponse) GetSuccess() bool
- func (*ResizeSessionResponse) ProtoMessage()
- func (x *ResizeSessionResponse) ProtoReflect() protoreflect.Message
- func (x *ResizeSessionResponse) Reset()
- func (x *ResizeSessionResponse) String() string
- type Session
- func (*Session) Descriptor() ([]byte, []int)deprecated
- func (x *Session) GetAttached() bool
- func (x *Session) GetCommand() []string
- func (x *Session) GetCreatedAt() *timestamppb.Timestamp
- func (x *Session) GetId() string
- func (x *Session) GetLabels() map[string]string
- func (x *Session) GetParams() map[string]string
- func (*Session) ProtoMessage()
- func (x *Session) ProtoReflect() protoreflect.Message
- func (x *Session) Reset()
- func (x *Session) String() string
- type SessionOptions
- func (*SessionOptions) Descriptor() ([]byte, []int)deprecated
- func (x *SessionOptions) GetCommand() []string
- func (x *SessionOptions) GetId() string
- func (x *SessionOptions) GetLabels() map[string]string
- func (x *SessionOptions) GetParams() map[string]string
- func (x *SessionOptions) GetResourceData() *structpb.Struct
- func (x *SessionOptions) GetResourceKey() string
- func (x *SessionOptions) GetResourcePlugin() string
- func (x *SessionOptions) GetTty() bool
- func (*SessionOptions) ProtoMessage()
- func (x *SessionOptions) ProtoReflect() protoreflect.Message
- func (x *SessionOptions) Reset()
- func (x *SessionOptions) String() string
- type StreamError
- func (*StreamError) Descriptor() ([]byte, []int)deprecated
- func (x *StreamError) GetMessage() string
- func (x *StreamError) GetRetryCommands() []string
- func (x *StreamError) GetRetryable() bool
- func (x *StreamError) GetSuggestion() string
- func (x *StreamError) GetTitle() string
- func (*StreamError) ProtoMessage()
- func (x *StreamError) ProtoReflect() protoreflect.Message
- func (x *StreamError) Reset()
- func (x *StreamError) String() string
- type StreamInput
- type StreamOutput
- func (*StreamOutput) Descriptor() ([]byte, []int)deprecated
- func (x *StreamOutput) GetData() []byte
- func (x *StreamOutput) GetError() *StreamError
- func (x *StreamOutput) GetId() string
- func (x *StreamOutput) GetSignal() StreamSignal
- func (x *StreamOutput) GetTarget() StreamOutput_Target
- func (*StreamOutput) ProtoMessage()
- func (x *StreamOutput) ProtoReflect() protoreflect.Message
- func (x *StreamOutput) Reset()
- func (x *StreamOutput) String() string
- type StreamOutput_Target
- func (StreamOutput_Target) Descriptor() protoreflect.EnumDescriptor
- func (x StreamOutput_Target) Enum() *StreamOutput_Target
- func (StreamOutput_Target) EnumDescriptor() ([]byte, []int)deprecated
- func (x StreamOutput_Target) Number() protoreflect.EnumNumber
- func (x StreamOutput_Target) String() string
- func (StreamOutput_Target) Type() protoreflect.EnumType
- type StreamSignal
- func (StreamSignal) Descriptor() protoreflect.EnumDescriptor
- func (x StreamSignal) Enum() *StreamSignal
- func (StreamSignal) EnumDescriptor() ([]byte, []int)deprecated
- func (x StreamSignal) Number() protoreflect.EnumNumber
- func (x StreamSignal) String() string
- func (StreamSignal) Type() protoreflect.EnumType
- type UnimplementedExecPluginServer
- func (UnimplementedExecPluginServer) AttachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)
- func (UnimplementedExecPluginServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
- func (UnimplementedExecPluginServer) CreateSession(context.Context, *SessionOptions) (*CreateSessionResponse, error)
- func (UnimplementedExecPluginServer) DetachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)
- func (UnimplementedExecPluginServer) GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)
- func (UnimplementedExecPluginServer) GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedResourcesResponse, error)
- func (UnimplementedExecPluginServer) ListSessions(context.Context, *emptypb.Empty) (*ListSessionsResponse, error)
- func (UnimplementedExecPluginServer) ResizeSession(context.Context, *ResizeSessionRequest) (*ResizeSessionResponse, error)
- func (UnimplementedExecPluginServer) Stream(ExecPlugin_StreamServer) error
- type UnsafeExecPluginServer
Constants ¶
const ( ExecPlugin_GetSupportedResources_FullMethodName = "/omniview.sdk.exec.v1.ExecPlugin/GetSupportedResources" ExecPlugin_GetSession_FullMethodName = "/omniview.sdk.exec.v1.ExecPlugin/GetSession" ExecPlugin_ListSessions_FullMethodName = "/omniview.sdk.exec.v1.ExecPlugin/ListSessions" ExecPlugin_CreateSession_FullMethodName = "/omniview.sdk.exec.v1.ExecPlugin/CreateSession" ExecPlugin_AttachSession_FullMethodName = "/omniview.sdk.exec.v1.ExecPlugin/AttachSession" ExecPlugin_DetachSession_FullMethodName = "/omniview.sdk.exec.v1.ExecPlugin/DetachSession" ExecPlugin_CloseSession_FullMethodName = "/omniview.sdk.exec.v1.ExecPlugin/CloseSession" ExecPlugin_ResizeSession_FullMethodName = "/omniview.sdk.exec.v1.ExecPlugin/ResizeSession" ExecPlugin_Stream_FullMethodName = "/omniview.sdk.exec.v1.ExecPlugin/Stream" )
Variables ¶
var ( StreamSignal_name = map[int32]string{ 0: "STREAM_SIGNAL_NONE", 1: "STREAM_SIGNAL_CLOSE", 2: "STREAM_SIGNAL_SIGINT", 3: "STREAM_SIGNAL_SIGQUIT", 4: "STREAM_SIGNAL_SIGTERM", 5: "STREAM_SIGNAL_SIGKILL", 6: "STREAM_SIGNAL_SIGHUP", 7: "STREAM_SIGNAL_SIGUSR1", 8: "STREAM_SIGNAL_SIGUSR2", 9: "STREAM_SIGNAL_SIGWINCH", 10: "STREAM_SIGNAL_ERROR", } StreamSignal_value = map[string]int32{ "STREAM_SIGNAL_NONE": 0, "STREAM_SIGNAL_CLOSE": 1, "STREAM_SIGNAL_SIGINT": 2, "STREAM_SIGNAL_SIGQUIT": 3, "STREAM_SIGNAL_SIGTERM": 4, "STREAM_SIGNAL_SIGKILL": 5, "STREAM_SIGNAL_SIGHUP": 6, "STREAM_SIGNAL_SIGUSR1": 7, "STREAM_SIGNAL_SIGUSR2": 8, "STREAM_SIGNAL_SIGWINCH": 9, "STREAM_SIGNAL_ERROR": 10, } )
Enum value maps for StreamSignal.
var ( StreamOutput_Target_name = map[int32]string{ 0: "STDOUT", 1: "STDERR", } StreamOutput_Target_value = map[string]int32{ "STDOUT": 0, "STDERR": 1, } )
Enum value maps for StreamOutput_Target.
var ExecPlugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "omniview.sdk.exec.v1.ExecPlugin", HandlerType: (*ExecPluginServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetSupportedResources", Handler: _ExecPlugin_GetSupportedResources_Handler, }, { MethodName: "GetSession", Handler: _ExecPlugin_GetSession_Handler, }, { MethodName: "ListSessions", Handler: _ExecPlugin_ListSessions_Handler, }, { MethodName: "CreateSession", Handler: _ExecPlugin_CreateSession_Handler, }, { MethodName: "AttachSession", Handler: _ExecPlugin_AttachSession_Handler, }, { MethodName: "DetachSession", Handler: _ExecPlugin_DetachSession_Handler, }, { MethodName: "CloseSession", Handler: _ExecPlugin_CloseSession_Handler, }, { MethodName: "ResizeSession", Handler: _ExecPlugin_ResizeSession_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Stream", Handler: _ExecPlugin_Stream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "proto/v1/exec/exec.proto", }
ExecPlugin_ServiceDesc is the grpc.ServiceDesc for ExecPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_v1_exec_exec_proto protoreflect.FileDescriptor
Functions ¶
func RegisterExecPluginServer ¶
func RegisterExecPluginServer(s grpc.ServiceRegistrar, srv ExecPluginServer)
Types ¶
type AttachSessionRequest ¶
type AttachSessionRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*AttachSessionRequest) Descriptor
deprecated
func (*AttachSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use AttachSessionRequest.ProtoReflect.Descriptor instead.
func (*AttachSessionRequest) GetId ¶
func (x *AttachSessionRequest) GetId() string
func (*AttachSessionRequest) ProtoMessage ¶
func (*AttachSessionRequest) ProtoMessage()
func (*AttachSessionRequest) ProtoReflect ¶
func (x *AttachSessionRequest) ProtoReflect() protoreflect.Message
func (*AttachSessionRequest) Reset ¶
func (x *AttachSessionRequest) Reset()
func (*AttachSessionRequest) String ¶
func (x *AttachSessionRequest) String() string
type AttachSessionResponse ¶
type AttachSessionResponse struct {
Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
Buffer []byte `protobuf:"bytes,2,opt,name=buffer,proto3" json:"buffer,omitempty"`
// contains filtered or unexported fields
}
func (*AttachSessionResponse) Descriptor
deprecated
func (*AttachSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use AttachSessionResponse.ProtoReflect.Descriptor instead.
func (*AttachSessionResponse) GetBuffer ¶
func (x *AttachSessionResponse) GetBuffer() []byte
func (*AttachSessionResponse) GetSession ¶
func (x *AttachSessionResponse) GetSession() *Session
func (*AttachSessionResponse) ProtoMessage ¶
func (*AttachSessionResponse) ProtoMessage()
func (*AttachSessionResponse) ProtoReflect ¶
func (x *AttachSessionResponse) ProtoReflect() protoreflect.Message
func (*AttachSessionResponse) Reset ¶
func (x *AttachSessionResponse) Reset()
func (*AttachSessionResponse) String ¶
func (x *AttachSessionResponse) String() string
type CloseSessionRequest ¶
type CloseSessionRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*CloseSessionRequest) Descriptor
deprecated
func (*CloseSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionRequest.ProtoReflect.Descriptor instead.
func (*CloseSessionRequest) GetId ¶
func (x *CloseSessionRequest) GetId() string
func (*CloseSessionRequest) ProtoMessage ¶
func (*CloseSessionRequest) ProtoMessage()
func (*CloseSessionRequest) ProtoReflect ¶
func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
func (*CloseSessionRequest) Reset ¶
func (x *CloseSessionRequest) Reset()
func (*CloseSessionRequest) String ¶
func (x *CloseSessionRequest) String() string
type CloseSessionResponse ¶
type CloseSessionResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*CloseSessionResponse) Descriptor
deprecated
func (*CloseSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.
func (*CloseSessionResponse) GetError ¶
func (x *CloseSessionResponse) GetError() string
func (*CloseSessionResponse) GetSuccess ¶
func (x *CloseSessionResponse) GetSuccess() bool
func (*CloseSessionResponse) ProtoMessage ¶
func (*CloseSessionResponse) ProtoMessage()
func (*CloseSessionResponse) ProtoReflect ¶
func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
func (*CloseSessionResponse) Reset ¶
func (x *CloseSessionResponse) Reset()
func (*CloseSessionResponse) String ¶
func (x *CloseSessionResponse) String() string
type CreateSessionRequest ¶
type CreateSessionRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
Tty bool `protobuf:"varint,3,opt,name=tty,proto3" json:"tty,omitempty"`
Params map[string]string `` /* 139-byte string literal not displayed */
Labels map[string]string `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CreateSessionRequest) Descriptor
deprecated
func (*CreateSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionRequest.ProtoReflect.Descriptor instead.
func (*CreateSessionRequest) GetCommand ¶
func (x *CreateSessionRequest) GetCommand() string
func (*CreateSessionRequest) GetId ¶
func (x *CreateSessionRequest) GetId() string
func (*CreateSessionRequest) GetLabels ¶
func (x *CreateSessionRequest) GetLabels() map[string]string
func (*CreateSessionRequest) GetParams ¶
func (x *CreateSessionRequest) GetParams() map[string]string
func (*CreateSessionRequest) GetTty ¶
func (x *CreateSessionRequest) GetTty() bool
func (*CreateSessionRequest) ProtoMessage ¶
func (*CreateSessionRequest) ProtoMessage()
func (*CreateSessionRequest) ProtoReflect ¶
func (x *CreateSessionRequest) ProtoReflect() protoreflect.Message
func (*CreateSessionRequest) Reset ¶
func (x *CreateSessionRequest) Reset()
func (*CreateSessionRequest) String ¶
func (x *CreateSessionRequest) String() string
type CreateSessionResponse ¶
type CreateSessionResponse struct {
Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*CreateSessionResponse) Descriptor
deprecated
func (*CreateSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionResponse.ProtoReflect.Descriptor instead.
func (*CreateSessionResponse) GetError ¶
func (x *CreateSessionResponse) GetError() string
func (*CreateSessionResponse) GetSession ¶
func (x *CreateSessionResponse) GetSession() *Session
func (*CreateSessionResponse) GetSuccess ¶
func (x *CreateSessionResponse) GetSuccess() bool
func (*CreateSessionResponse) ProtoMessage ¶
func (*CreateSessionResponse) ProtoMessage()
func (*CreateSessionResponse) ProtoReflect ¶
func (x *CreateSessionResponse) ProtoReflect() protoreflect.Message
func (*CreateSessionResponse) Reset ¶
func (x *CreateSessionResponse) Reset()
func (*CreateSessionResponse) String ¶
func (x *CreateSessionResponse) String() string
type ExecHandler ¶
type ExecHandler struct {
Plugin string `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
Resource string `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
TargetBuilder *common.ActionTargetBuilder `protobuf:"bytes,3,opt,name=target_builder,json=targetBuilder,proto3" json:"target_builder,omitempty"`
DefaultCommand []string `protobuf:"bytes,4,rep,name=default_command,json=defaultCommand,proto3" json:"default_command,omitempty"`
// contains filtered or unexported fields
}
func (*ExecHandler) Descriptor
deprecated
func (*ExecHandler) Descriptor() ([]byte, []int)
Deprecated: Use ExecHandler.ProtoReflect.Descriptor instead.
func (*ExecHandler) GetDefaultCommand ¶
func (x *ExecHandler) GetDefaultCommand() []string
func (*ExecHandler) GetPlugin ¶
func (x *ExecHandler) GetPlugin() string
func (*ExecHandler) GetResource ¶
func (x *ExecHandler) GetResource() string
func (*ExecHandler) GetTargetBuilder ¶
func (x *ExecHandler) GetTargetBuilder() *common.ActionTargetBuilder
func (*ExecHandler) ProtoMessage ¶
func (*ExecHandler) ProtoMessage()
func (*ExecHandler) ProtoReflect ¶
func (x *ExecHandler) ProtoReflect() protoreflect.Message
func (*ExecHandler) Reset ¶
func (x *ExecHandler) Reset()
func (*ExecHandler) String ¶
func (x *ExecHandler) String() string
type ExecPluginClient ¶
type ExecPluginClient interface {
GetSupportedResources(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSupportedResourcesResponse, error)
GetSession(ctx context.Context, in *GetSessionRequest, opts ...grpc.CallOption) (*GetSessionResponse, error)
ListSessions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListSessionsResponse, error)
CreateSession(ctx context.Context, in *SessionOptions, opts ...grpc.CallOption) (*CreateSessionResponse, error)
AttachSession(ctx context.Context, in *AttachSessionRequest, opts ...grpc.CallOption) (*AttachSessionResponse, error)
DetachSession(ctx context.Context, in *AttachSessionRequest, opts ...grpc.CallOption) (*AttachSessionResponse, error)
CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
ResizeSession(ctx context.Context, in *ResizeSessionRequest, opts ...grpc.CallOption) (*ResizeSessionResponse, error)
// Multiplexed stream for input and output
Stream(ctx context.Context, opts ...grpc.CallOption) (ExecPlugin_StreamClient, error)
}
ExecPluginClient is the client API for ExecPlugin 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 NewExecPluginClient ¶
func NewExecPluginClient(cc grpc.ClientConnInterface) ExecPluginClient
type ExecPluginServer ¶
type ExecPluginServer interface {
GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedResourcesResponse, error)
GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)
ListSessions(context.Context, *emptypb.Empty) (*ListSessionsResponse, error)
CreateSession(context.Context, *SessionOptions) (*CreateSessionResponse, error)
AttachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)
DetachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)
CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
ResizeSession(context.Context, *ResizeSessionRequest) (*ResizeSessionResponse, error)
// Multiplexed stream for input and output
Stream(ExecPlugin_StreamServer) error
}
ExecPluginServer is the server API for ExecPlugin service. All implementations should embed UnimplementedExecPluginServer for forward compatibility
type ExecPlugin_StreamClient ¶
type ExecPlugin_StreamClient interface {
Send(*StreamInput) error
Recv() (*StreamOutput, error)
grpc.ClientStream
}
type ExecPlugin_StreamServer ¶
type ExecPlugin_StreamServer interface {
Send(*StreamOutput) error
Recv() (*StreamInput, error)
grpc.ServerStream
}
type GetSessionRequest ¶
type GetSessionRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*GetSessionRequest) Descriptor
deprecated
func (*GetSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSessionRequest.ProtoReflect.Descriptor instead.
func (*GetSessionRequest) GetId ¶
func (x *GetSessionRequest) GetId() string
func (*GetSessionRequest) ProtoMessage ¶
func (*GetSessionRequest) ProtoMessage()
func (*GetSessionRequest) ProtoReflect ¶
func (x *GetSessionRequest) ProtoReflect() protoreflect.Message
func (*GetSessionRequest) Reset ¶
func (x *GetSessionRequest) Reset()
func (*GetSessionRequest) String ¶
func (x *GetSessionRequest) String() string
type GetSessionResponse ¶
type GetSessionResponse struct {
Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*GetSessionResponse) Descriptor
deprecated
func (*GetSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSessionResponse.ProtoReflect.Descriptor instead.
func (*GetSessionResponse) GetError ¶
func (x *GetSessionResponse) GetError() string
func (*GetSessionResponse) GetSession ¶
func (x *GetSessionResponse) GetSession() *Session
func (*GetSessionResponse) GetSuccess ¶
func (x *GetSessionResponse) GetSuccess() bool
func (*GetSessionResponse) ProtoMessage ¶
func (*GetSessionResponse) ProtoMessage()
func (*GetSessionResponse) ProtoReflect ¶
func (x *GetSessionResponse) ProtoReflect() protoreflect.Message
func (*GetSessionResponse) Reset ¶
func (x *GetSessionResponse) Reset()
func (*GetSessionResponse) String ¶
func (x *GetSessionResponse) String() string
type GetSupportedResourcesResponse ¶
type GetSupportedResourcesResponse struct {
Handlers []*ExecHandler `protobuf:"bytes,1,rep,name=handlers,proto3" json:"handlers,omitempty"`
// contains filtered or unexported fields
}
func (*GetSupportedResourcesResponse) Descriptor
deprecated
func (*GetSupportedResourcesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSupportedResourcesResponse.ProtoReflect.Descriptor instead.
func (*GetSupportedResourcesResponse) GetHandlers ¶
func (x *GetSupportedResourcesResponse) GetHandlers() []*ExecHandler
func (*GetSupportedResourcesResponse) ProtoMessage ¶
func (*GetSupportedResourcesResponse) ProtoMessage()
func (*GetSupportedResourcesResponse) ProtoReflect ¶
func (x *GetSupportedResourcesResponse) ProtoReflect() protoreflect.Message
func (*GetSupportedResourcesResponse) Reset ¶
func (x *GetSupportedResourcesResponse) Reset()
func (*GetSupportedResourcesResponse) String ¶
func (x *GetSupportedResourcesResponse) String() string
type ListSessionsResponse ¶
type ListSessionsResponse struct {
Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*ListSessionsResponse) Descriptor
deprecated
func (*ListSessionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSessionsResponse.ProtoReflect.Descriptor instead.
func (*ListSessionsResponse) GetError ¶
func (x *ListSessionsResponse) GetError() string
func (*ListSessionsResponse) GetSessions ¶
func (x *ListSessionsResponse) GetSessions() []*Session
func (*ListSessionsResponse) GetSuccess ¶
func (x *ListSessionsResponse) GetSuccess() bool
func (*ListSessionsResponse) ProtoMessage ¶
func (*ListSessionsResponse) ProtoMessage()
func (*ListSessionsResponse) ProtoReflect ¶
func (x *ListSessionsResponse) ProtoReflect() protoreflect.Message
func (*ListSessionsResponse) Reset ¶
func (x *ListSessionsResponse) Reset()
func (*ListSessionsResponse) String ¶
func (x *ListSessionsResponse) String() string
type ResizeSessionRequest ¶
type ResizeSessionRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Rows int32 `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
Cols int32 `protobuf:"varint,3,opt,name=cols,proto3" json:"cols,omitempty"`
// contains filtered or unexported fields
}
func (*ResizeSessionRequest) Descriptor
deprecated
func (*ResizeSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResizeSessionRequest.ProtoReflect.Descriptor instead.
func (*ResizeSessionRequest) GetCols ¶
func (x *ResizeSessionRequest) GetCols() int32
func (*ResizeSessionRequest) GetId ¶
func (x *ResizeSessionRequest) GetId() string
func (*ResizeSessionRequest) GetRows ¶
func (x *ResizeSessionRequest) GetRows() int32
func (*ResizeSessionRequest) ProtoMessage ¶
func (*ResizeSessionRequest) ProtoMessage()
func (*ResizeSessionRequest) ProtoReflect ¶
func (x *ResizeSessionRequest) ProtoReflect() protoreflect.Message
func (*ResizeSessionRequest) Reset ¶
func (x *ResizeSessionRequest) Reset()
func (*ResizeSessionRequest) String ¶
func (x *ResizeSessionRequest) String() string
type ResizeSessionResponse ¶
type ResizeSessionResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*ResizeSessionResponse) Descriptor
deprecated
func (*ResizeSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResizeSessionResponse.ProtoReflect.Descriptor instead.
func (*ResizeSessionResponse) GetError ¶
func (x *ResizeSessionResponse) GetError() string
func (*ResizeSessionResponse) GetSuccess ¶
func (x *ResizeSessionResponse) GetSuccess() bool
func (*ResizeSessionResponse) ProtoMessage ¶
func (*ResizeSessionResponse) ProtoMessage()
func (*ResizeSessionResponse) ProtoReflect ¶
func (x *ResizeSessionResponse) ProtoReflect() protoreflect.Message
func (*ResizeSessionResponse) Reset ¶
func (x *ResizeSessionResponse) Reset()
func (*ResizeSessionResponse) String ¶
func (x *ResizeSessionResponse) String() string
type Session ¶
type Session struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Attached bool `protobuf:"varint,2,opt,name=attached,proto3" json:"attached,omitempty"`
Command []string `protobuf:"bytes,3,rep,name=command,proto3" json:"command,omitempty"`
Params map[string]string `` /* 139-byte string literal not displayed */
Labels map[string]string `` /* 139-byte string literal not displayed */
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
// contains filtered or unexported fields
}
func (*Session) Descriptor
deprecated
func (*Session) GetAttached ¶
func (*Session) GetCommand ¶
func (*Session) GetCreatedAt ¶
func (x *Session) GetCreatedAt() *timestamppb.Timestamp
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶
func (x *Session) ProtoReflect() protoreflect.Message
type SessionOptions ¶
type SessionOptions struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Command []string `protobuf:"bytes,2,rep,name=command,proto3" json:"command,omitempty"`
Tty bool `protobuf:"varint,3,opt,name=tty,proto3" json:"tty,omitempty"`
Params map[string]string `` /* 139-byte string literal not displayed */
Labels map[string]string `` /* 139-byte string literal not displayed */
ResourcePlugin string `protobuf:"bytes,6,opt,name=resource_plugin,json=resourcePlugin,proto3" json:"resource_plugin,omitempty"`
ResourceKey string `protobuf:"bytes,7,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
ResourceData *structpb.Struct `protobuf:"bytes,8,opt,name=resource_data,json=resourceData,proto3" json:"resource_data,omitempty"`
// contains filtered or unexported fields
}
func (*SessionOptions) Descriptor
deprecated
func (*SessionOptions) Descriptor() ([]byte, []int)
Deprecated: Use SessionOptions.ProtoReflect.Descriptor instead.
func (*SessionOptions) GetCommand ¶
func (x *SessionOptions) GetCommand() []string
func (*SessionOptions) GetId ¶
func (x *SessionOptions) GetId() string
func (*SessionOptions) GetLabels ¶
func (x *SessionOptions) GetLabels() map[string]string
func (*SessionOptions) GetParams ¶
func (x *SessionOptions) GetParams() map[string]string
func (*SessionOptions) GetResourceData ¶
func (x *SessionOptions) GetResourceData() *structpb.Struct
func (*SessionOptions) GetResourceKey ¶
func (x *SessionOptions) GetResourceKey() string
func (*SessionOptions) GetResourcePlugin ¶
func (x *SessionOptions) GetResourcePlugin() string
func (*SessionOptions) GetTty ¶
func (x *SessionOptions) GetTty() bool
func (*SessionOptions) ProtoMessage ¶
func (*SessionOptions) ProtoMessage()
func (*SessionOptions) ProtoReflect ¶
func (x *SessionOptions) ProtoReflect() protoreflect.Message
func (*SessionOptions) Reset ¶
func (x *SessionOptions) Reset()
func (*SessionOptions) String ¶
func (x *SessionOptions) String() string
type StreamError ¶
type StreamError struct {
Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Suggestion string `protobuf:"bytes,3,opt,name=suggestion,proto3" json:"suggestion,omitempty"`
Retryable bool `protobuf:"varint,4,opt,name=retryable,proto3" json:"retryable,omitempty"`
RetryCommands []string `protobuf:"bytes,5,rep,name=retry_commands,json=retryCommands,proto3" json:"retry_commands,omitempty"`
// contains filtered or unexported fields
}
func (*StreamError) Descriptor
deprecated
func (*StreamError) Descriptor() ([]byte, []int)
Deprecated: Use StreamError.ProtoReflect.Descriptor instead.
func (*StreamError) GetMessage ¶
func (x *StreamError) GetMessage() string
func (*StreamError) GetRetryCommands ¶
func (x *StreamError) GetRetryCommands() []string
func (*StreamError) GetRetryable ¶
func (x *StreamError) GetRetryable() bool
func (*StreamError) GetSuggestion ¶
func (x *StreamError) GetSuggestion() string
func (*StreamError) GetTitle ¶
func (x *StreamError) GetTitle() string
func (*StreamError) ProtoMessage ¶
func (*StreamError) ProtoMessage()
func (*StreamError) ProtoReflect ¶
func (x *StreamError) ProtoReflect() protoreflect.Message
func (*StreamError) Reset ¶
func (x *StreamError) Reset()
func (*StreamError) String ¶
func (x *StreamError) String() string
type StreamInput ¶
type StreamInput struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
func (*StreamInput) Descriptor
deprecated
func (*StreamInput) Descriptor() ([]byte, []int)
Deprecated: Use StreamInput.ProtoReflect.Descriptor instead.
func (*StreamInput) GetData ¶
func (x *StreamInput) GetData() []byte
func (*StreamInput) GetId ¶
func (x *StreamInput) GetId() string
func (*StreamInput) ProtoMessage ¶
func (*StreamInput) ProtoMessage()
func (*StreamInput) ProtoReflect ¶
func (x *StreamInput) ProtoReflect() protoreflect.Message
func (*StreamInput) Reset ¶
func (x *StreamInput) Reset()
func (*StreamInput) String ¶
func (x *StreamInput) String() string
type StreamOutput ¶
type StreamOutput struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Target StreamOutput_Target `protobuf:"varint,2,opt,name=target,proto3,enum=omniview.sdk.exec.v1.StreamOutput_Target" json:"target,omitempty"`
Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
Signal StreamSignal `protobuf:"varint,4,opt,name=signal,proto3,enum=omniview.sdk.exec.v1.StreamSignal" json:"signal,omitempty"`
Error *StreamError `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*StreamOutput) Descriptor
deprecated
func (*StreamOutput) Descriptor() ([]byte, []int)
Deprecated: Use StreamOutput.ProtoReflect.Descriptor instead.
func (*StreamOutput) GetData ¶
func (x *StreamOutput) GetData() []byte
func (*StreamOutput) GetError ¶
func (x *StreamOutput) GetError() *StreamError
func (*StreamOutput) GetId ¶
func (x *StreamOutput) GetId() string
func (*StreamOutput) GetSignal ¶
func (x *StreamOutput) GetSignal() StreamSignal
func (*StreamOutput) GetTarget ¶
func (x *StreamOutput) GetTarget() StreamOutput_Target
func (*StreamOutput) ProtoMessage ¶
func (*StreamOutput) ProtoMessage()
func (*StreamOutput) ProtoReflect ¶
func (x *StreamOutput) ProtoReflect() protoreflect.Message
func (*StreamOutput) Reset ¶
func (x *StreamOutput) Reset()
func (*StreamOutput) String ¶
func (x *StreamOutput) String() string
type StreamOutput_Target ¶
type StreamOutput_Target int32
const ( StreamOutput_STDOUT StreamOutput_Target = 0 StreamOutput_STDERR StreamOutput_Target = 1 )
func (StreamOutput_Target) Descriptor ¶
func (StreamOutput_Target) Descriptor() protoreflect.EnumDescriptor
func (StreamOutput_Target) Enum ¶
func (x StreamOutput_Target) Enum() *StreamOutput_Target
func (StreamOutput_Target) EnumDescriptor
deprecated
func (StreamOutput_Target) EnumDescriptor() ([]byte, []int)
Deprecated: Use StreamOutput_Target.Descriptor instead.
func (StreamOutput_Target) Number ¶
func (x StreamOutput_Target) Number() protoreflect.EnumNumber
func (StreamOutput_Target) String ¶
func (x StreamOutput_Target) String() string
func (StreamOutput_Target) Type ¶
func (StreamOutput_Target) Type() protoreflect.EnumType
type StreamSignal ¶
type StreamSignal int32
const ( StreamSignal_STREAM_SIGNAL_NONE StreamSignal = 0 StreamSignal_STREAM_SIGNAL_CLOSE StreamSignal = 1 StreamSignal_STREAM_SIGNAL_SIGINT StreamSignal = 2 StreamSignal_STREAM_SIGNAL_SIGQUIT StreamSignal = 3 StreamSignal_STREAM_SIGNAL_SIGTERM StreamSignal = 4 StreamSignal_STREAM_SIGNAL_SIGKILL StreamSignal = 5 StreamSignal_STREAM_SIGNAL_SIGHUP StreamSignal = 6 StreamSignal_STREAM_SIGNAL_SIGUSR1 StreamSignal = 7 StreamSignal_STREAM_SIGNAL_SIGUSR2 StreamSignal = 8 StreamSignal_STREAM_SIGNAL_SIGWINCH StreamSignal = 9 StreamSignal_STREAM_SIGNAL_ERROR StreamSignal = 10 )
func (StreamSignal) Descriptor ¶
func (StreamSignal) Descriptor() protoreflect.EnumDescriptor
func (StreamSignal) Enum ¶
func (x StreamSignal) Enum() *StreamSignal
func (StreamSignal) EnumDescriptor
deprecated
func (StreamSignal) EnumDescriptor() ([]byte, []int)
Deprecated: Use StreamSignal.Descriptor instead.
func (StreamSignal) Number ¶
func (x StreamSignal) Number() protoreflect.EnumNumber
func (StreamSignal) String ¶
func (x StreamSignal) String() string
func (StreamSignal) Type ¶
func (StreamSignal) Type() protoreflect.EnumType
type UnimplementedExecPluginServer ¶
type UnimplementedExecPluginServer struct {
}
UnimplementedExecPluginServer should be embedded to have forward compatible implementations.
func (UnimplementedExecPluginServer) AttachSession ¶
func (UnimplementedExecPluginServer) AttachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)
func (UnimplementedExecPluginServer) CloseSession ¶
func (UnimplementedExecPluginServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
func (UnimplementedExecPluginServer) CreateSession ¶
func (UnimplementedExecPluginServer) CreateSession(context.Context, *SessionOptions) (*CreateSessionResponse, error)
func (UnimplementedExecPluginServer) DetachSession ¶
func (UnimplementedExecPluginServer) DetachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)
func (UnimplementedExecPluginServer) GetSession ¶
func (UnimplementedExecPluginServer) GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)
func (UnimplementedExecPluginServer) GetSupportedResources ¶
func (UnimplementedExecPluginServer) GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedResourcesResponse, error)
func (UnimplementedExecPluginServer) ListSessions ¶
func (UnimplementedExecPluginServer) ListSessions(context.Context, *emptypb.Empty) (*ListSessionsResponse, error)
func (UnimplementedExecPluginServer) ResizeSession ¶
func (UnimplementedExecPluginServer) ResizeSession(context.Context, *ResizeSessionRequest) (*ResizeSessionResponse, error)
func (UnimplementedExecPluginServer) Stream ¶
func (UnimplementedExecPluginServer) Stream(ExecPlugin_StreamServer) error
type UnsafeExecPluginServer ¶
type UnsafeExecPluginServer interface {
// contains filtered or unexported methods
}
UnsafeExecPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecPluginServer will result in compilation errors.