Versions in this module Expand all Collapse all v1 v1.137.2 Nov 5, 2024 v1.137.1 Oct 24, 2024 Changes in this version + const MockErrorBlockHeight + const ScanPosKey + type Block struct + Height int64 + Txs []string + type BlockScanStatus byte + const Failed + const Finished + const NotStarted + const Processing + type BlockScanner struct + func NewBlockScanner(cfg config.BifrostBlockScannerConfiguration, scannerStorage ScannerStorage, ...) (*BlockScanner, error) + func (b *BlockScanner) FetchLastHeight() (int64, error) + func (b *BlockScanner) GetMessages() <-chan int64 + func (b *BlockScanner) IsHealthy() bool + func (b *BlockScanner) PreviousHeight() int64 + func (b *BlockScanner) Start(globalTxsQueue chan types.TxIn) + func (b *BlockScanner) Stop() + type BlockScannerFetcher interface + FetchMemPool func(height int64) (types.TxIn, error) + FetchTxs func(fetchHeight, chainHeight int64) (types.TxIn, error) + GetHeight func() (int64, error) + type BlockScannerStorage struct + func NewBlockScannerStorage(levelDbFolder string, opts config.LevelDBOptions) (*BlockScannerStorage, error) + func (s *BlockScannerStorage) GetInternalDb() *leveldb.DB + type BlockStatusItem struct + Block Block + Status BlockScanStatus + type DummyFetcher struct + Err error + Tx types.TxIn + func (d DummyFetcher) FetchMemPool(height int64) (types.TxIn, error) + func (d DummyFetcher) FetchTxs(height, _ int64) (types.TxIn, error) + func (d DummyFetcher) GetHeight() (int64, error) + type LevelDBScannerStorage struct + func NewLevelDBScannerStorage(db *leveldb.DB) (*LevelDBScannerStorage, error) + func (ldbss *LevelDBScannerStorage) Close() error + func (ldbss *LevelDBScannerStorage) GetBlocksForRetry(failedOnly bool) ([]Block, error) + func (ldbss *LevelDBScannerStorage) GetScanPos() (int64, error) + func (ldbss *LevelDBScannerStorage) RemoveBlockStatus(block int64) error + func (ldbss *LevelDBScannerStorage) SetBlockScanStatus(block Block, status BlockScanStatus) error + func (ldbss *LevelDBScannerStorage) SetScanPos(block int64) error + type MockScannerStorage struct + func NewMockScannerStorage() *MockScannerStorage + func (mss *MockScannerStorage) Close() error + func (mss *MockScannerStorage) GetBlocksForRetry(failedOnly bool) ([]Block, error) + func (mss *MockScannerStorage) GetInternalDb() *leveldb.DB + func (mss *MockScannerStorage) GetScanPos() (int64, error) + func (mss *MockScannerStorage) RemoveBlockStatus(block int64) error + func (mss *MockScannerStorage) SetBlockScanStatus(block Block, status BlockScanStatus) error + func (mss *MockScannerStorage) SetScanPos(block int64) error + type ScannerStorage interface + GetBlocksForRetry func(failedOnly bool) ([]Block, error) + GetInternalDb func() *leveldb.DB + GetScanPos func() (int64, error) + RemoveBlockStatus func(block int64) error + SetBlockScanStatus func(block Block, status BlockScanStatus) error + SetScanPos func(block int64) error
Go to main page