Versions in this module Expand all Collapse all v0 v0.38.78 Jul 18, 2023 v0.38.77 Jul 18, 2023 Changes in this version + type BackportBlockIndexer struct + func (BackportBlockIndexer) Has(_ int64) (bool, error) + func (BackportBlockIndexer) Search(context.Context, *query.Query) ([]int64, error) + func (BackportBlockIndexer) SetLogger(log.Logger) + func (b BackportBlockIndexer) Index(block types.EventDataNewBlockEvents) error + type BackportTxIndexer struct + func (BackportTxIndexer) Get([]byte) (*abci.TxResult, error) + func (BackportTxIndexer) Search(context.Context, *query.Query) ([]*abci.TxResult, error) + func (BackportTxIndexer) SetLogger(log.Logger) + 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(_ []byte) (*abci.TxResult, error) + func (es *EventSink) HasBlock(_ int64) (bool, error) + func (es *EventSink) IndexBlockEvents(h types.EventDataNewBlockEvents) error + func (es *EventSink) IndexTxEvents(txrs []*abci.TxResult) error + func (es *EventSink) SearchBlockEvents(_ context.Context, _ *query.Query) ([]int64, error) + func (es *EventSink) SearchTxEvents(_ context.Context, _ *query.Query) ([]*abci.TxResult, error) + func (es *EventSink) Stop() error + func (es *EventSink) TxIndexer() BackportTxIndexer
Go to main page