Documentation
¶
Index ¶
- Constants
- func LoadFirstBlock(db dbm.DB) (int64, error)
- func LoadLastBlock(db dbm.DB) (int64, error)
- func TxHashKey(hash common.Hash) []byte
- func TxIndexKey(blockNumber int64, txIndex int32) []byte
- type KVIndexer
- func (kv *KVIndexer) FirstIndexedBlock() (int64, error)
- func (kv *KVIndexer) GetByBlockAndIndex(blockNumber int64, txIndex int32) (*evertypes.TxResult, error)
- func (kv *KVIndexer) GetByTxHash(hash common.Hash) (*evertypes.TxResult, error)
- func (kv *KVIndexer) GetLastRequestIndexedBlock() (int64, error)
- func (kv *KVIndexer) IndexBlock(block *tmtypes.Block, txResults []*abci.ResponseDeliverTx) error
- func (kv *KVIndexer) IsReady() bool
- func (kv *KVIndexer) LastIndexedBlock() (int64, error)
- func (kv *KVIndexer) Ready()
Constants ¶
const ( KeyPrefixTxHash = 1 KeyPrefixTxIndex = 2 // TxIndexKeyLength is the length of tx-index key TxIndexKeyLength = 1 + 8 + 8 )
Variables ¶
This section is empty.
Functions ¶
func LoadFirstBlock ¶
LoadFirstBlock loads the first indexed block, returns -1 if db is empty
func LoadLastBlock ¶
LoadLastBlock returns the latest indexed block number, returns -1 if db is empty
func TxIndexKey ¶
TxIndexKey returns the key for db entry: `(block number, tx index) -> tx hash`
Types ¶
type KVIndexer ¶
type KVIndexer struct {
// contains filtered or unexported fields
}
KVIndexer implements an ETH-Tx indexer on a KV db.
func NewKVIndexer ¶
NewKVIndexer creates the KVIndexer
func (*KVIndexer) FirstIndexedBlock ¶
FirstIndexedBlock returns the first indexed block number, returns -1 if db is empty
func (*KVIndexer) GetByBlockAndIndex ¶
func (kv *KVIndexer) GetByBlockAndIndex(blockNumber int64, txIndex int32) (*evertypes.TxResult, error)
GetByBlockAndIndex finds eth tx by block number and eth tx index
func (*KVIndexer) GetByTxHash ¶
GetByTxHash finds eth tx by eth tx hash
func (*KVIndexer) GetLastRequestIndexedBlock ¶ added in v12.2.4
GetLastRequestIndexedBlock returns the block height of the latest success called to IndexBlock()
func (*KVIndexer) IndexBlock ¶
IndexBlock indexes all ETH Txs of the block. Notes: no guarantee data is flushed into database after this function returns, it might be flushed at later point.
Steps: - Iterates over all-of-the Txs in Block - Parses eth Tx infos from cosmos-sdk events for every TxResult - Iterates over all the messages of the Tx - Builds and stores a `indexer.TxResult` based on parsed events for every message
func (*KVIndexer) LastIndexedBlock ¶
LastIndexedBlock returns the last block number which was indexed and flushed into database. Returns -1 if db is empty.
Source Files