Versions in this module Expand all Collapse all v0 v0.5.2 Mar 28, 2026 v0.5.1 Mar 28, 2026 v0.5.0 Mar 20, 2026 v0.4.1 Mar 18, 2026 v0.4.0 Mar 16, 2026 v0.3.1 Mar 14, 2026 v0.3.0 Mar 12, 2026 v0.2.1 Mar 10, 2026 v0.2.0 Mar 6, 2026 Changes in this version + const ExecPlugin_AttachSession_FullMethodName + const ExecPlugin_CloseSession_FullMethodName + const ExecPlugin_CreateSession_FullMethodName + const ExecPlugin_DetachSession_FullMethodName + const ExecPlugin_GetSession_FullMethodName + const ExecPlugin_GetSupportedResources_FullMethodName + const ExecPlugin_ListSessions_FullMethodName + const ExecPlugin_ResizeSession_FullMethodName + const ExecPlugin_Stream_FullMethodName + var ExecPlugin_ServiceDesc = grpc.ServiceDesc + var File_proto_v1_exec_exec_proto protoreflect.FileDescriptor + var StreamOutput_Target_name = map[int32]string + var StreamOutput_Target_value = map[string]int32 + var StreamSignal_name = map[int32]string + var StreamSignal_value = map[string]int32 + func RegisterExecPluginServer(s grpc.ServiceRegistrar, srv ExecPluginServer) + type AttachSessionRequest struct + Id string + func (*AttachSessionRequest) Descriptor() ([]byte, []int) + func (*AttachSessionRequest) ProtoMessage() + func (x *AttachSessionRequest) GetId() string + func (x *AttachSessionRequest) ProtoReflect() protoreflect.Message + func (x *AttachSessionRequest) Reset() + func (x *AttachSessionRequest) String() string + type AttachSessionResponse struct + Buffer []byte + Session *Session + func (*AttachSessionResponse) Descriptor() ([]byte, []int) + func (*AttachSessionResponse) ProtoMessage() + func (x *AttachSessionResponse) GetBuffer() []byte + func (x *AttachSessionResponse) GetSession() *Session + func (x *AttachSessionResponse) ProtoReflect() protoreflect.Message + func (x *AttachSessionResponse) Reset() + func (x *AttachSessionResponse) String() string + type CloseSessionRequest struct + Id string + func (*CloseSessionRequest) Descriptor() ([]byte, []int) + func (*CloseSessionRequest) ProtoMessage() + func (x *CloseSessionRequest) GetId() string + func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message + func (x *CloseSessionRequest) Reset() + func (x *CloseSessionRequest) String() string + type CloseSessionResponse struct + Error string + Success bool + func (*CloseSessionResponse) Descriptor() ([]byte, []int) + func (*CloseSessionResponse) ProtoMessage() + func (x *CloseSessionResponse) GetError() string + func (x *CloseSessionResponse) GetSuccess() bool + func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message + func (x *CloseSessionResponse) Reset() + func (x *CloseSessionResponse) String() string + type CreateSessionRequest struct + Command string + Id string + Labels map[string]string + Params map[string]string + Tty bool + func (*CreateSessionRequest) Descriptor() ([]byte, []int) + func (*CreateSessionRequest) ProtoMessage() + 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 (x *CreateSessionRequest) ProtoReflect() protoreflect.Message + func (x *CreateSessionRequest) Reset() + func (x *CreateSessionRequest) String() string + type CreateSessionResponse struct + Error string + Session *Session + Success bool + func (*CreateSessionResponse) Descriptor() ([]byte, []int) + func (*CreateSessionResponse) ProtoMessage() + func (x *CreateSessionResponse) GetError() string + func (x *CreateSessionResponse) GetSession() *Session + func (x *CreateSessionResponse) GetSuccess() bool + func (x *CreateSessionResponse) ProtoReflect() protoreflect.Message + func (x *CreateSessionResponse) Reset() + func (x *CreateSessionResponse) String() string + type ExecHandler struct + DefaultCommand []string + Plugin string + Resource string + TargetBuilder *common.ActionTargetBuilder + func (*ExecHandler) Descriptor() ([]byte, []int) + func (*ExecHandler) ProtoMessage() + func (x *ExecHandler) GetDefaultCommand() []string + func (x *ExecHandler) GetPlugin() string + func (x *ExecHandler) GetResource() string + func (x *ExecHandler) GetTargetBuilder() *common.ActionTargetBuilder + func (x *ExecHandler) ProtoReflect() protoreflect.Message + func (x *ExecHandler) Reset() + func (x *ExecHandler) String() string + type ExecPluginClient interface + AttachSession func(ctx context.Context, in *AttachSessionRequest, opts ...grpc.CallOption) (*AttachSessionResponse, error) + CloseSession func(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) + CreateSession func(ctx context.Context, in *SessionOptions, opts ...grpc.CallOption) (*CreateSessionResponse, error) + DetachSession func(ctx context.Context, in *AttachSessionRequest, opts ...grpc.CallOption) (*AttachSessionResponse, error) + GetSession func(ctx context.Context, in *GetSessionRequest, opts ...grpc.CallOption) (*GetSessionResponse, error) + GetSupportedResources func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSupportedResourcesResponse, error) + ListSessions func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListSessionsResponse, error) + ResizeSession func(ctx context.Context, in *ResizeSessionRequest, opts ...grpc.CallOption) (*ResizeSessionResponse, error) + Stream func(ctx context.Context, opts ...grpc.CallOption) (ExecPlugin_StreamClient, error) + func NewExecPluginClient(cc grpc.ClientConnInterface) ExecPluginClient + type ExecPluginServer interface + AttachSession func(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error) + CloseSession func(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) + CreateSession func(context.Context, *SessionOptions) (*CreateSessionResponse, error) + DetachSession func(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error) + GetSession func(context.Context, *GetSessionRequest) (*GetSessionResponse, error) + GetSupportedResources func(context.Context, *emptypb.Empty) (*GetSupportedResourcesResponse, error) + ListSessions func(context.Context, *emptypb.Empty) (*ListSessionsResponse, error) + ResizeSession func(context.Context, *ResizeSessionRequest) (*ResizeSessionResponse, error) + Stream func(ExecPlugin_StreamServer) error + type ExecPlugin_StreamClient interface + Recv func() (*StreamOutput, error) + Send func(*StreamInput) error + type ExecPlugin_StreamServer interface + Recv func() (*StreamInput, error) + Send func(*StreamOutput) error + type GetSessionRequest struct + Id string + func (*GetSessionRequest) Descriptor() ([]byte, []int) + func (*GetSessionRequest) ProtoMessage() + func (x *GetSessionRequest) GetId() string + func (x *GetSessionRequest) ProtoReflect() protoreflect.Message + func (x *GetSessionRequest) Reset() + func (x *GetSessionRequest) String() string + type GetSessionResponse struct + Error string + Session *Session + Success bool + func (*GetSessionResponse) Descriptor() ([]byte, []int) + func (*GetSessionResponse) ProtoMessage() + func (x *GetSessionResponse) GetError() string + func (x *GetSessionResponse) GetSession() *Session + func (x *GetSessionResponse) GetSuccess() bool + func (x *GetSessionResponse) ProtoReflect() protoreflect.Message + func (x *GetSessionResponse) Reset() + func (x *GetSessionResponse) String() string + type GetSupportedResourcesResponse struct + Handlers []*ExecHandler + func (*GetSupportedResourcesResponse) Descriptor() ([]byte, []int) + func (*GetSupportedResourcesResponse) ProtoMessage() + func (x *GetSupportedResourcesResponse) GetHandlers() []*ExecHandler + func (x *GetSupportedResourcesResponse) ProtoReflect() protoreflect.Message + func (x *GetSupportedResourcesResponse) Reset() + func (x *GetSupportedResourcesResponse) String() string + type ListSessionsResponse struct + Error string + Sessions []*Session + Success bool + func (*ListSessionsResponse) Descriptor() ([]byte, []int) + func (*ListSessionsResponse) ProtoMessage() + func (x *ListSessionsResponse) GetError() string + func (x *ListSessionsResponse) GetSessions() []*Session + func (x *ListSessionsResponse) GetSuccess() bool + func (x *ListSessionsResponse) ProtoReflect() protoreflect.Message + func (x *ListSessionsResponse) Reset() + func (x *ListSessionsResponse) String() string + type ResizeSessionRequest struct + Cols int32 + Id string + Rows int32 + func (*ResizeSessionRequest) Descriptor() ([]byte, []int) + func (*ResizeSessionRequest) ProtoMessage() + func (x *ResizeSessionRequest) GetCols() int32 + func (x *ResizeSessionRequest) GetId() string + func (x *ResizeSessionRequest) GetRows() int32 + func (x *ResizeSessionRequest) ProtoReflect() protoreflect.Message + func (x *ResizeSessionRequest) Reset() + func (x *ResizeSessionRequest) String() string + type ResizeSessionResponse struct + Error string + Success bool + func (*ResizeSessionResponse) Descriptor() ([]byte, []int) + func (*ResizeSessionResponse) ProtoMessage() + func (x *ResizeSessionResponse) GetError() string + func (x *ResizeSessionResponse) GetSuccess() bool + func (x *ResizeSessionResponse) ProtoReflect() protoreflect.Message + func (x *ResizeSessionResponse) Reset() + func (x *ResizeSessionResponse) String() string + type Session struct + Attached bool + Command []string + CreatedAt *timestamppb.Timestamp + Id string + Labels map[string]string + Params map[string]string + func (*Session) Descriptor() ([]byte, []int) + func (*Session) ProtoMessage() + 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 (x *Session) ProtoReflect() protoreflect.Message + func (x *Session) Reset() + func (x *Session) String() string + type SessionOptions struct + Command []string + Id string + Labels map[string]string + Params map[string]string + ResourceData *structpb.Struct + ResourceKey string + ResourcePlugin string + Tty bool + func (*SessionOptions) Descriptor() ([]byte, []int) + func (*SessionOptions) ProtoMessage() + 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 (x *SessionOptions) ProtoReflect() protoreflect.Message + func (x *SessionOptions) Reset() + func (x *SessionOptions) String() string + type StreamError struct + Message string + RetryCommands []string + Retryable bool + Suggestion string + Title string + func (*StreamError) Descriptor() ([]byte, []int) + func (*StreamError) ProtoMessage() + 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 (x *StreamError) ProtoReflect() protoreflect.Message + func (x *StreamError) Reset() + func (x *StreamError) String() string + type StreamInput struct + Data []byte + Id string + func (*StreamInput) Descriptor() ([]byte, []int) + func (*StreamInput) ProtoMessage() + func (x *StreamInput) GetData() []byte + func (x *StreamInput) GetId() string + func (x *StreamInput) ProtoReflect() protoreflect.Message + func (x *StreamInput) Reset() + func (x *StreamInput) String() string + type StreamOutput struct + Data []byte + Error *StreamError + Id string + Signal StreamSignal + Target StreamOutput_Target + func (*StreamOutput) Descriptor() ([]byte, []int) + func (*StreamOutput) ProtoMessage() + 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 (x *StreamOutput) ProtoReflect() protoreflect.Message + func (x *StreamOutput) Reset() + func (x *StreamOutput) String() string + type StreamOutput_Target int32 + const StreamOutput_STDERR + const StreamOutput_STDOUT + func (StreamOutput_Target) Descriptor() protoreflect.EnumDescriptor + func (StreamOutput_Target) EnumDescriptor() ([]byte, []int) + func (StreamOutput_Target) Type() protoreflect.EnumType + func (x StreamOutput_Target) Enum() *StreamOutput_Target + func (x StreamOutput_Target) Number() protoreflect.EnumNumber + func (x StreamOutput_Target) String() string + type StreamSignal int32 + const StreamSignal_STREAM_SIGNAL_CLOSE + const StreamSignal_STREAM_SIGNAL_ERROR + const StreamSignal_STREAM_SIGNAL_NONE + const StreamSignal_STREAM_SIGNAL_SIGHUP + const StreamSignal_STREAM_SIGNAL_SIGINT + const StreamSignal_STREAM_SIGNAL_SIGKILL + const StreamSignal_STREAM_SIGNAL_SIGQUIT + const StreamSignal_STREAM_SIGNAL_SIGTERM + const StreamSignal_STREAM_SIGNAL_SIGUSR1 + const StreamSignal_STREAM_SIGNAL_SIGUSR2 + const StreamSignal_STREAM_SIGNAL_SIGWINCH + func (StreamSignal) Descriptor() protoreflect.EnumDescriptor + func (StreamSignal) EnumDescriptor() ([]byte, []int) + func (StreamSignal) Type() protoreflect.EnumType + func (x StreamSignal) Enum() *StreamSignal + func (x StreamSignal) Number() protoreflect.EnumNumber + func (x StreamSignal) String() string + type UnimplementedExecPluginServer struct + 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 interface
Go to main page