resile

package module

Go to main page

Versions in this module

v1

v1.0.6

Jul 6, 2026

Changes in this version

+ func WithPriority(ctx context.Context, p Priority) context.Context

type AdaptiveLimiter

+ func (al *AdaptiveLimiter) Health() <-chan StateEvent

type Config

+ PriorityBulkhead *PriorityBulkhead

+ type HealthState int

+ const HealthStateDegraded

+ const HealthStateHealthy

+ const HealthStateUnhealthy

type Option

+ func WithPriorityBulkhead(capacity uint, thresholds map[Priority]float64) Option

+ func WithPriorityBulkheadInstance(bh *PriorityBulkhead) Option

type Policy

+ func (p *Policy) Health() <-chan circuit.StateEvent

+ type Priority int

+ const PriorityCritical

+ const PriorityLow

+ const PriorityStandard

+ func GetPriority(ctx context.Context) Priority

+ type PriorityBulkhead struct

+ func NewPriorityBulkhead(capacity uint, thresholds map[Priority]float64) *PriorityBulkhead

+ func (b *PriorityBulkhead) Execute(ctx context.Context, action func() error) error

+ type StateEvent struct

+ Component string

+ Message string

+ State HealthState

+ Timestamp time.Time

v1.0.5

Apr 11, 2026

Changes in this version

+ func InjectDeadlineHeader(ctx context.Context, header Header, key string)

type Config

+ Chaos *chaos.Injector

+ MinDeadlineThreshold time.Duration

+ type Header interface

+ Set func(key, value string)

type Option

+ func WithChaos(cfg chaos.Config) Option

+ func WithMinDeadlineThreshold(threshold time.Duration) Option

v1.0.4

Apr 2, 2026

Changes in this version

+ var ErrShedLoad = errors.New("load shed: adaptive concurrency limit reached")

+ type AdaptiveLimiter struct

+ func NewAdaptiveLimiter() *AdaptiveLimiter

+ func (al *AdaptiveLimiter) Execute(ctx context.Context, action func() error) error

+ func (al *AdaptiveLimiter) GetMaxConcurrency() int32

type Config

+ AdaptiveLimiter *AdaptiveLimiter

type Option

+ func WithAdaptiveLimiter() Option

+ func WithAdaptiveLimiterInstance(al *AdaptiveLimiter) Option

v1.0.3

Mar 22, 2026

Changes in this version

+ var ErrBulkheadFull = errors.New("bulkhead capacity reached")

+ var ErrRateLimitExceeded = errors.New("rate limit exceeded")

+ type Bulkhead struct

+ func NewBulkhead(capacity uint) *Bulkhead

+ func (b *Bulkhead) Execute(ctx context.Context, action func() error) error

type Config

+ Bulkhead *Bulkhead

+ RateLimiter *RateLimiter

+ Timeout time.Duration

type Instrumenter

+ OnBulkheadFull func(ctx context.Context, state RetryState)

+ OnRateLimitExceeded func(ctx context.Context, state RetryState)

type Option

+ func WithBulkhead(capacity uint) Option

+ func WithBulkheadInstance(bh *Bulkhead) Option

+ func WithRateLimiter(limit float64, interval time.Duration) Option

+ func WithRateLimiterInstance(rl *RateLimiter) Option

+ func WithRetry(attempts uint) Option

+ func WithTimeout(timeout time.Duration) Option

+ type Policy struct

+ func NewPolicy(opts ...Option) *Policy

+ func (p *Policy) Do(ctx context.Context, action func(context.Context) (any, error)) (any, error)

+ func (p *Policy) DoErr(ctx context.Context, action func(context.Context) error) error

+ type RateLimiter struct

+ func NewRateLimiter(limit float64, interval time.Duration) *RateLimiter

+ func (rl *RateLimiter) Acquire(ctx context.Context) bool

v1.0.2

Mar 16, 2026

Changes in this version

+ type StateMachine struct

+ func NewStateMachine[S any, D any, E any](initialState S, initialData D, transition TransitionFunc[S, D, E], ...) *StateMachine[S, D, E]

+ func (sm *StateMachine[S, D, E]) GetData() D

+ func (sm *StateMachine[S, D, E]) GetState() S

+ func (sm *StateMachine[S, D, E]) Handle(ctx context.Context, event E) error

