syncer

Documentation

Index

• func New(logger logging.Logger, ev BlockHeightContractFilterer, blockTime uint64, ...) *service
• type BlockHeightContractFilterer
• type EventUpdater
• type Service
• type Shutdowner
• type Sync

Functions

func New

func New(
	logger logging.Logger,
	ev BlockHeightContractFilterer,
	blockTime uint64,
	shutdowner Shutdowner,
) *service

Types

type BlockHeightContractFilterer

type BlockHeightContractFilterer interface {
	bind.ContractFilterer
	BlockNumber(context.Context) (uint64, error)
}

type EventUpdater

type EventUpdater interface {
	ProcessEvent(e types.Log) error
	UpdateBlockNumber(blockNumber uint64) error
	TransactionStart() error
	TransactionEnd() error
}

type Service

type Service interface {
	AddSync(sync *Sync)
	Worker() <-chan struct{}
}

type Shutdowner

type Shutdowner interface {
	Shutdown(context.Context) error
}

type Sync

type Sync struct {
	From       uint64
	Updater    EventUpdater
	FilterLogs func(from, to *big.Int) ethereum.FilterQuery
}