Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
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) Inspect(arg0 context.Context, arg1 string) (*inspector.Session, 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)
- func (m *ConnectorOrchestrator) Validate(arg0 context.Context, arg1 connector.Type, arg2 connector.Config) 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) Inspect(arg0, arg1 interface{}) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Validate(arg0, arg1, arg2 interface{}) *gomock.Call
- type ConnectorService_InspectConnectorServer
- func (m *ConnectorService_InspectConnectorServer) Context() context.Context
- func (m *ConnectorService_InspectConnectorServer) EXPECT() *ConnectorService_InspectConnectorServerMockRecorder
- func (m *ConnectorService_InspectConnectorServer) RecvMsg(arg0 interface{}) error
- func (m *ConnectorService_InspectConnectorServer) Send(arg0 *apiv1.InspectConnectorResponse) error
- func (m *ConnectorService_InspectConnectorServer) SendHeader(arg0 metadata.MD) error
- func (m *ConnectorService_InspectConnectorServer) SendMsg(arg0 interface{}) error
- func (m *ConnectorService_InspectConnectorServer) SetHeader(arg0 metadata.MD) error
- func (m *ConnectorService_InspectConnectorServer) SetTrailer(arg0 metadata.MD)
- type ConnectorService_InspectConnectorServerMockRecorder
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) Context() *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetTrailer(arg0 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 PluginOrchestrator
- type PluginOrchestratorMockRecorder
- type ProcessorOrchestrator
- func (m *ProcessorOrchestrator) Create(arg0 context.Context, arg1 string, arg2 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 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.
func (*ConnectorOrchestrator) Inspect ¶ added in v0.4.0
func (m *ConnectorOrchestrator) Inspect(arg0 context.Context, arg1 string) (*inspector.Session, error)
Inspect mocks base method.
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) Inspect ¶ added in v0.4.0
func (mr *ConnectorOrchestratorMockRecorder) Inspect(arg0, arg1 interface{}) *gomock.Call
Inspect indicates an expected call of Inspect.
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.
func (*ConnectorOrchestratorMockRecorder) Validate ¶ added in v0.2.1
func (mr *ConnectorOrchestratorMockRecorder) Validate(arg0, arg1, arg2 interface{}) *gomock.Call
Validate indicates an expected call of Validate.
type ConnectorService_InspectConnectorServer ¶ added in v0.4.0
type ConnectorService_InspectConnectorServer struct {
// contains filtered or unexported fields
}
ConnectorService_InspectConnectorServer is a mock of ConnectorService_InspectConnectorServer interface.
func NewConnectorService_InspectConnectorServer ¶ added in v0.4.0
func NewConnectorService_InspectConnectorServer(ctrl *gomock.Controller) *ConnectorService_InspectConnectorServer
NewConnectorService_InspectConnectorServer creates a new mock instance.
func (*ConnectorService_InspectConnectorServer) Context ¶ added in v0.4.0
func (m *ConnectorService_InspectConnectorServer) Context() context.Context
Context mocks base method.
func (*ConnectorService_InspectConnectorServer) EXPECT ¶ added in v0.4.0
func (m *ConnectorService_InspectConnectorServer) EXPECT() *ConnectorService_InspectConnectorServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*ConnectorService_InspectConnectorServer) RecvMsg ¶ added in v0.4.0
func (m *ConnectorService_InspectConnectorServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*ConnectorService_InspectConnectorServer) Send ¶ added in v0.4.0
func (m *ConnectorService_InspectConnectorServer) Send(arg0 *apiv1.InspectConnectorResponse) error
Send mocks base method.
func (*ConnectorService_InspectConnectorServer) SendHeader ¶ added in v0.4.0
func (m *ConnectorService_InspectConnectorServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*ConnectorService_InspectConnectorServer) SendMsg ¶ added in v0.4.0
func (m *ConnectorService_InspectConnectorServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*ConnectorService_InspectConnectorServer) SetHeader ¶ added in v0.4.0
func (m *ConnectorService_InspectConnectorServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*ConnectorService_InspectConnectorServer) SetTrailer ¶ added in v0.4.0
func (m *ConnectorService_InspectConnectorServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type ConnectorService_InspectConnectorServerMockRecorder ¶ added in v0.4.0
type ConnectorService_InspectConnectorServerMockRecorder struct {
// contains filtered or unexported fields
}
ConnectorService_InspectConnectorServerMockRecorder is the mock recorder for ConnectorService_InspectConnectorServer.
func (*ConnectorService_InspectConnectorServerMockRecorder) Context ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*ConnectorService_InspectConnectorServerMockRecorder) RecvMsg ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*ConnectorService_InspectConnectorServerMockRecorder) Send ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*ConnectorService_InspectConnectorServerMockRecorder) SendHeader ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*ConnectorService_InspectConnectorServerMockRecorder) SendMsg ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*ConnectorService_InspectConnectorServerMockRecorder) SetHeader ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*ConnectorService_InspectConnectorServerMockRecorder) SetTrailer ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
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 PluginOrchestrator ¶ added in v0.2.0
type PluginOrchestrator struct {
// contains filtered or unexported fields
}
PluginOrchestrator is a mock of PluginOrchestrator interface.
func NewPluginOrchestrator ¶ added in v0.2.0
func NewPluginOrchestrator(ctrl *gomock.Controller) *PluginOrchestrator
NewPluginOrchestrator creates a new mock instance.
func (*PluginOrchestrator) EXPECT ¶ added in v0.2.0
func (m *PluginOrchestrator) EXPECT() *PluginOrchestratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*PluginOrchestrator) List ¶ added in v0.2.0
func (m *PluginOrchestrator) List(arg0 context.Context) (map[string]plugin.Specification, error)
List mocks base method.
type PluginOrchestratorMockRecorder ¶ added in v0.2.0
type PluginOrchestratorMockRecorder struct {
// contains filtered or unexported fields
}
PluginOrchestratorMockRecorder is the mock recorder for PluginOrchestrator.
func (*PluginOrchestratorMockRecorder) List ¶ added in v0.2.0
func (mr *PluginOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call
List indicates an expected call of List.
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.Parent, arg3 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 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.