Documentation
¶
Overview ¶
Package mock_pipeline is a generated GoMock package.
Index ¶
- type MockLogger
- type MockLoggerMockRecorder
- type MockPayload
- type MockPayloadFactory
- type MockPayloadFactoryMockRecorder
- type MockPayloadMockRecorder
- type MockSink
- type MockSinkMockRecorder
- type MockSource
- type MockSourceMockRecorder
- type MockStage
- type MockStageMockRecorder
- type MockTask
- type MockTaskMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockLogger ¶ added in v0.1.8
type MockLogger struct {
// contains filtered or unexported fields
}
MockLogger is a mock of Logger interface
func NewMockLogger ¶ added in v0.1.8
func NewMockLogger(ctrl *gomock.Controller) *MockLogger
NewMockLogger creates a new mock instance
func (*MockLogger) Debug ¶ added in v0.1.8
func (m *MockLogger) Debug(arg0 string)
Debug mocks base method
func (*MockLogger) EXPECT ¶ added in v0.1.8
func (m *MockLogger) EXPECT() *MockLoggerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockLogger) Info ¶ added in v0.1.8
func (m *MockLogger) Info(arg0 string)
Info mocks base method
type MockLoggerMockRecorder ¶ added in v0.1.8
type MockLoggerMockRecorder struct {
// contains filtered or unexported fields
}
MockLoggerMockRecorder is the mock recorder for MockLogger
func (*MockLoggerMockRecorder) Debug ¶ added in v0.1.8
func (mr *MockLoggerMockRecorder) Debug(arg0 interface{}) *gomock.Call
Debug indicates an expected call of Debug
func (*MockLoggerMockRecorder) Info ¶ added in v0.1.8
func (mr *MockLoggerMockRecorder) Info(arg0 interface{}) *gomock.Call
Info indicates an expected call of Info
type MockPayload ¶
type MockPayload struct {
// contains filtered or unexported fields
}
MockPayload is a mock of Payload interface
func NewMockPayload ¶
func NewMockPayload(ctrl *gomock.Controller) *MockPayload
NewMockPayload creates a new mock instance
func (*MockPayload) EXPECT ¶
func (m *MockPayload) EXPECT() *MockPayloadMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockPayload) MarkAsProcessed ¶
func (m *MockPayload) MarkAsProcessed()
MarkAsProcessed mocks base method
type MockPayloadFactory ¶
type MockPayloadFactory struct {
// contains filtered or unexported fields
}
MockPayloadFactory is a mock of PayloadFactory interface
func NewMockPayloadFactory ¶
func NewMockPayloadFactory(ctrl *gomock.Controller) *MockPayloadFactory
NewMockPayloadFactory creates a new mock instance
func (*MockPayloadFactory) EXPECT ¶
func (m *MockPayloadFactory) EXPECT() *MockPayloadFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockPayloadFactory) GetPayload ¶
func (m *MockPayloadFactory) GetPayload(arg0 int64) pipeline.Payload
GetPayload mocks base method
type MockPayloadFactoryMockRecorder ¶
type MockPayloadFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockPayloadFactoryMockRecorder is the mock recorder for MockPayloadFactory
func (*MockPayloadFactoryMockRecorder) GetPayload ¶
func (mr *MockPayloadFactoryMockRecorder) GetPayload(arg0 interface{}) *gomock.Call
GetPayload indicates an expected call of GetPayload
type MockPayloadMockRecorder ¶
type MockPayloadMockRecorder struct {
// contains filtered or unexported fields
}
MockPayloadMockRecorder is the mock recorder for MockPayload
func (*MockPayloadMockRecorder) MarkAsProcessed ¶
func (mr *MockPayloadMockRecorder) MarkAsProcessed() *gomock.Call
MarkAsProcessed indicates an expected call of MarkAsProcessed
type MockSink ¶
type MockSink struct {
// contains filtered or unexported fields
}
MockSink is a mock of Sink interface
func NewMockSink ¶
func NewMockSink(ctrl *gomock.Controller) *MockSink
NewMockSink creates a new mock instance
func (*MockSink) EXPECT ¶
func (m *MockSink) EXPECT() *MockSinkMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockSinkMockRecorder ¶
type MockSinkMockRecorder struct {
// contains filtered or unexported fields
}
MockSinkMockRecorder is the mock recorder for MockSink
func (*MockSinkMockRecorder) Consume ¶
func (mr *MockSinkMockRecorder) Consume(arg0, arg1 interface{}) *gomock.Call
Consume indicates an expected call of Consume
type MockSource ¶
type MockSource struct {
// contains filtered or unexported fields
}
MockSource is a mock of Source interface
func NewMockSource ¶
func NewMockSource(ctrl *gomock.Controller) *MockSource
NewMockSource creates a new mock instance
func (*MockSource) EXPECT ¶
func (m *MockSource) EXPECT() *MockSourceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockSourceMockRecorder ¶
type MockSourceMockRecorder struct {
// contains filtered or unexported fields
}
MockSourceMockRecorder is the mock recorder for MockSource
func (*MockSourceMockRecorder) Current ¶
func (mr *MockSourceMockRecorder) Current() *gomock.Call
Current indicates an expected call of Current
func (*MockSourceMockRecorder) Err ¶
func (mr *MockSourceMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err
func (*MockSourceMockRecorder) Next ¶
func (mr *MockSourceMockRecorder) Next(arg0, arg1 interface{}) *gomock.Call
Next indicates an expected call of Next
func (*MockSourceMockRecorder) Skip ¶ added in v0.1.14
func (mr *MockSourceMockRecorder) Skip() *gomock.Call
Skip indicates an expected call of Skip
type MockStage ¶
type MockStage struct {
// contains filtered or unexported fields
}
MockStage is a mock of Stage interface
func NewMockStage ¶
func NewMockStage(ctrl *gomock.Controller) *MockStage
NewMockStage creates a new mock instance
func (*MockStage) EXPECT ¶
func (m *MockStage) EXPECT() *MockStageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockStageMockRecorder ¶
type MockStageMockRecorder struct {
// contains filtered or unexported fields
}
MockStageMockRecorder is the mock recorder for MockStage
func (*MockStageMockRecorder) Run ¶
func (mr *MockStageMockRecorder) Run(arg0, arg1, arg2 interface{}) *gomock.Call
Run indicates an expected call of Run
type MockTask ¶
type MockTask struct {
// contains filtered or unexported fields
}
MockTask is a mock of Task interface
func NewMockTask ¶
func NewMockTask(ctrl *gomock.Controller) *MockTask
NewMockTask creates a new mock instance
func (*MockTask) EXPECT ¶
func (m *MockTask) EXPECT() *MockTaskMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockTaskMockRecorder ¶
type MockTaskMockRecorder struct {
// contains filtered or unexported fields
}
MockTaskMockRecorder is the mock recorder for MockTask
func (*MockTaskMockRecorder) GetName ¶ added in v0.1.5
func (mr *MockTaskMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName
func (*MockTaskMockRecorder) Run ¶
func (mr *MockTaskMockRecorder) Run(arg0, arg1 interface{}) *gomock.Call
Run indicates an expected call of Run
Source Files