timesource

Documentation

Index

• Constants
• func GetCurrentTimeInMillis() (uint64, error)
• type NTPTimeSource
  • func Default() *NTPTimeSource
  • func (s *NTPTimeSource) AddCallback(callback func(time.Time)) *sync.WaitGroup
  • func (s *NTPTimeSource) Now() time.Time
  • func (s *NTPTimeSource) Start() error
  • func (s *NTPTimeSource) Stop() error

Constants

const (
	// DefaultMaxAllowedFailures defines how many failures will be tolerated.
	DefaultMaxAllowedFailures = 1

	// FastNTPSyncPeriod period between ntp synchronizations before the first
	// successful connection.
	FastNTPSyncPeriod = 2 * time.Minute

	// SlowNTPSyncPeriod period between ntp synchronizations after the first
	// successful connection.
	SlowNTPSyncPeriod = 1 * time.Hour

	// DefaultRPCTimeout defines write deadline for single ntp server request.
	DefaultRPCTimeout = 2 * time.Second
)

Functions

func GetCurrentTimeInMillis

func GetCurrentTimeInMillis() (uint64, error)

Types

type NTPTimeSource

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

NTPTimeSource provides source of time that tries to be resistant to time skews. It does so by periodically querying time offset from ntp servers.

func Default

func Default() *NTPTimeSource

Default initializes time source with default config values.

func (*NTPTimeSource) AddCallback

func (s *NTPTimeSource) AddCallback(callback func(time.Time)) *sync.WaitGroup

AddCallback adds callback that will be called when offset is updated. If offset is already updated once, callback will be called immediately.

func (*NTPTimeSource) Now

func (s *NTPTimeSource) Now() time.Time

Now returns time adjusted by latest known offset

func (*NTPTimeSource) Start

func (s *NTPTimeSource) Start() error

Start runs a goroutine that updates local offset every updatePeriod.

func (*NTPTimeSource) Stop

func (s *NTPTimeSource) Stop() error

Stop goroutine that updates time source.