delay

Documentation

Index

• type Delay
  • func New() *Delay
  • func (d *Delay) Add(delayTime time.Duration, f func(ts int64, args interface{}), arg interface{}) int64
  • func (d *Delay) Del(f func(ts int64, args interface{}) bool)
  • func (d *Delay) Done() <-chan time.Time
  • func (d *Delay) Handler()
  • func (d *Delay) QueueAdd(unit *Unit)
  • func (d *Delay) QueueLen() int
  • func (d *Delay) QueueRange(f func(unit *Unit) bool)
  • func (d *Delay) QueueRangeDel(f func(unit *Unit) (bool, bool))
  • func (d *Delay) Range(f func(ts int64, args interface{}) bool)
• type Unit

Types

type Delay

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

func New

func New() *Delay

func (*Delay) Add

func (d *Delay) Add(delayTime time.Duration, f func(ts int64, args interface{}), arg interface{}) int64

func (*Delay) Del

func (d *Delay) Del(f func(ts int64, args interface{}) bool)

func (*Delay) Done

func (d *Delay) Done() <-chan time.Time

func (*Delay) Handler

func (d *Delay) Handler()

func (*Delay) QueueAdd

func (d *Delay) QueueAdd(unit *Unit)

func (*Delay) QueueLen

func (d *Delay) QueueLen() int

func (*Delay) QueueRange

func (d *Delay) QueueRange(f func(unit *Unit) bool)

func (*Delay) QueueRangeDel

func (d *Delay) QueueRangeDel(f func(unit *Unit) (bool, bool))

func (*Delay) Range

func (d *Delay) Range(f func(ts int64, args interface{}) bool)

type Unit

type Unit struct {
	DelayTime time.Duration
	CallTs    int64
	F         func(ts int64, arg interface{})
	Arg       interface{}
}