indexer

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 NewKVIndexer(db dbm.DB, logger log.Logger, clientCtx client.Context) *KVIndexer
  • func (kv *KVIndexer) FirstIndexedBlock() (int64, error)
  • func (kv *KVIndexer) GetByBlockAndIndex(blockNumber int64, txIndex int32) (*cvntypes.TxResult, error)
  • func (kv *KVIndexer) GetByTxHash(hash common.Hash) (*cvntypes.TxResult, error)
  • func (kv *KVIndexer) IndexBlock(block *tmtypes.Block, txResults []*abci.ResponseDeliverTx) error
  • func (kv *KVIndexer) LastIndexedBlock() (int64, error)

Constants

const (
	KeyPrefixTxHash  = 1
	KeyPrefixTxIndex = 2

	// TxIndexKeyLength is the length of tx-index key
	TxIndexKeyLength = 1 + 8 + 8
)

Functions

func LoadFirstBlock

func LoadFirstBlock(db dbm.DB) (int64, error)

LoadFirstBlock loads the first indexed block, returns -1 if db is empty

func LoadLastBlock

func LoadLastBlock(db dbm.DB) (int64, error)

LoadLastBlock returns the latest indexed block number, returns -1 if db is empty

func TxHashKey

func TxHashKey(hash common.Hash) []byte

TxHashKey returns the key for db entry: `tx hash -> tx result struct`

func TxIndexKey

func TxIndexKey(blockNumber int64, txIndex int32) []byte

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 a eth tx indexer on a KV db.

func NewKVIndexer

func NewKVIndexer(db dbm.DB, logger log.Logger, clientCtx client.Context) *KVIndexer

NewKVIndexer creates the KVIndexer

func (*KVIndexer) FirstIndexedBlock

func (kv *KVIndexer) FirstIndexedBlock() (int64, error)

FirstIndexedBlock returns the first indexed block number, returns -1 if db is empty

func (*KVIndexer) GetByBlockAndIndex

func (kv *KVIndexer) GetByBlockAndIndex(blockNumber int64, txIndex int32) (*cvntypes.TxResult, error)

GetByBlockAndIndex finds eth tx by block number and eth tx index

func (*KVIndexer) GetByTxHash

func (kv *KVIndexer) GetByTxHash(hash common.Hash) (*cvntypes.TxResult, error)

GetByTxHash finds eth tx by eth tx hash

func (*KVIndexer) IndexBlock

func (kv *KVIndexer) IndexBlock(block *tmtypes.Block, txResults []*abci.ResponseDeliverTx) error

IndexBlock index all the eth txs in a block through the following 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

func (kv *KVIndexer) LastIndexedBlock() (int64, error)

LastIndexedBlock returns the latest indexed block number, returns -1 if db is empty