Versions in this module Expand all Collapse all v0 v0.0.3 Feb 7, 2021 Changes in this version + const MaxBlockStallDuration + const MaxStallDuration + const StallSampleInterval + func UseLogger(logger l.Logger) + type BlockManager struct + func NewBlockManager(ntmgr notify.Notify, indexManager blockchain.IndexManager, db database.DB, ...) (*BlockManager, error) + func (b *BlockManager) API() rpc.API + func (b *BlockManager) ChainParams() *params.Params + func (b *BlockManager) Current() bool + func (b *BlockManager) DAGSync() *blockdag.DAGSync + func (b *BlockManager) DonePeer(sp *peer.ServerPeer) + func (b *BlockManager) GetChain() *blockchain.BlockChain + func (b *BlockManager) GetCurrentTemplate() *types.BlockTemplate + func (b *BlockManager) GetParentTemplate() *types.BlockTemplate + func (b *BlockManager) GetTxManager() TxManager + func (b *BlockManager) IntellectSyncBlocks(peer *peer.ServerPeer, refresh bool) + func (b *BlockManager) IsCurrent() bool + func (b *BlockManager) NewPeer(sp *peer.ServerPeer) + func (b *BlockManager) ProcessBlock(block *types.SerializedBlock, flags blockchain.BehaviorFlags) (bool, error) + func (b *BlockManager) ProcessTransaction(tx *types.Tx, allowOrphans bool, rateLimit bool, allowHighFees bool) ([]*types.TxDesc, error) + func (b *BlockManager) PushSyncDAGMsg(peer *peer.ServerPeer) + func (b *BlockManager) QueueBlock(block *types.SerializedBlock, sp *peer.ServerPeer) + func (b *BlockManager) QueueInv(inv *message.MsgInv, sp *peer.ServerPeer) + func (b *BlockManager) QueueTx(tx *types.Tx, sp *peer.ServerPeer) + func (b *BlockManager) RequestFromPeer(p *peer.ServerPeer, blocks []*hash.Hash) error + func (b *BlockManager) SetCurrentTemplate(bt *types.BlockTemplate) + func (b *BlockManager) SetParentTemplate(bt *types.BlockTemplate) + func (b *BlockManager) SetTxManager(txManager TxManager) + func (b *BlockManager) Start() + func (b *BlockManager) Stop() error + func (b *BlockManager) SyncPeerID() int32 + func (b *BlockManager) TipGeneration() ([]hash.Hash, error) + func (b *BlockManager) WaitForStop() + type PublicBlockAPI struct + func NewPublicBlockAPI(bm *BlockManager) *PublicBlockAPI + func (api *PublicBlockAPI) GetBestBlockHash() (interface{}, error) + func (api *PublicBlockAPI) GetBlock(h hash.Hash, verbose *bool, inclTx *bool, fullTx *bool) (interface{}, error) + func (api *PublicBlockAPI) GetBlockByID(id uint64, verbose *bool, inclTx *bool, fullTx *bool) (interface{}, error) + func (api *PublicBlockAPI) GetBlockByNum(num uint64, verbose *bool, inclTx *bool, fullTx *bool) (interface{}, error) + func (api *PublicBlockAPI) GetBlockByOrder(order uint64, verbose *bool, inclTx *bool, fullTx *bool) (interface{}, error) + func (api *PublicBlockAPI) GetBlockCount() (interface{}, error) + func (api *PublicBlockAPI) GetBlockHeader(hash hash.Hash, verbose bool) (interface{}, error) + func (api *PublicBlockAPI) GetBlockTotal() (interface{}, error) + func (api *PublicBlockAPI) GetBlockV2(h hash.Hash, verbose *bool, inclTx *bool, fullTx *bool) (interface{}, error) + func (api *PublicBlockAPI) GetBlockWeight(h hash.Hash) (interface{}, error) + func (api *PublicBlockAPI) GetBlockhash(order uint) (string, error) + func (api *PublicBlockAPI) GetBlockhashByRange(start uint, end uint) ([]string, error) + func (api *PublicBlockAPI) GetCoinbase(h hash.Hash, verbose *bool) (interface{}, error) + func (api *PublicBlockAPI) GetFees(h hash.Hash) (interface{}, error) + func (api *PublicBlockAPI) GetMainChainHeight() (interface{}, error) + func (api *PublicBlockAPI) GetOrphansTotal() (interface{}, error) + func (api *PublicBlockAPI) IsBlue(h hash.Hash) (interface{}, error) + func (api *PublicBlockAPI) IsCurrent() (interface{}, error) + func (api *PublicBlockAPI) IsOnMainChain(h hash.Hash) (interface{}, error) + func (api *PublicBlockAPI) Tips() (interface{}, error) + type TxManager interface + MemPool func() TxPool + type TxPool interface + AddTransaction func(utxoView *blockchain.UtxoViewpoint, tx *types.Tx, height uint64, fee int64) + HaveTransaction func(hash *hash.Hash) bool + MaybeAcceptTransaction func(tx *types.Tx, isNew, rateLimit bool) ([]*hash.Hash, error) + ProcessOrphans func(hash *hash.Hash) []*types.TxDesc + ProcessTransaction func(tx *types.Tx, allowOrphan, rateLimit, allowHighFees bool) ([]*types.TxDesc, error) + PruneExpiredTx func() + RemoveDoubleSpends func(tx *types.Tx) + RemoveOrphan func(txHash *hash.Hash) + RemoveTransaction func(tx *types.Tx, removeRedeemers bool)
Go to main page