processors

Documentation

Index

• type Job
  • func (j *Job) Enqueue(job *types.Job) error
  • func (j *Job) Start() error

Types

type Job

type Job struct {
	DB                    *db.DB
	WorkerNum, MaxRetries int
}

Job is a processor responsible for enqueuing, running, and completing jobs

func (*Job) Enqueue

func (j *Job) Enqueue(job *types.Job) error

Enqueue adds a job to the pool

func (*Job) Start

func (j *Job) Start() error

Start adds a job to the pool