Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer)
- type AWSECRAuth
- func (*AWSECRAuth) Descriptor() ([]byte, []int)deprecated
- func (x *AWSECRAuth) GetAwsAccessKeyId() string
- func (x *AWSECRAuth) GetAwsSecretKey() string
- func (x *AWSECRAuth) GetRegion() string
- func (*AWSECRAuth) ProtoMessage()
- func (x *AWSECRAuth) ProtoReflect() protoreflect.Message
- func (x *AWSECRAuth) Reset()
- func (x *AWSECRAuth) String() string
- type BasicAuth
- type CloseRequest
- func (*CloseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseRequest) GetBarrierId() string
- func (x *CloseRequest) GetRuntimeId() string
- func (*CloseRequest) ProtoMessage()
- func (x *CloseRequest) ProtoReflect() protoreflect.Message
- func (x *CloseRequest) Reset()
- func (x *CloseRequest) String() string
- type CloseResponse
- type DockerOpts
- type DockerPullAuth
- func (*DockerPullAuth) Descriptor() ([]byte, []int)deprecated
- func (m *DockerPullAuth) GetAuth() isDockerPullAuth_Auth
- func (x *DockerPullAuth) GetAwsEcr() *AWSECRAuth
- func (x *DockerPullAuth) GetBasic() *BasicAuth
- func (*DockerPullAuth) ProtoMessage()
- func (x *DockerPullAuth) ProtoReflect() protoreflect.Message
- func (x *DockerPullAuth) Reset()
- func (x *DockerPullAuth) String() string
- type DockerPullAuth_AwsEcr
- type DockerPullAuth_Basic
- type DockerPullOpts
- func (*DockerPullOpts) Descriptor() ([]byte, []int)deprecated
- func (x *DockerPullOpts) GetAuth() *DockerPullAuth
- func (x *DockerPullOpts) GetImageUri() string
- func (x *DockerPullOpts) GetPullStrategy() DockerPullOpts_PullStrategy
- func (*DockerPullOpts) ProtoMessage()
- func (x *DockerPullOpts) ProtoReflect() protoreflect.Message
- func (x *DockerPullOpts) Reset()
- func (x *DockerPullOpts) String() string
- type DockerPullOpts_PullStrategy
- func (DockerPullOpts_PullStrategy) Descriptor() protoreflect.EnumDescriptor
- func (x DockerPullOpts_PullStrategy) Enum() *DockerPullOpts_PullStrategy
- func (DockerPullOpts_PullStrategy) EnumDescriptor() ([]byte, []int)deprecated
- func (x DockerPullOpts_PullStrategy) Number() protoreflect.EnumNumber
- func (x DockerPullOpts_PullStrategy) String() string
- func (DockerPullOpts_PullStrategy) Type() protoreflect.EnumType
- type EventsRequest
- func (*EventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EventsRequest) GetBarrierId() string
- func (x *EventsRequest) GetBuildId() string
- func (x *EventsRequest) GetRuntimeId() string
- func (*EventsRequest) ProtoMessage()
- func (x *EventsRequest) ProtoReflect() protoreflect.Message
- func (x *EventsRequest) Reset()
- func (x *EventsRequest) String() string
- type ExecOpts
- func (*ExecOpts) Descriptor() ([]byte, []int)deprecated
- func (x *ExecOpts) GetArgs() []string
- func (x *ExecOpts) GetEnv() []string
- func (x *ExecOpts) GetName() string
- func (x *ExecOpts) GetTags() map[string]string
- func (*ExecOpts) ProtoMessage()
- func (x *ExecOpts) ProtoReflect() protoreflect.Message
- func (x *ExecOpts) Reset()
- func (x *ExecOpts) String() string
- type ExecRequest
- func (*ExecRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecRequest) GetBarrierId() string
- func (x *ExecRequest) GetExecId() string
- func (x *ExecRequest) GetOpts() *ExecOpts
- func (x *ExecRequest) GetRuntimeId() string
- func (*ExecRequest) ProtoMessage()
- func (x *ExecRequest) ProtoReflect() protoreflect.Message
- func (x *ExecRequest) Reset()
- func (x *ExecRequest) String() string
- type ExecResponse
- type ExecutorClient
- type ExecutorInfo
- type ExecutorServer
- type Executor_EventsClient
- type Executor_EventsServer
- type Executor_ExportClient
- type Executor_ExportServer
- type Executor_ImportClient
- type Executor_ImportServer
- type ExportOpts
- func (*ExportOpts) Descriptor() ([]byte, []int)deprecated
- func (x *ExportOpts) GetDestPath() string
- func (x *ExportOpts) GetExcludes() []string
- func (*ExportOpts) ProtoMessage()
- func (x *ExportOpts) ProtoReflect() protoreflect.Message
- func (x *ExportOpts) Reset()
- func (x *ExportOpts) String() string
- type ExportRequest
- func (*ExportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExportRequest) GetExportId() string
- func (x *ExportRequest) GetOpts() *ExportOpts
- func (x *ExportRequest) GetRuntimeId() string
- func (x *ExportRequest) GetSrcPath() string
- func (*ExportRequest) ProtoMessage()
- func (x *ExportRequest) ProtoReflect() protoreflect.Message
- func (x *ExportRequest) Reset()
- func (x *ExportRequest) String() string
- type FileTransfer
- func (*FileTransfer) Descriptor() ([]byte, []int)deprecated
- func (x *FileTransfer) GetBody() *FileTransferBody
- func (x *FileTransfer) GetFileId() string
- func (x *FileTransfer) GetHeader() *FileTransferHeader
- func (x *FileTransfer) GetRuntimeId() string
- func (x *FileTransfer) GetTrailer() *FileTransferTrailer
- func (x *FileTransfer) GetTransferId() string
- func (*FileTransfer) ProtoMessage()
- func (x *FileTransfer) ProtoReflect() protoreflect.Message
- func (x *FileTransfer) Reset()
- func (x *FileTransfer) String() string
- type FileTransferBody
- func (*FileTransferBody) Descriptor() ([]byte, []int)deprecated
- func (x *FileTransferBody) GetData() []byte
- func (x *FileTransferBody) GetOffset() uint64
- func (*FileTransferBody) ProtoMessage()
- func (x *FileTransferBody) ProtoReflect() protoreflect.Message
- func (x *FileTransferBody) Reset()
- func (x *FileTransferBody) String() string
- type FileTransferHeader
- func (*FileTransferHeader) Descriptor() ([]byte, []int)deprecated
- func (x *FileTransferHeader) GetDestPath() string
- func (x *FileTransferHeader) GetIsDir() bool
- func (x *FileTransferHeader) GetMode() uint32
- func (x *FileTransferHeader) GetSize() uint64
- func (x *FileTransferHeader) GetSrcPath() string
- func (*FileTransferHeader) ProtoMessage()
- func (x *FileTransferHeader) ProtoReflect() protoreflect.Message
- func (x *FileTransferHeader) Reset()
- func (x *FileTransferHeader) String() string
- type FileTransferTrailer
- func (*FileTransferTrailer) Descriptor() ([]byte, []int)deprecated
- func (x *FileTransferTrailer) GetMd5() []byte
- func (*FileTransferTrailer) ProtoMessage()
- func (x *FileTransferTrailer) ProtoReflect() protoreflect.Message
- func (x *FileTransferTrailer) Reset()
- func (x *FileTransferTrailer) String() string
- type HeartbeatRequest
- type HeartbeatResponse
- func (*HeartbeatResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatResponse) GetExtendedBy() *durationpb.Duration
- func (*HeartbeatResponse) ProtoMessage()
- func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
- func (x *HeartbeatResponse) Reset()
- func (x *HeartbeatResponse) String() string
- type HostOpts
- type ImportResponse
- type IntrospectRequest
- type IntrospectResponse
- func (*IntrospectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *IntrospectResponse) GetExecutorInfo() *ExecutorInfo
- func (x *IntrospectResponse) GetLabels() []string
- func (x *IntrospectResponse) GetSysInfo() *SystemInfo
- func (*IntrospectResponse) ProtoMessage()
- func (x *IntrospectResponse) ProtoReflect() protoreflect.Message
- func (x *IntrospectResponse) Reset()
- func (x *IntrospectResponse) String() string
- type OpenRequest
- func (*OpenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OpenRequest) GetBuildId() string
- func (x *OpenRequest) GetOpts() *Opts
- func (x *OpenRequest) GetRuntimeId() string
- func (*OpenRequest) ProtoMessage()
- func (x *OpenRequest) ProtoReflect() protoreflect.Message
- func (x *OpenRequest) Reset()
- func (x *OpenRequest) String() string
- type OpenResponse
- func (*OpenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OpenResponse) GetSysInfo() *SystemInfo
- func (x *OpenResponse) GetWorkDirectory() string
- func (*OpenResponse) ProtoMessage()
- func (x *OpenResponse) ProtoReflect() protoreflect.Message
- func (x *OpenResponse) Reset()
- func (x *OpenResponse) String() string
- type Opts
- func (*Opts) Descriptor() ([]byte, []int)deprecated
- func (x *Opts) GetDocker() *DockerOpts
- func (x *Opts) GetHost() *HostOpts
- func (x *Opts) GetLabels() []string
- func (m *Opts) GetOpts() isOpts_Opts
- func (x *Opts) GetTags() map[string]string
- func (x *Opts) GetType() RuntimeType
- func (*Opts) ProtoMessage()
- func (x *Opts) ProtoReflect() protoreflect.Message
- func (x *Opts) Reset()
- func (x *Opts) String() string
- type Opts_Docker
- type Opts_Host
- type RuntimeType
- func (RuntimeType) Descriptor() protoreflect.EnumDescriptor
- func (x RuntimeType) Enum() *RuntimeType
- func (RuntimeType) EnumDescriptor() ([]byte, []int)deprecated
- func (x RuntimeType) Number() protoreflect.EnumNumber
- func (x RuntimeType) String() string
- func (RuntimeType) Type() protoreflect.EnumType
- type SystemInfo
- func (*SystemInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SystemInfo) GetArch() string
- func (x *SystemInfo) GetOs() string
- func (x *SystemInfo) GetTotalCpuCores() uint32
- func (x *SystemInfo) GetTotalMemory() uint64
- func (*SystemInfo) ProtoMessage()
- func (x *SystemInfo) ProtoReflect() protoreflect.Message
- func (x *SystemInfo) Reset()
- func (x *SystemInfo) String() string
- type UnimplementedExecutorServer
- func (UnimplementedExecutorServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)
- func (UnimplementedExecutorServer) Events(*EventsRequest, Executor_EventsServer) error
- func (UnimplementedExecutorServer) Exec(context.Context, *ExecRequest) (*ExecResponse, error)
- func (UnimplementedExecutorServer) Export(*ExportRequest, Executor_ExportServer) error
- func (UnimplementedExecutorServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
- func (UnimplementedExecutorServer) Import(Executor_ImportServer) error
- func (UnimplementedExecutorServer) Introspect(context.Context, *IntrospectRequest) (*IntrospectResponse, error)
- func (UnimplementedExecutorServer) Open(context.Context, *OpenRequest) (*OpenResponse, error)
- type UnsafeExecutorServer
Constants ¶
const ( Executor_Introspect_FullMethodName = "/executor.knita.io.Executor/Introspect" Executor_Events_FullMethodName = "/executor.knita.io.Executor/Events" Executor_Open_FullMethodName = "/executor.knita.io.Executor/Open" Executor_Heartbeat_FullMethodName = "/executor.knita.io.Executor/Heartbeat" Executor_Exec_FullMethodName = "/executor.knita.io.Executor/Exec" Executor_Import_FullMethodName = "/executor.knita.io.Executor/Import" Executor_Export_FullMethodName = "/executor.knita.io.Executor/Export" Executor_Close_FullMethodName = "/executor.knita.io.Executor/Close" )
Variables ¶
var ( RuntimeType_name = map[int32]string{ 0: "RUNTIME_UNSPECIFIED", 1: "RUNTIME_HOST", 2: "RUNTIME_DOCKER", } RuntimeType_value = map[string]int32{ "RUNTIME_UNSPECIFIED": 0, "RUNTIME_HOST": 1, "RUNTIME_DOCKER": 2, } )
Enum value maps for RuntimeType.
var ( DockerPullOpts_PullStrategy_name = map[int32]string{ 0: "PULL_STRATEGY_UNSPECIFIED", 1: "PULL_STRATEGY_NEVER", 2: "PULL_STRATEGY_ALWAYS", 3: "PULL_STRATEGY_NOT_EXISTS", } DockerPullOpts_PullStrategy_value = map[string]int32{ "PULL_STRATEGY_UNSPECIFIED": 0, "PULL_STRATEGY_NEVER": 1, "PULL_STRATEGY_ALWAYS": 2, "PULL_STRATEGY_NOT_EXISTS": 3, } )
Enum value maps for DockerPullOpts_PullStrategy.
var Executor_ServiceDesc = grpc.ServiceDesc{ ServiceName: "executor.knita.io.Executor", HandlerType: (*ExecutorServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Introspect", Handler: _Executor_Introspect_Handler, }, { MethodName: "Open", Handler: _Executor_Open_Handler, }, { MethodName: "Heartbeat", Handler: _Executor_Heartbeat_Handler, }, { MethodName: "Exec", Handler: _Executor_Exec_Handler, }, { MethodName: "Close", Handler: _Executor_Close_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Events", Handler: _Executor_Events_Handler, ServerStreams: true, }, { StreamName: "Import", Handler: _Executor_Import_Handler, ClientStreams: true, }, { StreamName: "Export", Handler: _Executor_Export_Handler, ServerStreams: true, }, }, Metadata: "executor/v1/executor.proto", }
Executor_ServiceDesc is the grpc.ServiceDesc for Executor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_executor_v1_executor_proto protoreflect.FileDescriptor
Functions ¶
func RegisterExecutorServer ¶
func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer)
Types ¶
type AWSECRAuth ¶
type AWSECRAuth struct { Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"` AwsAccessKeyId string `protobuf:"bytes,2,opt,name=aws_access_key_id,json=awsAccessKeyId,proto3" json:"aws_access_key_id,omitempty"` AwsSecretKey string `protobuf:"bytes,3,opt,name=aws_secret_key,json=awsSecretKey,proto3" json:"aws_secret_key,omitempty"` // contains filtered or unexported fields }
func (*AWSECRAuth) Descriptor
deprecated
func (*AWSECRAuth) Descriptor() ([]byte, []int)
Deprecated: Use AWSECRAuth.ProtoReflect.Descriptor instead.
func (*AWSECRAuth) GetAwsAccessKeyId ¶
func (x *AWSECRAuth) GetAwsAccessKeyId() string
func (*AWSECRAuth) GetAwsSecretKey ¶
func (x *AWSECRAuth) GetAwsSecretKey() string
func (*AWSECRAuth) GetRegion ¶
func (x *AWSECRAuth) GetRegion() string
func (*AWSECRAuth) ProtoMessage ¶
func (*AWSECRAuth) ProtoMessage()
func (*AWSECRAuth) ProtoReflect ¶
func (x *AWSECRAuth) ProtoReflect() protoreflect.Message
func (*AWSECRAuth) Reset ¶
func (x *AWSECRAuth) Reset()
func (*AWSECRAuth) String ¶
func (x *AWSECRAuth) String() string
type BasicAuth ¶
type BasicAuth struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*BasicAuth) Descriptor
deprecated
func (*BasicAuth) GetPassword ¶
func (*BasicAuth) GetUsername ¶
func (*BasicAuth) ProtoMessage ¶
func (*BasicAuth) ProtoMessage()
func (*BasicAuth) ProtoReflect ¶
func (x *BasicAuth) ProtoReflect() protoreflect.Message
type CloseRequest ¶
type CloseRequest struct { RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"` BarrierId string `protobuf:"bytes,2,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"` // contains filtered or unexported fields }
func (*CloseRequest) Descriptor
deprecated
func (*CloseRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.
func (*CloseRequest) GetBarrierId ¶
func (x *CloseRequest) GetBarrierId() string
func (*CloseRequest) GetRuntimeId ¶
func (x *CloseRequest) GetRuntimeId() string
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) ProtoReflect ¶
func (x *CloseRequest) ProtoReflect() protoreflect.Message
func (*CloseRequest) Reset ¶
func (x *CloseRequest) Reset()
func (*CloseRequest) String ¶
func (x *CloseRequest) String() string
type CloseResponse ¶
type CloseResponse struct {
// contains filtered or unexported fields
}
func (*CloseResponse) Descriptor
deprecated
func (*CloseResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) ProtoReflect ¶
func (x *CloseResponse) ProtoReflect() protoreflect.Message
func (*CloseResponse) Reset ¶
func (x *CloseResponse) Reset()
func (*CloseResponse) String ¶
func (x *CloseResponse) String() string
type DockerOpts ¶
type DockerOpts struct { Image *DockerPullOpts `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"` // contains filtered or unexported fields }
func (*DockerOpts) Descriptor
deprecated
func (*DockerOpts) Descriptor() ([]byte, []int)
Deprecated: Use DockerOpts.ProtoReflect.Descriptor instead.
func (*DockerOpts) GetImage ¶
func (x *DockerOpts) GetImage() *DockerPullOpts
func (*DockerOpts) ProtoMessage ¶
func (*DockerOpts) ProtoMessage()
func (*DockerOpts) ProtoReflect ¶
func (x *DockerOpts) ProtoReflect() protoreflect.Message
func (*DockerOpts) Reset ¶
func (x *DockerOpts) Reset()
func (*DockerOpts) String ¶
func (x *DockerOpts) String() string
type DockerPullAuth ¶
type DockerPullAuth struct { // Types that are assignable to Auth: // // *DockerPullAuth_Basic // *DockerPullAuth_AwsEcr Auth isDockerPullAuth_Auth `protobuf_oneof:"auth"` // contains filtered or unexported fields }
func (*DockerPullAuth) Descriptor
deprecated
func (*DockerPullAuth) Descriptor() ([]byte, []int)
Deprecated: Use DockerPullAuth.ProtoReflect.Descriptor instead.
func (*DockerPullAuth) GetAuth ¶
func (m *DockerPullAuth) GetAuth() isDockerPullAuth_Auth
func (*DockerPullAuth) GetAwsEcr ¶
func (x *DockerPullAuth) GetAwsEcr() *AWSECRAuth
func (*DockerPullAuth) GetBasic ¶
func (x *DockerPullAuth) GetBasic() *BasicAuth
func (*DockerPullAuth) ProtoMessage ¶
func (*DockerPullAuth) ProtoMessage()
func (*DockerPullAuth) ProtoReflect ¶
func (x *DockerPullAuth) ProtoReflect() protoreflect.Message
func (*DockerPullAuth) Reset ¶
func (x *DockerPullAuth) Reset()
func (*DockerPullAuth) String ¶
func (x *DockerPullAuth) String() string
type DockerPullAuth_AwsEcr ¶
type DockerPullAuth_AwsEcr struct {
AwsEcr *AWSECRAuth `protobuf:"bytes,2,opt,name=aws_ecr,json=awsEcr,proto3,oneof"`
}
type DockerPullAuth_Basic ¶
type DockerPullAuth_Basic struct {
Basic *BasicAuth `protobuf:"bytes,1,opt,name=basic,proto3,oneof"`
}
type DockerPullOpts ¶
type DockerPullOpts struct { ImageUri string `protobuf:"bytes,1,opt,name=image_uri,json=imageUri,proto3" json:"image_uri,omitempty"` PullStrategy DockerPullOpts_PullStrategy `` /* 149-byte string literal not displayed */ Auth *DockerPullAuth `protobuf:"bytes,3,opt,name=auth,proto3" json:"auth,omitempty"` // contains filtered or unexported fields }
func (*DockerPullOpts) Descriptor
deprecated
func (*DockerPullOpts) Descriptor() ([]byte, []int)
Deprecated: Use DockerPullOpts.ProtoReflect.Descriptor instead.
func (*DockerPullOpts) GetAuth ¶
func (x *DockerPullOpts) GetAuth() *DockerPullAuth
func (*DockerPullOpts) GetImageUri ¶
func (x *DockerPullOpts) GetImageUri() string
func (*DockerPullOpts) GetPullStrategy ¶
func (x *DockerPullOpts) GetPullStrategy() DockerPullOpts_PullStrategy
func (*DockerPullOpts) ProtoMessage ¶
func (*DockerPullOpts) ProtoMessage()
func (*DockerPullOpts) ProtoReflect ¶
func (x *DockerPullOpts) ProtoReflect() protoreflect.Message
func (*DockerPullOpts) Reset ¶
func (x *DockerPullOpts) Reset()
func (*DockerPullOpts) String ¶
func (x *DockerPullOpts) String() string
type DockerPullOpts_PullStrategy ¶
type DockerPullOpts_PullStrategy int32
const ( DockerPullOpts_PULL_STRATEGY_UNSPECIFIED DockerPullOpts_PullStrategy = 0 DockerPullOpts_PULL_STRATEGY_NEVER DockerPullOpts_PullStrategy = 1 DockerPullOpts_PULL_STRATEGY_ALWAYS DockerPullOpts_PullStrategy = 2 DockerPullOpts_PULL_STRATEGY_NOT_EXISTS DockerPullOpts_PullStrategy = 3 )
func (DockerPullOpts_PullStrategy) Descriptor ¶
func (DockerPullOpts_PullStrategy) Descriptor() protoreflect.EnumDescriptor
func (DockerPullOpts_PullStrategy) Enum ¶
func (x DockerPullOpts_PullStrategy) Enum() *DockerPullOpts_PullStrategy
func (DockerPullOpts_PullStrategy) EnumDescriptor
deprecated
func (DockerPullOpts_PullStrategy) EnumDescriptor() ([]byte, []int)
Deprecated: Use DockerPullOpts_PullStrategy.Descriptor instead.
func (DockerPullOpts_PullStrategy) Number ¶
func (x DockerPullOpts_PullStrategy) Number() protoreflect.EnumNumber
func (DockerPullOpts_PullStrategy) String ¶
func (x DockerPullOpts_PullStrategy) String() string
func (DockerPullOpts_PullStrategy) Type ¶
func (DockerPullOpts_PullStrategy) Type() protoreflect.EnumType
type EventsRequest ¶
type EventsRequest struct { BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"` RuntimeId string `protobuf:"bytes,2,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"` BarrierId string `protobuf:"bytes,3,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"` // contains filtered or unexported fields }
func (*EventsRequest) Descriptor
deprecated
func (*EventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.
func (*EventsRequest) GetBarrierId ¶
func (x *EventsRequest) GetBarrierId() string
func (*EventsRequest) GetBuildId ¶
func (x *EventsRequest) GetBuildId() string
func (*EventsRequest) GetRuntimeId ¶
func (x *EventsRequest) GetRuntimeId() string
func (*EventsRequest) ProtoMessage ¶
func (*EventsRequest) ProtoMessage()
func (*EventsRequest) ProtoReflect ¶
func (x *EventsRequest) ProtoReflect() protoreflect.Message
func (*EventsRequest) Reset ¶
func (x *EventsRequest) Reset()
func (*EventsRequest) String ¶
func (x *EventsRequest) String() string
type ExecOpts ¶
type ExecOpts struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"` Env []string `protobuf:"bytes,3,rep,name=env,proto3" json:"env,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ExecOpts) Descriptor
deprecated
func (*ExecOpts) ProtoMessage ¶
func (*ExecOpts) ProtoMessage()
func (*ExecOpts) ProtoReflect ¶
func (x *ExecOpts) ProtoReflect() protoreflect.Message
type ExecRequest ¶
type ExecRequest struct { RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"` ExecId string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"` BarrierId string `protobuf:"bytes,3,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"` Opts *ExecOpts `protobuf:"bytes,4,opt,name=opts,proto3" json:"opts,omitempty"` // contains filtered or unexported fields }
func (*ExecRequest) Descriptor
deprecated
func (*ExecRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.
func (*ExecRequest) GetBarrierId ¶
func (x *ExecRequest) GetBarrierId() string
func (*ExecRequest) GetExecId ¶
func (x *ExecRequest) GetExecId() string
func (*ExecRequest) GetOpts ¶
func (x *ExecRequest) GetOpts() *ExecOpts
func (*ExecRequest) GetRuntimeId ¶
func (x *ExecRequest) GetRuntimeId() string
func (*ExecRequest) ProtoMessage ¶
func (*ExecRequest) ProtoMessage()
func (*ExecRequest) ProtoReflect ¶
func (x *ExecRequest) ProtoReflect() protoreflect.Message
func (*ExecRequest) Reset ¶
func (x *ExecRequest) Reset()
func (*ExecRequest) String ¶
func (x *ExecRequest) String() string
type ExecResponse ¶
type ExecResponse struct { ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"` // contains filtered or unexported fields }
func (*ExecResponse) Descriptor
deprecated
func (*ExecResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.
func (*ExecResponse) GetExitCode ¶
func (x *ExecResponse) GetExitCode() int32
func (*ExecResponse) ProtoMessage ¶
func (*ExecResponse) ProtoMessage()
func (*ExecResponse) ProtoReflect ¶
func (x *ExecResponse) ProtoReflect() protoreflect.Message
func (*ExecResponse) Reset ¶
func (x *ExecResponse) Reset()
func (*ExecResponse) String ¶
func (x *ExecResponse) String() string
type ExecutorClient ¶
type ExecutorClient interface { Introspect(ctx context.Context, in *IntrospectRequest, opts ...grpc.CallOption) (*IntrospectResponse, error) Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (Executor_EventsClient, error) Open(ctx context.Context, in *OpenRequest, opts ...grpc.CallOption) (*OpenResponse, error) Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error) Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error) Import(ctx context.Context, opts ...grpc.CallOption) (Executor_ImportClient, error) Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (Executor_ExportClient, error) Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error) }
ExecutorClient is the client API for Executor service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkgo.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewExecutorClient ¶
func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient
type ExecutorInfo ¶
type ExecutorInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*ExecutorInfo) Descriptor
deprecated
func (*ExecutorInfo) Descriptor() ([]byte, []int)
Deprecated: Use ExecutorInfo.ProtoReflect.Descriptor instead.
func (*ExecutorInfo) GetName ¶
func (x *ExecutorInfo) GetName() string
func (*ExecutorInfo) ProtoMessage ¶
func (*ExecutorInfo) ProtoMessage()
func (*ExecutorInfo) ProtoReflect ¶
func (x *ExecutorInfo) ProtoReflect() protoreflect.Message
func (*ExecutorInfo) Reset ¶
func (x *ExecutorInfo) Reset()
func (*ExecutorInfo) String ¶
func (x *ExecutorInfo) String() string
type ExecutorServer ¶
type ExecutorServer interface { Introspect(context.Context, *IntrospectRequest) (*IntrospectResponse, error) Events(*EventsRequest, Executor_EventsServer) error Open(context.Context, *OpenRequest) (*OpenResponse, error) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error) Exec(context.Context, *ExecRequest) (*ExecResponse, error) Import(Executor_ImportServer) error Export(*ExportRequest, Executor_ExportServer) error Close(context.Context, *CloseRequest) (*CloseResponse, error) // contains filtered or unexported methods }
ExecutorServer is the server API for Executor service. All implementations must embed UnimplementedExecutorServer for forward compatibility
type Executor_EventsClient ¶
type Executor_EventsClient interface { Recv() (*v1.Event, error) grpc.ClientStream }
type Executor_EventsServer ¶
type Executor_EventsServer interface { Send(*v1.Event) error grpc.ServerStream }
type Executor_ExportClient ¶
type Executor_ExportClient interface { Recv() (*FileTransfer, error) grpc.ClientStream }
type Executor_ExportServer ¶
type Executor_ExportServer interface { Send(*FileTransfer) error grpc.ServerStream }
type Executor_ImportClient ¶
type Executor_ImportClient interface { Send(*FileTransfer) error CloseAndRecv() (*ImportResponse, error) grpc.ClientStream }
type Executor_ImportServer ¶
type Executor_ImportServer interface { SendAndClose(*ImportResponse) error Recv() (*FileTransfer, error) grpc.ServerStream }
type ExportOpts ¶
type ExportOpts struct { DestPath string `protobuf:"bytes,1,opt,name=dest_path,json=destPath,proto3" json:"dest_path,omitempty"` Excludes []string `protobuf:"bytes,2,rep,name=excludes,proto3" json:"excludes,omitempty"` // contains filtered or unexported fields }
func (*ExportOpts) Descriptor
deprecated
func (*ExportOpts) Descriptor() ([]byte, []int)
Deprecated: Use ExportOpts.ProtoReflect.Descriptor instead.
func (*ExportOpts) GetDestPath ¶
func (x *ExportOpts) GetDestPath() string
func (*ExportOpts) GetExcludes ¶
func (x *ExportOpts) GetExcludes() []string
func (*ExportOpts) ProtoMessage ¶
func (*ExportOpts) ProtoMessage()
func (*ExportOpts) ProtoReflect ¶
func (x *ExportOpts) ProtoReflect() protoreflect.Message
func (*ExportOpts) Reset ¶
func (x *ExportOpts) Reset()
func (*ExportOpts) String ¶
func (x *ExportOpts) String() string
type ExportRequest ¶
type ExportRequest struct { RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"` ExportId string `protobuf:"bytes,2,opt,name=export_id,json=exportId,proto3" json:"export_id,omitempty"` SrcPath string `protobuf:"bytes,3,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"` Opts *ExportOpts `protobuf:"bytes,4,opt,name=opts,proto3" json:"opts,omitempty"` // contains filtered or unexported fields }
func (*ExportRequest) Descriptor
deprecated
func (*ExportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExportRequest.ProtoReflect.Descriptor instead.
func (*ExportRequest) GetExportId ¶
func (x *ExportRequest) GetExportId() string
func (*ExportRequest) GetOpts ¶
func (x *ExportRequest) GetOpts() *ExportOpts
func (*ExportRequest) GetRuntimeId ¶
func (x *ExportRequest) GetRuntimeId() string
func (*ExportRequest) GetSrcPath ¶
func (x *ExportRequest) GetSrcPath() string
func (*ExportRequest) ProtoMessage ¶
func (*ExportRequest) ProtoMessage()
func (*ExportRequest) ProtoReflect ¶
func (x *ExportRequest) ProtoReflect() protoreflect.Message
func (*ExportRequest) Reset ¶
func (x *ExportRequest) Reset()
func (*ExportRequest) String ¶
func (x *ExportRequest) String() string
type FileTransfer ¶
type FileTransfer struct { RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"` TransferId string `protobuf:"bytes,2,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"` FileId string `protobuf:"bytes,3,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"` Header *FileTransferHeader `protobuf:"bytes,4,opt,name=header,proto3" json:"header,omitempty"` Body *FileTransferBody `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"` Trailer *FileTransferTrailer `protobuf:"bytes,6,opt,name=trailer,proto3" json:"trailer,omitempty"` // contains filtered or unexported fields }
func (*FileTransfer) Descriptor
deprecated
func (*FileTransfer) Descriptor() ([]byte, []int)
Deprecated: Use FileTransfer.ProtoReflect.Descriptor instead.
func (*FileTransfer) GetBody ¶
func (x *FileTransfer) GetBody() *FileTransferBody
func (*FileTransfer) GetFileId ¶
func (x *FileTransfer) GetFileId() string
func (*FileTransfer) GetHeader ¶
func (x *FileTransfer) GetHeader() *FileTransferHeader
func (*FileTransfer) GetRuntimeId ¶
func (x *FileTransfer) GetRuntimeId() string
func (*FileTransfer) GetTrailer ¶
func (x *FileTransfer) GetTrailer() *FileTransferTrailer
func (*FileTransfer) GetTransferId ¶
func (x *FileTransfer) GetTransferId() string
func (*FileTransfer) ProtoMessage ¶
func (*FileTransfer) ProtoMessage()
func (*FileTransfer) ProtoReflect ¶
func (x *FileTransfer) ProtoReflect() protoreflect.Message
func (*FileTransfer) Reset ¶
func (x *FileTransfer) Reset()
func (*FileTransfer) String ¶
func (x *FileTransfer) String() string
type FileTransferBody ¶
type FileTransferBody struct { Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*FileTransferBody) Descriptor
deprecated
func (*FileTransferBody) Descriptor() ([]byte, []int)
Deprecated: Use FileTransferBody.ProtoReflect.Descriptor instead.
func (*FileTransferBody) GetData ¶
func (x *FileTransferBody) GetData() []byte
func (*FileTransferBody) GetOffset ¶
func (x *FileTransferBody) GetOffset() uint64
func (*FileTransferBody) ProtoMessage ¶
func (*FileTransferBody) ProtoMessage()
func (*FileTransferBody) ProtoReflect ¶
func (x *FileTransferBody) ProtoReflect() protoreflect.Message
func (*FileTransferBody) Reset ¶
func (x *FileTransferBody) Reset()
func (*FileTransferBody) String ¶
func (x *FileTransferBody) String() string
type FileTransferHeader ¶
type FileTransferHeader struct { IsDir bool `protobuf:"varint,1,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"` SrcPath string `protobuf:"bytes,2,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"` DestPath string `protobuf:"bytes,3,opt,name=dest_path,json=destPath,proto3" json:"dest_path,omitempty"` Mode uint32 `protobuf:"varint,4,opt,name=mode,proto3" json:"mode,omitempty"` Size uint64 `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"` // contains filtered or unexported fields }
func (*FileTransferHeader) Descriptor
deprecated
func (*FileTransferHeader) Descriptor() ([]byte, []int)
Deprecated: Use FileTransferHeader.ProtoReflect.Descriptor instead.
func (*FileTransferHeader) GetDestPath ¶
func (x *FileTransferHeader) GetDestPath() string
func (*FileTransferHeader) GetIsDir ¶
func (x *FileTransferHeader) GetIsDir() bool
func (*FileTransferHeader) GetMode ¶
func (x *FileTransferHeader) GetMode() uint32
func (*FileTransferHeader) GetSize ¶
func (x *FileTransferHeader) GetSize() uint64
func (*FileTransferHeader) GetSrcPath ¶
func (x *FileTransferHeader) GetSrcPath() string
func (*FileTransferHeader) ProtoMessage ¶
func (*FileTransferHeader) ProtoMessage()
func (*FileTransferHeader) ProtoReflect ¶
func (x *FileTransferHeader) ProtoReflect() protoreflect.Message
func (*FileTransferHeader) Reset ¶
func (x *FileTransferHeader) Reset()
func (*FileTransferHeader) String ¶
func (x *FileTransferHeader) String() string
type FileTransferTrailer ¶
type FileTransferTrailer struct { Md5 []byte `protobuf:"bytes,1,opt,name=md5,proto3" json:"md5,omitempty"` // contains filtered or unexported fields }
func (*FileTransferTrailer) Descriptor
deprecated
func (*FileTransferTrailer) Descriptor() ([]byte, []int)
Deprecated: Use FileTransferTrailer.ProtoReflect.Descriptor instead.
func (*FileTransferTrailer) GetMd5 ¶
func (x *FileTransferTrailer) GetMd5() []byte
func (*FileTransferTrailer) ProtoMessage ¶
func (*FileTransferTrailer) ProtoMessage()
func (*FileTransferTrailer) ProtoReflect ¶
func (x *FileTransferTrailer) ProtoReflect() protoreflect.Message
func (*FileTransferTrailer) Reset ¶
func (x *FileTransferTrailer) Reset()
func (*FileTransferTrailer) String ¶
func (x *FileTransferTrailer) String() string
type HeartbeatRequest ¶
type HeartbeatRequest struct { RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"` // contains filtered or unexported fields }
func (*HeartbeatRequest) Descriptor
deprecated
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.
func (*HeartbeatRequest) GetRuntimeId ¶
func (x *HeartbeatRequest) GetRuntimeId() string
func (*HeartbeatRequest) ProtoMessage ¶
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) ProtoReflect ¶
func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
func (*HeartbeatRequest) Reset ¶
func (x *HeartbeatRequest) Reset()
func (*HeartbeatRequest) String ¶
func (x *HeartbeatRequest) String() string
type HeartbeatResponse ¶
type HeartbeatResponse struct { ExtendedBy *durationpb.Duration `protobuf:"bytes,1,opt,name=extended_by,json=extendedBy,proto3" json:"extended_by,omitempty"` // contains filtered or unexported fields }
func (*HeartbeatResponse) Descriptor
deprecated
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.
func (*HeartbeatResponse) GetExtendedBy ¶
func (x *HeartbeatResponse) GetExtendedBy() *durationpb.Duration
func (*HeartbeatResponse) ProtoMessage ¶
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) ProtoReflect ¶
func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
func (*HeartbeatResponse) Reset ¶
func (x *HeartbeatResponse) Reset()
func (*HeartbeatResponse) String ¶
func (x *HeartbeatResponse) String() string
type HostOpts ¶
type HostOpts struct {
// contains filtered or unexported fields
}
func (*HostOpts) Descriptor
deprecated
func (*HostOpts) ProtoMessage ¶
func (*HostOpts) ProtoMessage()
func (*HostOpts) ProtoReflect ¶
func (x *HostOpts) ProtoReflect() protoreflect.Message
type ImportResponse ¶
type ImportResponse struct {
// contains filtered or unexported fields
}
func (*ImportResponse) Descriptor
deprecated
func (*ImportResponse) Descriptor() ([]byte, []int)
Deprecated: Use ImportResponse.ProtoReflect.Descriptor instead.
func (*ImportResponse) ProtoMessage ¶
func (*ImportResponse) ProtoMessage()
func (*ImportResponse) ProtoReflect ¶
func (x *ImportResponse) ProtoReflect() protoreflect.Message
func (*ImportResponse) Reset ¶
func (x *ImportResponse) Reset()
func (*ImportResponse) String ¶
func (x *ImportResponse) String() string
type IntrospectRequest ¶
type IntrospectRequest struct {
// contains filtered or unexported fields
}
func (*IntrospectRequest) Descriptor
deprecated
func (*IntrospectRequest) Descriptor() ([]byte, []int)
Deprecated: Use IntrospectRequest.ProtoReflect.Descriptor instead.
func (*IntrospectRequest) ProtoMessage ¶
func (*IntrospectRequest) ProtoMessage()
func (*IntrospectRequest) ProtoReflect ¶
func (x *IntrospectRequest) ProtoReflect() protoreflect.Message
func (*IntrospectRequest) Reset ¶
func (x *IntrospectRequest) Reset()
func (*IntrospectRequest) String ¶
func (x *IntrospectRequest) String() string
type IntrospectResponse ¶
type IntrospectResponse struct { SysInfo *SystemInfo `protobuf:"bytes,1,opt,name=sys_info,json=sysInfo,proto3" json:"sys_info,omitempty"` ExecutorInfo *ExecutorInfo `protobuf:"bytes,3,opt,name=executor_info,json=executorInfo,proto3" json:"executor_info,omitempty"` Labels []string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*IntrospectResponse) Descriptor
deprecated
func (*IntrospectResponse) Descriptor() ([]byte, []int)
Deprecated: Use IntrospectResponse.ProtoReflect.Descriptor instead.
func (*IntrospectResponse) GetExecutorInfo ¶
func (x *IntrospectResponse) GetExecutorInfo() *ExecutorInfo
func (*IntrospectResponse) GetLabels ¶
func (x *IntrospectResponse) GetLabels() []string
func (*IntrospectResponse) GetSysInfo ¶
func (x *IntrospectResponse) GetSysInfo() *SystemInfo
func (*IntrospectResponse) ProtoMessage ¶
func (*IntrospectResponse) ProtoMessage()
func (*IntrospectResponse) ProtoReflect ¶
func (x *IntrospectResponse) ProtoReflect() protoreflect.Message
func (*IntrospectResponse) Reset ¶
func (x *IntrospectResponse) Reset()
func (*IntrospectResponse) String ¶
func (x *IntrospectResponse) String() string
type OpenRequest ¶
type OpenRequest struct { BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"` RuntimeId string `protobuf:"bytes,2,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"` Opts *Opts `protobuf:"bytes,3,opt,name=opts,proto3" json:"opts,omitempty"` // contains filtered or unexported fields }
func (*OpenRequest) Descriptor
deprecated
func (*OpenRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenRequest.ProtoReflect.Descriptor instead.
func (*OpenRequest) GetBuildId ¶
func (x *OpenRequest) GetBuildId() string
func (*OpenRequest) GetOpts ¶
func (x *OpenRequest) GetOpts() *Opts
func (*OpenRequest) GetRuntimeId ¶
func (x *OpenRequest) GetRuntimeId() string
func (*OpenRequest) ProtoMessage ¶
func (*OpenRequest) ProtoMessage()
func (*OpenRequest) ProtoReflect ¶
func (x *OpenRequest) ProtoReflect() protoreflect.Message
func (*OpenRequest) Reset ¶
func (x *OpenRequest) Reset()
func (*OpenRequest) String ¶
func (x *OpenRequest) String() string
type OpenResponse ¶
type OpenResponse struct { WorkDirectory string `protobuf:"bytes,1,opt,name=work_directory,json=workDirectory,proto3" json:"work_directory,omitempty"` SysInfo *SystemInfo `protobuf:"bytes,2,opt,name=sys_info,json=sysInfo,proto3" json:"sys_info,omitempty"` // contains filtered or unexported fields }
func (*OpenResponse) Descriptor
deprecated
func (*OpenResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenResponse.ProtoReflect.Descriptor instead.
func (*OpenResponse) GetSysInfo ¶
func (x *OpenResponse) GetSysInfo() *SystemInfo
func (*OpenResponse) GetWorkDirectory ¶
func (x *OpenResponse) GetWorkDirectory() string
func (*OpenResponse) ProtoMessage ¶
func (*OpenResponse) ProtoMessage()
func (*OpenResponse) ProtoReflect ¶
func (x *OpenResponse) ProtoReflect() protoreflect.Message
func (*OpenResponse) Reset ¶
func (x *OpenResponse) Reset()
func (*OpenResponse) String ¶
func (x *OpenResponse) String() string
type Opts ¶
type Opts struct { Type RuntimeType `protobuf:"varint,1,opt,name=type,proto3,enum=executor.knita.io.RuntimeType" json:"type,omitempty"` Labels []string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"` // TODO becomes "label selector". Runner labels become k/v pairs, with the same semantics as event labels. Tags map[string]string `` // TODO moves up to Event /* 149-byte string literal not displayed */ // Types that are assignable to Opts: // // *Opts_Host // *Opts_Docker Opts isOpts_Opts `protobuf_oneof:"opts"` // contains filtered or unexported fields }
func (*Opts) Descriptor
deprecated
func (*Opts) GetDocker ¶
func (x *Opts) GetDocker() *DockerOpts
func (*Opts) GetType ¶
func (x *Opts) GetType() RuntimeType
func (*Opts) ProtoMessage ¶
func (*Opts) ProtoMessage()
func (*Opts) ProtoReflect ¶
func (x *Opts) ProtoReflect() protoreflect.Message
type Opts_Docker ¶
type Opts_Docker struct {
Docker *DockerOpts `protobuf:"bytes,3,opt,name=docker,proto3,oneof"`
}
type Opts_Host ¶
type Opts_Host struct {
Host *HostOpts `protobuf:"bytes,2,opt,name=host,proto3,oneof"`
}
type RuntimeType ¶
type RuntimeType int32
const ( RuntimeType_RUNTIME_UNSPECIFIED RuntimeType = 0 RuntimeType_RUNTIME_HOST RuntimeType = 1 RuntimeType_RUNTIME_DOCKER RuntimeType = 2 )
func (RuntimeType) Descriptor ¶
func (RuntimeType) Descriptor() protoreflect.EnumDescriptor
func (RuntimeType) Enum ¶
func (x RuntimeType) Enum() *RuntimeType
func (RuntimeType) EnumDescriptor
deprecated
func (RuntimeType) EnumDescriptor() ([]byte, []int)
Deprecated: Use RuntimeType.Descriptor instead.
func (RuntimeType) Number ¶
func (x RuntimeType) Number() protoreflect.EnumNumber
func (RuntimeType) String ¶
func (x RuntimeType) String() string
func (RuntimeType) Type ¶
func (RuntimeType) Type() protoreflect.EnumType
type SystemInfo ¶
type SystemInfo struct { Os string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"` Arch string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"` TotalCpuCores uint32 `protobuf:"varint,4,opt,name=total_cpu_cores,json=totalCpuCores,proto3" json:"total_cpu_cores,omitempty"` TotalMemory uint64 `protobuf:"varint,5,opt,name=total_memory,json=totalMemory,proto3" json:"total_memory,omitempty"` // contains filtered or unexported fields }
func (*SystemInfo) Descriptor
deprecated
func (*SystemInfo) Descriptor() ([]byte, []int)
Deprecated: Use SystemInfo.ProtoReflect.Descriptor instead.
func (*SystemInfo) GetArch ¶
func (x *SystemInfo) GetArch() string
func (*SystemInfo) GetOs ¶
func (x *SystemInfo) GetOs() string
func (*SystemInfo) GetTotalCpuCores ¶
func (x *SystemInfo) GetTotalCpuCores() uint32
func (*SystemInfo) GetTotalMemory ¶
func (x *SystemInfo) GetTotalMemory() uint64
func (*SystemInfo) ProtoMessage ¶
func (*SystemInfo) ProtoMessage()
func (*SystemInfo) ProtoReflect ¶
func (x *SystemInfo) ProtoReflect() protoreflect.Message
func (*SystemInfo) Reset ¶
func (x *SystemInfo) Reset()
func (*SystemInfo) String ¶
func (x *SystemInfo) String() string
type UnimplementedExecutorServer ¶
type UnimplementedExecutorServer struct { }
UnimplementedExecutorServer must be embedded to have forward compatible implementations.
func (UnimplementedExecutorServer) Close ¶
func (UnimplementedExecutorServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)
func (UnimplementedExecutorServer) Events ¶
func (UnimplementedExecutorServer) Events(*EventsRequest, Executor_EventsServer) error
func (UnimplementedExecutorServer) Exec ¶
func (UnimplementedExecutorServer) Exec(context.Context, *ExecRequest) (*ExecResponse, error)
func (UnimplementedExecutorServer) Export ¶
func (UnimplementedExecutorServer) Export(*ExportRequest, Executor_ExportServer) error
func (UnimplementedExecutorServer) Heartbeat ¶
func (UnimplementedExecutorServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
func (UnimplementedExecutorServer) Import ¶
func (UnimplementedExecutorServer) Import(Executor_ImportServer) error
func (UnimplementedExecutorServer) Introspect ¶
func (UnimplementedExecutorServer) Introspect(context.Context, *IntrospectRequest) (*IntrospectResponse, error)
func (UnimplementedExecutorServer) Open ¶
func (UnimplementedExecutorServer) Open(context.Context, *OpenRequest) (*OpenResponse, error)
type UnsafeExecutorServer ¶
type UnsafeExecutorServer interface {
// contains filtered or unexported methods
}
UnsafeExecutorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutorServer will result in compilation errors.