timewheel

Documentation

Index

• Variables
• type Job
• type Task
• type TimeWheel
  • func GetTimeWheel() *TimeWheel
  • func NewTimeWheel(interval time.Duration, slotNums int, job Job) *TimeWheel
  • func (tw *TimeWheel) AddTask(interval time.Duration, key interface{}, createdTime time.Time, times int, ...) error
  • func (tw *TimeWheel) IsRunning() bool
  • func (tw *TimeWheel) RemoveTask(key interface{}) error
  • func (tw *TimeWheel) Start()
  • func (tw *TimeWheel) Stop()

Variables

var (
	ErrDuplicateTaskKey = errors.New("duplicate task key")
	ErrTaskKeyNotFount  = errors.New("task key doesn't existed in task list, please check your input")
)

Types

type Job

type Job func(interface{})

type Task

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

type TimeWheel

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

func GetTimeWheel

func GetTimeWheel() *TimeWheel

func NewTimeWheel

func NewTimeWheel(interval time.Duration, slotNums int, job Job) *TimeWheel

func (*TimeWheel) AddTask

func (tw *TimeWheel) AddTask(interval time.Duration, key interface{}, createdTime time.Time, times int, job Job) error

func (*TimeWheel) IsRunning

func (tw *TimeWheel) IsRunning() bool

func (*TimeWheel) RemoveTask

func (tw *TimeWheel) RemoveTask(key interface{}) error

func (*TimeWheel) Start

func (tw *TimeWheel) Start()

func (*TimeWheel) Stop

func (tw *TimeWheel) Stop()