Versions in this module Expand all Collapse all v1 v1.10.17 Oct 18, 2021 Changes in this version type Broadcast + func (_m *Broadcast) EVMChainID() big.Int + type Config struct + func (_m *Config) BlockBackfillDepth() uint64 + func (_m *Config) BlockBackfillSkip() bool + func (_m *Config) EvmFinalityDepth() uint32 + func (_m *Config) EvmLogBackfillBatchSize() uint32 v1.10.16 Oct 18, 2021 Changes in this version + type AbigenContract struct + func (_m *AbigenContract) Address() common.Address + func (_m *AbigenContract) ParseLog(_a0 types.Log) (generated.AbigenLog, error) + type Broadcast struct + func (_m *Broadcast) DecodedLog() interface{} + func (_m *Broadcast) JobID() log.JobIdSelect + func (_m *Broadcast) LatestBlockHash() common.Hash + func (_m *Broadcast) LatestBlockNumber() uint64 + func (_m *Broadcast) RawLog() types.Log + func (_m *Broadcast) String() string + type Broadcaster struct + func (_m *Broadcaster) AddDependents(n int) + func (_m *Broadcaster) AwaitDependents() <-chan struct{} + func (_m *Broadcaster) BackfillBlockNumber() null.Int64 + func (_m *Broadcaster) Close() error + func (_m *Broadcaster) Connect(head *models.Head) error + func (_m *Broadcaster) DependentReady() + func (_m *Broadcaster) Healthy() error + func (_m *Broadcaster) IsConnected() bool + func (_m *Broadcaster) MarkConsumed(db *gorm.DB, lb log.Broadcast) error + func (_m *Broadcaster) OnNewLongestChain(ctx context.Context, head models.Head) + func (_m *Broadcaster) Ready() error + func (_m *Broadcaster) Register(listener log.Listener, opts log.ListenerOpts) func() + func (_m *Broadcaster) ReplayFromBlock(number int64) + func (_m *Broadcaster) Start() error + func (_m *Broadcaster) TrackedAddressesCount() uint32 + func (_m *Broadcaster) WasAlreadyConsumed(db *gorm.DB, lb log.Broadcast) (bool, error) + type Listener struct + func (_m *Listener) HandleLog(b log.Broadcast) + func (_m *Listener) IsV2Job() bool + func (_m *Listener) JobID() models.JobID + func (_m *Listener) JobIDV2() int32 + type ORM struct + func (_m *ORM) FindConsumedLogs(fromBlockNum int64, toBlockNum int64) ([]log.LogBroadcast, error) + func (_m *ORM) MarkBroadcastConsumed(tx *gorm.DB, blockHash common.Hash, blockNumber uint64, logIndex uint, ...) error + func (_m *ORM) WasBroadcastConsumed(tx *gorm.DB, blockHash common.Hash, logIndex uint, jobID log.JobIdSelect) (bool, error)