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

resilience

package module

Go to main page

Versions in this module

v0

v0.3.8

Jul 7, 2026

v0.3.7

May 27, 2026

v0.3.6

May 1, 2026

v0.3.5

Apr 2, 2026

v0.3.4

Feb 3, 2026

v0.3.3

Jan 23, 2026

v0.3.2

Jan 12, 2026

v0.3.1

Jan 12, 2026

v0.3.0

Nov 22, 2025

v0.2.0

Nov 21, 2025

v0.1.0

Nov 15, 2025

Changes in this version

+ func NewStatusCodeError(statusCode int, err error) error

+ type CircuitBreakerConfig struct

+ ErrorClassifier CircuitBreakerErrorClassifier

+ Interval time.Duration

+ Logger *slog.Logger

+ MaxRequests uint32

+ OnStateChange func(name string, from, to CircuitBreakerState)

+ ReadyToTrip func(counts CircuitBreakerCounts) bool

+ Timeout time.Duration

+ func DefaultCircuitBreakerConfig() *CircuitBreakerConfig

+ type CircuitBreakerCounts struct

+ ConsecutiveFailures uint32

+ ConsecutiveSuccesses uint32

+ Requests uint32

+ TotalFailures uint32

+ TotalSuccesses uint32

+ type CircuitBreakerErrorClassifier interface

+ ShouldTripCircuit func(err error) bool

+ func DefaultCircuitBreakerErrorClassifier() CircuitBreakerErrorClassifier

+ type CircuitBreakerOption func(*CircuitBreakerConfig)

+ func WithCircuitBreakerErrorClassifier(classifier CircuitBreakerErrorClassifier) CircuitBreakerOption

+ func WithCircuitBreakerLogger(logger *slog.Logger) CircuitBreakerOption

+ func WithInterval(interval time.Duration) CircuitBreakerOption

+ func WithMaxRequests(maxRequests uint32) CircuitBreakerOption

+ func WithReadyToTrip(fn func(counts CircuitBreakerCounts) bool) CircuitBreakerOption

+ func WithStateChangeHandler(fn func(name string, from, to CircuitBreakerState)) CircuitBreakerOption

+ func WithTimeout(timeout time.Duration) CircuitBreakerOption

+ type CircuitBreakerState int

+ const StateClosed

+ const StateHalfOpen

+ const StateOpen

+ func (s CircuitBreakerState) String() string

+ type CircuitBreakerWrapper struct

+ func NewCircuitBreakerWrapper[Req, Resp any](client ResilientClient[Req, Resp], opts ...CircuitBreakerOption) *CircuitBreakerWrapper[Req, Resp]

+ func (w *CircuitBreakerWrapper[Req, Resp]) Counts() CircuitBreakerCounts

+ func (w *CircuitBreakerWrapper[Req, Resp]) Execute(ctx context.Context, req Req) (Resp, error)

+ func (w *CircuitBreakerWrapper[Req, Resp]) GetHealth() HealthStatus

+ func (w *CircuitBreakerWrapper[Req, Resp]) State() CircuitBreakerState

+ type ErrorClassifier interface

+ IsRetryable func(err error) bool

+ func DefaultErrorClassifier() ErrorClassifier

+ type HTTPError interface

+ StatusCode func() int

+ type HTTPStatusClassifier struct

+ CircuitTripStatuses []int

+ RetryableStatuses []int

+ func NewHTTPStatusClassifier() *HTTPStatusClassifier

+ func (c *HTTPStatusClassifier) IsRetryable(err error) bool

+ func (c *HTTPStatusClassifier) ShouldTripCircuit(err error) bool

+ type HealthStatus struct

+ ConsecutiveFailures uint32

+ ConsecutiveSuccesses uint32

+ Healthy bool

+ Requests uint32

+ State string

+ Status string

+ TotalFailures uint32

+ TotalSuccesses uint32

+ type ResilientClient interface

+ Execute func(ctx context.Context, req Req) (Resp, error)

+ func CombineRetryAndCircuitBreaker[Req, Resp any](client ResilientClient[Req, Resp], retryConfig *RetryConfig, ...) ResilientClient[Req, Resp]

+ type RetryConfig struct

+ ErrorClassifier ErrorClassifier

+ InitialDelay time.Duration

+ Logger *slog.Logger

+ MaxAttempts int

+ MaxDelay time.Duration

+ Multiplier float64

+ Strategy RetryStrategy

+ func DefaultRetryConfig() *RetryConfig

+ type RetryOption func(*RetryConfig)

+ func WithConstantBackoff(delay time.Duration) RetryOption

+ func WithErrorClassifier(classifier ErrorClassifier) RetryOption

+ func WithExponentialBackoff(initialDelay, maxDelay time.Duration) RetryOption

+ func WithFibonacciBackoff(initialDelay, maxDelay time.Duration) RetryOption

+ func WithMaxAttempts(attempts int) RetryOption

+ func WithMultiplier(multiplier float64) RetryOption

+ func WithRetryLogger(logger *slog.Logger) RetryOption

+ type RetryStats struct

+ LastAttemptTime time.Time

+ LastError error

+ TotalAttempts int64

+ TotalFailures int64

+ TotalRetries int64

+ TotalSuccesses int64

+ type RetryStrategy string

+ const RetryStrategyConstant

+ const RetryStrategyExponential

+ const RetryStrategyFibonacci

+ type RetryWrapper struct

+ func NewRetryWrapper[Req, Resp any](client ResilientClient[Req, Resp], opts ...RetryOption) *RetryWrapper[Req, Resp]

+ func (w *RetryWrapper[Req, Resp]) Execute(ctx context.Context, req Req) (Resp, error)

+ func (w *RetryWrapper[Req, Resp]) GetRetryStats() RetryStats

+ type StatusCodeError struct

+ Code int

+ Err error

+ func (e *StatusCodeError) Error() string

+ func (e *StatusCodeError) StatusCode() int

+ func (e *StatusCodeError) Unwrap() error