timetool

Documentation

Index

• type DistributedTimer
  • func NewDistributedTimer(nextDurationFunc NextDurationFunc) *DistributedTimer
  • func (dt *DistributedTimer) Close()
• type NextDurationFunc

Types

type DistributedTimer

type DistributedTimer struct {
	C chan time.Time
	// contains filtered or unexported fields
}

DistributedTimer keeps timer's tick time consistent. Please notice nextDurationFunc assumes different instances running under the same system clock.

func NewDistributedTimer

func NewDistributedTimer(nextDurationFunc NextDurationFunc) *DistributedTimer

NewDistributedTimer creates a DistributedTimer

func (*DistributedTimer) Close

func (dt *DistributedTimer) Close()

Close closes DistributedTimer.

type NextDurationFunc

type NextDurationFunc func() time.Duration

NextDurationFunc is the type for registering callback function to determinate the timer to tick after the returned duration.