mq

type JobBoard struct {
	// contains filtered or unexported fields
}

type JobWorker struct {
	JobWorkerOpts
	// contains filtered or unexported fields
}

type JobWorkerOpts struct {
	Channel    string
	NumWorkers int
	OnFinish   func(ctx context.Context, task *Task)
}

type STAGE int32

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
}

type TaskMgr interface {
	Push(channel string, task *Task) error
	Shift(channel string) (*Task, error)
	Remove(channel string, id string) error
	Destroy(channel string) error
}