loop

Documentation

Index

• func CancelTimer(t *Timer)
• func NumHandled() int32
• func Push(f func())
• func QLen() int32
• func Stop()
• func UpdateTimer(t *Timer, ts time.Time)
• type Timer
  • func SetTimeout(ts time.Time, f func()) *Timer
  • func (self *Timer) Time() time.Time
• type TimerQueue
  • func NewTimerQueue() *TimerQueue
  • func (self *TimerQueue) Cancel(t *Timer)
  • func (self *TimerQueue) Expire(now time.Time) bool
  • func (self *TimerQueue) SetTimeout(ts time.Time, f func()) *Timer
  • func (self *TimerQueue) Update(t *Timer, ts time.Time)

Functions

func CancelTimer

func CancelTimer(t *Timer)

func NumHandled

func NumHandled() int32

func Push

func Push(f func())

func QLen

func QLen() int32

func Stop

func Stop()

func UpdateTimer

func UpdateTimer(t *Timer, ts time.Time)

Types

type Timer

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

func SetTimeout

func SetTimeout(ts time.Time, f func()) *Timer

func (*Timer) Time

func (self *Timer) Time() time.Time

type TimerQueue

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

func NewTimerQueue

func NewTimerQueue() *TimerQueue

func (*TimerQueue) Cancel

func (self *TimerQueue) Cancel(t *Timer)

func (*TimerQueue) Expire

func (self *TimerQueue) Expire(now time.Time) bool

func (*TimerQueue) SetTimeout

func (self *TimerQueue) SetTimeout(ts time.Time, f func()) *Timer

func (*TimerQueue) Update

func (self *TimerQueue) Update(t *Timer, ts time.Time)