Documentation
¶
Index ¶
- type MockDataProcessor
- type MockDataProcessor_Expecter
- type MockDataProcessor_Process_Call
- func (_c *MockDataProcessor_Process_Call[T]) Return(_a0 T, _a1 error) *MockDataProcessor_Process_Call[T]
- func (_c *MockDataProcessor_Process_Call[T]) Run(run func(_a0 T)) *MockDataProcessor_Process_Call[T]
- func (_c *MockDataProcessor_Process_Call[T]) RunAndReturn(run func(T) (T, error)) *MockDataProcessor_Process_Call[T]
- type MockDataWriter
- type MockDataWriter_Close_Call
- type MockDataWriter_Expecter
- type MockDataWriter_Write_Call
- type MockWorker
- type MockWorker_Expecter
- type MockWorker_Run_Call
- type MockWorker_SetReceiveChan_Call
- func (_c *MockWorker_SetReceiveChan_Call[T]) Return() *MockWorker_SetReceiveChan_Call[T]
- func (_c *MockWorker_SetReceiveChan_Call[T]) Run(run func(_a0 <-chan T)) *MockWorker_SetReceiveChan_Call[T]
- func (_c *MockWorker_SetReceiveChan_Call[T]) RunAndReturn(run func(<-chan T)) *MockWorker_SetReceiveChan_Call[T]
- type MockWorker_SetSendChan_Call
- type MockdataReader
- type MockdataReader_Close_Call
- type MockdataReader_Expecter
- type MockdataReader_Read_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockDataProcessor ¶ added in v0.2.0
MockDataProcessor is an autogenerated mock type for the DataProcessor type
func NewMockDataProcessor ¶ added in v0.2.0
func NewMockDataProcessor[T interface{}](t interface { mock.TestingT Cleanup(func()) }) *MockDataProcessor[T]
NewMockDataProcessor creates a new instance of MockDataProcessor. 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 (*MockDataProcessor[T]) EXPECT ¶ added in v0.2.0
func (_m *MockDataProcessor[T]) EXPECT() *MockDataProcessor_Expecter[T]
func (*MockDataProcessor[T]) Process ¶ added in v0.2.0
func (_m *MockDataProcessor[T]) Process(_a0 T) (T, error)
Process provides a mock function with given fields: _a0
type MockDataProcessor_Expecter ¶ added in v0.2.0
type MockDataProcessor_Expecter[T interface{}] struct {
// contains filtered or unexported fields
}
func (*MockDataProcessor_Expecter[T]) Process ¶ added in v0.2.0
func (_e *MockDataProcessor_Expecter[T]) Process(_a0 interface{}) *MockDataProcessor_Process_Call[T]
Process is a helper method to define mock.On call
- _a0 T
type MockDataProcessor_Process_Call ¶ added in v0.2.0
MockDataProcessor_Process_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Process'
func (*MockDataProcessor_Process_Call[T]) Return ¶ added in v0.2.0
func (_c *MockDataProcessor_Process_Call[T]) Return(_a0 T, _a1 error) *MockDataProcessor_Process_Call[T]
func (*MockDataProcessor_Process_Call[T]) Run ¶ added in v0.2.0
func (_c *MockDataProcessor_Process_Call[T]) Run(run func(_a0 T)) *MockDataProcessor_Process_Call[T]
func (*MockDataProcessor_Process_Call[T]) RunAndReturn ¶ added in v0.2.0
func (_c *MockDataProcessor_Process_Call[T]) RunAndReturn(run func(T) (T, error)) *MockDataProcessor_Process_Call[T]
type MockDataWriter ¶
MockDataWriter is an autogenerated mock type for the DataWriter type
func NewMockDataWriter ¶
func NewMockDataWriter[T interface{}](t interface { mock.TestingT Cleanup(func()) }) *MockDataWriter[T]
NewMockDataWriter creates a new instance of MockDataWriter. 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 (*MockDataWriter[T]) Close ¶
func (_m *MockDataWriter[T]) Close() error
Close provides a mock function with given fields:
func (*MockDataWriter[T]) EXPECT ¶
func (_m *MockDataWriter[T]) EXPECT() *MockDataWriter_Expecter[T]
func (*MockDataWriter[T]) Write ¶
func (_m *MockDataWriter[T]) Write(_a0 T) (int, error)
Write provides a mock function with given fields: _a0
type MockDataWriter_Close_Call ¶
MockDataWriter_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MockDataWriter_Close_Call[T]) Return ¶
func (_c *MockDataWriter_Close_Call[T]) Return(err error) *MockDataWriter_Close_Call[T]
func (*MockDataWriter_Close_Call[T]) Run ¶
func (_c *MockDataWriter_Close_Call[T]) Run(run func()) *MockDataWriter_Close_Call[T]
func (*MockDataWriter_Close_Call[T]) RunAndReturn ¶
func (_c *MockDataWriter_Close_Call[T]) RunAndReturn(run func() error) *MockDataWriter_Close_Call[T]
type MockDataWriter_Expecter ¶
type MockDataWriter_Expecter[T interface{}] struct {
// contains filtered or unexported fields
}
func (*MockDataWriter_Expecter[T]) Close ¶
func (_e *MockDataWriter_Expecter[T]) Close() *MockDataWriter_Close_Call[T]
Close is a helper method to define mock.On call
func (*MockDataWriter_Expecter[T]) Write ¶
func (_e *MockDataWriter_Expecter[T]) Write(_a0 interface{}) *MockDataWriter_Write_Call[T]
Write is a helper method to define mock.On call
- _a0 T
type MockDataWriter_Write_Call ¶
MockDataWriter_Write_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Write'
func (*MockDataWriter_Write_Call[T]) Return ¶
func (_c *MockDataWriter_Write_Call[T]) Return(n int, err error) *MockDataWriter_Write_Call[T]
func (*MockDataWriter_Write_Call[T]) Run ¶
func (_c *MockDataWriter_Write_Call[T]) Run(run func(_a0 T)) *MockDataWriter_Write_Call[T]
func (*MockDataWriter_Write_Call[T]) RunAndReturn ¶
func (_c *MockDataWriter_Write_Call[T]) RunAndReturn(run func(T) (int, error)) *MockDataWriter_Write_Call[T]
type MockWorker ¶
MockWorker is an autogenerated mock type for the Worker type
func NewMockWorker ¶
func NewMockWorker[T interface{}](t interface { mock.TestingT Cleanup(func()) }) *MockWorker[T]
NewMockWorker creates a new instance of MockWorker. 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 (*MockWorker[T]) EXPECT ¶
func (_m *MockWorker[T]) EXPECT() *MockWorker_Expecter[T]
func (*MockWorker[T]) Run ¶
func (_m *MockWorker[T]) Run(_a0 context.Context) error
Run provides a mock function with given fields: _a0
func (*MockWorker[T]) SetReceiveChan ¶
func (_m *MockWorker[T]) SetReceiveChan(_a0 <-chan T)
SetReceiveChan provides a mock function with given fields: _a0
func (*MockWorker[T]) SetSendChan ¶
func (_m *MockWorker[T]) SetSendChan(_a0 chan<- T)
SetSendChan provides a mock function with given fields: _a0
type MockWorker_Expecter ¶
type MockWorker_Expecter[T interface{}] struct {
// contains filtered or unexported fields
}
func (*MockWorker_Expecter[T]) Run ¶
func (_e *MockWorker_Expecter[T]) Run(_a0 interface{}) *MockWorker_Run_Call[T]
Run is a helper method to define mock.On call
- _a0 context.Context
func (*MockWorker_Expecter[T]) SetReceiveChan ¶
func (_e *MockWorker_Expecter[T]) SetReceiveChan(_a0 interface{}) *MockWorker_SetReceiveChan_Call[T]
SetReceiveChan is a helper method to define mock.On call
- _a0 <-chan T
func (*MockWorker_Expecter[T]) SetSendChan ¶
func (_e *MockWorker_Expecter[T]) SetSendChan(_a0 interface{}) *MockWorker_SetSendChan_Call[T]
SetSendChan is a helper method to define mock.On call
- _a0 chan<- T
type MockWorker_Run_Call ¶
MockWorker_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'
func (*MockWorker_Run_Call[T]) Return ¶
func (_c *MockWorker_Run_Call[T]) Return(_a0 error) *MockWorker_Run_Call[T]
func (*MockWorker_Run_Call[T]) Run ¶
func (_c *MockWorker_Run_Call[T]) Run(run func(_a0 context.Context)) *MockWorker_Run_Call[T]
func (*MockWorker_Run_Call[T]) RunAndReturn ¶
func (_c *MockWorker_Run_Call[T]) RunAndReturn(run func(context.Context) error) *MockWorker_Run_Call[T]
type MockWorker_SetReceiveChan_Call ¶
MockWorker_SetReceiveChan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetReceiveChan'
func (*MockWorker_SetReceiveChan_Call[T]) Return ¶
func (_c *MockWorker_SetReceiveChan_Call[T]) Return() *MockWorker_SetReceiveChan_Call[T]
func (*MockWorker_SetReceiveChan_Call[T]) Run ¶
func (_c *MockWorker_SetReceiveChan_Call[T]) Run(run func(_a0 <-chan T)) *MockWorker_SetReceiveChan_Call[T]
func (*MockWorker_SetReceiveChan_Call[T]) RunAndReturn ¶
func (_c *MockWorker_SetReceiveChan_Call[T]) RunAndReturn(run func(<-chan T)) *MockWorker_SetReceiveChan_Call[T]
type MockWorker_SetSendChan_Call ¶
MockWorker_SetSendChan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetSendChan'
func (*MockWorker_SetSendChan_Call[T]) Return ¶
func (_c *MockWorker_SetSendChan_Call[T]) Return() *MockWorker_SetSendChan_Call[T]
func (*MockWorker_SetSendChan_Call[T]) Run ¶
func (_c *MockWorker_SetSendChan_Call[T]) Run(run func(_a0 chan<- T)) *MockWorker_SetSendChan_Call[T]
func (*MockWorker_SetSendChan_Call[T]) RunAndReturn ¶
func (_c *MockWorker_SetSendChan_Call[T]) RunAndReturn(run func(chan<- T)) *MockWorker_SetSendChan_Call[T]
type MockdataReader ¶
MockdataReader is an autogenerated mock type for the dataReader type
func NewMockdataReader ¶
func NewMockdataReader[T interface{}](t interface { mock.TestingT Cleanup(func()) }) *MockdataReader[T]
NewMockdataReader creates a new instance of MockdataReader. 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 (*MockdataReader[T]) Close ¶
func (_m *MockdataReader[T]) Close()
Close provides a mock function with given fields:
func (*MockdataReader[T]) EXPECT ¶
func (_m *MockdataReader[T]) EXPECT() *MockdataReader_Expecter[T]
func (*MockdataReader[T]) Read ¶
func (_m *MockdataReader[T]) Read() (T, error)
Read provides a mock function with given fields:
type MockdataReader_Close_Call ¶
MockdataReader_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MockdataReader_Close_Call[T]) Return ¶
func (_c *MockdataReader_Close_Call[T]) Return() *MockdataReader_Close_Call[T]
func (*MockdataReader_Close_Call[T]) Run ¶
func (_c *MockdataReader_Close_Call[T]) Run(run func()) *MockdataReader_Close_Call[T]
func (*MockdataReader_Close_Call[T]) RunAndReturn ¶
func (_c *MockdataReader_Close_Call[T]) RunAndReturn(run func()) *MockdataReader_Close_Call[T]
type MockdataReader_Expecter ¶
type MockdataReader_Expecter[T interface{}] struct {
// contains filtered or unexported fields
}
func (*MockdataReader_Expecter[T]) Close ¶
func (_e *MockdataReader_Expecter[T]) Close() *MockdataReader_Close_Call[T]
Close is a helper method to define mock.On call
func (*MockdataReader_Expecter[T]) Read ¶
func (_e *MockdataReader_Expecter[T]) Read() *MockdataReader_Read_Call[T]
Read is a helper method to define mock.On call
type MockdataReader_Read_Call ¶
MockdataReader_Read_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Read'
func (*MockdataReader_Read_Call[T]) Return ¶
func (_c *MockdataReader_Read_Call[T]) Return(_a0 T, _a1 error) *MockdataReader_Read_Call[T]
func (*MockdataReader_Read_Call[T]) Run ¶
func (_c *MockdataReader_Read_Call[T]) Run(run func()) *MockdataReader_Read_Call[T]
func (*MockdataReader_Read_Call[T]) RunAndReturn ¶
func (_c *MockdataReader_Read_Call[T]) RunAndReturn(run func() (T, error)) *MockdataReader_Read_Call[T]