gocelery

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

type Job struct {
	ID         JobID                  `json:"JobID" swaggertype:"primitive,string"` // Job Identifier
	Desc       string                 `json:"desc"`                                 // description of the Job
	Runner     string                 `json:"runner"`                               // name of the Runner
	Overrides  map[string]interface{} `json:"overrides"`                            // overrides for the Job
	Tasks      []*Task                `json:"tasks"`                                // list of tasks ran under this Job
	ValidUntil time.Time              `json:"valid_until"`                          // validity of the job
	FinishedAt time.Time              `json:"finished_at"`                          // Job finished at. If empty, job is not complete yet
	Finished   bool                   `json:"finished"`                             // job status
}

type JobID []byte

type Queue interface {
	Start(ctx context.Context)
	EnqueueNow(id []byte) error
	EnqueueAfter(id []byte, t time.Time) error
	Dequeue() ([]byte, error)
	Finished(id []byte)
	Len() int
}

type Result struct {
	JobID      JobID
	Dispatcher *Dispatcher
}

type Runner interface {
	New() Runner
	RunnerFunc(task string) RunnerFunc
	Next(task string) (next string, ok bool) // next task after the task
}

type RunnerFunc func(args []interface{}, overrides map[string]interface{}) (result interface{}, err error)

type Storage interface {
	Get(key []byte) ([]byte, error)
	Set(key, value []byte) error
	Delete(key []byte) error
	Iterate(prefix []byte, f func(key, value []byte))
}

type Task struct {
	RunnerFunc string        `json:"runnerFuncs"` // name of the runnerFuncs
	Args       []interface{} `json:"args"`        // arguments passed to this task
	Result     interface{}   `json:"result"`      // result after the task run
	Error      string        `json:"error"`       // error after task run
	Tries      uint          `json:"tries"`       // number of times task was run.
	Delay      time.Time     `json:"delay"`       // delay until ready to be run
}