Documentation ¶
Index ¶
- Variables
- func RegisterExecutorServiceServer(s grpc.ServiceRegistrar, srv ExecutorServiceServer)
- type Command
- func (*Command) Descriptor() ([]byte, []int)deprecated
- func (x *Command) GetBinary() string
- func (x *Command) GetDeleteOnComplete() bool
- func (x *Command) GetParameters() []string
- func (*Command) ProtoMessage()
- func (x *Command) ProtoReflect() protoreflect.Message
- func (x *Command) Reset()
- func (x *Command) String() string
- type CommandStatus
- func (CommandStatus) Descriptor() protoreflect.EnumDescriptor
- func (x CommandStatus) Enum() *CommandStatus
- func (CommandStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x CommandStatus) Number() protoreflect.EnumNumber
- func (x CommandStatus) String() string
- func (CommandStatus) Type() protoreflect.EnumType
- type ExecuteRequest
- func (*ExecuteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteRequest) GetCommand() *Command
- func (x *ExecuteRequest) GetKey() string
- func (x *ExecuteRequest) GetReadyForDeletion() bool
- func (*ExecuteRequest) ProtoMessage()
- func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteRequest) Reset()
- func (x *ExecuteRequest) String() string
- type ExecuteResponse
- func (*ExecuteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteResponse) GetCommandOutput() string
- func (x *ExecuteResponse) GetExitCode() int32
- func (x *ExecuteResponse) GetStatus() CommandStatus
- func (x *ExecuteResponse) GetTimeTakenInMillis() int64
- func (*ExecuteResponse) ProtoMessage()
- func (x *ExecuteResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteResponse) Reset()
- func (x *ExecuteResponse) String() string
- type ExecutorServiceClient
- type ExecutorServiceServer
- type UnimplementedExecutorServiceServer
- type UnsafeExecutorServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( CommandStatus_name = map[int32]string{ 0: "UNKNOWN", 1: "IN_QUEUE", 2: "IN_PROGRESS", 3: "COMPLETE", } CommandStatus_value = map[string]int32{ "UNKNOWN": 0, "IN_QUEUE": 1, "IN_PROGRESS": 2, "COMPLETE": 3, } )
Enum value maps for CommandStatus.
var File_executor_proto protoreflect.FileDescriptor
Functions ¶
func RegisterExecutorServiceServer ¶
func RegisterExecutorServiceServer(s grpc.ServiceRegistrar, srv ExecutorServiceServer)
Types ¶
type Command ¶
type Command struct { Binary string `protobuf:"bytes,1,opt,name=binary,proto3" json:"binary,omitempty"` Parameters []string `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"` DeleteOnComplete bool `protobuf:"varint,3,opt,name=delete_on_complete,json=deleteOnComplete,proto3" json:"delete_on_complete,omitempty"` // contains filtered or unexported fields }
func (*Command) Descriptor
deprecated
func (*Command) GetDeleteOnComplete ¶
func (*Command) GetParameters ¶
func (*Command) ProtoMessage ¶
func (*Command) ProtoMessage()
func (*Command) ProtoReflect ¶
func (x *Command) ProtoReflect() protoreflect.Message
type CommandStatus ¶
type CommandStatus int32
const ( CommandStatus_UNKNOWN CommandStatus = 0 CommandStatus_IN_QUEUE CommandStatus = 1 CommandStatus_IN_PROGRESS CommandStatus = 2 CommandStatus_COMPLETE CommandStatus = 3 )
func (CommandStatus) Descriptor ¶
func (CommandStatus) Descriptor() protoreflect.EnumDescriptor
func (CommandStatus) Enum ¶
func (x CommandStatus) Enum() *CommandStatus
func (CommandStatus) EnumDescriptor
deprecated
func (CommandStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use CommandStatus.Descriptor instead.
func (CommandStatus) Number ¶
func (x CommandStatus) Number() protoreflect.EnumNumber
func (CommandStatus) String ¶
func (x CommandStatus) String() string
func (CommandStatus) Type ¶
func (CommandStatus) Type() protoreflect.EnumType
type ExecuteRequest ¶
type ExecuteRequest struct { Command *Command `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"` ReadyForDeletion bool `protobuf:"varint,2,opt,name=ready_for_deletion,json=readyForDeletion,proto3" json:"ready_for_deletion,omitempty"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*ExecuteRequest) Descriptor
deprecated
func (*ExecuteRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.
func (*ExecuteRequest) GetCommand ¶
func (x *ExecuteRequest) GetCommand() *Command
func (*ExecuteRequest) GetKey ¶
func (x *ExecuteRequest) GetKey() string
func (*ExecuteRequest) GetReadyForDeletion ¶
func (x *ExecuteRequest) GetReadyForDeletion() bool
func (*ExecuteRequest) ProtoMessage ¶
func (*ExecuteRequest) ProtoMessage()
func (*ExecuteRequest) ProtoReflect ¶
func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
func (*ExecuteRequest) Reset ¶
func (x *ExecuteRequest) Reset()
func (*ExecuteRequest) String ¶
func (x *ExecuteRequest) String() string
type ExecuteResponse ¶
type ExecuteResponse struct { TimeTakenInMillis int64 `protobuf:"varint,1,opt,name=time_taken_in_millis,json=timeTakenInMillis,proto3" json:"time_taken_in_millis,omitempty"` CommandOutput string `protobuf:"bytes,2,opt,name=command_output,json=commandOutput,proto3" json:"command_output,omitempty"` Status CommandStatus `protobuf:"varint,3,opt,name=status,proto3,enum=executor.CommandStatus" json:"status,omitempty"` ExitCode int32 `protobuf:"varint,4,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"` // contains filtered or unexported fields }
func (*ExecuteResponse) Descriptor
deprecated
func (*ExecuteResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.
func (*ExecuteResponse) GetCommandOutput ¶
func (x *ExecuteResponse) GetCommandOutput() string
func (*ExecuteResponse) GetExitCode ¶
func (x *ExecuteResponse) GetExitCode() int32
func (*ExecuteResponse) GetStatus ¶
func (x *ExecuteResponse) GetStatus() CommandStatus
func (*ExecuteResponse) GetTimeTakenInMillis ¶
func (x *ExecuteResponse) GetTimeTakenInMillis() int64
func (*ExecuteResponse) ProtoMessage ¶
func (*ExecuteResponse) ProtoMessage()
func (*ExecuteResponse) ProtoReflect ¶
func (x *ExecuteResponse) ProtoReflect() protoreflect.Message
func (*ExecuteResponse) Reset ¶
func (x *ExecuteResponse) Reset()
func (*ExecuteResponse) String ¶
func (x *ExecuteResponse) String() string
type ExecutorServiceClient ¶
type ExecutorServiceClient interface { Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error) QueueExecute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error) }
ExecutorServiceClient is the client API for ExecutorService 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 NewExecutorServiceClient ¶
func NewExecutorServiceClient(cc grpc.ClientConnInterface) ExecutorServiceClient
type ExecutorServiceServer ¶
type ExecutorServiceServer interface { Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error) QueueExecute(context.Context, *ExecuteRequest) (*ExecuteResponse, error) }
ExecutorServiceServer is the server API for ExecutorService service. All implementations should embed UnimplementedExecutorServiceServer for forward compatibility
type UnimplementedExecutorServiceServer ¶
type UnimplementedExecutorServiceServer struct { }
UnimplementedExecutorServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedExecutorServiceServer) Execute ¶
func (UnimplementedExecutorServiceServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
func (UnimplementedExecutorServiceServer) QueueExecute ¶
func (UnimplementedExecutorServiceServer) QueueExecute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
type UnsafeExecutorServiceServer ¶
type UnsafeExecutorServiceServer interface {
// contains filtered or unexported methods
}
UnsafeExecutorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutorServiceServer will result in compilation errors.