chainsync

Documentation

Index

• type BlockProposer
• type Manager
  • func NewManager(fv syncer.StateProcessor, hv *consensus.BlockValidator, ...) (Manager, error)
  • func (m *Manager) BlockProposer() BlockProposer
  • func (m *Manager) Start(ctx context.Context) error

Types

type BlockProposer

type BlockProposer interface {
	SetConcurrent(number int64)
	Concurrent() int64
	SyncTracker() *types.TargetTracker
	SendHello(ci *types2.ChainInfo) error
	SendOwnBlock(ci *types2.ChainInfo) error
	SendGossipBlock(ci *types2.ChainInfo) error
}

BlockProposer allows callers to propose new blocks for inclusion in the chain.

type Manager

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

Manager sync the chain.

func NewManager

func NewManager(fv syncer.StateProcessor,
	hv *consensus.BlockValidator,
	cs syncer.ChainSelector,
	s syncer.ChainReaderWriter,
	m *chain.MessageStore,
	bsstore blockstore.Blockstore,
	exchangeClient exchange.Client,
	c clock.Clock,
	fork fork.IFork) (Manager, error)

NewManager creates a new chain sync manager.

func (*Manager) BlockProposer

func (m *Manager) BlockProposer() BlockProposer

BlockProposer returns the block proposer.

func (*Manager) Start

func (m *Manager) Start(ctx context.Context) error

Start starts the chain sync manager.