Documentation ¶
Index ¶
- Variables
- type JobBoard
- type JobWorker
- type JobWorkerOpts
- type STAGE
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetArgv() []byte
- func (x *Task) GetId() string
- func (x *Task) GetStage() STAGE
- func (x *Task) GetSubject() string
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- type TaskMgr
Constants ¶
This section is empty.
Variables ¶
View Source
var ( STAGE_name = map[int32]string{ 0: "PENDING", 1: "SUCCESS", 2: "FAILED", } STAGE_value = map[string]int32{ "PENDING": 0, "SUCCESS": 1, "FAILED": 2, } )
Enum value maps for STAGE.
View Source
var File_task_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type JobBoard ¶
type JobBoard struct {
// contains filtered or unexported fields
}
func NewJobBoard ¶
type JobWorker ¶
type JobWorker struct { JobWorkerOpts // contains filtered or unexported fields }
func NewJobWorker ¶
func NewJobWorker(taskMgr TaskMgr, opts JobWorkerOpts) *JobWorker
type JobWorkerOpts ¶
type STAGE ¶
type STAGE int32
func (STAGE) Descriptor ¶ added in v1.3.1
func (STAGE) Descriptor() protoreflect.EnumDescriptor
func (STAGE) EnumDescriptor
deprecated
func (STAGE) Number ¶ added in v1.3.1
func (x STAGE) Number() protoreflect.EnumNumber
func (STAGE) Type ¶ added in v1.3.1
func (STAGE) Type() protoreflect.EnumType
type Task ¶
type Task struct { Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Argv []byte `protobuf:"bytes,3,opt,name=argv,proto3" json:"argv,omitempty"` Stage STAGE `protobuf:"varint,4,opt,name=stage,proto3,enum=proto.STAGE" json:"stage,omitempty"` // contains filtered or unexported fields }
func (*Task) Descriptor
deprecated
func (*Task) GetSubject ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶ added in v1.3.1
func (x *Task) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.