retry

Documentation

Index

• type RetryFetcher
  • func NewRetryFetcher(inner model.JobFetcher, maxRetries int, baseDelay time.Duration, ...) *RetryFetcher
  • func (f *RetryFetcher) FetchJobs(ctx context.Context) ([]model.Job, error)

Types

type RetryFetcher

type RetryFetcher struct {
	// contains filtered or unexported fields
}

RetryFetcher is a decorator that retries transient failures with exponential backoff and jitter before delegating to the wrapped JobFetcher.

func NewRetryFetcher

func NewRetryFetcher(inner model.JobFetcher, maxRetries int, baseDelay time.Duration, logger *slog.Logger) *RetryFetcher

NewRetryFetcher wraps a JobFetcher with retry logic. maxRetries is the number of additional attempts after the first failure (default: 2). baseDelay is the delay before the first retry (default: 5s), doubled on each subsequent retry.

func (*RetryFetcher) FetchJobs

func (f *RetryFetcher) FetchJobs(ctx context.Context) ([]model.Job, error)

FetchJobs attempts to fetch jobs, retrying on transient errors.