sync

Documentation

Index

• type Config
  • func DefaultConfig() *Config
  • func (conf *Config) BasicCheck() error
  • func (conf *Config) CacheSize() int
  • func (conf *Config) Services() service.Services
• type MockSync
  • func MockingSync(ts *testsuite.TestSuite) *MockSync
  • func (*MockSync) GetClockOffset() (time.Duration, error)
  • func (*MockSync) Moniker() string
  • func (*MockSync) OutOfSync(_ time.Duration) bool
  • func (m *MockSync) PeerSet() *peerset.PeerSet
  • func (m *MockSync) SelfID() peer.ID
  • func (m *MockSync) Services() service.Services
  • func (*MockSync) Start() error
  • func (*MockSync) Stop()
• type Synchronizer
  • func NewSynchronizer(conf *Config, valKeys []*bls.ValidatorKey, st state.Facade, ...) (Synchronizer, error)

Types

type Config

type Config struct {
	Moniker        string           `toml:"moniker"`
	SessionTimeout time.Duration    `toml:"session_timeout"`
	NodeNetwork    bool             `toml:"node_network"`
	Firewall       *firewall.Config `toml:"firewall"`

	// Private configs
	MaxSessions         int             `toml:"-"`
	LatestBlockInterval uint32          `toml:"-"`
	BlockPerMessage     uint32          `toml:"-"`
	LatestSupportingVer version.Version `toml:"-"`
}

func DefaultConfig

func DefaultConfig() *Config

func (*Config) BasicCheck

func (conf *Config) BasicCheck() error

BasicCheck performs basic checks on the configuration.

func (*Config) CacheSize

func (conf *Config) CacheSize() int

func (*Config) Services

func (conf *Config) Services() service.Services

type MockSync

type MockSync struct {
	TestID       peer.ID
	TestPeerSet  *peerset.PeerSet
	TestServices service.Services
}

func MockingSync

func MockingSync(ts *testsuite.TestSuite) *MockSync

func (*MockSync) GetClockOffset

func (*MockSync) GetClockOffset() (time.Duration, error)

func (*MockSync) Moniker

func (*MockSync) Moniker() string

func (*MockSync) OutOfSync

func (*MockSync) OutOfSync(_ time.Duration) bool

func (*MockSync) PeerSet

func (m *MockSync) PeerSet() *peerset.PeerSet

func (*MockSync) SelfID

func (m *MockSync) SelfID() peer.ID

func (*MockSync) Services

func (m *MockSync) Services() service.Services

func (*MockSync) Start

func (*MockSync) Start() error

func (*MockSync) Stop

func (*MockSync) Stop()

type Synchronizer

type Synchronizer interface {
	Start() error
	Stop()
	Moniker() string
	SelfID() peer.ID
	PeerSet() *peerset.PeerSet
	Services() service.Services
	GetClockOffset() (time.Duration, error)
	OutOfSync(time.Duration) bool
}

func NewSynchronizer

func NewSynchronizer(
	conf *Config,
	valKeys []*bls.ValidatorKey,
	st state.Facade,
	consMgr consensus.Manager,
	net network.Network,
	broadcastCh <-chan message.Message,
) (Synchronizer, error)