Versions in this module Expand all Collapse all v0 v0.1.0 Oct 5, 2019 Changes in this version + type Job struct + Data []byte + ID uint64 + Message string + RetryCount int + Status JobStatus + func DecodeJob(b []byte) *Job + func (j *Job) Bytes() []byte + type JobStatus int + const Ack + const Failed + const Nack + const Uack + type Queue struct + ID string + func Init(filepath string) (*Queue, error) + func (q *Queue) Close() error + func (q *Queue) GetJobByID(id uint64) (*Job, error) + func (q *Queue) PushBytes(d []byte) (uint64, error) + func (q *Queue) PushJob(j *Job) (uint64, error) + func (q *Queue) RegisterWorker(w Worker) + func (q *Queue) UpdateJobStatus(id uint64, status JobStatus, message string) error + type RecoverableWorkerError struct + func NewRecoverableWorkerError(message string) RecoverableWorkerError + func (e RecoverableWorkerError) Error() string + type Worker interface + DoWork func(context.Context, *Job) error + ID func() string + type WorkerConfig struct + PollingRate uint8
Go to main page