retry

Documentation

Overview

Package retry는 pkg/backoff의 지연 값 계산을 사용해 context 취소를 존중하며 sleep·재시도·중단을 수행하는 재시도 루프(WithRetry)를 제공합니다. backoff가 순수 값 helper라면 이 패키지는 루프입니다.

DelayOverride가 반환한 지연도 MaxDelay로 함께 캡됩니다(API 시그니처만으로는 드러나지 않음).

context 취소·만료와 직전 fn 에러가 공존하면 operational(직전 fn) 에러를 우선 반환합니다. 한 번이라도 fn이 실패한 뒤 ctx가 취소되면 — 다음 시도 진입 시점의 ctx 검사에서든 sleep이 취소로 중단됐든 — context.Canceled가 아니라 마지막 fn 에러를 반환합니다. ctx가 취소됐고 직전 fn 에러가 없을 때(예: 첫 시도 전 취소)에만 "context error: <ctx.Err()>"로 wrap된 context 에러를 반환합니다.

Index

• func ComputeBackoffDelay(attempt int, base, jitter time.Duration) time.Duration
• func WithRetry(ctx context.Context, opts RetryOptions, fn func(ctx context.Context) error) error
• type RetryOptions

Functions

func ComputeBackoffDelay

func ComputeBackoffDelay(attempt int, base, jitter time.Duration) time.Duration

func WithRetry

func WithRetry(ctx context.Context, opts RetryOptions, fn func(ctx context.Context) error) error

Types

type RetryOptions

type RetryOptions struct {
	MaxAttempts   int
	BaseDelay     time.Duration
	Jitter        time.Duration
	ShouldRetry   func(err error) bool
	OnRetry       func(attempt int, err error, delay time.Duration)
	MaxDelay      time.Duration
	DelayOverride func(err error, computed time.Duration) (delay time.Duration, ok bool)
	Sleep         func(ctx context.Context, d time.Duration) bool
}