index

Documentation

Index

• func GetContractABI(std indexer.Standard) (*abi.ABI, error)
• func GetContractTopics(std indexer.Standard) [][]common.Hash
• type ErrIndexing
• type Indexer
  • func New(rate int, chainID *big.Int, db *db.DB, evm indexer.EVMRequester, ...) (*Indexer, error)
  • func (i *Indexer) Background(syncrate int) error
  • func (e *Indexer) Close()
  • func (i *Indexer) EventsFromBlock(ev *indexer.Event, blk *block) error
  • func (i *Indexer) EventsFromLogStream(ctx context.Context, quitAck chan error, ev *indexer.Event) error
  • func (i *Indexer) FilterQueryFromEvent(ev *indexer.Event) *ethereum.FilterQuery
  • func (i *Indexer) IndexERC20From(contract string, from int64) error
  • func (i *Indexer) ListenBackground(ctx context.Context) error
  • func (i *Indexer) Process(evs []*indexer.Event, blk *block) error
  • func (i *Indexer) Start() error

Functions

func GetContractABI

func GetContractABI(std indexer.Standard) (*abi.ABI, error)

func GetContractTopics

func GetContractTopics(std indexer.Standard) [][]common.Hash

Types

type ErrIndexing

type ErrIndexing error

var (
	ErrIndexingRecoverable ErrIndexing = errors.New("error indexing recoverable") // an error occurred while indexing but it is not fatal
)

type Indexer

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

func New

func New(rate int, chainID *big.Int, db *db.DB, evm indexer.EVMRequester, fb *firebase.PushService) (*Indexer, error)

func (*Indexer) Background

func (i *Indexer) Background(syncrate int) error

Background starts an indexer service in the background

func (*Indexer) Close

func (e *Indexer) Close()

func (*Indexer) EventsFromBlock

func (i *Indexer) EventsFromBlock(ev *indexer.Event, blk *block) error

func (*Indexer) EventsFromLogStream

func (i *Indexer) EventsFromLogStream(ctx context.Context, quitAck chan error, ev *indexer.Event) error

func (*Indexer) FilterQueryFromEvent

func (i *Indexer) FilterQueryFromEvent(ev *indexer.Event) *ethereum.FilterQuery

func (*Indexer) IndexERC20From

func (i *Indexer) IndexERC20From(contract string, from int64) error

func (*Indexer) ListenBackground

func (i *Indexer) ListenBackground(ctx context.Context) error

ListenBackground starts an indexer service that listens for blocks in the background

func (*Indexer) Process

func (i *Indexer) Process(evs []*indexer.Event, blk *block) error

Process events

func (*Indexer) Start

func (i *Indexer) Start() error

Start starts the indexer service