consensus

Jul 19, 2023

Changes in this version

type Bft

+ Node func() *enode.Node

type BftMock

+ func (bm *BftMock) Node() *enode.Node

Nov 30, 2022

Changes in this version

type BftMock

+ func (bm *BftMock) Stop() error

type BlockCacheWriter

+ Stop func()

type Engine

+ Stop func() error

Mar 31, 2022

Changes in this version

type BftMock

+ func NewFakerWithDataBase(database ethdb.Database) *BftMock

Apr 24, 2021

Changes in this version

type BftMock

+ func (bm *BftMock) GetBlockByHashAndNum(hash common.Hash, number uint64) *types.Block

+ func (bm *BftMock) GetPrepareQC(number uint64) *ctypes.QuorumCert

+ func (bm *BftMock) Syncing() bool

type Engine

+ GetBlockByHashAndNum func(hash common.Hash, number uint64) *types.Block

+ Syncing func() bool

Dec 13, 2019

Changes in this version

type BftMock

+ Base *types.Block

+ Current *types.Block

+ EventMux *event.TypeMux

+ Next uint32

+ func NewFailFaker(number uint64) *BftMock

+ func NewFaker() *BftMock

Oct 21, 2019

Changes in this version

type Agency

+ OnCommit func(block *types.Block) error

type BftMock

+ func (bm *BftMock) DecodeExtra(extra []byte) (common.Hash, uint64, error)

type ChainReader

+ CurrentBlock func() *types.Block

type Engine

+ DecodeExtra func(extra []byte) (common.Hash, uint64, error)

Sep 7, 2019

Changes in this version

+ type Agency interface

+ Flush func(header *types.Header) error

+ GetLastNumber func(blockNumber uint64) uint64

+ GetValidator func(blockNumber uint64) (*cbfttypes.Validators, error)

+ IsCandidateNode func(nodeID discover.NodeID) bool

+ Sign func(msg interface{}) error

+ VerifyHeader func(header *types.Header, stateDB *state.StateDB) error

+ VerifySign func(msg interface{}) error

type Bft

+ NodeID func() discover.NodeID

+ Start func(chain ChainReader, blockCacheWriter BlockCacheWriter, pool TxPoolReset, ...) error

+ TracingSwitch func(flag int8)

type BftMock

+ Blocks []*types.Block

+ func (bm *BftMock) CalcBlockDeadline(timePoint time.Time) time.Time

+ func (bm *BftMock) CalcNextBlockTime(timePoint time.Time) time.Time

+ func (bm *BftMock) Evidences() string

+ func (bm *BftMock) GetBlockWithoutLock(hash common.Hash, number uint64) *types.Block

+ func (bm *BftMock) IsSignedBySelf(sealHash common.Hash, header *types.Header) bool

+ func (bm *BftMock) NodeID() discover.NodeID

+ func (bm *BftMock) Pause()

+ func (bm *BftMock) Resume()

+ func (bm *BftMock) Start(chain ChainReader, blockCacheWriter BlockCacheWriter, pool TxPoolReset, ...) error

+ func (bm *BftMock) TracingSwitch(flag int8)

+ func (bm *BftMock) UnmarshalEvidence(data []byte) (consensus.Evidences, error)

+ type BlockCacheWriter interface

+ ClearCache func(block *types.Block)

+ Execute func(block *types.Block, parent *types.Block) error

+ WriteBlock func(block *types.Block) error

type Engine

+ Pause func()

+ Resume func()

+ type TxPoolReset interface

+ ForkedReset func(newHeader *types.Header, rollback []*types.Block)

+ Reset func(newBlock *types.Block)

Jun 17, 2019

Changes in this version

+ var ErrMissingSignature = errors.New("extra-data 65 byte signature suffix missing")

+ var ExtraSeal = 65

+ func Ecrecover(header *types.Header, sigcache *lru.ARCCache) (common.Address, error)

+ func SigHash(header *types.Header) (hash common.Hash)

+ type Bft interface

+ CalcBlockDeadline func(timePoint int64) (time.Time, error)

+ CalcNextBlockTime func(timePoint int64) (time.Time, error)

+ CheckConsensusNode func(address common.Address) bool

+ CommitBlockBP func(block *types.Block, txs int, gasUsed uint64, elapse time.Duration)

+ ConsensusNodes func() ([]discover.NodeID, error)

+ Evidences func() string

+ GetBlock func(hash common.Hash, number uint64) *types.Block

+ GetBlockWithoutLock func(hash common.Hash, number uint64) *types.Block

+ HighestConfirmedBlock func() *types.Block

+ HighestLogicalBlock func() *types.Block

+ IsConsensusNode func() bool

+ IsSignedBySelf func(sealHash common.Hash, signature []byte) bool

+ OnPong func(nodeID discover.NodeID, netLatency int64) error

+ SetPrivateKey func(privateKey *ecdsa.PrivateKey)

+ ShouldSeal func(curTime int64) (bool, error)

