execpb

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Mar 16, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
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.

View Source
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.

View Source
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)

View Source
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

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 (*GetSupportedResourcesResponse) Reset

func (x *GetSupportedResourcesResponse) Reset()

func (*GetSupportedResourcesResponse) 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) Descriptor() ([]byte, []int)

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetAttached

func (x *Session) GetAttached() bool

func (*Session) GetCommand

func (x *Session) GetCommand() []string

func (*Session) GetCreatedAt

func (x *Session) GetCreatedAt() *timestamppb.Timestamp

func (*Session) GetId

func (x *Session) GetId() string

func (*Session) GetLabels

func (x *Session) GetLabels() map[string]string

func (*Session) GetParams

func (x *Session) GetParams() map[string]string

func (*Session) ProtoMessage

func (*Session) ProtoMessage()

func (*Session) ProtoReflect

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

func (*Session) Reset

func (x *Session) Reset()

func (*Session) String

func (x *Session) String() string

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) Enum

func (StreamOutput_Target) EnumDescriptor deprecated

func (StreamOutput_Target) EnumDescriptor() ([]byte, []int)

Deprecated: Use StreamOutput_Target.Descriptor instead.

func (StreamOutput_Target) Number

func (StreamOutput_Target) String

func (x StreamOutput_Target) String() string

func (StreamOutput_Target) Type

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) Enum

func (x StreamSignal) Enum() *StreamSignal

func (StreamSignal) EnumDescriptor deprecated

func (StreamSignal) EnumDescriptor() ([]byte, []int)

Deprecated: Use StreamSignal.Descriptor instead.

func (StreamSignal) Number

func (StreamSignal) String

func (x StreamSignal) String() string

func (StreamSignal) Type

type UnimplementedExecPluginServer

type UnimplementedExecPluginServer struct {
}

UnimplementedExecPluginServer should be embedded to have forward compatible implementations.

func (UnimplementedExecPluginServer) AttachSession

func (UnimplementedExecPluginServer) CloseSession

func (UnimplementedExecPluginServer) CreateSession

func (UnimplementedExecPluginServer) DetachSession

func (UnimplementedExecPluginServer) GetSession

func (UnimplementedExecPluginServer) GetSupportedResources

func (UnimplementedExecPluginServer) ListSessions

func (UnimplementedExecPluginServer) ResizeSession

func (UnimplementedExecPluginServer) Stream

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.

Jump to

Keyboard shortcuts

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