Versions in this module Expand all Collapse all v0 v0.0.3 Sep 6, 2022 v0.0.2 Sep 6, 2022 Changes in this version + type BackportBlockIndexer struct + func (BackportBlockIndexer) Has(height int64) (bool, error) + func (BackportBlockIndexer) Search(context.Context, *query.Query) ([]int64, error) + func (b BackportBlockIndexer) Index(block types.EventDataNewBlockHeader) error + type BackportTxIndexer struct + func (BackportTxIndexer) Get([]byte) (*abci.TxResult, error) + func (BackportTxIndexer) Search(context.Context, *query.Query) ([]*abci.TxResult, error) + func (b BackportTxIndexer) AddBatch(batch *txindex.Batch) error + func (b BackportTxIndexer) Index(txr *abci.TxResult) error + type EventSink struct + func NewEventSink(connStr, chainID string) (*EventSink, error) + func (es *EventSink) BlockIndexer() BackportBlockIndexer + func (es *EventSink) DB() *sql.DB + func (es *EventSink) GetTxByHash(hash []byte) (*abci.TxResult, error) + func (es *EventSink) HasBlock(h int64) (bool, error) + func (es *EventSink) IndexBlockEvents(h types.EventDataNewBlockHeader) error + func (es *EventSink) IndexTxEvents(txrs []*abci.TxResult) error + func (es *EventSink) SearchBlockEvents(ctx context.Context, q *query.Query) ([]int64, error) + func (es *EventSink) SearchTxEvents(ctx context.Context, q *query.Query) ([]*abci.TxResult, error) + func (es *EventSink) Stop() error + func (es *EventSink) TxIndexer() BackportTxIndexer
Go to main page