Versions in this module Expand all Collapse all v0 v0.0.3 May 11, 2021 v0.0.2 May 11, 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) LatestBlockHash() common.Hash + func (_m *Broadcast) LatestBlockNumber() uint64 + func (_m *Broadcast) MarkConsumed() error + func (_m *Broadcast) RawLog() types.Log + func (_m *Broadcast) SetDecodedLog(_a0 interface{}) + func (_m *Broadcast) String() string + func (_m *Broadcast) WasAlreadyConsumed() (bool, error) + type Broadcaster struct + func (_m *Broadcaster) AddDependents(n int) + func (_m *Broadcaster) AwaitDependents() <-chan struct{} + func (_m *Broadcaster) DependentReady() + func (_m *Broadcaster) IsConnected() bool + func (_m *Broadcaster) LatestHead() *models.Head + func (_m *Broadcaster) Register(listener log.Listener, opts log.ListenerOpts) func() + func (_m *Broadcaster) SetLatestHeadFromStorage(head *models.Head) + func (_m *Broadcaster) Start() error + func (_m *Broadcaster) Stop() error + func (_m *Broadcaster) TrackedAddressesCount() uint32 + 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) MarkBroadcastConsumed(blockHash common.Hash, blockNumber uint64, logIndex uint, jobID interface{}) error + func (_m *ORM) WasBroadcastConsumed(blockHash common.Hash, logIndex uint, jobID interface{}) (bool, error)