ticker

package

v1.7.0 Latest Latest Go to latest Published: Jan 22, 2018 License: AGPL-3.0 Imports: 5 Imported by: 4

Details

This section is empty.

This section is empty.

func Began(interval uint, now uint) time.Time

Return time when interval began for current time.

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

func NewClock(tickerFactory TickerFactory, nowFunc func() int64) *Clock

func (clock *Clock) Add(c chan time.Time, atInterval uint, sync bool)

func (clock *Clock) ETA(c chan time.Time) float64

func (clock *Clock) Remove(c chan time.Time)

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

func NewEvenTicker(atInterval uint, sleep func(time.Duration)) *EvenTicker

func (et *EvenTicker) Add(c chan time.Time)

func (et *EvenTicker) ETA(nowNanosecond int64) float64

func (et *EvenTicker) Remove(c chan time.Time)

func (et *EvenTicker) Run(nowNanosecond int64)

func (et *EvenTicker) Stop()

type Manager interface {
	Add(c chan time.Time, atInterval uint, sync bool)
	Remove(c chan time.Time)
	ETA(c chan time.Time) float64
}

type RealTickerFactory struct {
}

func (f *RealTickerFactory) Make(atInterval uint, sync bool) Ticker

type Ticker interface {
	Run(nowNanosecond int64)
	Stop()
	Add(c chan time.Time)
	Remove(c chan time.Time)
	ETA(now int64) float64
}

type TickerFactory interface {
	Make(atInterval uint, sync bool) Ticker
}

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

func NewWaitTicker(atInterval uint) *WaitTicker

func (wt *WaitTicker) Add(c chan time.Time)

func (wt *WaitTicker) ETA(now int64) float64

func (wt *WaitTicker) Remove(c chan time.Time)

func (wt *WaitTicker) Run(nowNanosecond int64)

func (wt *WaitTicker) Stop()