Documentation
¶
Index ¶
- type AbigenContract
- type Broadcast
- type Broadcaster
- func (_m *Broadcaster) AddDependents(n int)
- func (_m *Broadcaster) AwaitDependents() <-chan struct{}
- func (_m *Broadcaster) Close() error
- func (_m *Broadcaster) DependentReady()
- func (_m *Broadcaster) Healthy() error
- func (_m *Broadcaster) IsConnected() bool
- func (_m *Broadcaster) MarkConsumed(lb log.Broadcast, qopts ...pg.QOpt) error
- func (_m *Broadcaster) OnNewLongestChain(ctx context.Context, head *eth.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) WasAlreadyConsumed(lb log.Broadcast, qopts ...pg.QOpt) (bool, error)
- type Config
- type Listener
- type ORM
- func (_m *ORM) CreateBroadcast(blockHash common.Hash, blockNumber uint64, logIndex uint, jobID int32, ...) error
- func (_m *ORM) FindBroadcasts(fromBlockNum int64, toBlockNum int64) ([]log.LogBroadcast, error)
- func (_m *ORM) GetPendingMinBlock(qopts ...pg.QOpt) (*int64, error)
- func (_m *ORM) MarkBroadcastConsumed(blockHash common.Hash, blockNumber uint64, logIndex uint, jobID int32, ...) error
- func (_m *ORM) Reinitialize(qopts ...pg.QOpt) (*int64, error)
- func (_m *ORM) SetPendingMinBlock(blockNum *int64, qopts ...pg.QOpt) error
- func (_m *ORM) WasBroadcastConsumed(blockHash common.Hash, logIndex uint, jobID int32, qopts ...pg.QOpt) (bool, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AbigenContract ¶ added in v0.10.3
AbigenContract is an autogenerated mock type for the AbigenContract type
func (*AbigenContract) Address ¶ added in v0.10.3
func (_m *AbigenContract) Address() common.Address
Address provides a mock function with given fields:
type Broadcast ¶ added in v0.10.3
Broadcast is an autogenerated mock type for the Broadcast type
func (*Broadcast) DecodedLog ¶ added in v0.10.3
func (_m *Broadcast) DecodedLog() interface{}
DecodedLog provides a mock function with given fields:
func (*Broadcast) EVMChainID ¶ added in v1.1.0
EVMChainID provides a mock function with given fields:
func (*Broadcast) LatestBlockHash ¶ added in v0.10.6
LatestBlockHash provides a mock function with given fields:
func (*Broadcast) LatestBlockNumber ¶ added in v0.10.6
LatestBlockNumber provides a mock function with given fields:
type Broadcaster ¶ added in v0.10.3
Broadcaster is an autogenerated mock type for the Broadcaster type
func (*Broadcaster) AddDependents ¶ added in v0.10.3
func (_m *Broadcaster) AddDependents(n int)
AddDependents provides a mock function with given fields: n
func (*Broadcaster) AwaitDependents ¶ added in v0.10.3
func (_m *Broadcaster) AwaitDependents() <-chan struct{}
AwaitDependents provides a mock function with given fields:
func (*Broadcaster) Close ¶ added in v0.10.8
func (_m *Broadcaster) Close() error
Close provides a mock function with given fields:
func (*Broadcaster) DependentReady ¶ added in v0.10.3
func (_m *Broadcaster) DependentReady()
DependentReady provides a mock function with given fields:
func (*Broadcaster) Healthy ¶ added in v0.10.8
func (_m *Broadcaster) Healthy() error
Healthy provides a mock function with given fields:
func (*Broadcaster) IsConnected ¶ added in v0.10.6
func (_m *Broadcaster) IsConnected() bool
IsConnected provides a mock function with given fields:
func (*Broadcaster) MarkConsumed ¶ added in v0.10.8
MarkConsumed provides a mock function with given fields: lb, qopts
func (*Broadcaster) OnNewLongestChain ¶ added in v0.10.8
func (_m *Broadcaster) OnNewLongestChain(ctx context.Context, head *eth.Head)
OnNewLongestChain provides a mock function with given fields: ctx, head
func (*Broadcaster) Ready ¶ added in v0.10.8
func (_m *Broadcaster) Ready() error
Ready provides a mock function with given fields:
func (*Broadcaster) Register ¶ added in v0.10.3
func (_m *Broadcaster) Register(listener log.Listener, opts log.ListenerOpts) func()
Register provides a mock function with given fields: listener, opts
func (*Broadcaster) ReplayFromBlock ¶ added in v0.10.11
func (_m *Broadcaster) ReplayFromBlock(number int64)
ReplayFromBlock provides a mock function with given fields: number
func (*Broadcaster) Start ¶ added in v0.10.3
func (_m *Broadcaster) Start() error
Start provides a mock function with given fields:
func (*Broadcaster) WasAlreadyConsumed ¶ added in v0.10.8
WasAlreadyConsumed provides a mock function with given fields: lb, qopts
type Config ¶ added in v1.0.0
Config is an autogenerated mock type for the Config type
func (*Config) BlockBackfillDepth ¶ added in v1.0.0
BlockBackfillDepth provides a mock function with given fields:
func (*Config) BlockBackfillSkip ¶ added in v1.0.0
BlockBackfillSkip provides a mock function with given fields:
func (*Config) EvmFinalityDepth ¶ added in v1.0.0
EvmFinalityDepth provides a mock function with given fields:
func (*Config) EvmLogBackfillBatchSize ¶ added in v1.0.0
EvmLogBackfillBatchSize provides a mock function with given fields:
type Listener ¶ added in v0.10.3
Listener is an autogenerated mock type for the Listener type
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func (*ORM) CreateBroadcast ¶ added in v1.1.0
func (_m *ORM) CreateBroadcast(blockHash common.Hash, blockNumber uint64, logIndex uint, jobID int32, qopts ...pg.QOpt) error
CreateBroadcast provides a mock function with given fields: blockHash, blockNumber, logIndex, jobID, qopts
func (*ORM) FindBroadcasts ¶ added in v1.1.0
FindBroadcasts provides a mock function with given fields: fromBlockNum, toBlockNum
func (*ORM) GetPendingMinBlock ¶ added in v1.1.0
GetPendingMinBlock provides a mock function with given fields: qopts
func (*ORM) MarkBroadcastConsumed ¶
func (_m *ORM) MarkBroadcastConsumed(blockHash common.Hash, blockNumber uint64, logIndex uint, jobID int32, qopts ...pg.QOpt) error
MarkBroadcastConsumed provides a mock function with given fields: blockHash, blockNumber, logIndex, jobID, qopts
func (*ORM) Reinitialize ¶ added in v1.1.0
Reinitialize provides a mock function with given fields: qopts
func (*ORM) SetPendingMinBlock ¶ added in v1.1.0
SetPendingMinBlock provides a mock function with given fields: blockNum, qopts