Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

retry

package

Go to main page

Versions in this module

v1

v1.16.16

Jun 24, 2022

v1.16.15

Jun 23, 2022

v1.16.14

Jun 23, 2022

v1.16.13

Jun 22, 2022

v1.16.12

Jun 22, 2022

v1.16.11

Jun 22, 2022

v1.16.10

Jun 22, 2022

v1.16.9

Jun 22, 2022

v1.16.8

Jun 22, 2022

v1.16.7

Jun 22, 2022

Changes in this version

+ const DefaultMaxAttempts

+ const DefaultMaxBackoff

+ const DefaultNoRetryIncrement

+ const DefaultRequestCost

+ const DefaultRetryCost

+ const DefaultRetryRateTokens

+ const DefaultRetryTimeoutCost

+ var DefaultRetryableErrorCodes = map[string]struct

+ var DefaultRetryableHTTPStatusCodes = map[int]struct

+ var DefaultRetryables = []IsErrorRetryable

+ var DefaultThrottleErrorCodes = map[string]struct

+ var DefaultThrottles = []IsErrorThrottle

+ var DefaultTimeouts = []IsErrorTimeout

+ func AddRetryMiddlewares(stack *smithymiddle.Stack, options AddRetryMiddlewaresOptions) error

+ func AddWithErrorCodes(r aws.Retryer, codes ...string) aws.Retryer

+ func AddWithMaxAttempts(r aws.Retryer, max int) aws.Retryer

+ func AddWithMaxBackoffDelay(r aws.Retryer, delay time.Duration) aws.Retryer

+ type AdaptiveMode struct

+ func NewAdaptiveMode(optFns ...func(*AdaptiveModeOptions)) *AdaptiveMode

+ func (a *AdaptiveMode) GetAttemptToken(ctx context.Context) (func(error) error, error)

+ func (a *AdaptiveMode) GetInitialToken() (releaseToken func(error) error)

+ func (a *AdaptiveMode) GetRetryToken(ctx context.Context, opErr error) (releaseToken func(error) error, err error)

+ func (a *AdaptiveMode) IsErrorRetryable(err error) bool

+ func (a *AdaptiveMode) MaxAttempts() int

+ func (a *AdaptiveMode) RetryDelay(attempt int, opErr error) (time.Duration, error)

+ type AdaptiveModeOptions struct

+ FailOnNoAttemptTokens bool

+ RequestCost uint

+ StandardOptions []func(*StandardOptions)

+ Throttles []IsErrorThrottle

+ type AddRetryMiddlewaresOptions struct

+ LogRetryAttempts bool

+ Retryer aws.Retryer

+ type Attempt struct

+ LogAttempts bool

+ func NewAttemptMiddleware(retryer aws.Retryer, requestCloner RequestCloner, optFns ...func(*Attempt)) *Attempt

+ func (r *Attempt) HandleFinalize(ctx context.Context, in smithymiddle.FinalizeInput, ...) (out smithymiddle.FinalizeOutput, metadata smithymiddle.Metadata, err error)

+ func (r *Attempt) ID() string

+ type AttemptResult struct

+ Err error

+ ResponseMetadata middleware.Metadata

+ Retried bool

+ Retryable bool

+ func (a AttemptResult) GetRawResponse() interface{}

+ type AttemptResults struct

+ Results []AttemptResult

+ func GetAttemptResults(metadata middleware.Metadata) (AttemptResults, bool)

+ type BackoffDelayer interface

+ BackoffDelay func(attempt int, err error) (time.Duration, error)

+ type BackoffDelayerFunc func(int, error) (time.Duration, error)

+ func (fn BackoffDelayerFunc) BackoffDelay(attempt int, err error) (time.Duration, error)

+ type ExponentialJitterBackoff struct

+ func NewExponentialJitterBackoff(maxBackoff time.Duration) *ExponentialJitterBackoff

