workqueue

Aug 9, 2022

Changes in this version

type Optioner

+ func WithAutoStart(auto bool) Optioner

type Queue

+ func (q *Queue) Start() bool

+ func (q *Queue) Stop()

Jun 23, 2022

Changes in this version

type Job

+ Handling bool

+ type Optioner func(q *Queue)

+ func WithArchive(archiveFailed bool) Optioner

+ func WithBackoff(backoff Backoff) Optioner

+ func WithBatchSize(size int) Optioner

+ func WithPollRate(rate time.Duration) Optioner

Jan 13, 2022

Changes in this version

type Backoff

+ Expiration time.Duration

+ Limit int

Nov 18, 2021

Changes in this version

type Queue

+ func (q *Queue) PushAfter(name string, obj interface{}, expectDelays ...time.Duration) (uint64, error)

Nov 11, 2021

Changes in this version

type Queue

+ func (q *Queue) Push(name string, obj interface{}, expectAts ...time.Time) (uint64, error)

Nov 11, 2021

Changes in this version

type Backoff

+ func (b *Backoff) GetAttempt() float64

type Job

+ ExpectAt int64

type Queue

+ func InitExtend(filepath string, w Worker, timingSchedule, archiveFailed bool) (*Queue, error)

+ func InitTiming(filepath string, w Worker) (*Queue, error)

Nov 10, 2021

Changes in this version

type Queue

+ func InitWithArchive(filepath string, w Worker, archiveFailed bool) (*Queue, error)

Nov 10, 2021

Changes in this version

+ type Backoff struct

+ Factor float64

+ Jitter bool

+ Max time.Duration

+ Min time.Duration

+ func (b *Backoff) Attempt() float64

+ func (b *Backoff) Copy() *Backoff

+ func (b *Backoff) Duration() time.Duration

+ func (b *Backoff) ForAttempt(attempt float64) time.Duration

+ func (b *Backoff) Reset()

+ type Job struct

+ Data []byte

+ ID uint64

+ Message string

+ Name string

+ RetryCount int

+ Status JobStatus

+ func DecodeJob(b []byte) (*Job, error)

+ func (j *Job) Bytes() []byte

+ func (j Job) String() string

+ type JobStatus int

+ const Ack

+ const Failed

+ const Nack

+ const Uack

+ func (s JobStatus) String() string

+ type Queue struct

+ ID string

+ PollRate time.Duration

+ func Init(filepath string, w Worker, archiveFailed bool) (*Queue, error)

+ func (q *Queue) Backoff(b *Backoff)

+ func (q *Queue) CleanFailedJobs() error

+ func (q *Queue) Close() error

+ func (q *Queue) PushBytes(name string, d []byte) (uint64, error)

+ func (q *Queue) RestoreFailedJobs() error

+ func (q *Queue) Size() (int, int, 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