worker

Documentation

Index

• func Backoff(base, maximum time.Duration, id string, attempt int) time.Duration
• type Config
• type Metrics
• type Pool
  • func New(store *store.Store, client *http.Client, logger *slog.Logger, config Config) *Pool
  • func (p *Pool) Metrics() Metrics
  • func (p *Pool) Start(ctx context.Context)
  • func (p *Pool) Wait()

Functions

func Backoff

func Backoff(base, maximum time.Duration, id string, attempt int) time.Duration

Types

type Config

type Config struct {
	Concurrency   int
	PollInterval  time.Duration
	LeaseDuration time.Duration
	BaseBackoff   time.Duration
	MaxBackoff    time.Duration
	PerTarget     int
}

type Metrics

type Metrics struct {
	Attempts         uint64
	Succeeded        uint64
	RetryableFailure uint64
	TerminalFailure  uint64
}

type Pool

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

func New

func New(store *store.Store, client *http.Client, logger *slog.Logger, config Config) *Pool

func (*Pool) Metrics

func (p *Pool) Metrics() Metrics

func (*Pool) Start

func (p *Pool) Start(ctx context.Context)

func (*Pool) Wait

func (p *Pool) Wait()