Versions in this module Expand all Collapse all v0 v0.8.14 Sep 15, 2021 Changes in this version + var ErrorEmptyHash = errors.New("transaction hash cannot be empty") + func IndexingEnabled(sinks []EventSink) bool + func IsRangeOperation(op query.Operator) bool + func KVSinkEnabled(sinks []EventSink) bool + type Batch struct + Ops []*abci.TxResult + func NewBatch(n int64) *Batch + func (b *Batch) Add(result *abci.TxResult) error + func (b *Batch) Size() int + type BlockIndexer interface + Has func(height int64) (bool, error) + Index func(types.EventDataNewBlockHeader) error + Search func(ctx context.Context, q *query.Query) ([]int64, error) + type EventSink interface + GetTxByHash func([]byte) (*abci.TxResult, error) + HasBlock func(int64) (bool, error) + IndexBlockEvents func(types.EventDataNewBlockHeader) error + IndexTxEvents func([]*abci.TxResult) error + SearchBlockEvents func(context.Context, *query.Query) ([]int64, error) + SearchTxEvents func(context.Context, *query.Query) ([]*abci.TxResult, error) + Stop func() error + Type func() EventSinkType + type EventSinkType string + const KV + const NULL + const PSQL + type QueryRange struct + IncludeLowerBound bool + IncludeUpperBound bool + Key string + LowerBound interface{} + UpperBound interface{} + func (qr QueryRange) AnyBound() interface{} + func (qr QueryRange) LowerBoundValue() interface{} + func (qr QueryRange) UpperBoundValue() interface{} + type QueryRanges map[string]QueryRange + func LookForRanges(conditions []query.Condition) (ranges QueryRanges, indexes []int) + type Service struct + func NewIndexerService(es []EventSink, eventBus *types.EventBus) *Service + func (is *Service) OnStart() error + func (is *Service) OnStop() + type TxIndexer interface + Get func(hash []byte) (*abci.TxResult, error) + Index func(results []*abci.TxResult) error + Search func(ctx context.Context, q *query.Query) ([]*abci.TxResult, error)
Go to main page