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
- API
  
  Reference documentation for the pkg.go.dev API
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

retrier

package module

Go to main page

Versions in this module

v1

v1.2.0

Aug 12, 2026

v1.1.0

Aug 12, 2026

Changes in this version

type Worker

+ func (w *Worker) UpdateConfig(cfg *WorkerConfig)

+ type WorkerConfig struct

+ func NewWorkerCfg(min, max int32, idleTimeout time.Duration) (*WorkerConfig, error)

v1.0.1

Aug 1, 2026

Changes in this version

+ const ExponentialBackOff

+ const JitterExponentialBackoff

+ const JitterLinearBackOff

+ const LinearBackOff

+ type BackOff interface

+ Get func(backOff BackOffParams) (time.Time, error)

+ type BackOffFn func(params BackOffParams) (time.Time, error)

+ type BackOffParam string

+ const BaseDelayKey

+ const DurationKey

+ const JitterKey

+ const MaxDelayKey

+ const MultiplierKey

+ type BackOffParams interface

+ GetBackOffCode func() string

+ GetBackOffParams func() map[BackOffParam]interface{}

+ GetRetries func() int

+ type BackOffStrategy struct

+ func NewBackOffStrategy() *BackOffStrategy

+ func (s *BackOffStrategy) Get(backOff BackOffParams) (time.Time, error)

+ func (s *BackOffStrategy) Register(code string, fn BackOffFn)

+ type Breaker interface

+ Allow func() bool

+ RecordFailure func()

+ RecordSuccess func()

+ Reset func()

+ State func() CircuitBreakerState

+ type CircuitBreaker struct

+ func NewSlidingWindowCircuitBreaker(windowSize time.Duration, failureThreshold float64, minRequests int, ...) *CircuitBreaker

+ func (cb *CircuitBreaker) Allow() bool

+ func (cb *CircuitBreaker) RecordFailure()

+ func (cb *CircuitBreaker) RecordSuccess()

+ func (cb *CircuitBreaker) Reset()

+ func (cb *CircuitBreaker) State() CircuitBreakerState

+ type CircuitBreakerState string

+ const StateClosed

+ const StateHalfOpen

+ const StateOpen

+ type ErrorState string

+ const CriticalState

+ const UsualState

+ type EventPublisher interface

+ Publish func(event WorkerExecutionResult)

+ type ExecutionError struct

+ Err error

+ State ErrorState

+ type FullWorkerState struct

+ ActiveTasks int32

+ ActiveWorkers int32

+ CBState CircuitBreakerState

+ Status WorkerStatus

+ type Logger interface

+ Errorf func(format string, args ...interface{})

+ Infof func(format string, args ...interface{})

+ type Manager struct

+ func NewManager(ctx context.Context, store Store, logger Logger, backOff BackOff, ...) *Manager

+ func (m *Manager) GetWorkerStatuses() map[string]FullWorkerState

+ func (m *Manager) RegisterWorker(name string, w ManagerWorker, b Breaker) error

+ func (m *Manager) Start()

+ func (m *Manager) Stop()

+ func (m *Manager) Submit(task *Task) error

+ func (m *Manager) UnregisterWorker(name string)

+ type ManagerWorker interface

+ GetOutChan func() chan WorkerExecutionResult

+ GetStatus func() WorkerState

+ Start func()

+ Stop func()

+ Submit func(t *Task) error

+ type MemStore struct

+ func NewMemStore() *MemStore

+ func (ms *MemStore) GetTasks() ([]Task, error)

+ func (ms *MemStore) SaveTask(t *Task, _ *TaskExecutionResult) error

+ type Store interface

+ GetTasks func() ([]Task, error)

+ SaveTask func(task *Task, result *TaskExecutionResult) error

+ type Task struct

+ BackOffCode string

+ BackOffParams map[BackOffParam]interface{}

+ CreatedAt time.Time

+ Ctx context.Context

+ Deadline time.Time

+ ID uuid.UUID

+ LastRun time.Time

+ MaxRetries int

+ NextRun time.Time

+ Payload []byte

+ Retries int

+ Status TaskStatus

+ Worker string

+ func (t *Task) GetBackOffCode() string

+ func (t *Task) GetBackOffParams() map[BackOffParam]interface{}

+ func (t *Task) GetRetries() int

+ func (t *Task) IsFinished() bool

+ type TaskExecutionResult struct

+ ExecutionTime time.Duration

+ ID uuid.UUID

+ IsCritical bool

+ Result []byte

+ RunAt time.Time

+ Status TaskStatus

+ TaskID uuid.UUID

+ type TaskStatus string

+ const StatusFailure

+ const StatusPending

+ const StatusSuccess

+ type Worker struct

+ func NewWorker(ctx context.Context, fn WorkerFn) *Worker

+ func (w *Worker) GetOutChan() chan WorkerExecutionResult

+ func (w *Worker) GetStatus() WorkerState

+ func (w *Worker) SetIdleTimeout(idleTimeout time.Duration)

+ func (w *Worker) SetMinAndMaxWorkers(minWorkers, maxWorkers int32)

+ func (w *Worker) Start()

+ func (w *Worker) Stop()

+ func (w *Worker) Submit(task *Task) error

+ func (w *Worker) Suspend()

+ type WorkerExecutionResult struct

+ Result *TaskExecutionResult

+ Task *Task

+ type WorkerFn func(ctx context.Context, payload []byte) (string, *ExecutionError)

+ type WorkerState struct

+ ActiveTasks int32

+ ActiveWorkers int32

+ Status WorkerStatus

+ type WorkerStatus string

+ const WorkerStatusCreated

+ const WorkerStatusRunning

+ const WorkerStatusStopped

+ const WorkerStatusSuspended

v1.0.0

Jul 22, 2026

v0

v0.3.0

Jul 22, 2026

v0.2.0

Jul 22, 2026

v0.1.0

Jul 22, 2026