retry

Documentation

Index

• type DelayTask
• type DelayTaskSchedule
  • func NewDelayTaskSchedule(ctx context.Context, handler func(key string, data interface{}), ...) *DelayTaskSchedule
  • func NewSchedule(ctx context.Context, options ...Option) *DelayTaskSchedule
  • func (d *DelayTaskSchedule) Create(task *Task) error
  • func (d *DelayTaskSchedule) Delete(key string)
  • func (d *DelayTaskSchedule) Start()
• type Option
  • func WithInterval(interval time.Duration) Option
  • func WithSlotNum(slotNum int) Option
• type Task
• type TimeWheel
  • func NewTimeWheel(ctx context.Context, interval time.Duration, slotNum int, ...) *TimeWheel
  • func (t *TimeWheel) CreateTask(key string, delay time.Duration, data interface{}) error
  • func (t *TimeWheel) DeleteTask(key string)
  • func (t *TimeWheel) Run()

Types

type DelayTask

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

type DelayTaskSchedule

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

func NewDelayTaskSchedule

func NewDelayTaskSchedule(ctx context.Context, handler func(key string, data interface{}), options ...Option) *DelayTaskSchedule

func NewSchedule

func NewSchedule(ctx context.Context, options ...Option) *DelayTaskSchedule

func (*DelayTaskSchedule) Create

func (d *DelayTaskSchedule) Create(task *Task) error

func (*DelayTaskSchedule) Delete

func (d *DelayTaskSchedule) Delete(key string)

func (*DelayTaskSchedule) Start

func (d *DelayTaskSchedule) Start()

type Option

type Option func(*DelayTaskSchedule)

func WithInterval

func WithInterval(interval time.Duration) Option

func WithSlotNum

func WithSlotNum(slotNum int) Option

type Task

type Task struct {
	MaxTimes     int
	MaxTime      time.Duration
	IntervalTime time.Duration

	Key        string
	Data       interface{}
	Job        func(task *Task)
	TimeoutJob func(task *Task)
	// contains filtered or unexported fields
}

type TimeWheel

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

func NewTimeWheel

func NewTimeWheel(ctx context.Context, interval time.Duration, slotNum int, handler callbackHandler) *TimeWheel

func (*TimeWheel) CreateTask

func (t *TimeWheel) CreateTask(key string, delay time.Duration, data interface{}) error

func (*TimeWheel) DeleteTask

func (t *TimeWheel) DeleteTask(key string)

func (*TimeWheel) Run

func (t *TimeWheel) Run()