Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type ConnectorOrchestrator
- func (m *ConnectorOrchestrator) Create(arg0 context.Context, arg1 connector.Type, arg2 connector.Config) (connector.Connector, error)
- func (m *ConnectorOrchestrator) Delete(arg0 context.Context, arg1 string) error
- func (m *ConnectorOrchestrator) EXPECT() *ConnectorOrchestratorMockRecorder
- func (m *ConnectorOrchestrator) Get(arg0 context.Context, arg1 string) (connector.Connector, error)
- func (m *ConnectorOrchestrator) List(arg0 context.Context) map[string]connector.Connector
- func (m *ConnectorOrchestrator) Update(arg0 context.Context, arg1 string, arg2 connector.Config) (connector.Connector, error)
- type ConnectorOrchestratorMockRecorder
- func (mr *ConnectorOrchestratorMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call
- type PipelineOrchestrator
- func (m *PipelineOrchestrator) Create(arg0 context.Context, arg1 pipeline.Config) (*pipeline.Instance, error)
- func (m *PipelineOrchestrator) Delete(arg0 context.Context, arg1 string) error
- func (m *PipelineOrchestrator) EXPECT() *PipelineOrchestratorMockRecorder
- func (m *PipelineOrchestrator) Get(arg0 context.Context, arg1 string) (*pipeline.Instance, error)
- func (m *PipelineOrchestrator) List(arg0 context.Context) map[string]*pipeline.Instance
- func (m *PipelineOrchestrator) Start(arg0 context.Context, arg1 string) error
- func (m *PipelineOrchestrator) Stop(arg0 context.Context, arg1 string) error
- func (m *PipelineOrchestrator) Update(arg0 context.Context, arg1 string, arg2 pipeline.Config) (*pipeline.Instance, error)
- type PipelineOrchestratorMockRecorder
- func (mr *PipelineOrchestratorMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Stop(arg0, arg1 interface{}) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call
- type ProcessorOrchestrator
- func (m *ProcessorOrchestrator) Create(arg0 context.Context, arg1 string, arg2 processor.Type, arg3 processor.Parent, ...) (*processor.Instance, error)
- func (m *ProcessorOrchestrator) Delete(arg0 context.Context, arg1 string) error
- func (m *ProcessorOrchestrator) EXPECT() *ProcessorOrchestratorMockRecorder
- func (m *ProcessorOrchestrator) Get(arg0 context.Context, arg1 string) (*processor.Instance, error)
- func (m *ProcessorOrchestrator) List(arg0 context.Context) map[string]*processor.Instance
- func (m *ProcessorOrchestrator) Update(arg0 context.Context, arg1 string, arg2 processor.Config) (*processor.Instance, error)
- type ProcessorOrchestratorMockRecorder
- func (mr *ProcessorOrchestratorMockRecorder) Create(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectorOrchestrator ¶
type ConnectorOrchestrator struct {
// contains filtered or unexported fields
}
ConnectorOrchestrator is a mock of ConnectorOrchestrator interface.
func NewConnectorOrchestrator ¶
func NewConnectorOrchestrator(ctrl *gomock.Controller) *ConnectorOrchestrator
NewConnectorOrchestrator creates a new mock instance.
func (*ConnectorOrchestrator) Create ¶
func (m *ConnectorOrchestrator) Create(arg0 context.Context, arg1 connector.Type, arg2 connector.Config) (connector.Connector, error)
Create mocks base method.
func (*ConnectorOrchestrator) Delete ¶
func (m *ConnectorOrchestrator) Delete(arg0 context.Context, arg1 string) error
Delete mocks base method.
func (*ConnectorOrchestrator) EXPECT ¶
func (m *ConnectorOrchestrator) EXPECT() *ConnectorOrchestratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type ConnectorOrchestratorMockRecorder ¶
type ConnectorOrchestratorMockRecorder struct {
// contains filtered or unexported fields
}
ConnectorOrchestratorMockRecorder is the mock recorder for ConnectorOrchestrator.
func (*ConnectorOrchestratorMockRecorder) Create ¶
func (mr *ConnectorOrchestratorMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*ConnectorOrchestratorMockRecorder) Delete ¶
func (mr *ConnectorOrchestratorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*ConnectorOrchestratorMockRecorder) Get ¶
func (mr *ConnectorOrchestratorMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*ConnectorOrchestratorMockRecorder) List ¶
func (mr *ConnectorOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call
List indicates an expected call of List.
func (*ConnectorOrchestratorMockRecorder) Update ¶
func (mr *ConnectorOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call
Update indicates an expected call of Update.
type PipelineOrchestrator ¶
type PipelineOrchestrator struct {
// contains filtered or unexported fields
}
PipelineOrchestrator is a mock of PipelineOrchestrator interface.
func NewPipelineOrchestrator ¶
func NewPipelineOrchestrator(ctrl *gomock.Controller) *PipelineOrchestrator
NewPipelineOrchestrator creates a new mock instance.
func (*PipelineOrchestrator) Create ¶
func (m *PipelineOrchestrator) Create(arg0 context.Context, arg1 pipeline.Config) (*pipeline.Instance, error)
Create mocks base method.
func (*PipelineOrchestrator) Delete ¶
func (m *PipelineOrchestrator) Delete(arg0 context.Context, arg1 string) error
Delete mocks base method.
func (*PipelineOrchestrator) EXPECT ¶
func (m *PipelineOrchestrator) EXPECT() *PipelineOrchestratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*PipelineOrchestrator) Start ¶
func (m *PipelineOrchestrator) Start(arg0 context.Context, arg1 string) error
Start mocks base method.
type PipelineOrchestratorMockRecorder ¶
type PipelineOrchestratorMockRecorder struct {
// contains filtered or unexported fields
}
PipelineOrchestratorMockRecorder is the mock recorder for PipelineOrchestrator.
func (*PipelineOrchestratorMockRecorder) Create ¶
func (mr *PipelineOrchestratorMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*PipelineOrchestratorMockRecorder) Delete ¶
func (mr *PipelineOrchestratorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*PipelineOrchestratorMockRecorder) Get ¶
func (mr *PipelineOrchestratorMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*PipelineOrchestratorMockRecorder) List ¶
func (mr *PipelineOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call
List indicates an expected call of List.
func (*PipelineOrchestratorMockRecorder) Start ¶
func (mr *PipelineOrchestratorMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call
Start indicates an expected call of Start.
func (*PipelineOrchestratorMockRecorder) Stop ¶
func (mr *PipelineOrchestratorMockRecorder) Stop(arg0, arg1 interface{}) *gomock.Call
Stop indicates an expected call of Stop.
func (*PipelineOrchestratorMockRecorder) Update ¶
func (mr *PipelineOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call
Update indicates an expected call of Update.
type ProcessorOrchestrator ¶
type ProcessorOrchestrator struct {
// contains filtered or unexported fields
}
ProcessorOrchestrator is a mock of ProcessorOrchestrator interface.
func NewProcessorOrchestrator ¶
func NewProcessorOrchestrator(ctrl *gomock.Controller) *ProcessorOrchestrator
NewProcessorOrchestrator creates a new mock instance.
func (*ProcessorOrchestrator) Create ¶
func (m *ProcessorOrchestrator) Create(arg0 context.Context, arg1 string, arg2 processor.Type, arg3 processor.Parent, arg4 processor.Config) (*processor.Instance, error)
Create mocks base method.
func (*ProcessorOrchestrator) Delete ¶
func (m *ProcessorOrchestrator) Delete(arg0 context.Context, arg1 string) error
Delete mocks base method.
func (*ProcessorOrchestrator) EXPECT ¶
func (m *ProcessorOrchestrator) EXPECT() *ProcessorOrchestratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type ProcessorOrchestratorMockRecorder ¶
type ProcessorOrchestratorMockRecorder struct {
// contains filtered or unexported fields
}
ProcessorOrchestratorMockRecorder is the mock recorder for ProcessorOrchestrator.
func (*ProcessorOrchestratorMockRecorder) Create ¶
func (mr *ProcessorOrchestratorMockRecorder) Create(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*ProcessorOrchestratorMockRecorder) Delete ¶
func (mr *ProcessorOrchestratorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*ProcessorOrchestratorMockRecorder) Get ¶
func (mr *ProcessorOrchestratorMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*ProcessorOrchestratorMockRecorder) List ¶
func (mr *ProcessorOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call
List indicates an expected call of List.
func (*ProcessorOrchestratorMockRecorder) Update ¶
func (mr *ProcessorOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call
Update indicates an expected call of Update.