timesync

Documentation

Overview

Package timesync is used to check system time reliability by communicating with NTP time servers.

Index

• Constants
• func CheckMessageDrift(data int64) bool
• func CheckSystemClockDrift() (time.Duration, error)
• type Clock
• type LayerConv
  • func (lc LayerConv) LayerToTime(id types.LayerID) time.Time
  • func (lc LayerConv) TimeToLayer(t time.Time) types.LayerID
• type LayerConverter
• type LayerTimer
• type NtpPacket
  • func (n *NtpPacket) Time() time.Time
• type RealClock
  • func (RealClock) Now() time.Time
• type Ticker
  • func NewTicker(c Clock, lc LayerConverter, opts ...TickerOption) *Ticker
  • func (t *Ticker) AwaitLayer(layerID types.LayerID) chan struct{}
  • func (t *Ticker) GetCurrentLayer() types.LayerID
  • func (t *Ticker) Notify() (int, error)
  • func (t *Ticker) StartNotifying()
  • func (s Ticker) Subscribe() LayerTimer
  • func (s Ticker) Unsubscribe(ch LayerTimer)
• type TickerOption
  • func WithLog(lg log.Log) TickerOption
• type TimeClock
  • func NewClock(c Clock, tickInterval time.Duration, genesisTime time.Time, logger log.Log) *TimeClock
  • func (t *TimeClock) Close()
  • func (t *TimeClock) GetGenesisTime() time.Time
  • func (t *TimeClock) GetInterval() time.Duration
  • func (s TimeClock) Subscribe() LayerTimer
  • func (s TimeClock) Unsubscribe(ch LayerTimer)

Constants

const (
	// MaxAllowedMessageDrift is the time we limit we receive and handle delivered messages within
	MaxAllowedMessageDrift = 10 * time.Minute
	// NtpOffset is 70 years in seconds since ntp counts from 1900 and unix from 1970
	NtpOffset = 2208988800
	// DefaultNtpPort is the ntp protocol port
	DefaultNtpPort = "123"
	// MaxRequestTries is the number of times we try to query ntp before we give up when encountering errors.
	MaxRequestTries = 3
	// RequestTriesInterval is the interval to wait between tries to ask ntp for the time
	RequestTriesInterval = time.Second * 5
	// MinResultsThreshold is the minimum number of successful ntp query results to calculate the drift
	MinResultsThreshold = 3
)

Functions

func CheckMessageDrift

func CheckMessageDrift(data int64) bool

CheckMessageDrift checks if a given message timestamp is too far from our local clock. accepts a unix timestamp. can be created with Time.Now().Unix()

func CheckSystemClockDrift

func CheckSystemClockDrift() (time.Duration, error)

CheckSystemClockDrift is comparing our clock to the collected ntp data return the drift and an error when drift reading failed or exceeds our preset MaxAllowedDrift

Types

type Clock

type Clock interface {
	Now() time.Time
}

Clock defines the functionality needed from any clock type

type LayerConv

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

LayerConv is a converter between time to layer ID struct

func (LayerConv) LayerToTime

func (lc LayerConv) LayerToTime(id types.LayerID) time.Time

LayerToTime returns the time of the provided layer

func (LayerConv) TimeToLayer

func (lc LayerConv) TimeToLayer(t time.Time) types.LayerID

TimeToLayer returns the layer of the provided time

type LayerConverter

type LayerConverter interface {
	TimeToLayer(time.Time) types.LayerID
	LayerToTime(types.LayerID) time.Time
}

LayerConverter provides conversions from time to layer and vice versa

type LayerTimer

type LayerTimer chan types.LayerID

LayerTimer is a channel of LayerIDs Subscribers will receive the ticked layer through such channel

type NtpPacket

type NtpPacket struct {
	Settings       uint8  // leap yr indicator, ver number, and mode
	Stratum        uint8  // stratum of local clock
	Poll           int8   // poll exponent
	Precision      int8   // precision exponent
	RootDelay      uint32 // root delay
	RootDispersion uint32 // root dispersion
	ReferenceID    uint32 // reference id
	RefTimeSec     uint32 // reference timestamp sec
	RefTimeFrac    uint32 // reference timestamp fractional
	OrigTimeSec    uint32 // origin time secs
	OrigTimeFrac   uint32 // origin time fractional
	RxTimeSec      uint32 // receive time secs
	RxTimeFrac     uint32 // receive time frac3
	TxTimeSec      uint32 // transmit time secs
	TxTimeFrac     uint32 // transmit time frac
}

NtpPacket is a 48 bytes packet used for querying ntp information.

func (*NtpPacket) Time

func (n *NtpPacket) Time() time.Time

Time makes a Time struct from NtpPacket data.

type RealClock

type RealClock struct{}

RealClock is the struct wrapping a local time struct

func (RealClock) Now

func (RealClock) Now() time.Time

Now returns the current local time

type Ticker

type Ticker struct {
	LayerConverter // layer conversions provider
	// contains filtered or unexported fields
}

Ticker is the struct responsible for notifying that a layer has been ticked to subscribers

func NewTicker

func NewTicker(c Clock, lc LayerConverter, opts ...TickerOption) *Ticker

NewTicker returns a new instance of ticker

func (*Ticker) AwaitLayer

func (t *Ticker) AwaitLayer(layerID types.LayerID) chan struct{}

AwaitLayer returns a channel that will be signald when layer id layerID was ticked by the clock, or if this layer has passed while sleeping. it does so by closing the returned channel

func (*Ticker) GetCurrentLayer

func (t *Ticker) GetCurrentLayer() types.LayerID

GetCurrentLayer gets the current layer

func (*Ticker) Notify

func (t *Ticker) Notify() (int, error)

Notify notifies all the subscribers with the current layer if the tick time has passed notify is skipped and errMissedTickTime is returned notify may be skipped also for non-monotonic tick if some of the subscribers where not listening, they are skipped. In that case, errMissedTicks is returned along the number of subscribers not listening

func (*Ticker) StartNotifying

func (t *Ticker) StartNotifying()

StartNotifying starts the clock notifying

func (Ticker) Subscribe

func (s Ticker) Subscribe() LayerTimer

Subscribe returns a channel on which the subscriber will be notified when a new layer starts

func (Ticker) Unsubscribe

func (s Ticker) Unsubscribe(ch LayerTimer)

Unsubscribe removed subscriber channel ch from notification list

type TickerOption

type TickerOption func(*Ticker)

TickerOption to configure Ticker.

func WithLog

func WithLog(lg log.Log) TickerOption

WithLog configures logger for Ticker.

type TimeClock

type TimeClock struct {
	*Ticker
	// contains filtered or unexported fields
}

TimeClock is the struct holding a real clock

func NewClock

func NewClock(c Clock, tickInterval time.Duration, genesisTime time.Time, logger log.Log) *TimeClock

NewClock return TimeClock struct that notifies tickInterval has passed

func (*TimeClock) Close

func (t *TimeClock) Close()

Close closes the clock ticker

func (*TimeClock) GetGenesisTime

func (t *TimeClock) GetGenesisTime() time.Time

GetGenesisTime returns at which time this clock has started (used to calculate current tick)

func (*TimeClock) GetInterval

func (t *TimeClock) GetInterval() time.Duration

GetInterval returns the time interval between clock ticks

func (TimeClock) Subscribe

func (s TimeClock) Subscribe() LayerTimer

Subscribe returns a channel on which the subscriber will be notified when a new layer starts

func (TimeClock) Unsubscribe

func (s TimeClock) Unsubscribe(ch LayerTimer)

Unsubscribe removed subscriber channel ch from notification list