Documentation
¶
Index ¶
Constants ¶
View Source
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 )
Variables ¶
This section is empty.
Functions ¶
func GetCurrentTime ¶ added in v0.171.10
func GetCurrentTimeInMillis ¶ added in v0.162.5
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.
Source Files
Click to show internal directories.
Click to hide internal directories.