Versions in this module Expand all Collapse all v0 v0.1.2 Dec 22, 2020 Changes in this version + type AuditMessage struct + Message string + Time time.Time type Job + AuditLog []*AuditMessage + Label string v0.1.1 Dec 21, 2020 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 + PollRate time.Duration + func Init(filepath string) (*Queue, error) + func (q *Queue) CleanOldJobs() 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) + 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