proto

package
v0.0.0-...-b69f10d Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2024 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

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

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

View Source 
var File_proto_enq_proto protoreflect.FileDescriptor
View Source 
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)

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

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use LogChunk.ProtoReflect.Descriptor instead.

func (*LogChunk) GetData 

func (x *LogChunk) GetData() []byte

func (*LogChunk) ProtoMessage 

func (*LogChunk) ProtoMessage()

func (*LogChunk) ProtoReflect 

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

func (*LogChunk) Reset 

func (x *LogChunk) Reset()

func (*LogChunk) String 

func (x *LogChunk) String() string

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 ParseShardedID(s string) (*ShardedID, error)

func (*ShardedID) Descriptor deprecated 

func (*ShardedID) Descriptor() ([]byte, []int)

Deprecated: Use ShardedID.ProtoReflect.Descriptor instead.

func (*ShardedID) Equal 

func (s *ShardedID) Equal(other *ShardedID) bool

func (*ShardedID) GetId 

func (x *ShardedID) GetId() string

func (*ShardedID) GetShard 

func (x *ShardedID) GetShard() string

func (*ShardedID) ProtoMessage 

func (*ShardedID) ProtoMessage()

func (*ShardedID) ProtoReflect 

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

func (*ShardedID) Reset 

func (x *ShardedID) Reset()

func (*ShardedID) String 

func (x *ShardedID) String() string

func (*ShardedID) ToString 

func (s *ShardedID) ToString() string

func (*ShardedID) Valid 

func (s *ShardedID) Valid() error

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetArgs 

func (x *Task) GetArgs() [][]byte

func (*Task) GetSpec 

func (x *Task) GetSpec() *TaskSpec

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

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

Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.

func (*TaskInfo) GetAttempts 

func (x *TaskInfo) GetAttempts() int32

func (*TaskInfo) GetCreatedAt 

func (x *TaskInfo) GetCreatedAt() *timestamp.Timestamp

func (*TaskInfo) GetSpec 

func (x *TaskInfo) GetSpec() *TaskSpec

func (*TaskInfo) GetStartedAt 

func (x *TaskInfo) GetStartedAt() *timestamp.Timestamp

func (*TaskInfo) GetState 

func (x *TaskInfo) GetState() TaskInfo_State

func (*TaskInfo) GetTerminatedAt 

func (x *TaskInfo) GetTerminatedAt() *timestamp.Timestamp

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) ProtoReflect 

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

func (*TaskInfo) Reset 

func (x *TaskInfo) Reset()

func (*TaskInfo) String 

func (x *TaskInfo) String() string

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

Deprecated: Use TaskSpec.ProtoReflect.Descriptor instead.

func (*TaskSpec) GetArgs 

func (x *TaskSpec) GetArgs() []*ArgumentSpec

func (*TaskSpec) GetDeadline 

func (x *TaskSpec) GetDeadline() *timestamp.Timestamp

func (*TaskSpec) GetDownstreamTaskId 

func (x *TaskSpec) GetDownstreamTaskId() *ShardedID

func (*TaskSpec) GetMethod 

func (x *TaskSpec) GetMethod() string

func (*TaskSpec) GetNotBefore 

func (x *TaskSpec) GetNotBefore() *timestamp.Timestamp

func (*TaskSpec) GetTaskArgIDs 

func (s *TaskSpec) GetTaskArgIDs() []*ShardedID

func (*TaskSpec) GetTaskArgs 

func (s *TaskSpec) GetTaskArgs() []*ArgumentSpec

func (*TaskSpec) GetTaskId 

func (x *TaskSpec) GetTaskId() *ShardedID

func (*TaskSpec) ProtoMessage 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) ProtoReflect 

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

func (*TaskSpec) Reset 

func (x *TaskSpec) Reset()

func (*TaskSpec) SetDefaults 

func (s *TaskSpec) SetDefaults()

SetDefaults sets defaults for unspcified fields.

func (*TaskSpec) String 

func (x *TaskSpec) String() string

func (*TaskSpec) Valid 

func (s *TaskSpec) Valid() error

Valid performs sanity checks on TaskSpec.

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 

func (UnimplementedInternalServer) SubmitTask(context.Context, *TaskSpec) (*empty.Empty, error)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.