Documentation ¶
Index ¶
- Variables
- func RegisterInternalServer(s grpc.ServiceRegistrar, srv InternalServer)
- func RegisterQueueServer(s grpc.ServiceRegistrar, srv QueueServer)
- func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)
- type ArgumentSpec
- func (*ArgumentSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ArgumentSpec) GetTaskId() *ShardedID
- func (x *ArgumentSpec) GetType() ArgumentSpec_Type
- func (x *ArgumentSpec) GetValueJson() []byte
- func (*ArgumentSpec) ProtoMessage()
- func (x *ArgumentSpec) ProtoReflect() protoreflect.Message
- func (x *ArgumentSpec) Reset()
- func (x *ArgumentSpec) String() string
- func (a *ArgumentSpec) Valid() error
- type ArgumentSpec_Type
- func (ArgumentSpec_Type) Descriptor() protoreflect.EnumDescriptor
- func (x ArgumentSpec_Type) Enum() *ArgumentSpec_Type
- func (ArgumentSpec_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x ArgumentSpec_Type) Number() protoreflect.EnumNumber
- func (x ArgumentSpec_Type) String() string
- func (ArgumentSpec_Type) Type() protoreflect.EnumType
- type GetLogsRequest
- type InternalClient
- type InternalServer
- type KeepaliveRequest
- type LogChunk
- type LogRequest
- type PollRequest
- func (*PollRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PollRequest) GetWorkerBaseUrl() string
- func (x *PollRequest) GetWorkerId() string
- func (*PollRequest) ProtoMessage()
- func (x *PollRequest) ProtoReflect() protoreflect.Message
- func (x *PollRequest) Reset()
- func (x *PollRequest) String() string
- type QueryRequest
- type QueueClient
- type QueueServer
- type Queue_GetLogsClient
- type Queue_GetLogsServer
- type ReportSuccessRequest
- func (*ReportSuccessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReportSuccessRequest) GetDownstreamTaskId() *ShardedID
- func (x *ReportSuccessRequest) GetResultData() []byte
- func (x *ReportSuccessRequest) GetTaskId() *ShardedID
- func (*ReportSuccessRequest) ProtoMessage()
- func (x *ReportSuccessRequest) ProtoReflect() protoreflect.Message
- func (x *ReportSuccessRequest) Reset()
- func (x *ReportSuccessRequest) String() string
- type ReportSuccessResponse
- func (*ReportSuccessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReportSuccessResponse) GetResultId() *ShardedID
- func (*ReportSuccessResponse) ProtoMessage()
- func (x *ReportSuccessResponse) ProtoReflect() protoreflect.Message
- func (x *ReportSuccessResponse) Reset()
- func (x *ReportSuccessResponse) String() string
- type SetCancelRequest
- type SetCancelResponse
- func (*SetCancelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SetCancelResponse) GetUpstreamTaskIds() []*ShardedID
- func (*SetCancelResponse) ProtoMessage()
- func (x *SetCancelResponse) ProtoReflect() protoreflect.Message
- func (x *SetCancelResponse) Reset()
- func (x *SetCancelResponse) String() string
- type SetFailedRequest
- func (*SetFailedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetFailedRequest) GetParentId() *ShardedID
- func (x *SetFailedRequest) GetTaskId() *ShardedID
- func (*SetFailedRequest) ProtoMessage()
- func (x *SetFailedRequest) ProtoReflect() protoreflect.Message
- func (x *SetFailedRequest) Reset()
- func (x *SetFailedRequest) String() string
- type ShardedID
- func (*ShardedID) Descriptor() ([]byte, []int)deprecated
- func (s *ShardedID) Equal(other *ShardedID) bool
- func (x *ShardedID) GetId() string
- func (x *ShardedID) GetShard() string
- func (*ShardedID) ProtoMessage()
- func (x *ShardedID) ProtoReflect() protoreflect.Message
- func (x *ShardedID) Reset()
- func (x *ShardedID) String() string
- func (s *ShardedID) ToString() string
- func (s *ShardedID) Valid() error
- type SubmitRequest
- type SubmitResponse
- type Task
- type TaskInfo
- func (*TaskInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TaskInfo) GetAttempts() int32
- func (x *TaskInfo) GetCreatedAt() *timestamp.Timestamp
- func (x *TaskInfo) GetSpec() *TaskSpec
- func (x *TaskInfo) GetStartedAt() *timestamp.Timestamp
- func (x *TaskInfo) GetState() TaskInfo_State
- func (x *TaskInfo) GetTerminatedAt() *timestamp.Timestamp
- func (*TaskInfo) ProtoMessage()
- func (x *TaskInfo) ProtoReflect() protoreflect.Message
- func (x *TaskInfo) Reset()
- func (x *TaskInfo) String() string
- type TaskInfo_State
- func (TaskInfo_State) Descriptor() protoreflect.EnumDescriptor
- func (x TaskInfo_State) Enum() *TaskInfo_State
- func (TaskInfo_State) EnumDescriptor() ([]byte, []int)deprecated
- func (i TaskInfo_State) IsFinal() bool
- func (x TaskInfo_State) Number() protoreflect.EnumNumber
- func (x TaskInfo_State) String() string
- func (TaskInfo_State) Type() protoreflect.EnumType
- type TaskSpec
- func (*TaskSpec) Descriptor() ([]byte, []int)deprecated
- func (x *TaskSpec) GetArgs() []*ArgumentSpec
- func (x *TaskSpec) GetDeadline() *timestamp.Timestamp
- func (x *TaskSpec) GetDownstreamTaskId() *ShardedID
- func (x *TaskSpec) GetMethod() string
- func (x *TaskSpec) GetNotBefore() *timestamp.Timestamp
- func (s *TaskSpec) GetTaskArgIDs() []*ShardedID
- func (s *TaskSpec) GetTaskArgs() []*ArgumentSpec
- func (x *TaskSpec) GetTaskId() *ShardedID
- func (*TaskSpec) ProtoMessage()
- func (x *TaskSpec) ProtoReflect() protoreflect.Message
- func (x *TaskSpec) Reset()
- func (s *TaskSpec) SetDefaults()
- func (x *TaskSpec) String() string
- func (s *TaskSpec) Valid() error
- type TaskStateTransition
- func (*TaskStateTransition) Descriptor() ([]byte, []int)deprecated
- func (x *TaskStateTransition) GetResultData() []byte
- func (x *TaskStateTransition) GetResultStatus() TaskStateTransition_ResultStatus
- func (x *TaskStateTransition) GetTaskId() *ShardedID
- func (*TaskStateTransition) ProtoMessage()
- func (x *TaskStateTransition) ProtoReflect() protoreflect.Message
- func (x *TaskStateTransition) Reset()
- func (x *TaskStateTransition) String() string
- type TaskStateTransition_ResultStatus
- func (TaskStateTransition_ResultStatus) Descriptor() protoreflect.EnumDescriptor
- func (x TaskStateTransition_ResultStatus) Enum() *TaskStateTransition_ResultStatus
- func (TaskStateTransition_ResultStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x TaskStateTransition_ResultStatus) Number() protoreflect.EnumNumber
- func (x TaskStateTransition_ResultStatus) String() string
- func (TaskStateTransition_ResultStatus) Type() protoreflect.EnumType
- type UnimplementedInternalServer
- func (UnimplementedInternalServer) ReportSuccess(context.Context, *ReportSuccessRequest) (*ReportSuccessResponse, error)
- func (UnimplementedInternalServer) SetCancel(context.Context, *SetCancelRequest) (*SetCancelResponse, error)
- func (UnimplementedInternalServer) SetFailed(context.Context, *SetFailedRequest) (*empty.Empty, error)
- func (UnimplementedInternalServer) SubmitTask(context.Context, *TaskSpec) (*empty.Empty, error)
- type UnimplementedQueueServer
- type UnimplementedWorkerServer
- func (UnimplementedWorkerServer) Done(context.Context, *TaskStateTransition) (*empty.Empty, error)
- func (UnimplementedWorkerServer) Keepalive(context.Context, *KeepaliveRequest) (*empty.Empty, error)
- func (UnimplementedWorkerServer) Log(context.Context, *LogRequest) (*empty.Empty, error)
- func (UnimplementedWorkerServer) Poll(context.Context, *PollRequest) (*Task, error)
- type UnsafeInternalServer
- type UnsafeQueueServer
- type UnsafeWorkerServer
- type WorkerClient
- type WorkerServer
Constants ¶
This section is empty.
Variables ¶
var ( ArgumentSpec_Type_name = map[int32]string{ 0: "VALUE", 1: "TASKREF", } ArgumentSpec_Type_value = map[string]int32{ "VALUE": 0, "TASKREF": 1, } )
Enum value maps for ArgumentSpec_Type.
var ( TaskInfo_State_name = map[int32]string{ 0: "PENDING", 1: "SCHEDULABLE", 2: "RUNNING", 3: "CANCELED", 4: "FAILED", 5: "SUCCESS", } TaskInfo_State_value = map[string]int32{ "PENDING": 0, "SCHEDULABLE": 1, "RUNNING": 2, "CANCELED": 3, "FAILED": 4, "SUCCESS": 5, } )
Enum value maps for TaskInfo_State.
var ( TaskStateTransition_ResultStatus_name = map[int32]string{ 0: "SUCCESS", 1: "TEMPORARY_FAILURE", 2: "FAILURE", } TaskStateTransition_ResultStatus_value = map[string]int32{ "SUCCESS": 0, "TEMPORARY_FAILURE": 1, "FAILURE": 2, } )
Enum value maps for TaskStateTransition_ResultStatus.
var File_proto_enq_proto protoreflect.FileDescriptor
var Internal_ServiceDesc = grpc.ServiceDesc{ ServiceName: "enq.Internal", HandlerType: (*InternalServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SetFailed", Handler: _Internal_SetFailed_Handler, }, { MethodName: "SetCancel", Handler: _Internal_SetCancel_Handler, }, { MethodName: "ReportSuccess", Handler: _Internal_ReportSuccess_Handler, }, { MethodName: "SubmitTask", Handler: _Internal_SubmitTask_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/enq.proto", }
Internal_ServiceDesc is the grpc.ServiceDesc for Internal service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Queue_ServiceDesc = grpc.ServiceDesc{ ServiceName: "enq.Queue", HandlerType: (*QueueServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Submit", Handler: _Queue_Submit_Handler, }, { MethodName: "Query", Handler: _Queue_Query_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetLogs", Handler: _Queue_GetLogs_Handler, ServerStreams: true, }, }, Metadata: "proto/enq.proto", }
Queue_ServiceDesc is the grpc.ServiceDesc for Queue service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Worker_ServiceDesc = grpc.ServiceDesc{ ServiceName: "enq.Worker", HandlerType: (*WorkerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Poll", Handler: _Worker_Poll_Handler, }, { MethodName: "Keepalive", Handler: _Worker_Keepalive_Handler, }, { MethodName: "Done", Handler: _Worker_Done_Handler, }, { MethodName: "Log", Handler: _Worker_Log_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/enq.proto", }
Worker_ServiceDesc is the grpc.ServiceDesc for Worker service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterInternalServer ¶
func RegisterInternalServer(s grpc.ServiceRegistrar, srv InternalServer)
func RegisterQueueServer ¶
func RegisterQueueServer(s grpc.ServiceRegistrar, srv QueueServer)
func RegisterWorkerServer ¶
func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)
Types ¶
type ArgumentSpec ¶
type ArgumentSpec struct { Type ArgumentSpec_Type `protobuf:"varint,1,opt,name=type,proto3,enum=enq.ArgumentSpec_Type" json:"type,omitempty"` ValueJson []byte `protobuf:"bytes,2,opt,name=value_json,json=valueJson,proto3" json:"value_json,omitempty"` TaskId *ShardedID `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
func (*ArgumentSpec) Descriptor
deprecated
func (*ArgumentSpec) Descriptor() ([]byte, []int)
Deprecated: Use ArgumentSpec.ProtoReflect.Descriptor instead.
func (*ArgumentSpec) GetTaskId ¶
func (x *ArgumentSpec) GetTaskId() *ShardedID
func (*ArgumentSpec) GetType ¶
func (x *ArgumentSpec) GetType() ArgumentSpec_Type
func (*ArgumentSpec) GetValueJson ¶
func (x *ArgumentSpec) GetValueJson() []byte
func (*ArgumentSpec) ProtoMessage ¶
func (*ArgumentSpec) ProtoMessage()
func (*ArgumentSpec) ProtoReflect ¶
func (x *ArgumentSpec) ProtoReflect() protoreflect.Message
func (*ArgumentSpec) Reset ¶
func (x *ArgumentSpec) Reset()
func (*ArgumentSpec) String ¶
func (x *ArgumentSpec) String() string
func (*ArgumentSpec) Valid ¶
func (a *ArgumentSpec) Valid() error
Valid performs sanity checks on ArgumentSpec.
type ArgumentSpec_Type ¶
type ArgumentSpec_Type int32
const ( ArgumentSpec_VALUE ArgumentSpec_Type = 0 ArgumentSpec_TASKREF ArgumentSpec_Type = 1 )
func (ArgumentSpec_Type) Descriptor ¶
func (ArgumentSpec_Type) Descriptor() protoreflect.EnumDescriptor
func (ArgumentSpec_Type) Enum ¶
func (x ArgumentSpec_Type) Enum() *ArgumentSpec_Type
func (ArgumentSpec_Type) EnumDescriptor
deprecated
func (ArgumentSpec_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use ArgumentSpec_Type.Descriptor instead.
func (ArgumentSpec_Type) Number ¶
func (x ArgumentSpec_Type) Number() protoreflect.EnumNumber
func (ArgumentSpec_Type) String ¶
func (x ArgumentSpec_Type) String() string
func (ArgumentSpec_Type) Type ¶
func (ArgumentSpec_Type) Type() protoreflect.EnumType
type GetLogsRequest ¶
type GetLogsRequest struct { TaskId *ShardedID `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
func (*GetLogsRequest) Descriptor
deprecated
func (*GetLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.
func (*GetLogsRequest) GetTaskId ¶
func (x *GetLogsRequest) GetTaskId() *ShardedID
func (*GetLogsRequest) ProtoMessage ¶
func (*GetLogsRequest) ProtoMessage()
func (*GetLogsRequest) ProtoReflect ¶
func (x *GetLogsRequest) ProtoReflect() protoreflect.Message
func (*GetLogsRequest) Reset ¶
func (x *GetLogsRequest) Reset()
func (*GetLogsRequest) String ¶
func (x *GetLogsRequest) String() string
type InternalClient ¶
type InternalClient interface { SetFailed(ctx context.Context, in *SetFailedRequest, opts ...grpc.CallOption) (*empty.Empty, error) SetCancel(ctx context.Context, in *SetCancelRequest, opts ...grpc.CallOption) (*SetCancelResponse, error) ReportSuccess(ctx context.Context, in *ReportSuccessRequest, opts ...grpc.CallOption) (*ReportSuccessResponse, error) SubmitTask(ctx context.Context, in *TaskSpec, opts ...grpc.CallOption) (*empty.Empty, error) }
InternalClient is the client API for Internal 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 NewInternalClient ¶
func NewInternalClient(cc grpc.ClientConnInterface) InternalClient
type InternalServer ¶
type InternalServer interface { SetFailed(context.Context, *SetFailedRequest) (*empty.Empty, error) SetCancel(context.Context, *SetCancelRequest) (*SetCancelResponse, error) ReportSuccess(context.Context, *ReportSuccessRequest) (*ReportSuccessResponse, error) SubmitTask(context.Context, *TaskSpec) (*empty.Empty, error) // contains filtered or unexported methods }
InternalServer is the server API for Internal service. All implementations must embed UnimplementedInternalServer for forward compatibility
type KeepaliveRequest ¶
type KeepaliveRequest struct { TaskId *ShardedID `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
func (*KeepaliveRequest) Descriptor
deprecated
func (*KeepaliveRequest) Descriptor() ([]byte, []int)
Deprecated: Use KeepaliveRequest.ProtoReflect.Descriptor instead.
func (*KeepaliveRequest) GetTaskId ¶
func (x *KeepaliveRequest) GetTaskId() *ShardedID
func (*KeepaliveRequest) ProtoMessage ¶
func (*KeepaliveRequest) ProtoMessage()
func (*KeepaliveRequest) ProtoReflect ¶
func (x *KeepaliveRequest) ProtoReflect() protoreflect.Message
func (*KeepaliveRequest) Reset ¶
func (x *KeepaliveRequest) Reset()
func (*KeepaliveRequest) String ¶
func (x *KeepaliveRequest) String() string
type LogChunk ¶
type LogChunk struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*LogChunk) Descriptor
deprecated
func (*LogChunk) ProtoMessage ¶
func (*LogChunk) ProtoMessage()
func (*LogChunk) ProtoReflect ¶
func (x *LogChunk) ProtoReflect() protoreflect.Message
type LogRequest ¶
type LogRequest struct { TaskId *ShardedID `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*LogRequest) Descriptor
deprecated
func (*LogRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.
func (*LogRequest) GetData ¶
func (x *LogRequest) GetData() []byte
func (*LogRequest) GetTaskId ¶
func (x *LogRequest) GetTaskId() *ShardedID
func (*LogRequest) ProtoMessage ¶
func (*LogRequest) ProtoMessage()
func (*LogRequest) ProtoReflect ¶
func (x *LogRequest) ProtoReflect() protoreflect.Message
func (*LogRequest) Reset ¶
func (x *LogRequest) Reset()
func (*LogRequest) String ¶
func (x *LogRequest) String() string
type PollRequest ¶
type PollRequest struct { WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` WorkerBaseUrl string `protobuf:"bytes,2,opt,name=worker_base_url,json=workerBaseUrl,proto3" json:"worker_base_url,omitempty"` // contains filtered or unexported fields }
func (*PollRequest) Descriptor
deprecated
func (*PollRequest) Descriptor() ([]byte, []int)
Deprecated: Use PollRequest.ProtoReflect.Descriptor instead.
func (*PollRequest) GetWorkerBaseUrl ¶
func (x *PollRequest) GetWorkerBaseUrl() string
func (*PollRequest) GetWorkerId ¶
func (x *PollRequest) GetWorkerId() string
func (*PollRequest) ProtoMessage ¶
func (*PollRequest) ProtoMessage()
func (*PollRequest) ProtoReflect ¶
func (x *PollRequest) ProtoReflect() protoreflect.Message
func (*PollRequest) Reset ¶
func (x *PollRequest) Reset()
func (*PollRequest) String ¶
func (x *PollRequest) String() string
type QueryRequest ¶
type QueryRequest struct { TaskId *ShardedID `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
func (*QueryRequest) Descriptor
deprecated
func (*QueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
func (*QueryRequest) GetTaskId ¶
func (x *QueryRequest) GetTaskId() *ShardedID
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) ProtoReflect ¶
func (x *QueryRequest) ProtoReflect() protoreflect.Message
func (*QueryRequest) Reset ¶
func (x *QueryRequest) Reset()
func (*QueryRequest) String ¶
func (x *QueryRequest) String() string
type QueueClient ¶
type QueueClient interface { // For clients. Submit(ctx context.Context, in *SubmitRequest, opts ...grpc.CallOption) (*SubmitResponse, error) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*TaskInfo, error) GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (Queue_GetLogsClient, error) }
QueueClient is the client API for Queue 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 NewQueueClient ¶
func NewQueueClient(cc grpc.ClientConnInterface) QueueClient
type QueueServer ¶
type QueueServer interface { // For clients. Submit(context.Context, *SubmitRequest) (*SubmitResponse, error) Query(context.Context, *QueryRequest) (*TaskInfo, error) GetLogs(*GetLogsRequest, Queue_GetLogsServer) error // contains filtered or unexported methods }
QueueServer is the server API for Queue service. All implementations must embed UnimplementedQueueServer for forward compatibility
type Queue_GetLogsClient ¶
type Queue_GetLogsClient interface { Recv() (*LogChunk, error) grpc.ClientStream }
type Queue_GetLogsServer ¶
type Queue_GetLogsServer interface { Send(*LogChunk) error grpc.ServerStream }
type ReportSuccessRequest ¶
type ReportSuccessRequest struct { TaskId *ShardedID `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` DownstreamTaskId *ShardedID `protobuf:"bytes,2,opt,name=downstream_task_id,json=downstreamTaskId,proto3" json:"downstream_task_id,omitempty"` ResultData []byte `protobuf:"bytes,3,opt,name=result_data,json=resultData,proto3" json:"result_data,omitempty"` // contains filtered or unexported fields }
func (*ReportSuccessRequest) Descriptor
deprecated
func (*ReportSuccessRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReportSuccessRequest.ProtoReflect.Descriptor instead.
func (*ReportSuccessRequest) GetDownstreamTaskId ¶
func (x *ReportSuccessRequest) GetDownstreamTaskId() *ShardedID
func (*ReportSuccessRequest) GetResultData ¶
func (x *ReportSuccessRequest) GetResultData() []byte
func (*ReportSuccessRequest) GetTaskId ¶
func (x *ReportSuccessRequest) GetTaskId() *ShardedID
func (*ReportSuccessRequest) ProtoMessage ¶
func (*ReportSuccessRequest) ProtoMessage()
func (*ReportSuccessRequest) ProtoReflect ¶
func (x *ReportSuccessRequest) ProtoReflect() protoreflect.Message
func (*ReportSuccessRequest) Reset ¶
func (x *ReportSuccessRequest) Reset()
func (*ReportSuccessRequest) String ¶
func (x *ReportSuccessRequest) String() string
type ReportSuccessResponse ¶
type ReportSuccessResponse struct { ResultId *ShardedID `protobuf:"bytes,1,opt,name=result_id,json=resultId,proto3" json:"result_id,omitempty"` // contains filtered or unexported fields }
func (*ReportSuccessResponse) Descriptor
deprecated
func (*ReportSuccessResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReportSuccessResponse.ProtoReflect.Descriptor instead.
func (*ReportSuccessResponse) GetResultId ¶
func (x *ReportSuccessResponse) GetResultId() *ShardedID
func (*ReportSuccessResponse) ProtoMessage ¶
func (*ReportSuccessResponse) ProtoMessage()
func (*ReportSuccessResponse) ProtoReflect ¶
func (x *ReportSuccessResponse) ProtoReflect() protoreflect.Message
func (*ReportSuccessResponse) Reset ¶
func (x *ReportSuccessResponse) Reset()
func (*ReportSuccessResponse) String ¶
func (x *ReportSuccessResponse) String() string
type SetCancelRequest ¶
type SetCancelRequest struct { TaskId *ShardedID `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
func (*SetCancelRequest) Descriptor
deprecated
func (*SetCancelRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetCancelRequest.ProtoReflect.Descriptor instead.
func (*SetCancelRequest) GetTaskId ¶
func (x *SetCancelRequest) GetTaskId() *ShardedID
func (*SetCancelRequest) ProtoMessage ¶
func (*SetCancelRequest) ProtoMessage()
func (*SetCancelRequest) ProtoReflect ¶
func (x *SetCancelRequest) ProtoReflect() protoreflect.Message
func (*SetCancelRequest) Reset ¶
func (x *SetCancelRequest) Reset()
func (*SetCancelRequest) String ¶
func (x *SetCancelRequest) String() string
type SetCancelResponse ¶
type SetCancelResponse struct { UpstreamTaskIds []*ShardedID `protobuf:"bytes,1,rep,name=upstream_task_ids,json=upstreamTaskIds,proto3" json:"upstream_task_ids,omitempty"` // contains filtered or unexported fields }
func (*SetCancelResponse) Descriptor
deprecated
func (*SetCancelResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetCancelResponse.ProtoReflect.Descriptor instead.
func (*SetCancelResponse) GetUpstreamTaskIds ¶
func (x *SetCancelResponse) GetUpstreamTaskIds() []*ShardedID
func (*SetCancelResponse) ProtoMessage ¶
func (*SetCancelResponse) ProtoMessage()
func (*SetCancelResponse) ProtoReflect ¶
func (x *SetCancelResponse) ProtoReflect() protoreflect.Message
func (*SetCancelResponse) Reset ¶
func (x *SetCancelResponse) Reset()
func (*SetCancelResponse) String ¶
func (x *SetCancelResponse) String() string
type SetFailedRequest ¶
type SetFailedRequest struct { TaskId *ShardedID `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` ParentId *ShardedID `protobuf:"bytes,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` // contains filtered or unexported fields }
func (*SetFailedRequest) Descriptor
deprecated
func (*SetFailedRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetFailedRequest.ProtoReflect.Descriptor instead.
func (*SetFailedRequest) GetParentId ¶
func (x *SetFailedRequest) GetParentId() *ShardedID
func (*SetFailedRequest) GetTaskId ¶
func (x *SetFailedRequest) GetTaskId() *ShardedID
func (*SetFailedRequest) ProtoMessage ¶
func (*SetFailedRequest) ProtoMessage()
func (*SetFailedRequest) ProtoReflect ¶
func (x *SetFailedRequest) ProtoReflect() protoreflect.Message
func (*SetFailedRequest) Reset ¶
func (x *SetFailedRequest) Reset()
func (*SetFailedRequest) String ¶
func (x *SetFailedRequest) String() string
type ShardedID ¶
type ShardedID struct { Shard string `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func ParseShardedID ¶
func (*ShardedID) Descriptor
deprecated
func (*ShardedID) ProtoMessage ¶
func (*ShardedID) ProtoMessage()
func (*ShardedID) ProtoReflect ¶
func (x *ShardedID) ProtoReflect() protoreflect.Message
type SubmitRequest ¶
type SubmitRequest struct { Tasks []*TaskSpec `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"` // contains filtered or unexported fields }
func (*SubmitRequest) Descriptor
deprecated
func (*SubmitRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubmitRequest.ProtoReflect.Descriptor instead.
func (*SubmitRequest) GetTasks ¶
func (x *SubmitRequest) GetTasks() []*TaskSpec
func (*SubmitRequest) ProtoMessage ¶
func (*SubmitRequest) ProtoMessage()
func (*SubmitRequest) ProtoReflect ¶
func (x *SubmitRequest) ProtoReflect() protoreflect.Message
func (*SubmitRequest) Reset ¶
func (x *SubmitRequest) Reset()
func (*SubmitRequest) String ¶
func (x *SubmitRequest) String() string
type SubmitResponse ¶
type SubmitResponse struct { RootTaskId *ShardedID `protobuf:"bytes,1,opt,name=root_task_id,json=rootTaskId,proto3" json:"root_task_id,omitempty"` // contains filtered or unexported fields }
func (*SubmitResponse) Descriptor
deprecated
func (*SubmitResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubmitResponse.ProtoReflect.Descriptor instead.
func (*SubmitResponse) GetRootTaskId ¶
func (x *SubmitResponse) GetRootTaskId() *ShardedID
func (*SubmitResponse) ProtoMessage ¶
func (*SubmitResponse) ProtoMessage()
func (*SubmitResponse) ProtoReflect ¶
func (x *SubmitResponse) ProtoReflect() protoreflect.Message
func (*SubmitResponse) Reset ¶
func (x *SubmitResponse) Reset()
func (*SubmitResponse) String ¶
func (x *SubmitResponse) String() string
type Task ¶
type Task struct { Spec *TaskSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` Args [][]byte `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"` // contains filtered or unexported fields }
func (*Task) Descriptor
deprecated
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶
func (x *Task) ProtoReflect() protoreflect.Message
type TaskInfo ¶
type TaskInfo struct { Spec *TaskSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` State TaskInfo_State `protobuf:"varint,2,opt,name=state,proto3,enum=enq.TaskInfo_State" json:"state,omitempty"` CreatedAt *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` StartedAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` TerminatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=terminated_at,json=terminatedAt,proto3" json:"terminated_at,omitempty"` Attempts int32 `protobuf:"varint,6,opt,name=attempts,proto3" json:"attempts,omitempty"` // contains filtered or unexported fields }
func (*TaskInfo) Descriptor
deprecated
func (*TaskInfo) GetAttempts ¶
func (*TaskInfo) GetCreatedAt ¶
func (*TaskInfo) GetStartedAt ¶
func (*TaskInfo) GetState ¶
func (x *TaskInfo) GetState() TaskInfo_State
func (*TaskInfo) GetTerminatedAt ¶
func (*TaskInfo) ProtoMessage ¶
func (*TaskInfo) ProtoMessage()
func (*TaskInfo) ProtoReflect ¶
func (x *TaskInfo) ProtoReflect() protoreflect.Message
type TaskInfo_State ¶
type TaskInfo_State int32
const ( TaskInfo_PENDING TaskInfo_State = 0 TaskInfo_SCHEDULABLE TaskInfo_State = 1 TaskInfo_RUNNING TaskInfo_State = 2 TaskInfo_CANCELED TaskInfo_State = 3 TaskInfo_FAILED TaskInfo_State = 4 TaskInfo_SUCCESS TaskInfo_State = 5 )
func (TaskInfo_State) Descriptor ¶
func (TaskInfo_State) Descriptor() protoreflect.EnumDescriptor
func (TaskInfo_State) Enum ¶
func (x TaskInfo_State) Enum() *TaskInfo_State
func (TaskInfo_State) EnumDescriptor
deprecated
func (TaskInfo_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use TaskInfo_State.Descriptor instead.
func (TaskInfo_State) IsFinal ¶
func (i TaskInfo_State) IsFinal() bool
func (TaskInfo_State) Number ¶
func (x TaskInfo_State) Number() protoreflect.EnumNumber
func (TaskInfo_State) String ¶
func (x TaskInfo_State) String() string
func (TaskInfo_State) Type ¶
func (TaskInfo_State) Type() protoreflect.EnumType
type TaskSpec ¶
type TaskSpec struct { TaskId *ShardedID `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` Method string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"` Args []*ArgumentSpec `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"` NotBefore *timestamp.Timestamp `protobuf:"bytes,5,opt,name=not_before,json=notBefore,proto3" json:"not_before,omitempty"` Deadline *timestamp.Timestamp `protobuf:"bytes,6,opt,name=deadline,proto3" json:"deadline,omitempty"` DownstreamTaskId *ShardedID `protobuf:"bytes,7,opt,name=downstream_task_id,json=downstreamTaskId,proto3" json:"downstream_task_id,omitempty"` // contains filtered or unexported fields }
func (*TaskSpec) Descriptor
deprecated
func (*TaskSpec) GetArgs ¶
func (x *TaskSpec) GetArgs() []*ArgumentSpec
func (*TaskSpec) GetDeadline ¶
func (*TaskSpec) GetDownstreamTaskId ¶
func (*TaskSpec) GetNotBefore ¶
func (*TaskSpec) GetTaskArgIDs ¶
func (*TaskSpec) GetTaskArgs ¶
func (s *TaskSpec) GetTaskArgs() []*ArgumentSpec
func (*TaskSpec) ProtoMessage ¶
func (*TaskSpec) ProtoMessage()
func (*TaskSpec) ProtoReflect ¶
func (x *TaskSpec) ProtoReflect() protoreflect.Message
func (*TaskSpec) SetDefaults ¶
func (s *TaskSpec) SetDefaults()
SetDefaults sets defaults for unspcified fields.
type TaskStateTransition ¶
type TaskStateTransition struct { TaskId *ShardedID `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` ResultStatus TaskStateTransition_ResultStatus `` /* 140-byte string literal not displayed */ ResultData []byte `protobuf:"bytes,3,opt,name=result_data,json=resultData,proto3" json:"result_data,omitempty"` // contains filtered or unexported fields }
func (*TaskStateTransition) Descriptor
deprecated
func (*TaskStateTransition) Descriptor() ([]byte, []int)
Deprecated: Use TaskStateTransition.ProtoReflect.Descriptor instead.
func (*TaskStateTransition) GetResultData ¶
func (x *TaskStateTransition) GetResultData() []byte
func (*TaskStateTransition) GetResultStatus ¶
func (x *TaskStateTransition) GetResultStatus() TaskStateTransition_ResultStatus
func (*TaskStateTransition) GetTaskId ¶
func (x *TaskStateTransition) GetTaskId() *ShardedID
func (*TaskStateTransition) ProtoMessage ¶
func (*TaskStateTransition) ProtoMessage()
func (*TaskStateTransition) ProtoReflect ¶
func (x *TaskStateTransition) ProtoReflect() protoreflect.Message
func (*TaskStateTransition) Reset ¶
func (x *TaskStateTransition) Reset()
func (*TaskStateTransition) String ¶
func (x *TaskStateTransition) String() string
type TaskStateTransition_ResultStatus ¶
type TaskStateTransition_ResultStatus int32
const ( TaskStateTransition_SUCCESS TaskStateTransition_ResultStatus = 0 TaskStateTransition_TEMPORARY_FAILURE TaskStateTransition_ResultStatus = 1 TaskStateTransition_FAILURE TaskStateTransition_ResultStatus = 2 )
func (TaskStateTransition_ResultStatus) Descriptor ¶
func (TaskStateTransition_ResultStatus) Descriptor() protoreflect.EnumDescriptor
func (TaskStateTransition_ResultStatus) Enum ¶
func (x TaskStateTransition_ResultStatus) Enum() *TaskStateTransition_ResultStatus
func (TaskStateTransition_ResultStatus) EnumDescriptor
deprecated
func (TaskStateTransition_ResultStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use TaskStateTransition_ResultStatus.Descriptor instead.
func (TaskStateTransition_ResultStatus) Number ¶
func (x TaskStateTransition_ResultStatus) Number() protoreflect.EnumNumber
func (TaskStateTransition_ResultStatus) String ¶
func (x TaskStateTransition_ResultStatus) String() string
func (TaskStateTransition_ResultStatus) Type ¶
func (TaskStateTransition_ResultStatus) Type() protoreflect.EnumType
type UnimplementedInternalServer ¶
type UnimplementedInternalServer struct { }
UnimplementedInternalServer must be embedded to have forward compatible implementations.
func (UnimplementedInternalServer) ReportSuccess ¶
func (UnimplementedInternalServer) ReportSuccess(context.Context, *ReportSuccessRequest) (*ReportSuccessResponse, error)
func (UnimplementedInternalServer) SetCancel ¶
func (UnimplementedInternalServer) SetCancel(context.Context, *SetCancelRequest) (*SetCancelResponse, error)
func (UnimplementedInternalServer) SetFailed ¶
func (UnimplementedInternalServer) SetFailed(context.Context, *SetFailedRequest) (*empty.Empty, error)
func (UnimplementedInternalServer) SubmitTask ¶
type UnimplementedQueueServer ¶
type UnimplementedQueueServer struct { }
UnimplementedQueueServer must be embedded to have forward compatible implementations.
func (UnimplementedQueueServer) GetLogs ¶
func (UnimplementedQueueServer) GetLogs(*GetLogsRequest, Queue_GetLogsServer) error
func (UnimplementedQueueServer) Query ¶
func (UnimplementedQueueServer) Query(context.Context, *QueryRequest) (*TaskInfo, error)
func (UnimplementedQueueServer) Submit ¶
func (UnimplementedQueueServer) Submit(context.Context, *SubmitRequest) (*SubmitResponse, error)
type UnimplementedWorkerServer ¶
type UnimplementedWorkerServer struct { }
UnimplementedWorkerServer must be embedded to have forward compatible implementations.
func (UnimplementedWorkerServer) Done ¶
func (UnimplementedWorkerServer) Done(context.Context, *TaskStateTransition) (*empty.Empty, error)
func (UnimplementedWorkerServer) Keepalive ¶
func (UnimplementedWorkerServer) Keepalive(context.Context, *KeepaliveRequest) (*empty.Empty, error)
func (UnimplementedWorkerServer) Log ¶
func (UnimplementedWorkerServer) Log(context.Context, *LogRequest) (*empty.Empty, error)
func (UnimplementedWorkerServer) Poll ¶
func (UnimplementedWorkerServer) Poll(context.Context, *PollRequest) (*Task, error)
type UnsafeInternalServer ¶
type UnsafeInternalServer interface {
// contains filtered or unexported methods
}
UnsafeInternalServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InternalServer will result in compilation errors.
type UnsafeQueueServer ¶
type UnsafeQueueServer interface {
// contains filtered or unexported methods
}
UnsafeQueueServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueueServer will result in compilation errors.
type UnsafeWorkerServer ¶
type UnsafeWorkerServer interface {
// contains filtered or unexported methods
}
UnsafeWorkerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServer will result in compilation errors.
type WorkerClient ¶
type WorkerClient interface { // For workers. Poll(ctx context.Context, in *PollRequest, opts ...grpc.CallOption) (*Task, error) Keepalive(ctx context.Context, in *KeepaliveRequest, opts ...grpc.CallOption) (*empty.Empty, error) Done(ctx context.Context, in *TaskStateTransition, opts ...grpc.CallOption) (*empty.Empty, error) Log(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*empty.Empty, error) }
WorkerClient is the client API for Worker 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 NewWorkerClient ¶
func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient
type WorkerServer ¶
type WorkerServer interface { // For workers. Poll(context.Context, *PollRequest) (*Task, error) Keepalive(context.Context, *KeepaliveRequest) (*empty.Empty, error) Done(context.Context, *TaskStateTransition) (*empty.Empty, error) Log(context.Context, *LogRequest) (*empty.Empty, error) // contains filtered or unexported methods }
WorkerServer is the server API for Worker service. All implementations must embed UnimplementedWorkerServer for forward compatibility