timer

Documentation

Index

• Constants
• type ExecuteHandler
• type TimingWheel
  • func NewTimingWheel(d time.Duration) *TimingWheel
  • func (tw *TimingWheel) NewWheel(p map[string]interface{}, d time.Duration, f ExecuteHandler) *Wheel
  • func (tw *TimingWheel) Start()
  • func (tw *TimingWheel) Stop()
• type Wheel

Constants

const (
	TimeNearShift  = 8
	TimeNear       = 1 << TimeNearShift
	TimeLevelShift = 6
	TimeLevel      = 1 << TimeLevelShift
	TimeNearMask   = TimeNear - 1
	TimeLevelMask  = TimeLevel - 1
)

Types

type ExecuteHandler

type ExecuteHandler func(param map[string]interface{}) error

type TimingWheel

type TimingWheel struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTimingWheel

func NewTimingWheel(d time.Duration) *TimingWheel

func (*TimingWheel) NewWheel

func (tw *TimingWheel) NewWheel(p map[string]interface{}, d time.Duration, f ExecuteHandler) *Wheel

func (*TimingWheel) Start

func (tw *TimingWheel) Start()

func (*TimingWheel) Stop

func (tw *TimingWheel) Stop()

type Wheel

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