Documentation
¶
Index ¶
- type AbigenContract
- type AbigenContract_Address_Call
- type AbigenContract_Expecter
- type AbigenContract_ParseLog_Call
- func (_c *AbigenContract_ParseLog_Call) Return(_a0 generated.AbigenLog, _a1 error) *AbigenContract_ParseLog_Call
- func (_c *AbigenContract_ParseLog_Call) Run(run func(_a0 types.Log)) *AbigenContract_ParseLog_Call
- func (_c *AbigenContract_ParseLog_Call) RunAndReturn(run func(types.Log) (generated.AbigenLog, error)) *AbigenContract_ParseLog_Call
- type Broadcast
- func (_m *Broadcast) DecodedLog() interface{}
- func (_m *Broadcast) EVMChainID() big.Int
- func (_m *Broadcast) EXPECT() *Broadcast_Expecter
- 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 Broadcast_DecodedLog_Call
- type Broadcast_EVMChainID_Call
- type Broadcast_Expecter
- func (_e *Broadcast_Expecter) DecodedLog() *Broadcast_DecodedLog_Call
- func (_e *Broadcast_Expecter) EVMChainID() *Broadcast_EVMChainID_Call
- func (_e *Broadcast_Expecter) JobID() *Broadcast_JobID_Call
- func (_e *Broadcast_Expecter) LatestBlockHash() *Broadcast_LatestBlockHash_Call
- func (_e *Broadcast_Expecter) LatestBlockNumber() *Broadcast_LatestBlockNumber_Call
- func (_e *Broadcast_Expecter) RawLog() *Broadcast_RawLog_Call
- func (_e *Broadcast_Expecter) ReceiptsRoot() *Broadcast_ReceiptsRoot_Call
- func (_e *Broadcast_Expecter) StateRoot() *Broadcast_StateRoot_Call
- func (_e *Broadcast_Expecter) String() *Broadcast_String_Call
- func (_e *Broadcast_Expecter) TransactionsRoot() *Broadcast_TransactionsRoot_Call
- type Broadcast_JobID_Call
- type Broadcast_LatestBlockHash_Call
- type Broadcast_LatestBlockNumber_Call
- func (_c *Broadcast_LatestBlockNumber_Call) Return(_a0 uint64) *Broadcast_LatestBlockNumber_Call
- func (_c *Broadcast_LatestBlockNumber_Call) Run(run func()) *Broadcast_LatestBlockNumber_Call
- func (_c *Broadcast_LatestBlockNumber_Call) RunAndReturn(run func() uint64) *Broadcast_LatestBlockNumber_Call
- type Broadcast_RawLog_Call
- type Broadcast_ReceiptsRoot_Call
- type Broadcast_StateRoot_Call
- type Broadcast_String_Call
- type Broadcast_TransactionsRoot_Call
- func (_c *Broadcast_TransactionsRoot_Call) Return(_a0 common.Hash) *Broadcast_TransactionsRoot_Call
- func (_c *Broadcast_TransactionsRoot_Call) Run(run func()) *Broadcast_TransactionsRoot_Call
- func (_c *Broadcast_TransactionsRoot_Call) RunAndReturn(run func() common.Hash) *Broadcast_TransactionsRoot_Call
- 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) EXPECT() *Broadcaster_Expecter
- func (_m *Broadcaster) HealthReport() map[string]error
- func (_m *Broadcaster) IsConnected() bool
- func (_m *Broadcaster) MarkConsumed(ctx context.Context, ds sqlutil.DataSource, lb 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)
- type Broadcaster_AddDependents_Call
- type Broadcaster_AwaitDependents_Call
- func (_c *Broadcaster_AwaitDependents_Call) Return(_a0 <-chan struct{}) *Broadcaster_AwaitDependents_Call
- func (_c *Broadcaster_AwaitDependents_Call) Run(run func()) *Broadcaster_AwaitDependents_Call
- func (_c *Broadcaster_AwaitDependents_Call) RunAndReturn(run func() <-chan struct{}) *Broadcaster_AwaitDependents_Call
- type Broadcaster_Close_Call
- type Broadcaster_DependentReady_Call
- type Broadcaster_Expecter
- func (_e *Broadcaster_Expecter) AddDependents(n interface{}) *Broadcaster_AddDependents_Call
- func (_e *Broadcaster_Expecter) AwaitDependents() *Broadcaster_AwaitDependents_Call
- func (_e *Broadcaster_Expecter) Close() *Broadcaster_Close_Call
- func (_e *Broadcaster_Expecter) DependentReady() *Broadcaster_DependentReady_Call
- func (_e *Broadcaster_Expecter) HealthReport() *Broadcaster_HealthReport_Call
- func (_e *Broadcaster_Expecter) IsConnected() *Broadcaster_IsConnected_Call
- func (_e *Broadcaster_Expecter) MarkConsumed(ctx interface{}, ds interface{}, lb interface{}) *Broadcaster_MarkConsumed_Call
- func (_e *Broadcaster_Expecter) Name() *Broadcaster_Name_Call
- func (_e *Broadcaster_Expecter) OnNewLongestChain(ctx interface{}, head interface{}) *Broadcaster_OnNewLongestChain_Call
- func (_e *Broadcaster_Expecter) Ready() *Broadcaster_Ready_Call
- func (_e *Broadcaster_Expecter) Register(listener interface{}, opts interface{}) *Broadcaster_Register_Call
- func (_e *Broadcaster_Expecter) ReplayFromBlock(number interface{}, forceBroadcast interface{}) *Broadcaster_ReplayFromBlock_Call
- func (_e *Broadcaster_Expecter) Start(_a0 interface{}) *Broadcaster_Start_Call
- func (_e *Broadcaster_Expecter) WasAlreadyConsumed(ctx interface{}, lb interface{}) *Broadcaster_WasAlreadyConsumed_Call
- type Broadcaster_HealthReport_Call
- func (_c *Broadcaster_HealthReport_Call) Return(_a0 map[string]error) *Broadcaster_HealthReport_Call
- func (_c *Broadcaster_HealthReport_Call) Run(run func()) *Broadcaster_HealthReport_Call
- func (_c *Broadcaster_HealthReport_Call) RunAndReturn(run func() map[string]error) *Broadcaster_HealthReport_Call
- type Broadcaster_IsConnected_Call
- type Broadcaster_MarkConsumed_Call
- func (_c *Broadcaster_MarkConsumed_Call) Return(_a0 error) *Broadcaster_MarkConsumed_Call
- func (_c *Broadcaster_MarkConsumed_Call) Run(run func(ctx context.Context, ds sqlutil.DataSource, lb log.Broadcast)) *Broadcaster_MarkConsumed_Call
- func (_c *Broadcaster_MarkConsumed_Call) RunAndReturn(run func(context.Context, sqlutil.DataSource, log.Broadcast) error) *Broadcaster_MarkConsumed_Call
- type Broadcaster_Name_Call
- type Broadcaster_OnNewLongestChain_Call
- func (_c *Broadcaster_OnNewLongestChain_Call) Return() *Broadcaster_OnNewLongestChain_Call
- func (_c *Broadcaster_OnNewLongestChain_Call) Run(run func(ctx context.Context, head *types.Head)) *Broadcaster_OnNewLongestChain_Call
- func (_c *Broadcaster_OnNewLongestChain_Call) RunAndReturn(run func(context.Context, *types.Head)) *Broadcaster_OnNewLongestChain_Call
- type Broadcaster_Ready_Call
- type Broadcaster_Register_Call
- func (_c *Broadcaster_Register_Call) Return(unsubscribe func()) *Broadcaster_Register_Call
- func (_c *Broadcaster_Register_Call) Run(run func(listener log.Listener, opts log.ListenerOpts)) *Broadcaster_Register_Call
- func (_c *Broadcaster_Register_Call) RunAndReturn(run func(log.Listener, log.ListenerOpts) func()) *Broadcaster_Register_Call
- type Broadcaster_ReplayFromBlock_Call
- func (_c *Broadcaster_ReplayFromBlock_Call) Return() *Broadcaster_ReplayFromBlock_Call
- func (_c *Broadcaster_ReplayFromBlock_Call) Run(run func(number int64, forceBroadcast bool)) *Broadcaster_ReplayFromBlock_Call
- func (_c *Broadcaster_ReplayFromBlock_Call) RunAndReturn(run func(int64, bool)) *Broadcaster_ReplayFromBlock_Call
- type Broadcaster_Start_Call
- type Broadcaster_WasAlreadyConsumed_Call
- func (_c *Broadcaster_WasAlreadyConsumed_Call) Return(_a0 bool, _a1 error) *Broadcaster_WasAlreadyConsumed_Call
- func (_c *Broadcaster_WasAlreadyConsumed_Call) Run(run func(ctx context.Context, lb log.Broadcast)) *Broadcaster_WasAlreadyConsumed_Call
- func (_c *Broadcaster_WasAlreadyConsumed_Call) RunAndReturn(run func(context.Context, log.Broadcast) (bool, error)) *Broadcaster_WasAlreadyConsumed_Call
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:
func (*AbigenContract) EXPECT ¶ added in v2.15.0
func (_m *AbigenContract) EXPECT() *AbigenContract_Expecter
type AbigenContract_Address_Call ¶ added in v2.15.0
AbigenContract_Address_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Address'
func (*AbigenContract_Address_Call) Return ¶ added in v2.15.0
func (_c *AbigenContract_Address_Call) Return(_a0 common.Address) *AbigenContract_Address_Call
func (*AbigenContract_Address_Call) Run ¶ added in v2.15.0
func (_c *AbigenContract_Address_Call) Run(run func()) *AbigenContract_Address_Call
func (*AbigenContract_Address_Call) RunAndReturn ¶ added in v2.15.0
func (_c *AbigenContract_Address_Call) RunAndReturn(run func() common.Address) *AbigenContract_Address_Call
type AbigenContract_Expecter ¶ added in v2.15.0
type AbigenContract_Expecter struct {
// contains filtered or unexported fields
}
func (*AbigenContract_Expecter) Address ¶ added in v2.15.0
func (_e *AbigenContract_Expecter) Address() *AbigenContract_Address_Call
Address is a helper method to define mock.On call
func (*AbigenContract_Expecter) ParseLog ¶ added in v2.15.0
func (_e *AbigenContract_Expecter) ParseLog(_a0 interface{}) *AbigenContract_ParseLog_Call
ParseLog is a helper method to define mock.On call
- _a0 types.Log
type AbigenContract_ParseLog_Call ¶ added in v2.15.0
AbigenContract_ParseLog_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ParseLog'
func (*AbigenContract_ParseLog_Call) Return ¶ added in v2.15.0
func (_c *AbigenContract_ParseLog_Call) Return(_a0 generated.AbigenLog, _a1 error) *AbigenContract_ParseLog_Call
func (*AbigenContract_ParseLog_Call) Run ¶ added in v2.15.0
func (_c *AbigenContract_ParseLog_Call) Run(run func(_a0 types.Log)) *AbigenContract_ParseLog_Call
func (*AbigenContract_ParseLog_Call) RunAndReturn ¶ added in v2.15.0
func (_c *AbigenContract_ParseLog_Call) RunAndReturn(run func(types.Log) (generated.AbigenLog, error)) *AbigenContract_ParseLog_Call
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) EXPECT ¶ added in v2.15.0
func (_m *Broadcast) EXPECT() *Broadcast_Expecter
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 Broadcast_DecodedLog_Call ¶ added in v2.15.0
Broadcast_DecodedLog_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DecodedLog'
func (*Broadcast_DecodedLog_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_DecodedLog_Call) Return(_a0 interface{}) *Broadcast_DecodedLog_Call
func (*Broadcast_DecodedLog_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_DecodedLog_Call) Run(run func()) *Broadcast_DecodedLog_Call
func (*Broadcast_DecodedLog_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_DecodedLog_Call) RunAndReturn(run func() interface{}) *Broadcast_DecodedLog_Call
type Broadcast_EVMChainID_Call ¶ added in v2.15.0
Broadcast_EVMChainID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EVMChainID'
func (*Broadcast_EVMChainID_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_EVMChainID_Call) Return(_a0 big.Int) *Broadcast_EVMChainID_Call
func (*Broadcast_EVMChainID_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_EVMChainID_Call) Run(run func()) *Broadcast_EVMChainID_Call
func (*Broadcast_EVMChainID_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_EVMChainID_Call) RunAndReturn(run func() big.Int) *Broadcast_EVMChainID_Call
type Broadcast_Expecter ¶ added in v2.15.0
type Broadcast_Expecter struct {
// contains filtered or unexported fields
}
func (*Broadcast_Expecter) DecodedLog ¶ added in v2.15.0
func (_e *Broadcast_Expecter) DecodedLog() *Broadcast_DecodedLog_Call
DecodedLog is a helper method to define mock.On call
func (*Broadcast_Expecter) EVMChainID ¶ added in v2.15.0
func (_e *Broadcast_Expecter) EVMChainID() *Broadcast_EVMChainID_Call
EVMChainID is a helper method to define mock.On call
func (*Broadcast_Expecter) JobID ¶ added in v2.15.0
func (_e *Broadcast_Expecter) JobID() *Broadcast_JobID_Call
JobID is a helper method to define mock.On call
func (*Broadcast_Expecter) LatestBlockHash ¶ added in v2.15.0
func (_e *Broadcast_Expecter) LatestBlockHash() *Broadcast_LatestBlockHash_Call
LatestBlockHash is a helper method to define mock.On call
func (*Broadcast_Expecter) LatestBlockNumber ¶ added in v2.15.0
func (_e *Broadcast_Expecter) LatestBlockNumber() *Broadcast_LatestBlockNumber_Call
LatestBlockNumber is a helper method to define mock.On call
func (*Broadcast_Expecter) RawLog ¶ added in v2.15.0
func (_e *Broadcast_Expecter) RawLog() *Broadcast_RawLog_Call
RawLog is a helper method to define mock.On call
func (*Broadcast_Expecter) ReceiptsRoot ¶ added in v2.15.0
func (_e *Broadcast_Expecter) ReceiptsRoot() *Broadcast_ReceiptsRoot_Call
ReceiptsRoot is a helper method to define mock.On call
func (*Broadcast_Expecter) StateRoot ¶ added in v2.15.0
func (_e *Broadcast_Expecter) StateRoot() *Broadcast_StateRoot_Call
StateRoot is a helper method to define mock.On call
func (*Broadcast_Expecter) String ¶ added in v2.15.0
func (_e *Broadcast_Expecter) String() *Broadcast_String_Call
String is a helper method to define mock.On call
func (*Broadcast_Expecter) TransactionsRoot ¶ added in v2.15.0
func (_e *Broadcast_Expecter) TransactionsRoot() *Broadcast_TransactionsRoot_Call
TransactionsRoot is a helper method to define mock.On call
type Broadcast_JobID_Call ¶ added in v2.15.0
Broadcast_JobID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'JobID'
func (*Broadcast_JobID_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_JobID_Call) Return(_a0 int32) *Broadcast_JobID_Call
func (*Broadcast_JobID_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_JobID_Call) Run(run func()) *Broadcast_JobID_Call
func (*Broadcast_JobID_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_JobID_Call) RunAndReturn(run func() int32) *Broadcast_JobID_Call
type Broadcast_LatestBlockHash_Call ¶ added in v2.15.0
Broadcast_LatestBlockHash_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LatestBlockHash'
func (*Broadcast_LatestBlockHash_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_LatestBlockHash_Call) Return(_a0 common.Hash) *Broadcast_LatestBlockHash_Call
func (*Broadcast_LatestBlockHash_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_LatestBlockHash_Call) Run(run func()) *Broadcast_LatestBlockHash_Call
func (*Broadcast_LatestBlockHash_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_LatestBlockHash_Call) RunAndReturn(run func() common.Hash) *Broadcast_LatestBlockHash_Call
type Broadcast_LatestBlockNumber_Call ¶ added in v2.15.0
Broadcast_LatestBlockNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LatestBlockNumber'
func (*Broadcast_LatestBlockNumber_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_LatestBlockNumber_Call) Return(_a0 uint64) *Broadcast_LatestBlockNumber_Call
func (*Broadcast_LatestBlockNumber_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_LatestBlockNumber_Call) Run(run func()) *Broadcast_LatestBlockNumber_Call
func (*Broadcast_LatestBlockNumber_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_LatestBlockNumber_Call) RunAndReturn(run func() uint64) *Broadcast_LatestBlockNumber_Call
type Broadcast_RawLog_Call ¶ added in v2.15.0
Broadcast_RawLog_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RawLog'
func (*Broadcast_RawLog_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_RawLog_Call) Return(_a0 types.Log) *Broadcast_RawLog_Call
func (*Broadcast_RawLog_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_RawLog_Call) Run(run func()) *Broadcast_RawLog_Call
func (*Broadcast_RawLog_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_RawLog_Call) RunAndReturn(run func() types.Log) *Broadcast_RawLog_Call
type Broadcast_ReceiptsRoot_Call ¶ added in v2.15.0
Broadcast_ReceiptsRoot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReceiptsRoot'
func (*Broadcast_ReceiptsRoot_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_ReceiptsRoot_Call) Return(_a0 common.Hash) *Broadcast_ReceiptsRoot_Call
func (*Broadcast_ReceiptsRoot_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_ReceiptsRoot_Call) Run(run func()) *Broadcast_ReceiptsRoot_Call
func (*Broadcast_ReceiptsRoot_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_ReceiptsRoot_Call) RunAndReturn(run func() common.Hash) *Broadcast_ReceiptsRoot_Call
type Broadcast_StateRoot_Call ¶ added in v2.15.0
Broadcast_StateRoot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StateRoot'
func (*Broadcast_StateRoot_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_StateRoot_Call) Return(_a0 common.Hash) *Broadcast_StateRoot_Call
func (*Broadcast_StateRoot_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_StateRoot_Call) Run(run func()) *Broadcast_StateRoot_Call
func (*Broadcast_StateRoot_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_StateRoot_Call) RunAndReturn(run func() common.Hash) *Broadcast_StateRoot_Call
type Broadcast_String_Call ¶ added in v2.15.0
Broadcast_String_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'String'
func (*Broadcast_String_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_String_Call) Return(_a0 string) *Broadcast_String_Call
func (*Broadcast_String_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_String_Call) Run(run func()) *Broadcast_String_Call
func (*Broadcast_String_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_String_Call) RunAndReturn(run func() string) *Broadcast_String_Call
type Broadcast_TransactionsRoot_Call ¶ added in v2.15.0
Broadcast_TransactionsRoot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TransactionsRoot'
func (*Broadcast_TransactionsRoot_Call) Return ¶ added in v2.15.0
func (_c *Broadcast_TransactionsRoot_Call) Return(_a0 common.Hash) *Broadcast_TransactionsRoot_Call
func (*Broadcast_TransactionsRoot_Call) Run ¶ added in v2.15.0
func (_c *Broadcast_TransactionsRoot_Call) Run(run func()) *Broadcast_TransactionsRoot_Call
func (*Broadcast_TransactionsRoot_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcast_TransactionsRoot_Call) RunAndReturn(run func() common.Hash) *Broadcast_TransactionsRoot_Call
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) EXPECT ¶ added in v2.15.0
func (_m *Broadcaster) EXPECT() *Broadcaster_Expecter
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 ¶
func (_m *Broadcaster) MarkConsumed(ctx context.Context, ds sqlutil.DataSource, lb log.Broadcast) error
MarkConsumed provides a mock function with given fields: ctx, ds, lb
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
type Broadcaster_AddDependents_Call ¶ added in v2.15.0
Broadcaster_AddDependents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddDependents'
func (*Broadcaster_AddDependents_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_AddDependents_Call) Return() *Broadcaster_AddDependents_Call
func (*Broadcaster_AddDependents_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_AddDependents_Call) Run(run func(n int)) *Broadcaster_AddDependents_Call
func (*Broadcaster_AddDependents_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_AddDependents_Call) RunAndReturn(run func(int)) *Broadcaster_AddDependents_Call
type Broadcaster_AwaitDependents_Call ¶ added in v2.15.0
Broadcaster_AwaitDependents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AwaitDependents'
func (*Broadcaster_AwaitDependents_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_AwaitDependents_Call) Return(_a0 <-chan struct{}) *Broadcaster_AwaitDependents_Call
func (*Broadcaster_AwaitDependents_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_AwaitDependents_Call) Run(run func()) *Broadcaster_AwaitDependents_Call
func (*Broadcaster_AwaitDependents_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_AwaitDependents_Call) RunAndReturn(run func() <-chan struct{}) *Broadcaster_AwaitDependents_Call
type Broadcaster_Close_Call ¶ added in v2.15.0
Broadcaster_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*Broadcaster_Close_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_Close_Call) Return(_a0 error) *Broadcaster_Close_Call
func (*Broadcaster_Close_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_Close_Call) Run(run func()) *Broadcaster_Close_Call
func (*Broadcaster_Close_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_Close_Call) RunAndReturn(run func() error) *Broadcaster_Close_Call
type Broadcaster_DependentReady_Call ¶ added in v2.15.0
Broadcaster_DependentReady_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DependentReady'
func (*Broadcaster_DependentReady_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_DependentReady_Call) Return() *Broadcaster_DependentReady_Call
func (*Broadcaster_DependentReady_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_DependentReady_Call) Run(run func()) *Broadcaster_DependentReady_Call
func (*Broadcaster_DependentReady_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_DependentReady_Call) RunAndReturn(run func()) *Broadcaster_DependentReady_Call
type Broadcaster_Expecter ¶ added in v2.15.0
type Broadcaster_Expecter struct {
// contains filtered or unexported fields
}
func (*Broadcaster_Expecter) AddDependents ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) AddDependents(n interface{}) *Broadcaster_AddDependents_Call
AddDependents is a helper method to define mock.On call
- n int
func (*Broadcaster_Expecter) AwaitDependents ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) AwaitDependents() *Broadcaster_AwaitDependents_Call
AwaitDependents is a helper method to define mock.On call
func (*Broadcaster_Expecter) Close ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) Close() *Broadcaster_Close_Call
Close is a helper method to define mock.On call
func (*Broadcaster_Expecter) DependentReady ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) DependentReady() *Broadcaster_DependentReady_Call
DependentReady is a helper method to define mock.On call
func (*Broadcaster_Expecter) HealthReport ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) HealthReport() *Broadcaster_HealthReport_Call
HealthReport is a helper method to define mock.On call
func (*Broadcaster_Expecter) IsConnected ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) IsConnected() *Broadcaster_IsConnected_Call
IsConnected is a helper method to define mock.On call
func (*Broadcaster_Expecter) MarkConsumed ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) MarkConsumed(ctx interface{}, ds interface{}, lb interface{}) *Broadcaster_MarkConsumed_Call
MarkConsumed is a helper method to define mock.On call
- ctx context.Context
- ds sqlutil.DataSource
- lb log.Broadcast
func (*Broadcaster_Expecter) Name ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) Name() *Broadcaster_Name_Call
Name is a helper method to define mock.On call
func (*Broadcaster_Expecter) OnNewLongestChain ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) OnNewLongestChain(ctx interface{}, head interface{}) *Broadcaster_OnNewLongestChain_Call
OnNewLongestChain is a helper method to define mock.On call
- ctx context.Context
- head *types.Head
func (*Broadcaster_Expecter) Ready ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) Ready() *Broadcaster_Ready_Call
Ready is a helper method to define mock.On call
func (*Broadcaster_Expecter) Register ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) Register(listener interface{}, opts interface{}) *Broadcaster_Register_Call
Register is a helper method to define mock.On call
- listener log.Listener
- opts log.ListenerOpts
func (*Broadcaster_Expecter) ReplayFromBlock ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) ReplayFromBlock(number interface{}, forceBroadcast interface{}) *Broadcaster_ReplayFromBlock_Call
ReplayFromBlock is a helper method to define mock.On call
- number int64
- forceBroadcast bool
func (*Broadcaster_Expecter) Start ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) Start(_a0 interface{}) *Broadcaster_Start_Call
Start is a helper method to define mock.On call
- _a0 context.Context
func (*Broadcaster_Expecter) WasAlreadyConsumed ¶ added in v2.15.0
func (_e *Broadcaster_Expecter) WasAlreadyConsumed(ctx interface{}, lb interface{}) *Broadcaster_WasAlreadyConsumed_Call
WasAlreadyConsumed is a helper method to define mock.On call
- ctx context.Context
- lb log.Broadcast
type Broadcaster_HealthReport_Call ¶ added in v2.15.0
Broadcaster_HealthReport_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HealthReport'
func (*Broadcaster_HealthReport_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_HealthReport_Call) Return(_a0 map[string]error) *Broadcaster_HealthReport_Call
func (*Broadcaster_HealthReport_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_HealthReport_Call) Run(run func()) *Broadcaster_HealthReport_Call
func (*Broadcaster_HealthReport_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_HealthReport_Call) RunAndReturn(run func() map[string]error) *Broadcaster_HealthReport_Call
type Broadcaster_IsConnected_Call ¶ added in v2.15.0
Broadcaster_IsConnected_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsConnected'
func (*Broadcaster_IsConnected_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_IsConnected_Call) Return(_a0 bool) *Broadcaster_IsConnected_Call
func (*Broadcaster_IsConnected_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_IsConnected_Call) Run(run func()) *Broadcaster_IsConnected_Call
func (*Broadcaster_IsConnected_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_IsConnected_Call) RunAndReturn(run func() bool) *Broadcaster_IsConnected_Call
type Broadcaster_MarkConsumed_Call ¶ added in v2.15.0
Broadcaster_MarkConsumed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkConsumed'
func (*Broadcaster_MarkConsumed_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_MarkConsumed_Call) Return(_a0 error) *Broadcaster_MarkConsumed_Call
func (*Broadcaster_MarkConsumed_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_MarkConsumed_Call) Run(run func(ctx context.Context, ds sqlutil.DataSource, lb log.Broadcast)) *Broadcaster_MarkConsumed_Call
func (*Broadcaster_MarkConsumed_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_MarkConsumed_Call) RunAndReturn(run func(context.Context, sqlutil.DataSource, log.Broadcast) error) *Broadcaster_MarkConsumed_Call
type Broadcaster_Name_Call ¶ added in v2.15.0
Broadcaster_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'
func (*Broadcaster_Name_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_Name_Call) Return(_a0 string) *Broadcaster_Name_Call
func (*Broadcaster_Name_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_Name_Call) Run(run func()) *Broadcaster_Name_Call
func (*Broadcaster_Name_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_Name_Call) RunAndReturn(run func() string) *Broadcaster_Name_Call
type Broadcaster_OnNewLongestChain_Call ¶ added in v2.15.0
Broadcaster_OnNewLongestChain_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnNewLongestChain'
func (*Broadcaster_OnNewLongestChain_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_OnNewLongestChain_Call) Return() *Broadcaster_OnNewLongestChain_Call
func (*Broadcaster_OnNewLongestChain_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_OnNewLongestChain_Call) Run(run func(ctx context.Context, head *types.Head)) *Broadcaster_OnNewLongestChain_Call
func (*Broadcaster_OnNewLongestChain_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_OnNewLongestChain_Call) RunAndReturn(run func(context.Context, *types.Head)) *Broadcaster_OnNewLongestChain_Call
type Broadcaster_Ready_Call ¶ added in v2.15.0
Broadcaster_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'
func (*Broadcaster_Ready_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_Ready_Call) Return(_a0 error) *Broadcaster_Ready_Call
func (*Broadcaster_Ready_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_Ready_Call) Run(run func()) *Broadcaster_Ready_Call
func (*Broadcaster_Ready_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_Ready_Call) RunAndReturn(run func() error) *Broadcaster_Ready_Call
type Broadcaster_Register_Call ¶ added in v2.15.0
Broadcaster_Register_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Register'
func (*Broadcaster_Register_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_Register_Call) Return(unsubscribe func()) *Broadcaster_Register_Call
func (*Broadcaster_Register_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_Register_Call) Run(run func(listener log.Listener, opts log.ListenerOpts)) *Broadcaster_Register_Call
func (*Broadcaster_Register_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_Register_Call) RunAndReturn(run func(log.Listener, log.ListenerOpts) func()) *Broadcaster_Register_Call
type Broadcaster_ReplayFromBlock_Call ¶ added in v2.15.0
Broadcaster_ReplayFromBlock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReplayFromBlock'
func (*Broadcaster_ReplayFromBlock_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_ReplayFromBlock_Call) Return() *Broadcaster_ReplayFromBlock_Call
func (*Broadcaster_ReplayFromBlock_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_ReplayFromBlock_Call) Run(run func(number int64, forceBroadcast bool)) *Broadcaster_ReplayFromBlock_Call
func (*Broadcaster_ReplayFromBlock_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_ReplayFromBlock_Call) RunAndReturn(run func(int64, bool)) *Broadcaster_ReplayFromBlock_Call
type Broadcaster_Start_Call ¶ added in v2.15.0
Broadcaster_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Broadcaster_Start_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_Start_Call) Return(_a0 error) *Broadcaster_Start_Call
func (*Broadcaster_Start_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_Start_Call) Run(run func(_a0 context.Context)) *Broadcaster_Start_Call
func (*Broadcaster_Start_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_Start_Call) RunAndReturn(run func(context.Context) error) *Broadcaster_Start_Call
type Broadcaster_WasAlreadyConsumed_Call ¶ added in v2.15.0
Broadcaster_WasAlreadyConsumed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WasAlreadyConsumed'
func (*Broadcaster_WasAlreadyConsumed_Call) Return ¶ added in v2.15.0
func (_c *Broadcaster_WasAlreadyConsumed_Call) Return(_a0 bool, _a1 error) *Broadcaster_WasAlreadyConsumed_Call
func (*Broadcaster_WasAlreadyConsumed_Call) Run ¶ added in v2.15.0
func (_c *Broadcaster_WasAlreadyConsumed_Call) Run(run func(ctx context.Context, lb log.Broadcast)) *Broadcaster_WasAlreadyConsumed_Call
func (*Broadcaster_WasAlreadyConsumed_Call) RunAndReturn ¶ added in v2.15.0
func (_c *Broadcaster_WasAlreadyConsumed_Call) RunAndReturn(run func(context.Context, log.Broadcast) (bool, error)) *Broadcaster_WasAlreadyConsumed_Call