timesource

Documentation

Index

• Constants
• func GetCurrentTime() time.Time
• func GetCurrentTimeInMillis() uint64
• type NTPTimeSource
  • func Default() *NTPTimeSource
  • func (s *NTPTimeSource) Now() time.Time
  • func (s *NTPTimeSource) Start()
  • func (s *NTPTimeSource) Stop() error

Constants

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

	// 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 GetCurrentTime

func GetCurrentTime() time.Time

func GetCurrentTimeInMillis

func GetCurrentTimeInMillis() uint64

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) Now

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

Now returns time adjusted by latest known offset

func (*NTPTimeSource) Start

func (s *NTPTimeSource) Start()

Start initializes the local offset and starts a goroutine that periodically updates the local offset.

func (*NTPTimeSource) Stop

func (s *NTPTimeSource) Stop() error

Stop goroutine that updates time source.