indexer

Documentation

Index

• func InitFromConfig(cfg *logic.Config, pastEvents bool, startBlockNumber *big.Int) error
• type Indexer
  • func NewIndexer(rpcURL, beaconURL, networkName, contractAddress string, pastEvents bool, ...) *Indexer
  • func (indexer *Indexer) HandleEvent(log types.Log)
  • func (indexer *Indexer) Start()
  • func (indexer *Indexer) SubscribeEvent(eventHash string, callbackFunc func(string, string, string, types.Log))

Functions

func InitFromConfig

func InitFromConfig(cfg *logic.Config, pastEvents bool, startBlockNumber *big.Int) error

Initialize and starts all the indexers from config.

Types

type Indexer

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

Indexer struct holds the configuration and state for the Ethereum chain listener.

func NewIndexer

func NewIndexer(rpcURL, beaconURL, networkName, contractAddress string, pastEvents bool, startBlockNumber *big.Int) *Indexer

NewIndexer creates a new Indexer instance.

func (*Indexer) HandleEvent

func (indexer *Indexer) HandleEvent(log types.Log)

HandleEvent handles the incoming Ethereum event.

func (*Indexer) Start

func (indexer *Indexer) Start()

Start starts the Ethereum chain listener/indexer.

func (*Indexer) SubscribeEvent

func (indexer *Indexer) SubscribeEvent(eventHash string, callbackFunc func(string, string, string, types.Log))

SubscribeEvent subscribes to the specified event.