Versions in this module Expand all Collapse all v0 v0.5.0 Mar 23, 2021 Changes in this version + type Database struct + func (db *Database) ContainsSnapShotHdrNode(txn *badger.Txn, root []byte) (bool, error) + func (db *Database) CountPendingHdrLeafKeys(txn *badger.Txn) (int, error) + func (db *Database) CountPendingHdrNodeKeys(txn *badger.Txn) (int, error) + func (db *Database) CountPendingLeafKeys(txn *badger.Txn) (int, error) + func (db *Database) CountPendingNodeKeys(txn *badger.Txn) (int, error) + func (db *Database) CountStagedBlockHeaderKeys(txn *badger.Txn) (int, error) + func (db *Database) DB() *badger.DB + func (db *Database) DeleteBeforeHistoricRoundState(txn *badger.Txn, height uint32, maxnum int) error + func (db *Database) DeleteCommittedBlockHeader(txn *badger.Txn, height uint32) error + func (db *Database) DeletePendingHdrLeafKey(txn *badger.Txn, hdrLeafKey []byte) error + func (db *Database) DeletePendingHdrNodeKey(txn *badger.Txn, nodeKey []byte) error + func (db *Database) DeletePendingLeafKey(txn *badger.Txn, leafKey []byte) error + func (db *Database) DeletePendingNodeKey(txn *badger.Txn, nodeKey []byte) error + func (db *Database) DeleteStagedBlockHeaderKey(txn *badger.Txn, height uint32) error + func (db *Database) DropPendingHdrLeafKeys() error + func (db *Database) DropPendingHdrNodeKeys() error + func (db *Database) DropPendingLeafKeys() error + func (db *Database) DropPendingNodeKeys() error + func (db *Database) DropStagedBlockHeaderKeys() error + func (db *Database) GarbageCollect() error + func (db *Database) GetBroadcastBlockHeader(txn *badger.Txn) (*objs.BlockHeader, error) + func (db *Database) GetBroadcastNextHeight(txn *badger.Txn) (*objs.NextHeight, error) + func (db *Database) GetBroadcastNextRound(txn *badger.Txn) (*objs.NextRound, error) + func (db *Database) GetBroadcastPreCommit(txn *badger.Txn) (*objs.PreCommit, error) + func (db *Database) GetBroadcastPreCommitNil(txn *badger.Txn) (*objs.PreCommitNil, error) + func (db *Database) GetBroadcastPreVote(txn *badger.Txn) (*objs.PreVote, error) + func (db *Database) GetBroadcastPreVoteNil(txn *badger.Txn) (*objs.PreVoteNil, error) + func (db *Database) GetBroadcastProposal(txn *badger.Txn) (*objs.Proposal, error) + func (db *Database) GetBroadcastRCert(txn *badger.Txn) (*objs.RCert, error) + func (db *Database) GetCommittedBlockHeader(txn *badger.Txn, height uint32) (*objs.BlockHeader, error) + func (db *Database) GetCommittedBlockHeaderByHash(txn *badger.Txn, hash []byte) (*objs.BlockHeader, error) + func (db *Database) GetCommittedBlockHeaderWithProof(txn *badger.Txn, root []byte, blockHeight uint32) (*objs.BlockHeader, []byte, error) + func (db *Database) GetCurrentRoundState(txn *badger.Txn, vaddr []byte) (*objs.RoundState, error) + func (db *Database) GetEncryptedStore(txn *badger.Txn, name []byte) (*objs.EncryptedStore, error) + func (db *Database) GetHeaderRootForProposal(txn *badger.Txn) ([]byte, error) + func (db *Database) GetHeaderTrieRoot(txn *badger.Txn, height uint32) ([]byte, error) + func (db *Database) GetHistoricRoundState(txn *badger.Txn, vaddr []byte, height uint32, round uint32) (*objs.RoundState, error) + func (db *Database) GetLastSnapshot(txn *badger.Txn) (*objs.BlockHeader, error) + func (db *Database) GetMostRecentCommittedBlockHeaderFastSync(txn *badger.Txn) (*objs.BlockHeader, error) + func (db *Database) GetOwnState(txn *badger.Txn) (*objs.OwnState, error) + func (db *Database) GetOwnValidatingState(txn *badger.Txn) (*objs.OwnValidatingState, error) + func (db *Database) GetPendingHdrLeafKey(txn *badger.Txn, hdrLeafKey []byte) ([]byte, error) + func (db *Database) GetPendingHdrLeafKeysIter(txn *badger.Txn) *PendingHdrLeafIter + func (db *Database) GetPendingHdrNodeKey(txn *badger.Txn, nodeKey []byte) (int, error) + func (db *Database) GetPendingHdrNodeKeysIter(txn *badger.Txn) *PendingHdrNodeIter + func (db *Database) GetPendingLeafKey(txn *badger.Txn, leafKey []byte) ([]byte, error) + func (db *Database) GetPendingLeafKeysIter(txn *badger.Txn) *PendingLeafIter + func (db *Database) GetPendingNodeKey(txn *badger.Txn, nodeKey []byte) (int, error) + func (db *Database) GetPendingNodeKeysIter(txn *badger.Txn) *PendingNodeIter + func (db *Database) GetSafeToProceed(txn *badger.Txn, height uint32) (bool, error) + func (db *Database) GetSnapShotHdrNode(txn *badger.Txn, root []byte) ([]byte, error) + func (db *Database) GetSnapshotBlockHeader(txn *badger.Txn, height uint32) (*objs.BlockHeader, error) + func (db *Database) GetStagedBlockHeader(txn *badger.Txn, height uint32) (*objs.BlockHeader, error) + func (db *Database) GetStagedBlockHeaderKeyIter(txn *badger.Txn) *StagedBlockHeaderKeyIter + func (db *Database) GetTxCacheItem(txn *badger.Txn, height uint32, txHash []byte) ([]byte, error) + func (db *Database) GetTxCacheSet(txn *badger.Txn, height uint32) ([][]byte, [][]byte, error) + func (db *Database) GetValidatorSet(txn *badger.Txn, height uint32) (*objs.ValidatorSet, error) + func (db *Database) Init(DB *badger.DB) error + func (db *Database) MakeHeaderTrieKeyFromHeight(height uint32) []byte + func (db *Database) SetBroadcastBlockHeader(txn *badger.Txn, v *objs.BlockHeader) error + func (db *Database) SetBroadcastNextHeight(txn *badger.Txn, v *objs.NextHeight) error + func (db *Database) SetBroadcastNextRound(txn *badger.Txn, v *objs.NextRound) error + func (db *Database) SetBroadcastPreCommit(txn *badger.Txn, v *objs.PreCommit) error + func (db *Database) SetBroadcastPreCommitNil(txn *badger.Txn, v *objs.PreCommitNil) error + func (db *Database) SetBroadcastPreVote(txn *badger.Txn, v *objs.PreVote) error + func (db *Database) SetBroadcastPreVoteNil(txn *badger.Txn, v *objs.PreVoteNil) error + func (db *Database) SetBroadcastProposal(txn *badger.Txn, v *objs.Proposal) error + func (db *Database) SetBroadcastRCert(txn *badger.Txn, v *objs.RCert) error + func (db *Database) SetBroadcastTransaction(txn *badger.Txn, v []byte) error + func (db *Database) SetCommittedBlockHeader(txn *badger.Txn, v *objs.BlockHeader) error + func (db *Database) SetCommittedBlockHeaderFastSync(txn *badger.Txn, v *objs.BlockHeader) error + func (db *Database) SetCurrentRoundState(txn *badger.Txn, v *objs.RoundState) error + func (db *Database) SetEncryptedStore(txn *badger.Txn, v *objs.EncryptedStore) error + func (db *Database) SetHeaderTrieRoot(txn *badger.Txn, height uint32, root []byte) error + func (db *Database) SetHistoricRoundState(txn *badger.Txn, v *objs.RoundState) error + func (db *Database) SetOwnState(txn *badger.Txn, v *objs.OwnState) error + func (db *Database) SetOwnValidatingState(txn *badger.Txn, v *objs.OwnValidatingState) error + func (db *Database) SetPendingHdrLeafKey(txn *badger.Txn, hdrLeafKey []byte, value []byte) error + func (db *Database) SetPendingHdrNodeKey(txn *badger.Txn, nodeKey []byte, layer int) error + func (db *Database) SetPendingLeafKey(txn *badger.Txn, leafKey []byte, value []byte) error + func (db *Database) SetPendingNodeKey(txn *badger.Txn, nodeKey []byte, layer int) error + func (db *Database) SetSafeToProceed(txn *badger.Txn, height uint32, isSafe bool) error + func (db *Database) SetSnapShotHdrNode(txn *badger.Txn, batch []byte, root []byte, layer int) ([][]byte, int, []trie.LeafNode, error) + func (db *Database) SetSnapshotBlockHeader(txn *badger.Txn, v *objs.BlockHeader) error + func (db *Database) SetStagedBlockHeader(txn *badger.Txn, height uint32, value []byte) error + func (db *Database) SetTxCacheItem(txn *badger.Txn, height uint32, txHash []byte, tx []byte) error + func (db *Database) SetValidatorSet(txn *badger.Txn, v *objs.ValidatorSet) error + func (db *Database) SubscribeBroadcastBlockHeader(ctx context.Context, cb func([]byte) error) + func (db *Database) SubscribeBroadcastNextHeight(ctx context.Context, cb func([]byte) error) + func (db *Database) SubscribeBroadcastNextRound(ctx context.Context, cb func([]byte) error) + func (db *Database) SubscribeBroadcastPreCommit(ctx context.Context, cb func([]byte) error) + func (db *Database) SubscribeBroadcastPreCommitNil(ctx context.Context, cb func([]byte) error) + func (db *Database) SubscribeBroadcastPreVote(ctx context.Context, cb func([]byte) error) + func (db *Database) SubscribeBroadcastPreVoteNil(ctx context.Context, cb func([]byte) error) + func (db *Database) SubscribeBroadcastProposal(ctx context.Context, cb func([]byte) error) + func (db *Database) SubscribeBroadcastRCert(ctx context.Context, cb func([]byte) error) + func (db *Database) SubscribeBroadcastTransaction(ctx context.Context, cb func([]byte) error) + func (db *Database) Sync() error + func (db *Database) TxCacheDropBefore(txn *badger.Txn, beforeHeight uint32, maxKeys int) error + func (db *Database) Update(fn TxnFunc) error + func (db *Database) UpdateHeaderTrieRootFastSync(txn *badger.Txn, v *objs.BlockHeader) error + func (db *Database) ValidateCommittedBlockHeaderWithProof(txn *badger.Txn, root []byte, blockHeader *objs.BlockHeader, proof []byte) (bool, error) + func (db *Database) View(fn TxnFunc) error + type DatabaseIface interface + ContainsSnapShotHdrNode func(txn *badger.Txn, root []byte) (bool, error) + CountPendingHdrLeafKeys func(txn *badger.Txn) (int, error) + CountPendingHdrNodeKeys func(txn *badger.Txn) (int, error) + CountPendingLeafKeys func(txn *badger.Txn) (int, error) + CountPendingNodeKeys func(txn *badger.Txn) (int, error) + CountStagedBlockHeaderKeys func(txn *badger.Txn) (int, error) + DB func() *badger.DB + DeleteBeforeHistoricRoundState func(txn *badger.Txn, height uint32, maxnum int) error + DeleteCommittedBlockHeader func(txn *badger.Txn, height uint32) error + DeletePendingHdrLeafKey func(txn *badger.Txn, hdrLeafKey []byte) error + DeletePendingHdrNodeKey func(txn *badger.Txn, nodeKey []byte) error + DeletePendingLeafKey func(txn *badger.Txn, leafKey []byte) error + DeletePendingNodeKey func(txn *badger.Txn, nodeKey []byte) error + DeleteStagedBlockHeaderKey func(txn *badger.Txn, height uint32) error + DropPendingHdrLeafKeys func() error + DropPendingHdrNodeKeys func() error + DropPendingLeafKeys func() error + DropPendingNodeKeys func() error + DropStagedBlockHeaderKeys func() error + GarbageCollect func() error + GetBroadcastBlockHeader func(txn *badger.Txn) (*objs.BlockHeader, error) + GetBroadcastNextHeight func(txn *badger.Txn) (*objs.NextHeight, error) + GetBroadcastNextRound func(txn *badger.Txn) (*objs.NextRound, error) + GetBroadcastPreCommit func(txn *badger.Txn) (*objs.PreCommit, error) + GetBroadcastPreCommitNil func(txn *badger.Txn) (*objs.PreCommitNil, error) + GetBroadcastPreVote func(txn *badger.Txn) (*objs.PreVote, error) + GetBroadcastPreVoteNil func(txn *badger.Txn) (*objs.PreVoteNil, error) + GetBroadcastProposal func(txn *badger.Txn) (*objs.Proposal, error) + GetBroadcastRCert func(txn *badger.Txn) (*objs.RCert, error) + GetCommittedBlockHeader func(txn *badger.Txn, height uint32) (*objs.BlockHeader, error) + GetCommittedBlockHeaderByHash func(txn *badger.Txn, hash []byte) (*objs.BlockHeader, error) + GetCommittedBlockHeaderWithProof func(txn *badger.Txn, root []byte, blockHeight uint32) (*objs.BlockHeader, []byte, error) + GetCurrentRoundState func(txn *badger.Txn, vaddr []byte) (*objs.RoundState, error) + GetEncryptedStore func(txn *badger.Txn, name []byte) (*objs.EncryptedStore, error) + GetHeaderRootForProposal func(txn *badger.Txn) ([]byte, error) + GetHeaderTrieRoot func(txn *badger.Txn, height uint32) ([]byte, error) + GetHistoricRoundState func(txn *badger.Txn, vaddr []byte, height uint32, round uint32) (*objs.RoundState, error) + GetLastSnapshot func(txn *badger.Txn) (*objs.BlockHeader, error) + GetMostRecentCommittedBlockHeaderFastSync func(txn *badger.Txn) (*objs.BlockHeader, error) + GetOwnState func(txn *badger.Txn) (*objs.OwnState, error) + GetOwnValidatingState func(txn *badger.Txn) (*objs.OwnValidatingState, error) + GetPendingHdrLeafKey func(txn *badger.Txn, hdrLeafKey []byte) ([]byte, error) + GetPendingHdrLeafKeysIter func(txn *badger.Txn) *PendingHdrLeafIter + GetPendingHdrNodeKey func(txn *badger.Txn, nodeKey []byte) (int, error) + GetPendingHdrNodeKeysIter func(txn *badger.Txn) *PendingHdrNodeIter + GetPendingLeafKey func(txn *badger.Txn, leafKey []byte) ([]byte, error) + GetPendingLeafKeysIter func(txn *badger.Txn) *PendingLeafIter + GetPendingNodeKey func(txn *badger.Txn, nodeKey []byte) (int, error) + GetPendingNodeKeysIter func(txn *badger.Txn) *PendingNodeIter + GetSafeToProceed func(txn *badger.Txn, height uint32) (bool, error) + GetSnapShotHdrNode func(txn *badger.Txn, root []byte) ([]byte, error) + GetSnapshotBlockHeader func(txn *badger.Txn, height uint32) (*objs.BlockHeader, error) + GetStagedBlockHeader func(txn *badger.Txn, height uint32) (*objs.BlockHeader, error) + GetStagedBlockHeaderKeyIter func(txn *badger.Txn) *StagedBlockHeaderKeyIter + GetTxCacheItem func(txn *badger.Txn, height uint32, txHash []byte) ([]byte, error) + GetTxCacheSet func(txn *badger.Txn, height uint32) ([][]byte, [][]byte, error) + GetValidatorSet func(txn *badger.Txn, height uint32) (*objs.ValidatorSet, error) + Init func(DB *badger.DB) error + MakeHeaderTrieKeyFromHeight func(height uint32) []byte + SetBroadcastBlockHeader func(txn *badger.Txn, v *objs.BlockHeader) error + SetBroadcastNextHeight func(txn *badger.Txn, v *objs.NextHeight) error + SetBroadcastNextRound func(txn *badger.Txn, v *objs.NextRound) error + SetBroadcastPreCommit func(txn *badger.Txn, v *objs.PreCommit) error + SetBroadcastPreCommitNil func(txn *badger.Txn, v *objs.PreCommitNil) error + SetBroadcastPreVote func(txn *badger.Txn, v *objs.PreVote) error + SetBroadcastPreVoteNil func(txn *badger.Txn, v *objs.PreVoteNil) error + SetBroadcastProposal func(txn *badger.Txn, v *objs.Proposal) error + SetBroadcastRCert func(txn *badger.Txn, v *objs.RCert) error + SetBroadcastTransaction func(txn *badger.Txn, v []byte) error + SetCommittedBlockHeader func(txn *badger.Txn, v *objs.BlockHeader) error + SetCommittedBlockHeaderFastSync func(txn *badger.Txn, v *objs.BlockHeader) error + SetCurrentRoundState func(txn *badger.Txn, v *objs.RoundState) error + SetEncryptedStore func(txn *badger.Txn, v *objs.EncryptedStore) error + SetHistoricRoundState func(txn *badger.Txn, v *objs.RoundState) error + SetOwnState func(txn *badger.Txn, v *objs.OwnState) error + SetOwnValidatingState func(txn *badger.Txn, v *objs.OwnValidatingState) error + SetPendingHdrLeafKey func(txn *badger.Txn, hdrLeafKey []byte, value []byte) error + SetPendingHdrNodeKey func(txn *badger.Txn, nodeKey []byte, layer int) error + SetPendingLeafKey func(txn *badger.Txn, leafKey []byte, value []byte) error + SetPendingNodeKey func(txn *badger.Txn, nodeKey []byte, layer int) error + SetSafeToProceed func(txn *badger.Txn, height uint32, isSafe bool) error + SetSnapShotHdrNode func(txn *badger.Txn, batch []byte, root []byte, layer int) ([][]byte, int, []trie.LeafNode, error) + SetSnapshotBlockHeader func(txn *badger.Txn, v *objs.BlockHeader) error + SetStagedBlockHeader func(txn *badger.Txn, height uint32, value []byte) error + SetTxCacheItem func(txn *badger.Txn, height uint32, txHash []byte, tx []byte) error + SetValidatorSet func(txn *badger.Txn, v *objs.ValidatorSet) error + SubscribeBroadcastBlockHeader func(ctx context.Context, cb func([]byte) error) + SubscribeBroadcastNextHeight func(ctx context.Context, cb func([]byte) error) + SubscribeBroadcastNextRound func(ctx context.Context, cb func([]byte) error) + SubscribeBroadcastPreCommit func(ctx context.Context, cb func([]byte) error) + SubscribeBroadcastPreCommitNil func(ctx context.Context, cb func([]byte) error) + SubscribeBroadcastPreVote func(ctx context.Context, cb func([]byte) error) + SubscribeBroadcastPreVoteNil func(ctx context.Context, cb func([]byte) error) + SubscribeBroadcastProposal func(ctx context.Context, cb func([]byte) error) + SubscribeBroadcastRCert func(ctx context.Context, cb func([]byte) error) + SubscribeBroadcastTransaction func(ctx context.Context, cb func([]byte) error) + Sync func() error + TxCacheDropBefore func(txn *badger.Txn, beforeHeight uint32, maxKeys int) error + Update func(fn TxnFunc) error + UpdateHeaderTrieRootFastSync func(txn *badger.Txn, v *objs.BlockHeader) error + ValidateCommittedBlockHeaderWithProof func(txn *badger.Txn, root []byte, blockHeader *objs.BlockHeader, proof []byte) (bool, error) + View func(fn TxnFunc) error + type MerkleProof struct + Bitmap []byte + Included bool + Key []byte + KeyHeight int + Path [][]byte + Value []byte + func (mp *MerkleProof) MarshalBinary() ([]byte, error) + func (mp *MerkleProof) UnmarshalBinary(data []byte) error + type MockDatabaseIface struct + func NewMockDatabaseIface(ctrl *gomock.Controller) *MockDatabaseIface + func (m *MockDatabaseIface) ContainsSnapShotHdrNode(txn *v2.Txn, root []byte) (bool, error) + func (m *MockDatabaseIface) CountPendingHdrLeafKeys(txn *v2.Txn) (int, error) + func (m *MockDatabaseIface) CountPendingHdrNodeKeys(txn *v2.Txn) (int, error) + func (m *MockDatabaseIface) CountPendingLeafKeys(txn *v2.Txn) (int, error) + func (m *MockDatabaseIface) CountPendingNodeKeys(txn *v2.Txn) (int, error) + func (m *MockDatabaseIface) CountStagedBlockHeaderKeys(txn *v2.Txn) (int, error) + func (m *MockDatabaseIface) DB() *v2.DB + func (m *MockDatabaseIface) DeleteBeforeHistoricRoundState(txn *v2.Txn, height uint32, maxnum int) error + func (m *MockDatabaseIface) DeleteCommittedBlockHeader(txn *v2.Txn, height uint32) error + func (m *MockDatabaseIface) DeletePendingHdrLeafKey(txn *v2.Txn, hdrLeafKey []byte) error + func (m *MockDatabaseIface) DeletePendingHdrNodeKey(txn *v2.Txn, nodeKey []byte) error + func (m *MockDatabaseIface) DeletePendingLeafKey(txn *v2.Txn, leafKey []byte) error + func (m *MockDatabaseIface) DeletePendingNodeKey(txn *v2.Txn, nodeKey []byte) error + func (m *MockDatabaseIface) DeleteStagedBlockHeaderKey(txn *v2.Txn, height uint32) error + func (m *MockDatabaseIface) DropPendingHdrLeafKeys() error + func (m *MockDatabaseIface) DropPendingHdrNodeKeys() error + func (m *MockDatabaseIface) DropPendingLeafKeys() error + func (m *MockDatabaseIface) DropPendingNodeKeys() error + func (m *MockDatabaseIface) DropStagedBlockHeaderKeys() error + func (m *MockDatabaseIface) EXPECT() *MockDatabaseIfaceMockRecorder + func (m *MockDatabaseIface) GarbageCollect() error + func (m *MockDatabaseIface) GetBroadcastBlockHeader(txn *v2.Txn) (*objs.BlockHeader, error) + func (m *MockDatabaseIface) GetBroadcastNextHeight(txn *v2.Txn) (*objs.NextHeight, error) + func (m *MockDatabaseIface) GetBroadcastNextRound(txn *v2.Txn) (*objs.NextRound, error) + func (m *MockDatabaseIface) GetBroadcastPreCommit(txn *v2.Txn) (*objs.PreCommit, error) + func (m *MockDatabaseIface) GetBroadcastPreCommitNil(txn *v2.Txn) (*objs.PreCommitNil, error) + func (m *MockDatabaseIface) GetBroadcastPreVote(txn *v2.Txn) (*objs.PreVote, error) + func (m *MockDatabaseIface) GetBroadcastPreVoteNil(txn *v2.Txn) (*objs.PreVoteNil, error) + func (m *MockDatabaseIface) GetBroadcastProposal(txn *v2.Txn) (*objs.Proposal, error) + func (m *MockDatabaseIface) GetBroadcastRCert(txn *v2.Txn) (*objs.RCert, error) + func (m *MockDatabaseIface) GetCommittedBlockHeader(txn *v2.Txn, height uint32) (*objs.BlockHeader, error) + func (m *MockDatabaseIface) GetCommittedBlockHeaderByHash(txn *v2.Txn, hash []byte) (*objs.BlockHeader, error) + func (m *MockDatabaseIface) GetCommittedBlockHeaderWithProof(txn *v2.Txn, root []byte, blockHeight uint32) (*objs.BlockHeader, []byte, error) + func (m *MockDatabaseIface) GetCurrentRoundState(txn *v2.Txn, vaddr []byte) (*objs.RoundState, error) + func (m *MockDatabaseIface) GetEncryptedStore(txn *v2.Txn, name []byte) (*objs.EncryptedStore, error) + func (m *MockDatabaseIface) GetHeaderRootForProposal(txn *v2.Txn) ([]byte, error) + func (m *MockDatabaseIface) GetHeaderTrieRoot(txn *v2.Txn, height uint32) ([]byte, error) + func (m *MockDatabaseIface) GetHistoricRoundState(txn *v2.Txn, vaddr []byte, height, round uint32) (*objs.RoundState, error) + func (m *MockDatabaseIface) GetLastSnapshot(txn *v2.Txn) (*objs.BlockHeader, error) + func (m *MockDatabaseIface) GetMostRecentCommittedBlockHeaderFastSync(txn *v2.Txn) (*objs.BlockHeader, error) + func (m *MockDatabaseIface) GetOwnState(txn *v2.Txn) (*objs.OwnState, error) + func (m *MockDatabaseIface) GetOwnValidatingState(txn *v2.Txn) (*objs.OwnValidatingState, error) + func (m *MockDatabaseIface) GetPendingHdrLeafKey(txn *v2.Txn, hdrLeafKey []byte) ([]byte, error) + func (m *MockDatabaseIface) GetPendingHdrLeafKeysIter(txn *v2.Txn) *PendingHdrLeafIter + func (m *MockDatabaseIface) GetPendingHdrNodeKey(txn *v2.Txn, nodeKey []byte) (int, error) + func (m *MockDatabaseIface) GetPendingHdrNodeKeysIter(txn *v2.Txn) *PendingHdrNodeIter + func (m *MockDatabaseIface) GetPendingLeafKey(txn *v2.Txn, leafKey []byte) ([]byte, error) + func (m *MockDatabaseIface) GetPendingLeafKeysIter(txn *v2.Txn) *PendingLeafIter + func (m *MockDatabaseIface) GetPendingNodeKey(txn *v2.Txn, nodeKey []byte) (int, error) + func (m *MockDatabaseIface) GetPendingNodeKeysIter(txn *v2.Txn) *PendingNodeIter + func (m *MockDatabaseIface) GetSafeToProceed(txn *v2.Txn, height uint32) (bool, error) + func (m *MockDatabaseIface) GetSnapShotHdrNode(txn *v2.Txn, root []byte) ([]byte, error) + func (m *MockDatabaseIface) GetSnapshotBlockHeader(txn *v2.Txn, height uint32) (*objs.BlockHeader, error) + func (m *MockDatabaseIface) GetStagedBlockHeader(txn *v2.Txn, height uint32) (*objs.BlockHeader, error) + func (m *MockDatabaseIface) GetStagedBlockHeaderKeyIter(txn *v2.Txn) *StagedBlockHeaderKeyIter + func (m *MockDatabaseIface) GetTxCacheItem(txn *v2.Txn, height uint32, txHash []byte) ([]byte, error) + func (m *MockDatabaseIface) GetTxCacheSet(txn *v2.Txn, height uint32) ([][]byte, [][]byte, error) + func (m *MockDatabaseIface) GetValidatorSet(txn *v2.Txn, height uint32) (*objs.ValidatorSet, error) + func (m *MockDatabaseIface) Init(DB *v2.DB) error + func (m *MockDatabaseIface) MakeHeaderTrieKeyFromHeight(height uint32) []byte + func (m *MockDatabaseIface) SetBroadcastBlockHeader(txn *v2.Txn, v *objs.BlockHeader) error + func (m *MockDatabaseIface) SetBroadcastNextHeight(txn *v2.Txn, v *objs.NextHeight) error + func (m *MockDatabaseIface) SetBroadcastNextRound(txn *v2.Txn, v *objs.NextRound) error + func (m *MockDatabaseIface) SetBroadcastPreCommit(txn *v2.Txn, v *objs.PreCommit) error + func (m *MockDatabaseIface) SetBroadcastPreCommitNil(txn *v2.Txn, v *objs.PreCommitNil) error + func (m *MockDatabaseIface) SetBroadcastPreVote(txn *v2.Txn, v *objs.PreVote) error + func (m *MockDatabaseIface) SetBroadcastPreVoteNil(txn *v2.Txn, v *objs.PreVoteNil) error + func (m *MockDatabaseIface) SetBroadcastProposal(txn *v2.Txn, v *objs.Proposal) error + func (m *MockDatabaseIface) SetBroadcastRCert(txn *v2.Txn, v *objs.RCert) error + func (m *MockDatabaseIface) SetBroadcastTransaction(txn *v2.Txn, v []byte) error + func (m *MockDatabaseIface) SetCommittedBlockHeader(txn *v2.Txn, v *objs.BlockHeader) error + func (m *MockDatabaseIface) SetCommittedBlockHeaderFastSync(txn *v2.Txn, v *objs.BlockHeader) error + func (m *MockDatabaseIface) SetCurrentRoundState(txn *v2.Txn, v *objs.RoundState) error + func (m *MockDatabaseIface) SetEncryptedStore(txn *v2.Txn, v *objs.EncryptedStore) error + func (m *MockDatabaseIface) SetHistoricRoundState(txn *v2.Txn, v *objs.RoundState) error + func (m *MockDatabaseIface) SetOwnState(txn *v2.Txn, v *objs.OwnState) error + func (m *MockDatabaseIface) SetOwnValidatingState(txn *v2.Txn, v *objs.OwnValidatingState) error + func (m *MockDatabaseIface) SetPendingHdrLeafKey(txn *v2.Txn, hdrLeafKey, value []byte) error + func (m *MockDatabaseIface) SetPendingHdrNodeKey(txn *v2.Txn, nodeKey []byte, layer int) error + func (m *MockDatabaseIface) SetPendingLeafKey(txn *v2.Txn, leafKey, value []byte) error + func (m *MockDatabaseIface) SetPendingNodeKey(txn *v2.Txn, nodeKey []byte, layer int) error + func (m *MockDatabaseIface) SetSafeToProceed(txn *v2.Txn, height uint32, isSafe bool) error + func (m *MockDatabaseIface) SetSnapShotHdrNode(txn *v2.Txn, batch, root []byte, layer int) ([][]byte, int, []badgerTrie.LeafNode, error) + func (m *MockDatabaseIface) SetSnapshotBlockHeader(txn *v2.Txn, v *objs.BlockHeader) error + func (m *MockDatabaseIface) SetStagedBlockHeader(txn *v2.Txn, height uint32, value []byte) error + func (m *MockDatabaseIface) SetTxCacheItem(txn *v2.Txn, height uint32, txHash, tx []byte) error + func (m *MockDatabaseIface) SetValidatorSet(txn *v2.Txn, v *objs.ValidatorSet) error + func (m *MockDatabaseIface) SubscribeBroadcastBlockHeader(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) SubscribeBroadcastNextHeight(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) SubscribeBroadcastNextRound(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) SubscribeBroadcastPreCommit(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) SubscribeBroadcastPreCommitNil(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) SubscribeBroadcastPreVote(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) SubscribeBroadcastPreVoteNil(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) SubscribeBroadcastProposal(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) SubscribeBroadcastRCert(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) SubscribeBroadcastTransaction(ctx context.Context, cb func([]byte) error) + func (m *MockDatabaseIface) Sync() error + func (m *MockDatabaseIface) TxCacheDropBefore(txn *v2.Txn, beforeHeight uint32, maxKeys int) error + func (m *MockDatabaseIface) Update(fn TxnFunc) error + func (m *MockDatabaseIface) UpdateHeaderTrieRootFastSync(txn *v2.Txn, v *objs.BlockHeader) error + func (m *MockDatabaseIface) ValidateCommittedBlockHeaderWithProof(txn *v2.Txn, root []byte, blockHeader *objs.BlockHeader, proof []byte) (bool, error) + func (m *MockDatabaseIface) View(fn TxnFunc) error + type MockDatabaseIfaceMockRecorder struct + func (mr *MockDatabaseIfaceMockRecorder) ContainsSnapShotHdrNode(txn, root interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) CountPendingHdrLeafKeys(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) CountPendingHdrNodeKeys(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) CountPendingLeafKeys(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) CountPendingNodeKeys(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) CountStagedBlockHeaderKeys(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DB() *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DeleteBeforeHistoricRoundState(txn, height, maxnum interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DeleteCommittedBlockHeader(txn, height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DeletePendingHdrLeafKey(txn, hdrLeafKey interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DeletePendingHdrNodeKey(txn, nodeKey interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DeletePendingLeafKey(txn, leafKey interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DeletePendingNodeKey(txn, nodeKey interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DeleteStagedBlockHeaderKey(txn, height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DropPendingHdrLeafKeys() *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DropPendingHdrNodeKeys() *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DropPendingLeafKeys() *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DropPendingNodeKeys() *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) DropStagedBlockHeaderKeys() *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GarbageCollect() *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetBroadcastBlockHeader(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetBroadcastNextHeight(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetBroadcastNextRound(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetBroadcastPreCommit(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetBroadcastPreCommitNil(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetBroadcastPreVote(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetBroadcastPreVoteNil(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetBroadcastProposal(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetBroadcastRCert(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetCommittedBlockHeader(txn, height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetCommittedBlockHeaderByHash(txn, hash interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetCommittedBlockHeaderWithProof(txn, root, blockHeight interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetCurrentRoundState(txn, vaddr interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetEncryptedStore(txn, name interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetHeaderRootForProposal(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetHeaderTrieRoot(txn, height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetHistoricRoundState(txn, vaddr, height, round interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetLastSnapshot(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetMostRecentCommittedBlockHeaderFastSync(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetOwnState(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetOwnValidatingState(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetPendingHdrLeafKey(txn, hdrLeafKey interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetPendingHdrLeafKeysIter(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetPendingHdrNodeKey(txn, nodeKey interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetPendingHdrNodeKeysIter(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetPendingLeafKey(txn, leafKey interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetPendingLeafKeysIter(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetPendingNodeKey(txn, nodeKey interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetPendingNodeKeysIter(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetSafeToProceed(txn, height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetSnapShotHdrNode(txn, root interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetSnapshotBlockHeader(txn, height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetStagedBlockHeader(txn, height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetStagedBlockHeaderKeyIter(txn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetTxCacheItem(txn, height, txHash interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetTxCacheSet(txn, height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) GetValidatorSet(txn, height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) Init(DB interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) MakeHeaderTrieKeyFromHeight(height interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastBlockHeader(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastNextHeight(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastNextRound(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastPreCommit(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastPreCommitNil(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastPreVote(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastPreVoteNil(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastProposal(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastRCert(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetBroadcastTransaction(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetCommittedBlockHeader(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetCommittedBlockHeaderFastSync(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetCurrentRoundState(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetEncryptedStore(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetHistoricRoundState(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetOwnState(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetOwnValidatingState(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetPendingHdrLeafKey(txn, hdrLeafKey, value interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetPendingHdrNodeKey(txn, nodeKey, layer interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetPendingLeafKey(txn, leafKey, value interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetPendingNodeKey(txn, nodeKey, layer interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetSafeToProceed(txn, height, isSafe interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetSnapShotHdrNode(txn, batch, root, layer interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetSnapshotBlockHeader(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetStagedBlockHeader(txn, height, value interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetTxCacheItem(txn, height, txHash, tx interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SetValidatorSet(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastBlockHeader(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastNextHeight(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastNextRound(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastPreCommit(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastPreCommitNil(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastPreVote(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastPreVoteNil(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastProposal(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastRCert(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) SubscribeBroadcastTransaction(ctx, cb interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) Sync() *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) TxCacheDropBefore(txn, beforeHeight, maxKeys interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) Update(fn interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) UpdateHeaderTrieRootFastSync(txn, v interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) ValidateCommittedBlockHeaderWithProof(txn, root, blockHeader, proof interface{}) *gomock.Call + func (mr *MockDatabaseIfaceMockRecorder) View(fn interface{}) *gomock.Call + type PendingHdrLeafIter struct + func (phli *PendingHdrLeafIter) Close() + func (phli *PendingHdrLeafIter) Next() ([]byte, []byte, bool, error) + type PendingHdrNodeIter struct + func (pni *PendingHdrNodeIter) Close() + func (pni *PendingHdrNodeIter) Next() ([]byte, int, bool, error) + type PendingLeafIter struct + func (pni *PendingLeafIter) Close() + func (pni *PendingLeafIter) Next() ([]byte, []byte, bool, error) + type PendingNodeIter struct + func (pni *PendingNodeIter) Close() + func (pni *PendingNodeIter) Next() ([]byte, int, bool, error) + type StagedBlockHeaderKeyIter struct + func (sbhki *StagedBlockHeaderKeyIter) Close() + func (sbhki *StagedBlockHeaderKeyIter) Next() (uint32, *objs.BlockHeader, bool, error) + type Txn struct + func (txn *Txn) AddCallback(fn TxnFunc) + type TxnFunc func(txn *badger.Txn) error
Go to main page