Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type ConnectorService
- func (m *ConnectorService) AddProcessor(arg0 context.Context, arg1, arg2 string) (*connector.Instance, error)
- func (m *ConnectorService) Create(arg0 context.Context, arg1 string, arg2 connector.Type, arg3, arg4 string, ...) (*connector.Instance, error)
- func (m *ConnectorService) Delete(arg0 context.Context, arg1 string, arg2 connector.PluginDispenserFetcher) error
- func (m *ConnectorService) EXPECT() *ConnectorServiceMockRecorder
- func (m *ConnectorService) Get(arg0 context.Context, arg1 string) (*connector.Instance, error)
- func (m *ConnectorService) RemoveProcessor(arg0 context.Context, arg1, arg2 string) (*connector.Instance, error)
- func (m *ConnectorService) SetState(arg0 context.Context, arg1 string, arg2 interface{}) (*connector.Instance, error)
- type ConnectorServiceMockRecorder
- func (mr *ConnectorServiceMockRecorder) AddProcessor(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *ConnectorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
- func (mr *ConnectorServiceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *ConnectorServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *ConnectorServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *ConnectorServiceMockRecorder) SetState(arg0, arg1, arg2 interface{}) *gomock.Call
- type PipelineService
- func (m *PipelineService) AddConnector(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)
- func (m *PipelineService) AddProcessor(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)
- func (m *PipelineService) Create(arg0 context.Context, arg1 string, arg2 pipeline.Config, ...) (*pipeline.Instance, error)
- func (m *PipelineService) Delete(arg0 context.Context, arg1 string) error
- func (m *PipelineService) EXPECT() *PipelineServiceMockRecorder
- func (m *PipelineService) Get(arg0 context.Context, arg1 string) (*pipeline.Instance, error)
- func (m *PipelineService) List(arg0 context.Context) map[string]*pipeline.Instance
- func (m *PipelineService) RemoveConnector(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)
- func (m *PipelineService) RemoveProcessor(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)
- func (m *PipelineService) Start(arg0 context.Context, arg1 pipeline.ConnectorFetcher, ...) error
- func (m *PipelineService) Stop(arg0 context.Context, arg1 string, arg2 bool) error
- func (m *PipelineService) UpdateDLQ(arg0 context.Context, arg1 string, arg2 pipeline.DLQ) (*pipeline.Instance, error)
- type PipelineServiceMockRecorder
- func (mr *PipelineServiceMockRecorder) AddConnector(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) AddProcessor(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) Create(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) List(arg0 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) RemoveConnector(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) Start(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) Stop(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *PipelineServiceMockRecorder) UpdateDLQ(arg0, arg1, arg2 interface{}) *gomock.Call
- type PluginService
- type PluginServiceMockRecorder
- type ProcessorService
- func (m *ProcessorService) Create(arg0 context.Context, arg1, arg2 string, arg3 processor.Parent, ...) (*processor.Instance, error)
- func (m *ProcessorService) Delete(arg0 context.Context, arg1 string) error
- func (m *ProcessorService) EXPECT() *ProcessorServiceMockRecorder
- func (m *ProcessorService) Get(arg0 context.Context, arg1 string) (*processor.Instance, error)
- type ProcessorServiceMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectorService ¶
type ConnectorService struct {
// contains filtered or unexported fields
}
ConnectorService is a mock of ConnectorService interface.
func NewConnectorService ¶
func NewConnectorService(ctrl *gomock.Controller) *ConnectorService
NewConnectorService creates a new mock instance.
func (*ConnectorService) AddProcessor ¶
func (m *ConnectorService) AddProcessor(arg0 context.Context, arg1, arg2 string) (*connector.Instance, error)
AddProcessor mocks base method.
func (*ConnectorService) Create ¶
func (m *ConnectorService) Create(arg0 context.Context, arg1 string, arg2 connector.Type, arg3, arg4 string, arg5 connector.Config, arg6 connector.ProvisionType) (*connector.Instance, error)
Create mocks base method.
func (*ConnectorService) Delete ¶
func (m *ConnectorService) Delete(arg0 context.Context, arg1 string, arg2 connector.PluginDispenserFetcher) error
Delete mocks base method.
func (*ConnectorService) EXPECT ¶
func (m *ConnectorService) EXPECT() *ConnectorServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*ConnectorService) RemoveProcessor ¶
func (m *ConnectorService) RemoveProcessor(arg0 context.Context, arg1, arg2 string) (*connector.Instance, error)
RemoveProcessor mocks base method.
type ConnectorServiceMockRecorder ¶
type ConnectorServiceMockRecorder struct {
// contains filtered or unexported fields
}
ConnectorServiceMockRecorder is the mock recorder for ConnectorService.
func (*ConnectorServiceMockRecorder) AddProcessor ¶
func (mr *ConnectorServiceMockRecorder) AddProcessor(arg0, arg1, arg2 interface{}) *gomock.Call
AddProcessor indicates an expected call of AddProcessor.
func (*ConnectorServiceMockRecorder) Create ¶
func (mr *ConnectorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*ConnectorServiceMockRecorder) Delete ¶
func (mr *ConnectorServiceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*ConnectorServiceMockRecorder) Get ¶
func (mr *ConnectorServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*ConnectorServiceMockRecorder) RemoveProcessor ¶
func (mr *ConnectorServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call
RemoveProcessor indicates an expected call of RemoveProcessor.
func (*ConnectorServiceMockRecorder) SetState ¶ added in v0.5.0
func (mr *ConnectorServiceMockRecorder) SetState(arg0, arg1, arg2 interface{}) *gomock.Call
SetState indicates an expected call of SetState.
type PipelineService ¶
type PipelineService struct {
// contains filtered or unexported fields
}
PipelineService is a mock of PipelineService interface.
func NewPipelineService ¶
func NewPipelineService(ctrl *gomock.Controller) *PipelineService
NewPipelineService creates a new mock instance.
func (*PipelineService) AddConnector ¶
func (m *PipelineService) AddConnector(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)
AddConnector mocks base method.
func (*PipelineService) AddProcessor ¶
func (m *PipelineService) AddProcessor(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)
AddProcessor mocks base method.
func (*PipelineService) Create ¶
func (m *PipelineService) Create(arg0 context.Context, arg1 string, arg2 pipeline.Config, arg3 pipeline.ProvisionType) (*pipeline.Instance, error)
Create mocks base method.
func (*PipelineService) Delete ¶
func (m *PipelineService) Delete(arg0 context.Context, arg1 string) error
Delete mocks base method.
func (*PipelineService) EXPECT ¶
func (m *PipelineService) EXPECT() *PipelineServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*PipelineService) RemoveConnector ¶
func (m *PipelineService) RemoveConnector(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)
RemoveConnector mocks base method.
func (*PipelineService) RemoveProcessor ¶
func (m *PipelineService) RemoveProcessor(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)
RemoveProcessor mocks base method.
func (*PipelineService) Start ¶
func (m *PipelineService) Start(arg0 context.Context, arg1 pipeline.ConnectorFetcher, arg2 pipeline.ProcessorFetcher, arg3 pipeline.PluginDispenserFetcher, arg4 string) error
Start mocks base method.
type PipelineServiceMockRecorder ¶
type PipelineServiceMockRecorder struct {
// contains filtered or unexported fields
}
PipelineServiceMockRecorder is the mock recorder for PipelineService.
func (*PipelineServiceMockRecorder) AddConnector ¶
func (mr *PipelineServiceMockRecorder) AddConnector(arg0, arg1, arg2 interface{}) *gomock.Call
AddConnector indicates an expected call of AddConnector.
func (*PipelineServiceMockRecorder) AddProcessor ¶
func (mr *PipelineServiceMockRecorder) AddProcessor(arg0, arg1, arg2 interface{}) *gomock.Call
AddProcessor indicates an expected call of AddProcessor.
func (*PipelineServiceMockRecorder) Create ¶
func (mr *PipelineServiceMockRecorder) Create(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*PipelineServiceMockRecorder) Delete ¶
func (mr *PipelineServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*PipelineServiceMockRecorder) Get ¶
func (mr *PipelineServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*PipelineServiceMockRecorder) List ¶
func (mr *PipelineServiceMockRecorder) List(arg0 interface{}) *gomock.Call
List indicates an expected call of List.
func (*PipelineServiceMockRecorder) RemoveConnector ¶
func (mr *PipelineServiceMockRecorder) RemoveConnector(arg0, arg1, arg2 interface{}) *gomock.Call
RemoveConnector indicates an expected call of RemoveConnector.
func (*PipelineServiceMockRecorder) RemoveProcessor ¶
func (mr *PipelineServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call
RemoveProcessor indicates an expected call of RemoveProcessor.
func (*PipelineServiceMockRecorder) Start ¶
func (mr *PipelineServiceMockRecorder) Start(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
Start indicates an expected call of Start.
func (*PipelineServiceMockRecorder) Stop ¶
func (mr *PipelineServiceMockRecorder) Stop(arg0, arg1, arg2 interface{}) *gomock.Call
Stop indicates an expected call of Stop.
func (*PipelineServiceMockRecorder) UpdateDLQ ¶ added in v0.4.0
func (mr *PipelineServiceMockRecorder) UpdateDLQ(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateDLQ indicates an expected call of UpdateDLQ.
type PluginService ¶ added in v0.5.0
type PluginService struct {
// contains filtered or unexported fields
}
PluginService is a mock of PluginService interface.
func NewPluginService ¶ added in v0.5.0
func NewPluginService(ctrl *gomock.Controller) *PluginService
NewPluginService creates a new mock instance.
func (*PluginService) EXPECT ¶ added in v0.5.0
func (m *PluginService) EXPECT() *PluginServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*PluginService) NewDispenser ¶ added in v0.5.0
NewDispenser mocks base method.
type PluginServiceMockRecorder ¶ added in v0.5.0
type PluginServiceMockRecorder struct {
// contains filtered or unexported fields
}
PluginServiceMockRecorder is the mock recorder for PluginService.
func (*PluginServiceMockRecorder) NewDispenser ¶ added in v0.5.0
func (mr *PluginServiceMockRecorder) NewDispenser(arg0, arg1 interface{}) *gomock.Call
NewDispenser indicates an expected call of NewDispenser.
type ProcessorService ¶
type ProcessorService struct {
// contains filtered or unexported fields
}
ProcessorService is a mock of ProcessorService interface.
func NewProcessorService ¶
func NewProcessorService(ctrl *gomock.Controller) *ProcessorService
NewProcessorService creates a new mock instance.
func (*ProcessorService) Create ¶
func (m *ProcessorService) Create(arg0 context.Context, arg1, arg2 string, arg3 processor.Parent, arg4 processor.Config, arg5 processor.ProvisionType) (*processor.Instance, error)
Create mocks base method.
func (*ProcessorService) Delete ¶
func (m *ProcessorService) Delete(arg0 context.Context, arg1 string) error
Delete mocks base method.
func (*ProcessorService) EXPECT ¶
func (m *ProcessorService) EXPECT() *ProcessorServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type ProcessorServiceMockRecorder ¶
type ProcessorServiceMockRecorder struct {
// contains filtered or unexported fields
}
ProcessorServiceMockRecorder is the mock recorder for ProcessorService.
func (*ProcessorServiceMockRecorder) Create ¶
func (mr *ProcessorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*ProcessorServiceMockRecorder) Delete ¶
func (mr *ProcessorServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*ProcessorServiceMockRecorder) Get ¶
func (mr *ProcessorServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.