cosmostxcollector

Documentation

Index

• type Collector
  • func New(db adapter.Saver, client TXsCollector) Collector
  • func (c Collector) Collect(ctx context.Context, fromHeight int64) error
• type TXsCollector

Types

type Collector

type Collector struct {
	// contains filtered or unexported fields
}

Collector defines a type to collect and save Cosmos transactions in a data backend.

func New

func New(db adapter.Saver, client TXsCollector) Collector

New creates a new Cosmos transaction collector.

func (Collector) Collect

func (c Collector) Collect(ctx context.Context, fromHeight int64) error

Collect gathers transactions for all blocks starting from a specific height. Each group of block transactions is saved sequentially after being collected.

type TXsCollector

type TXsCollector interface {
	CollectTXs(ctx context.Context, fromHeight int64, tc chan<- []cosmosclient.TX) error
}

TXsCollector defines the interface for Cosmos clients that support collection of transactions.