indexer

Documentation

Index

• Variables
• type KVIndexer
  • func NewKVIndexer(logger log.Logger, clientCtx client.Context, cacheSize int) *KVIndexer
  • func (kv *KVIndexer) Close()
  • func (kv *KVIndexer) GetByBlockAndIndex(blockNumber int64, txIndex uint) (*bbtypes.TxResult, error)
  • func (kv *KVIndexer) GetByTxHash(hash common.Hash) (*bbtypes.TxResult, error)
  • func (kv *KVIndexer) SetBlockAndIndex(blockNumber int64, txIndex uint, txRes *bbtypes.TxResult) error
  • func (kv *KVIndexer) SetTxHash(hash common.Hash, txRes *bbtypes.TxResult) error

Variables

var ErrorTxNotFound = errors.New("tx not found")

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(logger log.Logger, clientCtx client.Context, cacheSize int) *KVIndexer

NewKVIndexer creates the KVIndexer with a specified cache size

func (*KVIndexer) Close

func (kv *KVIndexer) Close()

Close gracefully shuts down the indexer

func (*KVIndexer) GetByBlockAndIndex

func (kv *KVIndexer) GetByBlockAndIndex(blockNumber int64, txIndex uint) (*bbtypes.TxResult, error)

GetByBlockAndIndex retrieves a transaction result by block number and transaction index

func (*KVIndexer) GetByTxHash

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

GetByTxHash retrieves a transaction result by its hash

func (*KVIndexer) SetBlockAndIndex

func (kv *KVIndexer) SetBlockAndIndex(blockNumber int64, txIndex uint, txRes *bbtypes.TxResult) error

SetBlockAndIndex adds the transaction result to the blockIndexCache with a copy of TxResult

func (*KVIndexer) SetTxHash

func (kv *KVIndexer) SetTxHash(hash common.Hash, txRes *bbtypes.TxResult) error

SetTxHash adds the transaction result to the txCache with a copy of TxResult