+ func (j *ExponentialJitterBackoff) BackoffDelay(attempt int, err error) (time.Duration, error)

+ type IsErrorRetryable interface

+ IsErrorRetryable func(error) aws.Ternary

+ type IsErrorRetryableFunc func(error) aws.Ternary

+ func (fn IsErrorRetryableFunc) IsErrorRetryable(err error) aws.Ternary

+ type IsErrorRetryables []IsErrorRetryable

+ func (r IsErrorRetryables) IsErrorRetryable(err error) aws.Ternary

+ type IsErrorThrottle interface

+ IsErrorThrottle func(error) aws.Ternary

+ type IsErrorThrottleFunc func(error) aws.Ternary

+ func (fn IsErrorThrottleFunc) IsErrorThrottle(err error) aws.Ternary

+ type IsErrorThrottles []IsErrorThrottle

+ func (r IsErrorThrottles) IsErrorThrottle(err error) aws.Ternary

+ type IsErrorTimeout interface

+ IsErrorTimeout func(err error) aws.Ternary

+ type IsErrorTimeoutFunc func(error) aws.Ternary

+ func (fn IsErrorTimeoutFunc) IsErrorTimeout(err error) aws.Ternary

+ type IsErrorTimeouts []IsErrorTimeout

+ func (ts IsErrorTimeouts) IsErrorTimeout(err error) aws.Ternary

+ type MaxAttemptsError struct

+ Attempt int

+ Err error

+ func (e *MaxAttemptsError) Error() string

+ func (e *MaxAttemptsError) Unwrap() error

+ type MetricsHeader struct

+ func (r *MetricsHeader) ID() string

+ func (r MetricsHeader) HandleFinalize(ctx context.Context, in smithymiddle.FinalizeInput, ...) (out smithymiddle.FinalizeOutput, metadata smithymiddle.Metadata, err error)

+ type NoRetryCanceledError struct

+ func (NoRetryCanceledError) IsErrorRetryable(err error) aws.Ternary

+ type RateLimiter interface

+ AddTokens func(uint) error

+ GetToken func(ctx context.Context, cost uint) (releaseToken func() error, err error)

+ type RequestCloner func(interface{}) interface

+ type RetryableConnectionError struct

+ func (r RetryableConnectionError) IsErrorRetryable(err error) aws.Ternary

+ type RetryableError struct

+ func (RetryableError) IsErrorRetryable(err error) aws.Ternary

+ type RetryableErrorCode struct

+ Codes map[string]struct{}

+ func (r RetryableErrorCode) IsErrorRetryable(err error) aws.Ternary

+ type RetryableHTTPStatusCode struct

+ Codes map[int]struct{}

+ func (r RetryableHTTPStatusCode) IsErrorRetryable(err error) aws.Ternary

+ type Standard struct

+ func NewStandard(fnOpts ...func(*StandardOptions)) *Standard

+ func (s *Standard) GetAttemptToken(context.Context) (func(error) error, error)

+ func (s *Standard) GetInitialToken() func(error) error

+ func (s *Standard) GetRetryToken(ctx context.Context, opErr error) (func(error) error, error)

+ func (s *Standard) IsErrorRetryable(err error) bool

+ func (s *Standard) MaxAttempts() int

+ func (s *Standard) RetryDelay(attempt int, err error) (time.Duration, error)

+ type StandardOptions struct

+ Backoff BackoffDelayer

+ MaxAttempts int

+ MaxBackoff time.Duration

+ NoRetryIncrement uint

+ RateLimiter RateLimiter

+ RetryCost uint

+ RetryTimeoutCost uint

+ Retryables []IsErrorRetryable

+ Timeouts []IsErrorTimeout

+ type ThrottleErrorCode struct

+ Codes map[string]struct{}

+ func (r ThrottleErrorCode) IsErrorThrottle(err error) aws.Ternary

+ type TimeouterError struct

+ func (t TimeouterError) IsErrorTimeout(err error) aws.Ternary