+ type TransitionFunc func(ctx context.Context, state S, data D, event E, rs RetryState) (S, D, error)

v1.0.1

Mar 15, 2026

Changes in this version

type Config

+ RecoverPanics bool

type Option

+ func WithPanicRecovery() Option

+ type PanicError struct

+ StackTrace string

+ Value any

+ func (p *PanicError) Error() string

v1.0.0

Mar 6, 2026

Changes in this version

+ func DoErr(ctx context.Context, action func(context.Context) error, opts ...Option) error

+ func DoErrHedged(ctx context.Context, action func(context.Context) error, opts ...Option) error

+ func DoErrState(ctx context.Context, action func(context.Context, RetryState) error, ...) error

+ func DoErrStateHedged(ctx context.Context, action func(context.Context, RetryState) error, ...) error

+ func DoHedged[T any](ctx context.Context, action func(context.Context) (T, error), opts ...Option) (T, error)

+ func DoStateHedged[T any](ctx context.Context, action func(context.Context, RetryState) (T, error), ...) (T, error)

+ func DoState[T any](ctx context.Context, action func(context.Context, RetryState) (T, error), ...) (T, error)

+ func Do[T any](ctx context.Context, action func(context.Context) (T, error), opts ...Option) (T, error)

+ func FatalError(err error) error

+ func WithTestingBypass(ctx context.Context) context.Context

+ type AdaptiveBucket struct

+ func DefaultAdaptiveBucket() *AdaptiveBucket

+ func NewAdaptiveBucket(maxCapacity, retryCost, successRefill float64) *AdaptiveBucket

+ func (b *AdaptiveBucket) AcquireRetryToken() bool

+ func (b *AdaptiveBucket) AddSuccessToken()

+ type Backoff interface

+ Next func(attempt uint) time.Duration

+ func NewFullJitter(base, cap time.Duration) Backoff

+ type Config struct

+ AdaptiveBucket *AdaptiveBucket

+ Backoff Backoff

+ BaseDelay time.Duration

+ CircuitBreaker *circuit.Breaker

+ Fallback any

+ HedgingDelay time.Duration

+ Instrumenter Instrumenter

+ MaxAttempts uint

+ MaxDelay time.Duration

+ Name string

+ Policy *retryPolicy

+ func DefaultConfig() *Config

+ func (c *Config) Do(ctx context.Context, action func(context.Context) (any, error)) (any, error)

+ func (c *Config) DoErr(ctx context.Context, action func(context.Context) error) error

+ func (c *Config) DoErrHedged(ctx context.Context, action func(context.Context) error) error

+ func (c *Config) DoHedged(ctx context.Context, action func(context.Context) (any, error)) (any, error)

+ type Instrumenter interface

+ AfterAttempt func(ctx context.Context, state RetryState)

+ BeforeAttempt func(ctx context.Context, state RetryState) context.Context

+ type Option func(*Config)

+ func WithAdaptiveBucket(bucket *AdaptiveBucket) Option

+ func WithBackoff(backoff Backoff) Option

+ func WithBaseDelay(delay time.Duration) Option

+ func WithCircuitBreaker(cb *circuit.Breaker) Option

+ func WithFallbackErr(f func(context.Context, error) error) Option

+ func WithFallback[T any](f func(context.Context, error) (T, error)) Option

+ func WithHedgingDelay(delay time.Duration) Option

+ func WithInstrumenter(instr Instrumenter) Option

+ func WithMaxAttempts(attempts uint) Option

+ func WithMaxDelay(delay time.Duration) Option

+ func WithName(name string) Option

+ func WithRetryIf(target error) Option

+ func WithRetryIfFunc(f func(error) bool) Option

+ type RetryAfterError interface

+ CancelAllRetries func() bool

+ RetryAfter func() time.Duration

+ type RetryState struct

+ Attempt uint

+ LastError error

+ MaxAttempts uint

+ Name string

+ NextDelay time.Duration

+ TotalDuration time.Duration

+ type Retryer interface

+ Do func(ctx context.Context, action func(context.Context) (any, error)) (any, error)

+ DoErr func(ctx context.Context, action func(context.Context) error) error

+ DoErrHedged func(ctx context.Context, action func(context.Context) error) error

+ DoHedged func(ctx context.Context, action func(context.Context) (any, error)) (any, error)

+ func New(opts ...Option) Retryer

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL