Versions in this module Expand all Collapse all v0 v0.1.0 Nov 8, 2021 Changes in this version + const JobDone + const JobFailed + const JobInProcess + const JobPending + const JobReAttempt + func DefaultJobNameGenerator(job worker.Job) string + func NewBoltDB(bo *Options) *boltDB + type BoltWorker struct + BusyWorkerSleepTime time.Duration + Concurrency int + DB *boltDB + DBSyncInterval time.Duration + IdleSleepTime time.Duration + Logger Logger + RetryAttempts int + func NewBoltWorker(opts Options) *BoltWorker + func NewBoltWorkerWithContext(ctx context.Context, opts Options) *BoltWorker + func (bw *BoltWorker) LoadPendingJobs() + func (bw *BoltWorker) Perform(job worker.Job) error + func (bw *BoltWorker) PerformAt(job worker.Job, t time.Time) error + func (bw *BoltWorker) PerformIn(job worker.Job, d time.Duration) error + func (bw *BoltWorker) Register(name string, h worker.Handler) error + func (bw *BoltWorker) SpawnWorkers() + func (bw *BoltWorker) Start(ctx context.Context) error + func (bw *BoltWorker) Stop() error + func (bw *BoltWorker) SyncWithDB() error + type JobNameGenerator func(worker.Job) string + type Logger interface + Debug func(...interface{}) + Debugf func(string, ...interface{}) + Error func(...interface{}) + Errorf func(string, ...interface{}) + Info func(...interface{}) + Infof func(string, ...interface{}) + type Options struct + BoltOptions bolt.Options + CompletedBucket string + DBSyncInterval string + FailedBucket string + FilePath string + IdleSleepTime string + JobNameHandler JobNameGenerator + Logger Logger + MaxConcurrency int + MaxRetryAttempts int + Name string + PendingBucket string + type RetryJobError struct + RetryIN time.Duration + func NewRetryJobError(msg string) RetryJobError + func (e *RetryJobError) SetRetryTime(t time.Duration) + func (e RetryJobError) Error() string