sync

Documentation

Index

• Variables
• type Config
  • func DefaultConfig() *Config
  • func (conf *Config) SanityCheck() error
• type MockSync
  • func MockingSync() *MockSync
  • func (m *MockSync) Fingerprint() string
  • func (m *MockSync) Moniker() string
  • func (m *MockSync) Peers() []peerset.Peer
  • func (m *MockSync) SelfID() peer.ID
  • func (m *MockSync) Start() error
  • func (m *MockSync) Stop()
• type Synchronizer
  • func NewSynchronizer(conf *Config, signers []crypto.Signer, state state.Facade, ...) (Synchronizer, error)

Variables

var LatestBlockInterval = uint32(720) // 720 blocks is about two hours

Types

type Config

type Config struct {
	Moniker         string           `toml:"moniker"`
	HeartBeatTimer  time.Duration    `toml:"heartbeat_timer"`
	SessionTimeout  time.Duration    `toml:"session_timeout"`
	MaxOpenSessions int              `toml:"max_open_sessions"`
	BlockPerMessage uint32           `toml:"block_per_message"`
	CacheSize       int              `toml:"cache_size"`
	NodeNetwork     bool             `toml:"node_network"`
	Firewall        *firewall.Config `toml:"firewall"`
}

func DefaultConfig

func DefaultConfig() *Config

func (*Config) SanityCheck

func (conf *Config) SanityCheck() error

SanityCheck performs basic checks on the configuration.

type MockSync

type MockSync struct {
	ID      peer.ID
	PeerSet *peerset.PeerSet
}

func MockingSync

func MockingSync() *MockSync

func (*MockSync) Fingerprint

func (m *MockSync) Fingerprint() string

func (*MockSync) Moniker

func (m *MockSync) Moniker() string

func (*MockSync) Peers

func (m *MockSync) Peers() []peerset.Peer

func (*MockSync) SelfID

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

func (*MockSync) Start

func (m *MockSync) Start() error

func (*MockSync) Stop

func (m *MockSync) Stop()

type Synchronizer

type Synchronizer interface {
	Start() error
	Stop()
	Moniker() string
	SelfID() peer.ID
	Peers() []peerset.Peer
	Fingerprint() string
}

func NewSynchronizer

func NewSynchronizer(
	conf *Config,
	signers []crypto.Signer,
	state state.Facade,
	consMgr consensus.Manager,
	net network.Network,
	broadcastCh <-chan message.Message) (Synchronizer, error)