Documentation ¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: github.com/conduitio/conduit/pkg/web/api (interfaces: ConnectorOrchestrator)
Generated by this command:
mockgen -destination=mock/connector.go -package=mock -mock_names=ConnectorOrchestrator=ConnectorOrchestrator . ConnectorOrchestrator
Package mock is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/conduitio/conduit/proto/api/v1 (interfaces: ConnectorService_InspectConnectorServer)
Generated by this command:
mockgen -destination=mock/connector_service.go -package=mock -mock_names=ConnectorService_InspectConnectorServer=ConnectorService_InspectConnectorServer github.com/conduitio/conduit/proto/api/v1 ConnectorService_InspectConnectorServer
Package mock is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/conduitio/conduit/pkg/web/api (interfaces: PipelineOrchestrator)
Generated by this command:
mockgen -destination=mock/pipeline.go -package=mock -mock_names=PipelineOrchestrator=PipelineOrchestrator . PipelineOrchestrator
Package mock is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/conduitio/conduit/pkg/web/api (interfaces: PluginOrchestrator)
Generated by this command:
mockgen -destination=mock/plugin.go -package=mock -mock_names=PluginOrchestrator=PluginOrchestrator . PluginOrchestrator
Package mock is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/conduitio/conduit/pkg/web/api (interfaces: ProcessorOrchestrator)
Generated by this command:
mockgen -destination=mock/processor.go -package=mock -mock_names=ProcessorOrchestrator=ProcessorOrchestrator . ProcessorOrchestrator
Package mock is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/conduitio/conduit/proto/api/v1 (interfaces: ProcessorService_InspectProcessorInServer)
Generated by this command:
mockgen -destination=mock/processor_service_in.go -package=mock -mock_names=ProcessorService_InspectProcessorInServer=ProcessorService_InspectProcessorInServer github.com/conduitio/conduit/proto/api/v1 ProcessorService_InspectProcessorInServer
Package mock is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/conduitio/conduit/proto/api/v1 (interfaces: ProcessorService_InspectProcessorOutServer)
Generated by this command:
mockgen -destination=mock/processor_service_out.go -package=mock -mock_names=ProcessorService_InspectProcessorOutServer=ProcessorService_InspectProcessorOutServer github.com/conduitio/conduit/proto/api/v1 ProcessorService_InspectProcessorOutServer
Package mock is a generated GoMock package.
Index ¶
- type ConnectorOrchestrator
- func (m *ConnectorOrchestrator) Create(arg0 context.Context, arg1 connector.Type, arg2, arg3 string, ...) (*connector.Instance, 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.Instance, error)
- func (m *ConnectorOrchestrator) Inspect(arg0 context.Context, arg1 string) (*inspector.Session, error)
- func (m *ConnectorOrchestrator) List(arg0 context.Context) map[string]*connector.Instance
- func (m *ConnectorOrchestrator) Update(arg0 context.Context, arg1 string, arg2 connector.Config) (*connector.Instance, error)
- func (m *ConnectorOrchestrator) Validate(arg0 context.Context, arg1 connector.Type, arg2 string, arg3 connector.Config) error
- type ConnectorOrchestratorMockRecorder
- func (mr *ConnectorOrchestratorMockRecorder) Create(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Delete(arg0, arg1 any) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Get(arg0, arg1 any) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Inspect(arg0, arg1 any) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) List(arg0 any) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call
- func (mr *ConnectorOrchestratorMockRecorder) Validate(arg0, arg1, arg2, arg3 any) *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 any) 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 any) 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 any) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendMsg(arg0 any) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetTrailer(arg0 any) *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, arg2 bool) error
- func (m *PipelineOrchestrator) Update(arg0 context.Context, arg1 string, arg2 pipeline.Config) (*pipeline.Instance, error)
- func (m *PipelineOrchestrator) UpdateDLQ(arg0 context.Context, arg1 string, arg2 pipeline.DLQ) (*pipeline.Instance, error)
- type PipelineOrchestratorMockRecorder
- func (mr *PipelineOrchestratorMockRecorder) Create(arg0, arg1 any) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Delete(arg0, arg1 any) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Get(arg0, arg1 any) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) List(arg0 any) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Start(arg0, arg1 any) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Stop(arg0, arg1, arg2 any) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call
- func (mr *PipelineOrchestratorMockRecorder) UpdateDLQ(arg0, arg1, arg2 any) *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) InspectIn(arg0 context.Context, arg1 string) (*inspector.Session, error)
- func (m *ProcessorOrchestrator) InspectOut(arg0 context.Context, arg1 string) (*inspector.Session, 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 any) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) Delete(arg0, arg1 any) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) Get(arg0, arg1 any) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) InspectIn(arg0, arg1 any) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) InspectOut(arg0, arg1 any) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) List(arg0 any) *gomock.Call
- func (mr *ProcessorOrchestratorMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call
- type ProcessorService_InspectProcessorInServer
- func (m *ProcessorService_InspectProcessorInServer) Context() context.Context
- func (m *ProcessorService_InspectProcessorInServer) EXPECT() *ProcessorService_InspectProcessorInServerMockRecorder
- func (m *ProcessorService_InspectProcessorInServer) RecvMsg(arg0 any) error
- func (m *ProcessorService_InspectProcessorInServer) Send(arg0 *apiv1.InspectProcessorInResponse) error
- func (m *ProcessorService_InspectProcessorInServer) SendHeader(arg0 metadata.MD) error
- func (m *ProcessorService_InspectProcessorInServer) SendMsg(arg0 any) error
- func (m *ProcessorService_InspectProcessorInServer) SetHeader(arg0 metadata.MD) error
- func (m *ProcessorService_InspectProcessorInServer) SetTrailer(arg0 metadata.MD)
- type ProcessorService_InspectProcessorInServerMockRecorder
- func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Context() *gomock.Call
- func (mr *ProcessorService_InspectProcessorInServerMockRecorder) RecvMsg(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendMsg(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type ProcessorService_InspectProcessorOutServer
- func (m *ProcessorService_InspectProcessorOutServer) Context() context.Context
- func (m *ProcessorService_InspectProcessorOutServer) EXPECT() *ProcessorService_InspectProcessorOutServerMockRecorder
- func (m *ProcessorService_InspectProcessorOutServer) RecvMsg(arg0 any) error
- func (m *ProcessorService_InspectProcessorOutServer) Send(arg0 *apiv1.InspectProcessorOutResponse) error
- func (m *ProcessorService_InspectProcessorOutServer) SendHeader(arg0 metadata.MD) error
- func (m *ProcessorService_InspectProcessorOutServer) SendMsg(arg0 any) error
- func (m *ProcessorService_InspectProcessorOutServer) SetHeader(arg0 metadata.MD) error
- func (m *ProcessorService_InspectProcessorOutServer) SetTrailer(arg0 metadata.MD)
- type ProcessorService_InspectProcessorOutServerMockRecorder
- func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Context() *gomock.Call
- func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) RecvMsg(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendMsg(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetTrailer(arg0 any) *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, arg3 string, arg4 connector.Config) (*connector.Instance, 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, arg3, arg4 any) *gomock.Call
Create indicates an expected call of Create.
func (*ConnectorOrchestratorMockRecorder) Delete ¶
func (mr *ConnectorOrchestratorMockRecorder) Delete(arg0, arg1 any) *gomock.Call
Delete indicates an expected call of Delete.
func (*ConnectorOrchestratorMockRecorder) Get ¶
func (mr *ConnectorOrchestratorMockRecorder) Get(arg0, arg1 any) *gomock.Call
Get indicates an expected call of Get.
func (*ConnectorOrchestratorMockRecorder) Inspect ¶ added in v0.4.0
func (mr *ConnectorOrchestratorMockRecorder) Inspect(arg0, arg1 any) *gomock.Call
Inspect indicates an expected call of Inspect.
func (*ConnectorOrchestratorMockRecorder) List ¶
func (mr *ConnectorOrchestratorMockRecorder) List(arg0 any) *gomock.Call
List indicates an expected call of List.
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 any) 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 any) 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 any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*ConnectorService_InspectConnectorServerMockRecorder) Send ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*ConnectorService_InspectConnectorServerMockRecorder) SendHeader ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*ConnectorService_InspectConnectorServerMockRecorder) SendMsg ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendMsg(arg0 any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*ConnectorService_InspectConnectorServerMockRecorder) SetHeader ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*ConnectorService_InspectConnectorServerMockRecorder) SetTrailer ¶ added in v0.4.0
func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetTrailer(arg0 any) *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 any) *gomock.Call
Create indicates an expected call of Create.
func (*PipelineOrchestratorMockRecorder) Delete ¶
func (mr *PipelineOrchestratorMockRecorder) Delete(arg0, arg1 any) *gomock.Call
Delete indicates an expected call of Delete.
func (*PipelineOrchestratorMockRecorder) Get ¶
func (mr *PipelineOrchestratorMockRecorder) Get(arg0, arg1 any) *gomock.Call
Get indicates an expected call of Get.
func (*PipelineOrchestratorMockRecorder) List ¶
func (mr *PipelineOrchestratorMockRecorder) List(arg0 any) *gomock.Call
List indicates an expected call of List.
func (*PipelineOrchestratorMockRecorder) Start ¶
func (mr *PipelineOrchestratorMockRecorder) Start(arg0, arg1 any) *gomock.Call
Start indicates an expected call of Start.
func (*PipelineOrchestratorMockRecorder) Stop ¶
func (mr *PipelineOrchestratorMockRecorder) Stop(arg0, arg1, arg2 any) *gomock.Call
Stop indicates an expected call of Stop.
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.
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.
func (*ProcessorOrchestrator) InspectIn ¶ added in v0.5.0
func (m *ProcessorOrchestrator) InspectIn(arg0 context.Context, arg1 string) (*inspector.Session, error)
InspectIn mocks base method.
func (*ProcessorOrchestrator) InspectOut ¶ added in v0.5.0
func (m *ProcessorOrchestrator) InspectOut(arg0 context.Context, arg1 string) (*inspector.Session, error)
InspectOut mocks base method.
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 any) *gomock.Call
Create indicates an expected call of Create.
func (*ProcessorOrchestratorMockRecorder) Delete ¶
func (mr *ProcessorOrchestratorMockRecorder) Delete(arg0, arg1 any) *gomock.Call
Delete indicates an expected call of Delete.
func (*ProcessorOrchestratorMockRecorder) Get ¶
func (mr *ProcessorOrchestratorMockRecorder) Get(arg0, arg1 any) *gomock.Call
Get indicates an expected call of Get.
func (*ProcessorOrchestratorMockRecorder) InspectIn ¶ added in v0.5.0
func (mr *ProcessorOrchestratorMockRecorder) InspectIn(arg0, arg1 any) *gomock.Call
InspectIn indicates an expected call of InspectIn.
func (*ProcessorOrchestratorMockRecorder) InspectOut ¶ added in v0.5.0
func (mr *ProcessorOrchestratorMockRecorder) InspectOut(arg0, arg1 any) *gomock.Call
InspectOut indicates an expected call of InspectOut.
type ProcessorService_InspectProcessorInServer ¶ added in v0.5.0
type ProcessorService_InspectProcessorInServer struct {
// contains filtered or unexported fields
}
ProcessorService_InspectProcessorInServer is a mock of ProcessorService_InspectProcessorInServer interface.
func NewProcessorService_InspectProcessorInServer ¶ added in v0.5.0
func NewProcessorService_InspectProcessorInServer(ctrl *gomock.Controller) *ProcessorService_InspectProcessorInServer
NewProcessorService_InspectProcessorInServer creates a new mock instance.
func (*ProcessorService_InspectProcessorInServer) Context ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorInServer) Context() context.Context
Context mocks base method.
func (*ProcessorService_InspectProcessorInServer) EXPECT ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorInServer) EXPECT() *ProcessorService_InspectProcessorInServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*ProcessorService_InspectProcessorInServer) RecvMsg ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorInServer) RecvMsg(arg0 any) error
RecvMsg mocks base method.
func (*ProcessorService_InspectProcessorInServer) Send ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorInServer) Send(arg0 *apiv1.InspectProcessorInResponse) error
Send mocks base method.
func (*ProcessorService_InspectProcessorInServer) SendHeader ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorInServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*ProcessorService_InspectProcessorInServer) SendMsg ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorInServer) SendMsg(arg0 any) error
SendMsg mocks base method.
func (*ProcessorService_InspectProcessorInServer) SetHeader ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorInServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*ProcessorService_InspectProcessorInServer) SetTrailer ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorInServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type ProcessorService_InspectProcessorInServerMockRecorder ¶ added in v0.5.0
type ProcessorService_InspectProcessorInServerMockRecorder struct {
// contains filtered or unexported fields
}
ProcessorService_InspectProcessorInServerMockRecorder is the mock recorder for ProcessorService_InspectProcessorInServer.
func (*ProcessorService_InspectProcessorInServerMockRecorder) Context ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*ProcessorService_InspectProcessorInServerMockRecorder) RecvMsg ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorInServerMockRecorder) RecvMsg(arg0 any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*ProcessorService_InspectProcessorInServerMockRecorder) Send ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*ProcessorService_InspectProcessorInServerMockRecorder) SendHeader ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*ProcessorService_InspectProcessorInServerMockRecorder) SendMsg ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendMsg(arg0 any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*ProcessorService_InspectProcessorInServerMockRecorder) SetHeader ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*ProcessorService_InspectProcessorInServerMockRecorder) SetTrailer ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type ProcessorService_InspectProcessorOutServer ¶ added in v0.5.0
type ProcessorService_InspectProcessorOutServer struct {
// contains filtered or unexported fields
}
ProcessorService_InspectProcessorOutServer is a mock of ProcessorService_InspectProcessorOutServer interface.
func NewProcessorService_InspectProcessorOutServer ¶ added in v0.5.0
func NewProcessorService_InspectProcessorOutServer(ctrl *gomock.Controller) *ProcessorService_InspectProcessorOutServer
NewProcessorService_InspectProcessorOutServer creates a new mock instance.
func (*ProcessorService_InspectProcessorOutServer) Context ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorOutServer) Context() context.Context
Context mocks base method.
func (*ProcessorService_InspectProcessorOutServer) EXPECT ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorOutServer) EXPECT() *ProcessorService_InspectProcessorOutServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*ProcessorService_InspectProcessorOutServer) RecvMsg ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorOutServer) RecvMsg(arg0 any) error
RecvMsg mocks base method.
func (*ProcessorService_InspectProcessorOutServer) Send ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorOutServer) Send(arg0 *apiv1.InspectProcessorOutResponse) error
Send mocks base method.
func (*ProcessorService_InspectProcessorOutServer) SendHeader ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorOutServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*ProcessorService_InspectProcessorOutServer) SendMsg ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorOutServer) SendMsg(arg0 any) error
SendMsg mocks base method.
func (*ProcessorService_InspectProcessorOutServer) SetHeader ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorOutServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*ProcessorService_InspectProcessorOutServer) SetTrailer ¶ added in v0.5.0
func (m *ProcessorService_InspectProcessorOutServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type ProcessorService_InspectProcessorOutServerMockRecorder ¶ added in v0.5.0
type ProcessorService_InspectProcessorOutServerMockRecorder struct {
// contains filtered or unexported fields
}
ProcessorService_InspectProcessorOutServerMockRecorder is the mock recorder for ProcessorService_InspectProcessorOutServer.
func (*ProcessorService_InspectProcessorOutServerMockRecorder) Context ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*ProcessorService_InspectProcessorOutServerMockRecorder) RecvMsg ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) RecvMsg(arg0 any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*ProcessorService_InspectProcessorOutServerMockRecorder) Send ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*ProcessorService_InspectProcessorOutServerMockRecorder) SendHeader ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*ProcessorService_InspectProcessorOutServerMockRecorder) SendMsg ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendMsg(arg0 any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*ProcessorService_InspectProcessorOutServerMockRecorder) SetHeader ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*ProcessorService_InspectProcessorOutServerMockRecorder) SetTrailer ¶ added in v0.5.0
func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.