Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

workers

package module

Go to main page

Versions in this module

v1

v1.2.0

Mar 10, 2026

Changes in this version

type BackoffStrategy

+ func DecorrelatedJitterBackoff(capDelay time.Duration) BackoffStrategy

+ func EqualJitterBackoff(capDelay time.Duration) BackoffStrategy

+ func FullJitterBackoff(capDelay time.Duration) BackoffStrategy

+ GetNextDelay func() time.Duration

+ Reset func()

+ SetBaseDelay func(baseDelay time.Duration)

+ type BaseBackoff struct

+ Attempt int

+ BaseDelay time.Duration

+ CapDelay time.Duration

+ PreviousDelay time.Duration

+ func (me *BaseBackoff) Reset()

+ func (me *BaseBackoff) SetBaseDelay(baseDelay time.Duration)

v1.1.0

Feb 28, 2026

v1.0.2

Feb 13, 2026

Changes in this version

+ type BackoffStrategy func(baseDelay time.Duration, attempt int) time.Duration

+ var ConstantBackoff BackoffStrategy = func(baseDelay time.Duration, attempt int) time.Duration { ... }

+ var ExponentialBackoff BackoffStrategy = func(baseDelay time.Duration, attempt int) time.Duration { ... }

+ var LinearBackoff BackoffStrategy = func(baseDelay time.Duration, attempt int) time.Duration { ... }

+ type Schedule struct

+ func DailyAt(hour, minute int) Schedule

+ func EveryNDays(n, hour, minute int) Schedule

+ func WeeklyAt(weekday time.Weekday, hour, minute int) Schedule

+ func (me Schedule) In(location *time.Location) Schedule

+ func (me Schedule) String() string

+ type Worker struct

+ func NewWorker(name string, job WorkerJob, options ...WorkerOption) Worker

+ type WorkerJob func(context.Context, *slog.Logger) error

+ type WorkerManager struct

+ func NewWorkerManager(options ...WorkerManagerOption) WorkerManager

+ func (me *WorkerManager) RegisterWorker(worker Worker)

+ func (me WorkerManager) Start()

+ type WorkerManagerOption func(*WorkerManager)

+ func WithLogger(logger *slog.Logger) WorkerManagerOption

+ type WorkerOption func(*Worker)

+ func WithBackoffStrategy(strategy BackoffStrategy) WorkerOption

+ func WithItsOwnLogger(logger *slog.Logger) WorkerOption

+ func WithNRetries(n int) WorkerOption

+ func WithNRuns(n int) WorkerOption

+ func WithRetryDelay(delay time.Duration) WorkerOption

+ func WithSchedules(schedules ...Schedule) WorkerOption

+ func WithTick(tick time.Duration) WorkerOption

+ func WithTimeout(timeout time.Duration) WorkerOption

v1.0.1

Feb 12, 2026

v1.0.0

Feb 11, 2026