Help us shape the future of Go! Take the 2026 Go Developer Survey

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

retry

package

Go to main page

Versions in this module

v21

v21.11.1

Apr 26, 2022

Changes in this version

+ func NewAction(officer *Officer, arbiter Arbiter, run func() error, notify Notify, ...) *action

+ type Option func(thing *action) error

v21.11.0

Feb 17, 2022

Changes in this version

+ var CommonArbiter = PrevailDone(Min(5), Max(10))

+ var DefaultArbiter = PrevailDone(Max(10), Timeout(temporal.GetBigDelay()))

+ func Action(run func() error, arbiter Arbiter, officer *Officer, first func() error, ...) fail.Error

+ func DefaultMetadataNotifier(metaID string) func(t Try, v verdict.Enum)

+ func DefaultNotifier() func(t Try, v verdict.Enum)

+ func DefaultNotifierWithContext(ctx context.Context) func(t Try, v verdict.Enum)

+ func DefaultTimeoutSelector() func(action) fail.Error

+ func LimitError(err error, limit uint) fail.Error

+ func NotifyByLog(try Try, verdict verdict.Enum)

+ func StopRetryError(err error, msg ...interface{}) fail.Error

+ func TimeoutError(err error, limit time.Duration, actual time.Duration, ...) fail.Error

+ func TimeoutSelector(hard bool) func(action) fail.Error

+ func WhileSuccessful(run func() error, delay time.Duration, timeout time.Duration) fail.Error

+ func WhileSuccessfulWithNotify(run func() error, delay time.Duration, timeout time.Duration, notify Notify) fail.Error

+ func WhileUnsuccessful(run func() error, delay time.Duration, timeout time.Duration) fail.Error

+ func WhileUnsuccessfulWithAggregator(run func() error, delay time.Duration, timeout time.Duration, ...) fail.Error

+ func WhileUnsuccessfulWithHardTimeout(run func() error, delay time.Duration, timeout time.Duration) fail.Error

+ func WhileUnsuccessfulWithHardTimeoutWithNotifier(run func() error, delay time.Duration, timeout time.Duration, notify Notify) fail.Error

+ func WhileUnsuccessfulWithLimitedRetries(run func() error, delay time.Duration, timeout time.Duration, retries uint) fail.Error

+ func WhileUnsuccessfulWithNotify(run func() error, delay time.Duration, timeout time.Duration, notify Notify) fail.Error

+ type Arbiter func(Try) (verdict.Enum, fail.Error)

+ func Max(limit uint) Arbiter

+ func Min(limit uint) Arbiter

+ func OrArbiter(arbiters ...Arbiter) Arbiter

+ func PrevailDone(arbiters ...Arbiter) Arbiter

+ func PrevailRetry(arbiters ...Arbiter) Arbiter

+ func Successful() Arbiter

+ func Timeout(limit time.Duration) Arbiter

+ func Unsuccessful() Arbiter

+ type ArbiterAggregator func(arbiters ...Arbiter) Arbiter

+ type Backoff func(duration time.Duration) *Officer

+ func BackoffSelector() Backoff

+ type ErrLimit = fail.ErrOverflow

+ type ErrStopRetry = fail.ErrAborted

+ type ErrTimeout = fail.ErrTimeout

+ type Notify func(Try, verdict.Enum)

+ type Officer struct

+ Block func(Try)

+ func Constant(duration time.Duration) *Officer

+ func Exponential(base time.Duration) *Officer

+ func Fibonacci(base time.Duration) *Officer

+ func Incremental(duration time.Duration) *Officer

+ func Linear(duration time.Duration) *Officer

+ func Randomized(bottom time.Duration, top time.Duration) *Officer

+ type Try struct

+ Count uint

+ Err error

+ Start time.Time

Other modules containing this package

github.com/CS-SI/SafeScale

github.com/CS-SI/SafeScale/v22