timesource

Documentation

Index

• Constants
• type NTPTimeSource
  • func Default() *NTPTimeSource
  • func (s *NTPTimeSource) APIs() []rpc.API
  • func (s *NTPTimeSource) Now() time.Time
  • func (s *NTPTimeSource) Protocols() []p2p.Protocol
  • func (s *NTPTimeSource) Start(*p2p.Server) 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
)

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

func (s *NTPTimeSource) APIs() []rpc.API

APIs used to be conformant with service interface

func (*NTPTimeSource) Now

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

Now returns time adjusted by latest known offset

func (*NTPTimeSource) Protocols

func (s *NTPTimeSource) Protocols() []p2p.Protocol

Protocols used to conformant with service interface

func (*NTPTimeSource) Start

func (s *NTPTimeSource) Start(*p2p.Server) 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.