txindex

Documentation

Index

• Variables
• func SyncTxIndexer(logger log.Logger, idr TxIndexer, b *Batch, height int64)
• type Batch
  • func NewBatch(n int64) *Batch
  • func (b *Batch) Add(result *types.TxResult) error
  • func (b *Batch) Size() int
• type IndexerService
  • func NewIndexerService(idr TxIndexer, eventBus *types.EventBus) *IndexerService
  • func (is *IndexerService) OnStart() error
  • func (is *IndexerService) OnStop()
• type TxIndexer

Variables

var ErrorEmptyHash = errors.New("transaction hash cannot be empty")

ErrorEmptyHash indicates empty hash

Functions

func SyncTxIndexer

func SyncTxIndexer(logger log.Logger, idr TxIndexer, b *Batch, height int64)

Types

type Batch

type Batch struct {
	Ops []*types.TxResult
}

Batch groups together multiple Index operations to be performed at the same time. NOTE: Batch is NOT thread-safe and must not be modified after starting its execution.

func NewBatch

func NewBatch(n int64) *Batch

NewBatch creates a new Batch.

func (*Batch) Add

func (b *Batch) Add(result *types.TxResult) error

Add or update an entry for the given result.Index.

func (*Batch) Size

func (b *Batch) Size() int

Size returns the total number of operations inside the batch.

type IndexerService

type IndexerService struct {
	service.BaseService
	// contains filtered or unexported fields
}

IndexerService connects event bus and transaction indexer together in order to index transactions coming from event bus.

func NewIndexerService

func NewIndexerService(idr TxIndexer, eventBus *types.EventBus) *IndexerService

NewIndexerService returns a new service instance.

func (*IndexerService) OnStart

func (is *IndexerService) OnStart() error

OnStart implements service.Service by subscribing for all transactions and indexing them by events.

func (*IndexerService) OnStop

func (is *IndexerService) OnStop()

OnStop implements service.Service by unsubscribing from all transactions.

type TxIndexer

type TxIndexer interface {

	// AddBatch analyzes, indexes and stores a batch of transactions.
	AddBatch(b *Batch) error

	// Index analyzes, indexes and stores a single transaction.
	Index(result *types.TxResult) error

	// Get returns the transaction specified by hash or nil if the transaction is not indexed
	// or stored.
	Get(hash []byte) (*types.TxResult, error)

	// Search allows you to query for transactions.
	Search(ctx context.Context, q *query.Query) ([]*types.TxResult, int, error)

	// DeleteFromHeight method added for rollback
	DeleteFromHeight(ctx context.Context, height int64) error
}

TxIndexer interface defines methods to index and search transactions.