wrap

Mar 27, 2026

Changes in this version

type Fn

+ func (f Fn[T, R]) Apply(ds ...Decorator[T, R]) Fn[T, R]

+ func (f Fn[T, R]) Breaker(b *Breaker) Fn[T, R]

+ func (f Fn[T, R]) MapError(mapper func(error) error) Fn[T, R]

+ func (f Fn[T, R]) OnError(handler func(error)) Fn[T, R]

+ func (f Fn[T, R]) Retry(max int, backoff Backoff, shouldRetry func(error) bool) Fn[T, R]

+ func (f Fn[T, R]) Throttle(n int) Fn[T, R]

+ func (f Fn[T, R]) Weighted(capacity int, cost func(T) int) Fn[T, R]

Mar 27, 2026

Changes in this version

+ type Features struct

+ Breaker *Breaker

+ MapError func(error) error

+ OnError func(error)

+ Retry *RetryConfig

+ Throttle *ThrottleConfig

+ type RetryConfig struct

+ Backoff Backoff

+ Max int

+ ShouldRetry func(error) bool

+ func Retry(max int, backoff Backoff, shouldRetry func(error) bool) *RetryConfig

+ type ThrottleConfig struct

+ N int

+ func Throttle(n int) *ThrottleConfig

Mar 27, 2026

Changes in this version

+ var ErrCircuitOpen = errors.New("call: circuit breaker is open")

+ func ConsecutiveFailures(n int) func(Snapshot) bool

+ type Backoff func(n int) time.Duration

+ func ExpBackoff(initial time.Duration) Backoff

+ type Breaker struct

+ func NewBreaker(cfg BreakerConfig) *Breaker

+ func (b *Breaker) Snapshot() Snapshot

+ type BreakerConfig struct

+ Clock func() time.Time

+ OnStateChange func(Transition)

+ ReadyToTrip func(Snapshot) bool

+ ResetTimeout time.Duration

+ ShouldCount func(error) bool

+ type BreakerState int

+ const StateClosed

+ const StateHalfOpen

+ const StateOpen

+ func (s BreakerState) String() string

+ type Decorator func(Fn[T, R]) Fn[T, R]

+ type Fn func(context.Context, T) (R, error)

+ func Func[T, R any](fn func(context.Context, T) (R, error)) Fn[T, R]

+ func (f Fn[T, R]) With(ds ...Decorator[T, R]) Fn[T, R]

+ func (f Fn[T, R]) WithBreaker(b *Breaker) Fn[T, R]

+ func (f Fn[T, R]) WithMapError(mapper func(error) error) Fn[T, R]

+ func (f Fn[T, R]) WithOnError(handler func(error)) Fn[T, R]

+ func (f Fn[T, R]) WithRetry(maxAttempts int, backoff Backoff, shouldRetry func(error) bool) Fn[T, R]

+ func (f Fn[T, R]) WithThrottle(n int) Fn[T, R]

+ func (f Fn[T, R]) WithThrottleWeighted(capacity int, cost func(T) int) Fn[T, R]

+ type Snapshot struct

+ ConsecutiveFailures int

+ Failures int

+ OpenedAt time.Time

+ Rejected int

+ State BreakerState

+ Successes int

+ type Transition struct

+ At time.Time

+ From BreakerState

+ To BreakerState