Documentation
¶
Overview ¶
Package mock_engine is a generated GoMock package.
Index ¶
- type MockConsumer
- type MockConsumerMockRecorder
- type MockEngine
- func (m *MockEngine) AddConsumer(arg0 engine.Consumer)
- func (m *MockEngine) AddDeferFunc(arg0 func(context.Context))
- func (m *MockEngine) AddPeriodicalWorker(arg0 string, arg1 engine.PeriodicalWorker)
- func (m *MockEngine) AddRoutine(arg0 engine.Routine)
- func (m *MockEngine) EXPECT() *MockEngineMockRecorder
- func (m *MockEngine) Run(arg0 context.Context) error
- type MockEngineMockRecorder
- func (mr *MockEngineMockRecorder) AddConsumer(arg0 interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) AddDeferFunc(arg0 interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) AddPeriodicalWorker(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) AddRoutine(arg0 interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) Run(arg0 interface{}) *gomock.Call
- type MockMessageProcessor
- type MockMessageProcessorMockRecorder
- type MockPeriodicalWorker
- type MockPeriodicalWorkerMockRecorder
- type MockRPCClient
- type MockRPCClientMockRecorder
- type MockRPCMessageProcessor
- type MockRPCMessageProcessorMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockConsumer ¶
type MockConsumer struct {
// contains filtered or unexported fields
}
MockConsumer is a mock of Consumer interface.
func NewMockConsumer ¶
func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
NewMockConsumer creates a new mock instance.
func (*MockConsumer) Consume ¶
func (m *MockConsumer) Consume(arg0 context.Context) error
Consume mocks base method.
func (*MockConsumer) EXPECT ¶
func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockConsumerMockRecorder ¶
type MockConsumerMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerMockRecorder is the mock recorder for MockConsumer.
func (*MockConsumerMockRecorder) Consume ¶
func (mr *MockConsumerMockRecorder) Consume(arg0 interface{}) *gomock.Call
Consume indicates an expected call of Consume.
type MockEngine ¶
type MockEngine struct {
// contains filtered or unexported fields
}
MockEngine is a mock of Engine interface.
func NewMockEngine ¶
func NewMockEngine(ctrl *gomock.Controller) *MockEngine
NewMockEngine creates a new mock instance.
func (*MockEngine) AddConsumer ¶
func (m *MockEngine) AddConsumer(arg0 engine.Consumer)
AddConsumer mocks base method.
func (*MockEngine) AddDeferFunc ¶
func (m *MockEngine) AddDeferFunc(arg0 func(context.Context))
AddDeferFunc mocks base method.
func (*MockEngine) AddPeriodicalWorker ¶
func (m *MockEngine) AddPeriodicalWorker(arg0 string, arg1 engine.PeriodicalWorker)
AddPeriodicalWorker mocks base method.
func (*MockEngine) AddRoutine ¶
func (m *MockEngine) AddRoutine(arg0 engine.Routine)
AddRoutine mocks base method.
func (*MockEngine) EXPECT ¶
func (m *MockEngine) EXPECT() *MockEngineMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockEngineMockRecorder ¶
type MockEngineMockRecorder struct {
// contains filtered or unexported fields
}
MockEngineMockRecorder is the mock recorder for MockEngine.
func (*MockEngineMockRecorder) AddConsumer ¶
func (mr *MockEngineMockRecorder) AddConsumer(arg0 interface{}) *gomock.Call
AddConsumer indicates an expected call of AddConsumer.
func (*MockEngineMockRecorder) AddDeferFunc ¶
func (mr *MockEngineMockRecorder) AddDeferFunc(arg0 interface{}) *gomock.Call
AddDeferFunc indicates an expected call of AddDeferFunc.
func (*MockEngineMockRecorder) AddPeriodicalWorker ¶
func (mr *MockEngineMockRecorder) AddPeriodicalWorker(arg0, arg1 interface{}) *gomock.Call
AddPeriodicalWorker indicates an expected call of AddPeriodicalWorker.
func (*MockEngineMockRecorder) AddRoutine ¶
func (mr *MockEngineMockRecorder) AddRoutine(arg0 interface{}) *gomock.Call
AddRoutine indicates an expected call of AddRoutine.
func (*MockEngineMockRecorder) Run ¶
func (mr *MockEngineMockRecorder) Run(arg0 interface{}) *gomock.Call
Run indicates an expected call of Run.
type MockMessageProcessor ¶
type MockMessageProcessor struct {
// contains filtered or unexported fields
}
MockMessageProcessor is a mock of MessageProcessor interface.
func NewMockMessageProcessor ¶
func NewMockMessageProcessor(ctrl *gomock.Controller) *MockMessageProcessor
NewMockMessageProcessor creates a new mock instance.
func (*MockMessageProcessor) EXPECT ¶
func (m *MockMessageProcessor) EXPECT() *MockMessageProcessorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockMessageProcessorMockRecorder ¶
type MockMessageProcessorMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageProcessorMockRecorder is the mock recorder for MockMessageProcessor.
func (*MockMessageProcessorMockRecorder) Process ¶
func (mr *MockMessageProcessorMockRecorder) Process(arg0, arg1 interface{}) *gomock.Call
Process indicates an expected call of Process.
type MockPeriodicalWorker ¶
type MockPeriodicalWorker struct {
// contains filtered or unexported fields
}
MockPeriodicalWorker is a mock of PeriodicalWorker interface.
func NewMockPeriodicalWorker ¶
func NewMockPeriodicalWorker(ctrl *gomock.Controller) *MockPeriodicalWorker
NewMockPeriodicalWorker creates a new mock instance.
func (*MockPeriodicalWorker) EXPECT ¶
func (m *MockPeriodicalWorker) EXPECT() *MockPeriodicalWorkerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPeriodicalWorker) GetInterval ¶
func (m *MockPeriodicalWorker) GetInterval() time.Duration
GetInterval mocks base method.
func (*MockPeriodicalWorker) Work ¶
func (m *MockPeriodicalWorker) Work(arg0 context.Context)
Work mocks base method.
type MockPeriodicalWorkerMockRecorder ¶
type MockPeriodicalWorkerMockRecorder struct {
// contains filtered or unexported fields
}
MockPeriodicalWorkerMockRecorder is the mock recorder for MockPeriodicalWorker.
func (*MockPeriodicalWorkerMockRecorder) GetInterval ¶
func (mr *MockPeriodicalWorkerMockRecorder) GetInterval() *gomock.Call
GetInterval indicates an expected call of GetInterval.
func (*MockPeriodicalWorkerMockRecorder) Work ¶
func (mr *MockPeriodicalWorkerMockRecorder) Work(arg0 interface{}) *gomock.Call
Work indicates an expected call of Work.
type MockRPCClient ¶
type MockRPCClient struct {
// contains filtered or unexported fields
}
MockRPCClient is a mock of RPCClient interface.
func NewMockRPCClient ¶
func NewMockRPCClient(ctrl *gomock.Controller) *MockRPCClient
NewMockRPCClient creates a new mock instance.
func (*MockRPCClient) Call ¶
func (m *MockRPCClient) Call(arg0 context.Context, arg1 engine.RPCMessage) error
Call mocks base method.
func (*MockRPCClient) Consume ¶
func (m *MockRPCClient) Consume(arg0 context.Context) error
Consume mocks base method.
func (*MockRPCClient) EXPECT ¶
func (m *MockRPCClient) EXPECT() *MockRPCClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockRPCClientMockRecorder ¶
type MockRPCClientMockRecorder struct {
// contains filtered or unexported fields
}
MockRPCClientMockRecorder is the mock recorder for MockRPCClient.
func (*MockRPCClientMockRecorder) Call ¶
func (mr *MockRPCClientMockRecorder) Call(arg0, arg1 interface{}) *gomock.Call
Call indicates an expected call of Call.
func (*MockRPCClientMockRecorder) Consume ¶
func (mr *MockRPCClientMockRecorder) Consume(arg0 interface{}) *gomock.Call
Consume indicates an expected call of Consume.
type MockRPCMessageProcessor ¶
type MockRPCMessageProcessor struct {
// contains filtered or unexported fields
}
MockRPCMessageProcessor is a mock of RPCMessageProcessor interface.
func NewMockRPCMessageProcessor ¶
func NewMockRPCMessageProcessor(ctrl *gomock.Controller) *MockRPCMessageProcessor
NewMockRPCMessageProcessor creates a new mock instance.
func (*MockRPCMessageProcessor) EXPECT ¶
func (m *MockRPCMessageProcessor) EXPECT() *MockRPCMessageProcessorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRPCMessageProcessor) Process ¶
func (m *MockRPCMessageProcessor) Process(arg0 context.Context, arg1 engine.RPCMessage) error
Process mocks base method.
type MockRPCMessageProcessorMockRecorder ¶
type MockRPCMessageProcessorMockRecorder struct {
// contains filtered or unexported fields
}
MockRPCMessageProcessorMockRecorder is the mock recorder for MockRPCMessageProcessor.
func (*MockRPCMessageProcessorMockRecorder) Process ¶
func (mr *MockRPCMessageProcessorMockRecorder) Process(arg0, arg1 interface{}) *gomock.Call
Process indicates an expected call of Process.
Source Files