timewheel

Documentation

Index

• func At(at time.Time, key string, job func())
• func Cancel(key string)
• func Delay(duration time.Duration, key string, job func())
• type TimeWheel
  • func New(interval time.Duration, slotNum int) *TimeWheel
  • func (tw *TimeWheel) AddJob(delay time.Duration, key string, job func())
  • func (tw *TimeWheel) RemoveJob(key string)
  • func (tw *TimeWheel) Start()
  • func (tw *TimeWheel) Stop()

Functions

func At

func At(at time.Time, key string, job func())

At executes job at given time

func Cancel

func Cancel(key string)

Cancel stops a pending job

func Delay

func Delay(duration time.Duration, key string, job func())

Delay executes job after waiting the given duration

Types

type TimeWheel

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

TimeWheel can execute job after waiting given duration

func New

func New(interval time.Duration, slotNum int) *TimeWheel

New creates a new time wheel

func (*TimeWheel) AddJob

func (tw *TimeWheel) AddJob(delay time.Duration, key string, job func())

AddJob add new job into pending queue

func (*TimeWheel) RemoveJob

func (tw *TimeWheel) RemoveJob(key string)

RemoveJob add remove job from pending queue if job is done or not found, then nothing happened

func (*TimeWheel) Start

func (tw *TimeWheel) Start()

Start starts ticker for time wheel

func (*TimeWheel) Stop

func (tw *TimeWheel) Stop()

Stop stops the time wheel