Versions in this module Expand all Collapse all v0 v0.1.1 Sep 2, 2022 v0.1.0 Aug 28, 2022 Changes in this version + var File_internal_flexletpb_flexlet_proto protoreflect.FileDescriptor + var File_internal_flexletpb_flexlet_service_proto protoreflect.FileDescriptor + var FlexletService_ServiceDesc = grpc.ServiceDesc + func RegisterFlexletServiceServer(s grpc.ServiceRegistrar, srv FlexletServiceServer) + type FinishTaskRequest struct + NeedRetry bool + Ref *TaskRef + Result *flex.TaskResult + func (*FinishTaskRequest) Descriptor() ([]byte, []int) + func (*FinishTaskRequest) ProtoMessage() + func (x *FinishTaskRequest) GetNeedRetry() bool + func (x *FinishTaskRequest) GetRef() *TaskRef + func (x *FinishTaskRequest) GetResult() *flex.TaskResult + func (x *FinishTaskRequest) ProtoReflect() protoreflect.Message + func (x *FinishTaskRequest) Reset() + func (x *FinishTaskRequest) String() string + type FinishTaskResponse struct + func (*FinishTaskResponse) Descriptor() ([]byte, []int) + func (*FinishTaskResponse) ProtoMessage() + func (x *FinishTaskResponse) ProtoReflect() protoreflect.Message + func (x *FinishTaskResponse) Reset() + func (x *FinishTaskResponse) String() string + type FlexletServiceClient interface + FinishTask func(ctx context.Context, in *FinishTaskRequest, opts ...grpc.CallOption) (*FinishTaskResponse, error) + TakeTask func(ctx context.Context, in *TakeTaskRequest, opts ...grpc.CallOption) (*TakeTaskResponse, error) + UpdateFlexlet func(ctx context.Context, in *UpdateFlexletRequest, opts ...grpc.CallOption) (*UpdateFlexletResponse, error) + UpdateTask func(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error) + func NewFlexletServiceClient(cc grpc.ClientConnInterface) FlexletServiceClient + type FlexletServiceServer interface + FinishTask func(context.Context, *FinishTaskRequest) (*FinishTaskResponse, error) + TakeTask func(context.Context, *TakeTaskRequest) (*TakeTaskResponse, error) + UpdateFlexlet func(context.Context, *UpdateFlexletRequest) (*UpdateFlexletResponse, error) + UpdateTask func(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error) + type TakeTaskRequest struct + FlexletName string + Wait bool + func (*TakeTaskRequest) Descriptor() ([]byte, []int) + func (*TakeTaskRequest) ProtoMessage() + func (x *TakeTaskRequest) GetFlexletName() string + func (x *TakeTaskRequest) GetWait() bool + func (x *TakeTaskRequest) ProtoReflect() protoreflect.Message + func (x *TakeTaskRequest) Reset() + func (x *TakeTaskRequest) String() string + type TakeTaskResponse struct + Task *Task + func (*TakeTaskResponse) Descriptor() ([]byte, []int) + func (*TakeTaskResponse) ProtoMessage() + func (x *TakeTaskResponse) GetTask() *Task + func (x *TakeTaskResponse) ProtoReflect() protoreflect.Message + func (x *TakeTaskResponse) Reset() + func (x *TakeTaskResponse) String() string + type Task struct + Ref *TaskRef + Spec *TaskSpec + func (*Task) Descriptor() ([]byte, []int) + func (*Task) ProtoMessage() + func (x *Task) GetRef() *TaskRef + func (x *Task) GetSpec() *TaskSpec + func (x *Task) ProtoReflect() protoreflect.Message + func (x *Task) Reset() + func (x *Task) String() string + type TaskInputs struct + Packages []*TaskPackage + func (*TaskInputs) Descriptor() ([]byte, []int) + func (*TaskInputs) ProtoMessage() + func (x *TaskInputs) GetPackages() []*TaskPackage + func (x *TaskInputs) ProtoReflect() protoreflect.Message + func (x *TaskInputs) Reset() + func (x *TaskInputs) String() string + type TaskOutputs struct + Stderr *flex.FileLocation + Stdout *flex.FileLocation + func (*TaskOutputs) Descriptor() ([]byte, []int) + func (*TaskOutputs) ProtoMessage() + func (x *TaskOutputs) GetStderr() *flex.FileLocation + func (x *TaskOutputs) GetStdout() *flex.FileLocation + func (x *TaskOutputs) ProtoReflect() protoreflect.Message + func (x *TaskOutputs) Reset() + func (x *TaskOutputs) String() string + type TaskPackage struct + InstallDir string + Location *flex.FileLocation + func (*TaskPackage) Descriptor() ([]byte, []int) + func (*TaskPackage) ProtoMessage() + func (x *TaskPackage) GetInstallDir() string + func (x *TaskPackage) GetLocation() *flex.FileLocation + func (x *TaskPackage) ProtoReflect() protoreflect.Message + func (x *TaskPackage) Reset() + func (x *TaskPackage) String() string + type TaskRef struct + JobId int64 + TaskId string + func (*TaskRef) Descriptor() ([]byte, []int) + func (*TaskRef) ProtoMessage() + func (x *TaskRef) GetJobId() int64 + func (x *TaskRef) GetTaskId() string + func (x *TaskRef) ProtoReflect() protoreflect.Message + func (x *TaskRef) Reset() + func (x *TaskRef) String() string + type TaskSpec struct + Command *flex.JobCommand + Inputs *TaskInputs + Limits *flex.JobLimits + Outputs *TaskOutputs + func (*TaskSpec) Descriptor() ([]byte, []int) + func (*TaskSpec) ProtoMessage() + func (x *TaskSpec) GetCommand() *flex.JobCommand + func (x *TaskSpec) GetInputs() *TaskInputs + func (x *TaskSpec) GetLimits() *flex.JobLimits + func (x *TaskSpec) GetOutputs() *TaskOutputs + func (x *TaskSpec) ProtoReflect() protoreflect.Message + func (x *TaskSpec) Reset() + func (x *TaskSpec) String() string + type UnimplementedFlexletServiceServer struct + func (UnimplementedFlexletServiceServer) FinishTask(context.Context, *FinishTaskRequest) (*FinishTaskResponse, error) + func (UnimplementedFlexletServiceServer) TakeTask(context.Context, *TakeTaskRequest) (*TakeTaskResponse, error) + func (UnimplementedFlexletServiceServer) UpdateFlexlet(context.Context, *UpdateFlexletRequest) (*UpdateFlexletResponse, error) + func (UnimplementedFlexletServiceServer) UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error) + type UnsafeFlexletServiceServer interface + type UpdateFlexletRequest struct + Status *flex.FlexletStatus + func (*UpdateFlexletRequest) Descriptor() ([]byte, []int) + func (*UpdateFlexletRequest) ProtoMessage() + func (x *UpdateFlexletRequest) GetStatus() *flex.FlexletStatus + func (x *UpdateFlexletRequest) ProtoReflect() protoreflect.Message + func (x *UpdateFlexletRequest) Reset() + func (x *UpdateFlexletRequest) String() string + type UpdateFlexletResponse struct + func (*UpdateFlexletResponse) Descriptor() ([]byte, []int) + func (*UpdateFlexletResponse) ProtoMessage() + func (x *UpdateFlexletResponse) ProtoReflect() protoreflect.Message + func (x *UpdateFlexletResponse) Reset() + func (x *UpdateFlexletResponse) String() string + type UpdateTaskRequest struct + Ref *TaskRef + func (*UpdateTaskRequest) Descriptor() ([]byte, []int) + func (*UpdateTaskRequest) ProtoMessage() + func (x *UpdateTaskRequest) GetRef() *TaskRef + func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message + func (x *UpdateTaskRequest) Reset() + func (x *UpdateTaskRequest) String() string + type UpdateTaskResponse struct + func (*UpdateTaskResponse) Descriptor() ([]byte, []int) + func (*UpdateTaskResponse) ProtoMessage() + func (x *UpdateTaskResponse) ProtoReflect() protoreflect.Message + func (x *UpdateTaskResponse) Reset() + func (x *UpdateTaskResponse) String() string
Go to main page