timers

Documentation

Index

• type Option
  • func TimerDispatcherLen(length int) Option
• type Options
• type Timers
  • func NewTimer(opts ...Option) *Timers
  • func (t *Timers) AfterFunc(d time.Duration, cb func()) *timer.Timer
  • func (t *Timers) CronFunc(cronExpr *timer.CronExpr, cb func()) *timer.Cron
  • func (t *Timers) OnDestroy()
  • func (t *Timers) OnInit()
  • func (t *Timers) OnRun(closeSig chan bool)

Types

type Option

type Option func(*Options)

func TimerDispatcherLen

func TimerDispatcherLen(length int) Option

Address of rpc service

type Options

type Options struct {
	TimerDispatcherLen int
}

type Timers

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

func NewTimer

func NewTimer(opts ...Option) *Timers

func (*Timers) AfterFunc

func (t *Timers) AfterFunc(d time.Duration, cb func()) *timer.Timer

func (*Timers) CronFunc

func (t *Timers) CronFunc(cronExpr *timer.CronExpr, cb func()) *timer.Cron

func (*Timers) OnDestroy

func (t *Timers) OnDestroy()

func (*Timers) OnInit

func (t *Timers) OnInit()

func (*Timers) OnRun

func (t *Timers) OnRun(closeSig chan bool)