chain_poller

Documentation

Overview

File: internal/chain_poller/chain_poller.go

File: internal/chain_poller/chain_poller_interface.go

Index

• type ChainPoller
  • func NewChainPoller(cfg ChainPollerConfig) (*ChainPoller, error)
  • func (cp *ChainPoller) FilterLogs(ctx context.Context, filterQueries []api.FilterQuery) ([]api.Log, error)
• type ChainPollerConfig
• type ChainPollerInterface

Types

type ChainPoller

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

ChainPoller is responsible for polling logs from the blockchain.

func NewChainPoller

func NewChainPoller(cfg ChainPollerConfig) (*ChainPoller, error)

NewChainPoller initializes a new ChainPoller.

func (*ChainPoller) FilterLogs

func (cp *ChainPoller) FilterLogs(ctx context.Context, filterQueries []api.FilterQuery) ([]api.Log, error)

Poll fetches logs from the blockchain based on the provided filter queries.

type ChainPollerConfig

type ChainPollerConfig struct {
	BlockchainClient api.BlockchainClient
	Logger           *zerolog.Logger
	ChainID          int64
}

ChainPollerConfig holds the configuration for the ChainPoller.

type ChainPollerInterface

type ChainPollerInterface interface {
	FilterLogs(ctx context.Context, filterQueries []api.FilterQuery) ([]api.Log, error)
}