again

Jan 20, 2026

Changes in this version

type Retrier

+ func (r *Retrier) DoWithContext(ctx context.Context, retryableFunc RetryableFuncWithContext, ...) (errs *Errors)

+ type RetryableFuncWithContext func(ctx context.Context) error

Aug 15, 2025

Changes in this version

type Errors

+ Attempts []error

+ func DoWithResult[T any](ctx context.Context, r *Retrier, fn func() (T, error), ...) (T, *Errors)

+ func (e *Errors) Join() error

+ func (e *Errors) Reset()

+ type Hooks struct

+ OnRetry func(attempt int, err error)

type Option

+ func WithHooks(h Hooks) Option

+ func WithLogger(logger *slog.Logger) Option

type Retrier

+ Hooks Hooks

+ Logger *slog.Logger

+ func (r *Retrier) PutErrors(errs *Errors)

+ func (r *Retrier) Stop()

Aug 15, 2025

Changes in this version

+ var ErrOperationFailed = ewrap.New("failed")

type Registry

+ func (r *Registry) Len() int

Apr 1, 2023

Changes in this version

type Errors

+ Registry map[int]error

type Registry

+ func (r *Registry) IsTemporaryError(err error, errorsList ...string) bool

Apr 1, 2023

Changes in this version

type Option

+ func WithBackoffFactor(factor float64) Option

+ type Registry struct

+ func (r *Registry) Clean()

+ func (r *Registry) GetTemporaryError(name string) (TemporaryError, bool)

+ func (r *Registry) GetTemporaryErrors(names ...string) []TemporaryError

+ func (r *Registry) ListTemporaryErrors() []TemporaryError

+ func (r *Registry) LoadDefaults() *Registry

+ func (r *Registry) RegisterTemporaryError(name string, fn func() TemporaryError)

+ func (r *Registry) RegisterTemporaryErrors(temporaryErrors map[string]func() TemporaryError)

+ func (r *Registry) UnRegisterTemporaryError(names ...string)

+ func (r *Registry) UnRegisterTemporaryErrors(temporaryErrors map[string]func() TemporaryError)

type Retrier

+ BackoffFactor float64

+ type TimerPool struct

+ func (p *TimerPool) Close()

+ func (p *TimerPool) Drain()

+ func (p *TimerPool) Get() *time.Timer

+ func (p *TimerPool) Len() int

+ func (p *TimerPool) Put(t *time.Timer)

Jan 20, 2023

Changes in this version

+ var ErrInvalidRetrier = errors.New("invalid retrier")

+ var ErrMaxRetriesReached = errors.New("maximum number of retries reached")

+ var ErrNilRetryableFunc = errors.New("failed to invoke the function. It appears to be is nil")

+ var ErrOperationCanceled = errors.New("retry canceled invoking the `Cancel` function")

+ var ErrOperationStopped = errors.New("operation stopped")

+ var ErrTimeoutReached = errors.New("operation timeout reached")

type Retrier

+ func (r *Retrier) Validate() error

Jan 19, 2023

Changes in this version

+ type Errors struct

+ Last error

+ Retries map[int]error

type Retrier

+ func (r *Retrier) Do(ctx context.Context, retryableFunc RetryableFunc, temporaryErrors ...string) (errs *Errors)

Jan 19, 2023

Changes in this version

+ type RetryErrors struct

+ ExitError error

+ Retries map[int]error

Jan 18, 2023

Changes in this version

+ type Option func(*Retrier)

+ func WithInterval(interval time.Duration) Option

+ func WithJitter(jitter time.Duration) Option

+ func WithMaxRetries(num int) Option

+ func WithTimeout(timeout time.Duration) Option

+ type RetryableFunc func() error

+ type TemporaryError error

Jan 18, 2023

Changes in this version

+ func NewTimerPool(size int, timeout time.Duration) *timerPool

type Retrier

+ Interval time.Duration

+ func (r *Retrier) Cancel()

Jan 18, 2023

Changes in this version

+ func NewRegistry() *registry

Jan 18, 2023

Changes in this version

+ type ITemporaryError interface

+ type Retrier struct

+ Jitter time.Duration

+ MaxRetries int

+ Registry *registry

+ Timeout time.Duration

+ func NewRetrier(maxRetries int, jitter time.Duration, timeout time.Duration) *Retrier

+ func (r *Retrier) IsTemporaryError(err error, names ...string) bool

+ func (r *Retrier) Retry(fn func() error, temporaryErrors ...string) error

+ func (r *Retrier) SetRegistry(reg *registry)

+ type RetryError struct

+ Err error

+ MaxRetries int

+ func (e *RetryError) Error() string

+ func (e *RetryError) Unwrap() error