peersync

Documentation

Index

• Variables
• type Config
  • func DefaultConfig() Config
• type Network
• type Option
  • func WithConfig(config Config) Option
  • func WithContext(ctx context.Context) Option
  • func WithLog(lg log.Log) Option
  • func WithTime(t Time) Option
• type Request
• type Response
• type Sync
  • func New(network Network, opts ...Option) *Sync
  • func (s *Sync) GetOffset(ctx context.Context, id uint64, prs []peers.Peer) (time.Duration, error)
  • func (s *Sync) Start()
  • func (s *Sync) Stop()
  • func (s *Sync) Wait() error
• type Time

Variables

var (
	// ErrPeersNotSynced returned if system clock is out of sync with peers clock for configured period of time.
	ErrPeersNotSynced = errors.New("timesync: peers are not time synced")
	// ErrTimesyncFailed returned if we weren't able to collect enough clock samples from peers.
	ErrTimesyncFailed = errors.New("timesync: failed request")
)

Types

type Config

type Config struct {
	Disable            bool          `mapstructure:"disable"`
	RoundRetryInterval time.Duration `mapstructure:"round-retry-interval"`
	RoundInterval      time.Duration `mapstructure:"round-interval"`
	RoundTimeout       time.Duration `mapstructure:"round-timeout"`
	MaxClockOffset     time.Duration `mapstructure:"max-clock-offset"`
	MaxOffsetErrors    int           `mapstructure:"max-offset-errors"`
	RequiredResponses  int           `mapstructure:"required-responses"`
	// ResponsesBufferSize should be updated from p2pconfig.BufferSize
	ResponsesBufferSize int
}

Config for Sync.

func DefaultConfig

func DefaultConfig() Config

DefaultConfig for Sync.

type Network

type Network interface {
	RegisterDirectProtocolWithChannel(protocol string, ingressChannel chan service.DirectMessage) chan service.DirectMessage
	SendWrappedMessage(ctx context.Context, nodeID p2pcrypto.PublicKey, protocol string, payload *service.DataMsgWrapper) error
	SubscribePeerEvents() (added, expired chan p2pcrypto.PublicKey)
}

Network ...

type Option

type Option func(*Sync)

Option to modify Sync behavior.

func WithConfig

func WithConfig(config Config) Option

WithConfig modifies config used in Sync.

func WithContext

func WithContext(ctx context.Context) Option

WithContext modifies parent context that is used for all operations in Sync.

func WithLog

func WithLog(lg log.Log) Option

WithLog modifies Log used in Sync.

func WithTime

func WithTime(t Time) Option

WithTime modifies source of time used in Sync.

type Request

type Request struct {
	ID uint64
}

Request for time from a peer.

type Response

type Response struct {
	ID        uint64
	Timestamp int64
}

Response for time from a peer.

type Sync

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

Sync manages background worker that compares peers time with system time.

func New

func New(network Network, opts ...Option) *Sync

New creates Sync instance and returns pointer.

func (*Sync) GetOffset

func (s *Sync) GetOffset(ctx context.Context, id uint64, prs []peers.Peer) (time.Duration, error)

GetOffset computes offset from received response. The method is stateless and safe to use concurrently.

func (*Sync) Start

func (s *Sync) Start()

Start background workers.

func (*Sync) Stop

func (s *Sync) Stop()

Stop background workers.

func (*Sync) Wait

func (s *Sync) Wait() error

Wait will return first error that is returned by background workers.

type Time

type Time interface {
	Now() time.Time
}

Time ...