Versions in this module Expand all Collapse all v0 v0.0.1 May 19, 2021 Changes in this version + func ListenerJobID(listener Listener) interface + func NewBroadcaster(orm ORM, ethClient eth.Client, config Config) *broadcaster + func NewORM(db *gorm.DB) *orm + type AbigenContract interface + Address func() common.Address + ParseLog func(log types.Log) (generated.AbigenLog, error) + type Broadcast interface + DecodedLog func() interface{} + LatestBlockHash func() common.Hash + LatestBlockNumber func() uint64 + MarkConsumed func() error + RawLog func() types.Log + SetDecodedLog func(interface{}) + String func() string + WasAlreadyConsumed func() (bool, error) + type Broadcaster interface + IsConnected func() bool + LatestHead func() *models.Head + Register func(listener Listener, opts ListenerOpts) (unsubscribe func()) + SetLatestHeadFromStorage func(head *models.Head) + Start func() error + Stop func() error + TrackedAddressesCount func() uint32 + type Config interface + BlockBackfillDepth func() uint64 + EthFinalityDepth func() uint + type Listener interface + HandleLog func(b Broadcast) + IsV2Job func() bool + JobID func() models.JobID + JobIDV2 func() int32 + type ListenerOpts struct + Contract AbigenContract + Logs []generated.AbigenLog + NumConfirmations uint64 + type ORM interface + MarkBroadcastConsumed func(blockHash common.Hash, blockNumber uint64, logIndex uint, jobID interface{}) error + WasBroadcastConsumed func(blockHash common.Hash, logIndex uint, jobID interface{}) (bool, error)
Go to main page