backoff

Documentation

Index

• type Backoff
  • func New(c Conf) Backoff
  • func (a Backoff) AddCron(c *cron.Cron, spec string) (cron.EntryID, error)
  • func (a Backoff) Start()
  • func (a Backoff) Worker()
• type Conf

Types

type Backoff

type Backoff struct {
	Content func() error
	// contains filtered or unexported fields
}

Backoff 错误重试 积分退避算法

func New

func New(c Conf) Backoff

func (Backoff) AddCron

func (a Backoff) AddCron(c *cron.Cron, spec string) (cron.EntryID, error)

func (Backoff) Start

func (a Backoff) Start()

func (Backoff) Worker

func (a Backoff) Worker()

Worker 请注意,此处使用的是普通接收器,当 worker 重新运行时 retry 会被重置

type Conf

type Conf struct {
	Content func() error
	// 最大重试等待时间
	MaxRetryDelay time.Duration
}