block_sync

Documentation

Index

• type BlockSync
  • func NewBlockSync(logger logrus.FieldLogger, fn func(height uint64) (*types.Block, error), ...) (*BlockSync, error)
  • func (bs *BlockSync) Commit() chan []*types.Block
  • func (bs *BlockSync) InitBlockSyncInfo(peers []string, latestBlockHash string, quorum, curHeight, targetHeight uint64, ...)
  • func (bs *BlockSync) Start() error
  • func (bs *BlockSync) StartSync(peers []string, latestBlockHash string, quorum, curHeight, targetHeight uint64, ...) error
  • func (bs *BlockSync) Stop()
  • func (bs *BlockSync) StopSync() error
• type Sync

Types

type BlockSync

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

todo: requester and chunk change to sync pool

func NewBlockSync

func NewBlockSync(logger logrus.FieldLogger, fn func(height uint64) (*types.Block, error), network network.Network, cnf repo.Sync) (*BlockSync, error)

func (*BlockSync) Commit

func (bs *BlockSync) Commit() chan []*types.Block

func (*BlockSync) InitBlockSyncInfo

func (bs *BlockSync) InitBlockSyncInfo(peers []string, latestBlockHash string, quorum, curHeight, targetHeight uint64,
	quorumCheckpoint *consensus.SignedCheckpoint, epc ...*consensus.EpochChange)

func (*BlockSync) Start

func (bs *BlockSync) Start() error

func (*BlockSync) StartSync

func (bs *BlockSync) StartSync(peers []string, latestBlockHash string, quorum, curHeight, targetHeight uint64,
	quorumCheckpoint *consensus.SignedCheckpoint, epc ...*consensus.EpochChange) error

func (*BlockSync) Stop

func (bs *BlockSync) Stop()

func (*BlockSync) StopSync

func (bs *BlockSync) StopSync() error

type Sync

type Sync interface {
	Start() error
	Stop()
	Commit() chan []*types.Block
	StartSync(peers []string, curBlockHash string, quorum, curHeight, targetHeight uint64, quorumCheckpoint *consensus.SignedCheckpoint, epc ...*consensus.EpochChange) error
	StopSync() error
}