indexers

Oct 14, 2021

Changes in this version

+ func DisableLog()

+ func DropAddrIndex(db database.DB, interrupt <-chan struct{}) error

+ func DropCfIndex(db database.DB, interrupt <-chan struct{}) error

+ func DropTxIndex(db database.DB, interrupt <-chan struct{}) error

+ func UseLogger(logger btclog.Logger)

+ type AddrIndex struct

+ func NewAddrIndex(db database.DB, chainParams *chaincfg.Params) *AddrIndex

+ func (idx *AddrIndex) AddUnconfirmedTx(tx *whiveutil.Tx, utxoView *blockchain.UtxoViewpoint)

+ func (idx *AddrIndex) ConnectBlock(dbTx database.Tx, block *whiveutil.Block, stxos []blockchain.SpentTxOut) error

+ func (idx *AddrIndex) Create(dbTx database.Tx) error

+ func (idx *AddrIndex) DisconnectBlock(dbTx database.Tx, block *whiveutil.Block, stxos []blockchain.SpentTxOut) error

+ func (idx *AddrIndex) Init() error

+ func (idx *AddrIndex) Key() []byte

+ func (idx *AddrIndex) Name() string

+ func (idx *AddrIndex) NeedsInputs() bool

+ func (idx *AddrIndex) RemoveUnconfirmedTx(hash *chainhash.Hash)

+ func (idx *AddrIndex) TxRegionsForAddress(dbTx database.Tx, addr whiveutil.Address, numToSkip, numRequested uint32, ...) ([]database.BlockRegion, uint32, error)

+ func (idx *AddrIndex) UnconfirmedTxnsForAddress(addr whiveutil.Address) []*btcutil.Tx

+ type AssertError string

+ func (e AssertError) Error() string

+ type CfIndex struct

+ func NewCfIndex(db database.DB, chainParams *chaincfg.Params) *CfIndex

+ func (idx *CfIndex) ConnectBlock(dbTx database.Tx, block *whiveutil.Block, stxos []blockchain.SpentTxOut) error

+ func (idx *CfIndex) Create(dbTx database.Tx) error

+ func (idx *CfIndex) DisconnectBlock(dbTx database.Tx, block *whiveutil.Block, _ []blockchain.SpentTxOut) error

+ func (idx *CfIndex) FilterByBlockHash(h *chainhash.Hash, filterType wire.FilterType) ([]byte, error)

+ func (idx *CfIndex) FilterHashByBlockHash(h *chainhash.Hash, filterType wire.FilterType) ([]byte, error)

+ func (idx *CfIndex) FilterHashesByBlockHashes(blockHashes []*chainhash.Hash, filterType wire.FilterType) ([][]byte, error)

+ func (idx *CfIndex) FilterHeaderByBlockHash(h *chainhash.Hash, filterType wire.FilterType) ([]byte, error)

+ func (idx *CfIndex) FilterHeadersByBlockHashes(blockHashes []*chainhash.Hash, filterType wire.FilterType) ([][]byte, error)

+ func (idx *CfIndex) FiltersByBlockHashes(blockHashes []*chainhash.Hash, filterType wire.FilterType) ([][]byte, error)

+ func (idx *CfIndex) Init() error

+ func (idx *CfIndex) Key() []byte

+ func (idx *CfIndex) Name() string

+ func (idx *CfIndex) NeedsInputs() bool

+ type Indexer interface

+ ConnectBlock func(database.Tx, *whiveutil.Block, []blockchain.SpentTxOut) error

+ Create func(dbTx database.Tx) error

+ DisconnectBlock func(database.Tx, *whiveutil.Block, []blockchain.SpentTxOut) error

+ Init func() error

+ Key func() []byte

+ Name func() string

+ type Manager struct

+ func NewManager(db database.DB, enabledIndexes []Indexer) *Manager

+ func (m *Manager) ConnectBlock(dbTx database.Tx, block *whiveutil.Block, stxos []blockchain.SpentTxOut) error

+ func (m *Manager) DisconnectBlock(dbTx database.Tx, block *whiveutil.Block, stxo []blockchain.SpentTxOut) error

+ func (m *Manager) Init(chain *blockchain.BlockChain, interrupt <-chan struct{}) error

+ type NeedsInputser interface

+ NeedsInputs func() bool

+ type TxIndex struct

+ func NewTxIndex(db database.DB) *TxIndex

+ func (idx *TxIndex) ConnectBlock(dbTx database.Tx, block *whiveutil.Block, stxos []blockchain.SpentTxOut) error

+ func (idx *TxIndex) Create(dbTx database.Tx) error

+ func (idx *TxIndex) DisconnectBlock(dbTx database.Tx, block *whiveutil.Block, stxos []blockchain.SpentTxOut) error

+ func (idx *TxIndex) Init() error

+ func (idx *TxIndex) Key() []byte

+ func (idx *TxIndex) Name() string

+ func (idx *TxIndex) TxBlockRegion(hash *chainhash.Hash) (*database.BlockRegion, error)