Documentation ¶
Index ¶
- type AbigenContract
- type Broadcast
- func (_m *Broadcast) DecodedLog() interface{}
- func (_m *Broadcast) EVMChainID() big.Int
- func (_m *Broadcast) JobID() int32
- func (_m *Broadcast) LatestBlockHash() common.Hash
- func (_m *Broadcast) LatestBlockNumber() uint64
- func (_m *Broadcast) RawLog() types.Log
- func (_m *Broadcast) ReceiptsRoot() common.Hash
- func (_m *Broadcast) StateRoot() common.Hash
- func (_m *Broadcast) String() string
- func (_m *Broadcast) TransactionsRoot() common.Hash
- 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) MarkManyConsumed(lbs []log.Broadcast, qopts ...pg.QOpt) error
- func (_m *Broadcaster) OnNewLongestChain(ctx context.Context, head *types.Head)
- func (_m *Broadcaster) Ready() error
- func (_m *Broadcaster) Register(listener log.Listener, opts log.ListenerOpts) func()
- func (_m *Broadcaster) ReplayFromBlock(number int64, forceBroadcast bool)
- func (_m *Broadcaster) Start(_a0 context.Context) 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) MarkBroadcastsConsumed(blockHashes []common.Hash, blockNumbers []uint64, logIndexes []uint, ...) error
- func (_m *ORM) MarkBroadcastsUnconsumed(fromBlock int64, qopts ...pg.QOpt) 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 ¶
AbigenContract is an autogenerated mock type for the AbigenContract type
func NewAbigenContract ¶ added in v1.7.0
func NewAbigenContract(t mockConstructorTestingTNewAbigenContract) *AbigenContract
NewAbigenContract creates a new instance of AbigenContract. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*AbigenContract) Address ¶
func (_m *AbigenContract) Address() common.Address
Address provides a mock function with given fields:
type Broadcast ¶
Broadcast is an autogenerated mock type for the Broadcast type
func NewBroadcast ¶ added in v1.5.0
func NewBroadcast(t mockConstructorTestingTNewBroadcast) *Broadcast
NewBroadcast creates a new instance of Broadcast. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Broadcast) DecodedLog ¶
func (_m *Broadcast) DecodedLog() interface{}
DecodedLog provides a mock function with given fields:
func (*Broadcast) EVMChainID ¶
EVMChainID provides a mock function with given fields:
func (*Broadcast) LatestBlockHash ¶
LatestBlockHash provides a mock function with given fields:
func (*Broadcast) LatestBlockNumber ¶
LatestBlockNumber provides a mock function with given fields:
func (*Broadcast) ReceiptsRoot ¶ added in v1.5.0
ReceiptsRoot provides a mock function with given fields:
func (*Broadcast) TransactionsRoot ¶ added in v1.5.0
TransactionsRoot provides a mock function with given fields:
type Broadcaster ¶
Broadcaster is an autogenerated mock type for the Broadcaster type
func NewBroadcaster ¶ added in v1.5.0
func NewBroadcaster(t mockConstructorTestingTNewBroadcaster) *Broadcaster
NewBroadcaster creates a new instance of Broadcaster. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Broadcaster) AddDependents ¶
func (_m *Broadcaster) AddDependents(n int)
AddDependents provides a mock function with given fields: n
func (*Broadcaster) AwaitDependents ¶
func (_m *Broadcaster) AwaitDependents() <-chan struct{}
AwaitDependents provides a mock function with given fields:
func (*Broadcaster) Close ¶
func (_m *Broadcaster) Close() error
Close provides a mock function with given fields:
func (*Broadcaster) DependentReady ¶
func (_m *Broadcaster) DependentReady()
DependentReady provides a mock function with given fields:
func (*Broadcaster) Healthy ¶
func (_m *Broadcaster) Healthy() error
Healthy provides a mock function with given fields:
func (*Broadcaster) IsConnected ¶
func (_m *Broadcaster) IsConnected() bool
IsConnected provides a mock function with given fields:
func (*Broadcaster) MarkConsumed ¶
MarkConsumed provides a mock function with given fields: lb, qopts
func (*Broadcaster) MarkManyConsumed ¶ added in v1.4.0
MarkManyConsumed provides a mock function with given fields: lbs, qopts
func (*Broadcaster) OnNewLongestChain ¶
func (_m *Broadcaster) OnNewLongestChain(ctx context.Context, head *types.Head)
OnNewLongestChain provides a mock function with given fields: ctx, head
func (*Broadcaster) Ready ¶
func (_m *Broadcaster) Ready() error
Ready provides a mock function with given fields:
func (*Broadcaster) Register ¶
func (_m *Broadcaster) Register(listener log.Listener, opts log.ListenerOpts) func()
Register provides a mock function with given fields: listener, opts
func (*Broadcaster) ReplayFromBlock ¶
func (_m *Broadcaster) ReplayFromBlock(number int64, forceBroadcast bool)
ReplayFromBlock provides a mock function with given fields: number, forceBroadcast
func (*Broadcaster) Start ¶
func (_m *Broadcaster) Start(_a0 context.Context) error
Start provides a mock function with given fields: _a0
func (*Broadcaster) WasAlreadyConsumed ¶
WasAlreadyConsumed provides a mock function with given fields: lb, qopts
type Config ¶
Config is an autogenerated mock type for the Config type
func NewConfig ¶ added in v1.5.0
func NewConfig(t mockConstructorTestingTNewConfig) *Config
NewConfig creates a new instance of Config. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Config) BlockBackfillDepth ¶
BlockBackfillDepth provides a mock function with given fields:
func (*Config) BlockBackfillSkip ¶
BlockBackfillSkip provides a mock function with given fields:
func (*Config) EvmFinalityDepth ¶
EvmFinalityDepth provides a mock function with given fields:
func (*Config) EvmLogBackfillBatchSize ¶
EvmLogBackfillBatchSize provides a mock function with given fields:
type Listener ¶
Listener is an autogenerated mock type for the Listener type
func NewListener ¶ added in v1.5.0
func NewListener(t mockConstructorTestingTNewListener) *Listener
NewListener creates a new instance of Listener. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func NewORM ¶ added in v1.5.0
func NewORM(t mockConstructorTestingTNewORM) *ORM
NewORM creates a new instance of ORM. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ORM) CreateBroadcast ¶
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 ¶
FindBroadcasts provides a mock function with given fields: fromBlockNum, toBlockNum
func (*ORM) GetPendingMinBlock ¶
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) MarkBroadcastsConsumed ¶ added in v1.4.0
func (_m *ORM) MarkBroadcastsConsumed(blockHashes []common.Hash, blockNumbers []uint64, logIndexes []uint, jobIDs []int32, qopts ...pg.QOpt) error
MarkBroadcastsConsumed provides a mock function with given fields: blockHashes, blockNumbers, logIndexes, jobIDs, qopts
func (*ORM) MarkBroadcastsUnconsumed ¶ added in v1.3.0
MarkBroadcastsUnconsumed provides a mock function with given fields: fromBlock, qopts
func (*ORM) Reinitialize ¶
Reinitialize provides a mock function with given fields: qopts
func (*ORM) SetPendingMinBlock ¶
SetPendingMinBlock provides a mock function with given fields: blockNum, qopts