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) HealthReport() map[string]error
- func (_m *Broadcaster) IsConnected() bool
- func (_m *Broadcaster) MarkConsumed(ctx context.Context, lb log.Broadcast) error
- func (_m *Broadcaster) MarkManyConsumed(ctx context.Context, lbs []log.Broadcast) error
- func (_m *Broadcaster) Name() string
- 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(ctx context.Context, lb log.Broadcast) (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 ¶
func NewAbigenContract(t interface { mock.TestingT Cleanup(func()) }) *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. The first argument is typically a *testing.T value.
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 ¶
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. The first argument is typically a *testing.T value.
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 ¶
ReceiptsRoot provides a mock function with given fields:
func (*Broadcast) TransactionsRoot ¶
TransactionsRoot provides a mock function with given fields:
type Broadcaster ¶
Broadcaster is an autogenerated mock type for the Broadcaster type
func NewBroadcaster ¶
func NewBroadcaster(t interface { mock.TestingT Cleanup(func()) }) *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. The first argument is typically a *testing.T value.
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) HealthReport ¶
func (_m *Broadcaster) HealthReport() map[string]error
HealthReport 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: ctx, lb
func (*Broadcaster) MarkManyConsumed ¶
MarkManyConsumed provides a mock function with given fields: ctx, lbs
func (*Broadcaster) Name ¶
func (_m *Broadcaster) Name() string
Name provides a mock function with given fields:
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: ctx, lb