retry

Dec 25, 2020

Changes in this version

type Retrier

+ Backoff Backoff

+ EnqueueWorkers int

+ Log fusion.Log

+ MaxRetries int

+ OnFailure func(item Item)

+ Proc fusion.Proc

+ ProcWorkers int

+ Queue DelayQueue

+ func (ret *Retrier) Run(ctx context.Context, stream <-chan fusion.Msg) error

Sep 17, 2020

Changes in this version

+ type Proc struct

+ Backoff Backoff

+ MaxRetries int

+ Proc fusion.Proc

+ Queue DelayQueue

+ Workers int

+ func (ret *Proc) Run(ctx context.Context, stream <-chan fusion.Msg) error

Jul 22, 2020

Changes in this version

+ type Backoff interface

+ RetryAfter func(attempts int) time.Duration

+ func ConstBackoff(interval time.Duration) Backoff

+ func ExpBackoff(base float64, initialTimeout, maxTimeout time.Duration) Backoff

+ type DelayQueue interface

+ Dequeue func(ctx context.Context, readFn ReadFn) error

+ Enqueue func(item Item) error

+ type InMemQ struct

+ func (q *InMemQ) Dequeue(ctx context.Context, readFn ReadFn) error

+ func (q *InMemQ) Enqueue(item Item) error

+ type Item struct

+ Attempts int

+ LastAttempt time.Time

+ Message fusion.Message

+ NextAttempt time.Time

+ type ReadFn func(ctx context.Context, item Item) error

+ type Retrier struct

+ func (r *Retrier) Process(ctx context.Context, msg fusion.Message) (*fusion.Message, error)