DecodeJob decodes a gob encoded byte array into a Job struct and returns a pointer to it.

Init creates a connection to the internal database and initializes the Queue typefilepath must be a valid path to a file.

NewRecoverableWorkerError creates a new RecoverableWorkerError.

size should in range [1,1000].

JobStatus types.

JobStatus types.

JobStatus types.

JobStatus types.

Backoff is a time.Duration counter, starting at Min.

Job wraps arbitrary data for processing (需要encode/decode，所以字段都需要大写).

Queue represents a queue.

RecoverableWorkerError defines an error that a worker DoWork funccan return that indicates the message should be retried.

Worker represents a worker for handling Jobs.

JobStatus is a enumerated int representing the processing status of a Job.