+ type BftMock struct

+ func (bm *BftMock) APIs(chain ChainReader) []rpc.API

+ func (bm *BftMock) Author(header *types.Header) (common.Address, error)

+ func (bm *BftMock) CalcDifficulty(chain ChainReader, time uint64, parent *types.Header) *big.Int

+ func (bm *BftMock) CheckConsensusNode(nodeID discover.NodeID) (bool, error)

+ func (bm *BftMock) Close() error

+ func (bm *BftMock) ConsensusNodes() ([]discover.NodeID, error)

+ func (bm *BftMock) CurrentBlock() *types.Block

+ func (bm *BftMock) FastSyncCommitHead() <-chan error

+ func (bm *BftMock) Finalize(chain ChainReader, header *types.Header, state *state.StateDB, ...) (*types.Block, error)

+ func (bm *BftMock) GetBlock(hash common.Hash, number uint64) *types.Block

+ func (bm *BftMock) GetBlockByHash(hash common.Hash) *types.Block

+ func (bm *BftMock) HasBlock(hash common.Hash, number uint64) bool

+ func (bm *BftMock) HighestConfirmedBlock() *types.Block

+ func (bm *BftMock) HighestLogicalBlock() *types.Block

+ func (bm *BftMock) InsertChain(block *types.Block, errCh chan error)

+ func (bm *BftMock) IsConsensusNode() (bool, error)

+ func (bm *BftMock) NextBaseBlock() *types.Block

+ func (bm *BftMock) OnBlockSignature(chain ChainReader, nodeID discover.NodeID, sig *cbfttypes.BlockSignature) error

+ func (bm *BftMock) OnBlockSynced()

+ func (bm *BftMock) OnNewBlock(chain ChainReader, block *types.Block) error

+ func (bm *BftMock) OnPong(nodeID discover.NodeID, netLatency int64) error

+ func (bm *BftMock) Prepare(chain ChainReader, header *types.Header) error

+ func (bm *BftMock) Protocols() []p2p.Protocol

+ func (bm *BftMock) Seal(chain ChainReader, block *types.Block, results chan<- *types.Block, ...) error

+ func (bm *BftMock) SealHash(header *types.Header) common.Hash

+ func (bm *BftMock) SetPrivateKey(privateKey *ecdsa.PrivateKey)

+ func (bm *BftMock) ShouldSeal(curTime int64) (bool, error)

+ func (bm *BftMock) Status() string

+ func (bm *BftMock) VerifyHeader(chain ChainReader, header *types.Header, seal bool) error

+ func (bm *BftMock) VerifyHeaders(chain ChainReader, headers []*types.Header, seals []bool) (chan<- struct{}, <-chan error)

+ func (bm *BftMock) VerifySeal(chain ChainReader, header *types.Header) error

+ func (bm *BftMock) VerifyUncles(chain ChainReader, block *types.Block) error

type Engine

+ CurrentBlock func() *types.Block

+ FastSyncCommitHead func() <-chan error

+ GetBlockByHash func(hash common.Hash) *types.Block

+ HasBlock func(hash common.Hash, number uint64) bool

+ InsertChain func(block *types.Block, errCh chan error)

+ NextBaseBlock func() *types.Block

+ Protocols func() []p2p.Protocol

+ Status func() string

Sep 24, 2018

Changes in this version

+ var ErrFutureBlock = errors.New("block in the future")

+ var ErrInvalidNumber = errors.New("invalid block number")

+ var ErrPrunedAncestor = errors.New("pruned ancestor")

+ var ErrUnknownAncestor = errors.New("unknown ancestor")

+ type ChainReader interface

+ Config func() *params.ChainConfig

+ CurrentHeader func() *types.Header

+ GetBlock func(hash common.Hash, number uint64) *types.Block

+ GetHeader func(hash common.Hash, number uint64) *types.Header

+ GetHeaderByHash func(hash common.Hash) *types.Header

+ GetHeaderByNumber func(number uint64) *types.Header

+ type Engine interface

+ APIs func(chain ChainReader) []rpc.API

+ Author func(header *types.Header) (common.Address, error)

+ CalcDifficulty func(chain ChainReader, time uint64, parent *types.Header) *big.Int

+ Close func() error

+ Finalize func(chain ChainReader, header *types.Header, state *state.StateDB, ...) (*types.Block, error)

+ Prepare func(chain ChainReader, header *types.Header) error

+ Seal func(chain ChainReader, block *types.Block, results chan<- *types.Block, ...) error

+ SealHash func(header *types.Header) common.Hash

+ VerifyHeader func(chain ChainReader, header *types.Header, seal bool) error

+ VerifyHeaders func(chain ChainReader, headers []*types.Header, seals []bool) (chan<- struct{}, <-chan error)

+ VerifySeal func(chain ChainReader, header *types.Header) error

+ VerifyUncles func(chain ChainReader, block *types.Block) error

+ type PoW interface

+ Hashrate func() float64