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 DestinationPlugin
- func (m *DestinationPlugin) Configure(arg0 context.Context, arg1 cpluginv1.DestinationConfigureRequest) (cpluginv1.DestinationConfigureResponse, error)
- func (m *DestinationPlugin) EXPECT() *DestinationPluginMockRecorder
- func (m *DestinationPlugin) LifecycleOnCreated(arg0 context.Context, arg1 cpluginv1.DestinationLifecycleOnCreatedRequest) (cpluginv1.DestinationLifecycleOnCreatedResponse, error)
- func (m *DestinationPlugin) LifecycleOnDeleted(arg0 context.Context, arg1 cpluginv1.DestinationLifecycleOnDeletedRequest) (cpluginv1.DestinationLifecycleOnDeletedResponse, error)
- func (m *DestinationPlugin) LifecycleOnUpdated(arg0 context.Context, arg1 cpluginv1.DestinationLifecycleOnUpdatedRequest) (cpluginv1.DestinationLifecycleOnUpdatedResponse, error)
- func (m *DestinationPlugin) Run(arg0 context.Context, arg1 cpluginv1.DestinationRunStream) error
- func (m *DestinationPlugin) Start(arg0 context.Context, arg1 cpluginv1.DestinationStartRequest) (cpluginv1.DestinationStartResponse, error)
- func (m *DestinationPlugin) Stop(arg0 context.Context, arg1 cpluginv1.DestinationStopRequest) (cpluginv1.DestinationStopResponse, error)
- func (m *DestinationPlugin) Teardown(arg0 context.Context, arg1 cpluginv1.DestinationTeardownRequest) (cpluginv1.DestinationTeardownResponse, error)
- type DestinationPluginMockRecorder
- func (mr *DestinationPluginMockRecorder) Configure(arg0, arg1 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) LifecycleOnUpdated(arg0, arg1 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) Run(arg0, arg1 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) Start(arg0, arg1 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) Stop(arg0, arg1 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) Teardown(arg0, arg1 any) *gomock.Call
- type DestinationRunStream
- type DestinationRunStreamMockRecorder
- type SourcePlugin
- func (m *SourcePlugin) Configure(arg0 context.Context, arg1 cpluginv1.SourceConfigureRequest) (cpluginv1.SourceConfigureResponse, error)
- func (m *SourcePlugin) EXPECT() *SourcePluginMockRecorder
- func (m *SourcePlugin) LifecycleOnCreated(arg0 context.Context, arg1 cpluginv1.SourceLifecycleOnCreatedRequest) (cpluginv1.SourceLifecycleOnCreatedResponse, error)
- func (m *SourcePlugin) LifecycleOnDeleted(arg0 context.Context, arg1 cpluginv1.SourceLifecycleOnDeletedRequest) (cpluginv1.SourceLifecycleOnDeletedResponse, error)
- func (m *SourcePlugin) LifecycleOnUpdated(arg0 context.Context, arg1 cpluginv1.SourceLifecycleOnUpdatedRequest) (cpluginv1.SourceLifecycleOnUpdatedResponse, error)
- func (m *SourcePlugin) Run(arg0 context.Context, arg1 cpluginv1.SourceRunStream) error
- func (m *SourcePlugin) Start(arg0 context.Context, arg1 cpluginv1.SourceStartRequest) (cpluginv1.SourceStartResponse, error)
- func (m *SourcePlugin) Stop(arg0 context.Context, arg1 cpluginv1.SourceStopRequest) (cpluginv1.SourceStopResponse, error)
- func (m *SourcePlugin) Teardown(arg0 context.Context, arg1 cpluginv1.SourceTeardownRequest) (cpluginv1.SourceTeardownResponse, error)
- type SourcePluginMockRecorder
- func (mr *SourcePluginMockRecorder) Configure(arg0, arg1 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) LifecycleOnUpdated(arg0, arg1 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) Run(arg0, arg1 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) Start(arg0, arg1 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) Stop(arg0, arg1 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) Teardown(arg0, arg1 any) *gomock.Call
- type SourceRunStream
- type SourceRunStreamMockRecorder
- type SpecifierPlugin
- type SpecifierPluginMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DestinationPlugin ¶
type DestinationPlugin struct {
// contains filtered or unexported fields
}
DestinationPlugin is a mock of DestinationPlugin interface.
func NewDestinationPlugin ¶
func NewDestinationPlugin(ctrl *gomock.Controller) *DestinationPlugin
NewDestinationPlugin creates a new mock instance.
func (*DestinationPlugin) Configure ¶
func (m *DestinationPlugin) Configure(arg0 context.Context, arg1 cpluginv1.DestinationConfigureRequest) (cpluginv1.DestinationConfigureResponse, error)
Configure mocks base method.
func (*DestinationPlugin) EXPECT ¶
func (m *DestinationPlugin) EXPECT() *DestinationPluginMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*DestinationPlugin) LifecycleOnCreated ¶ added in v0.5.0
func (m *DestinationPlugin) LifecycleOnCreated(arg0 context.Context, arg1 cpluginv1.DestinationLifecycleOnCreatedRequest) (cpluginv1.DestinationLifecycleOnCreatedResponse, error)
LifecycleOnCreated mocks base method.
func (*DestinationPlugin) LifecycleOnDeleted ¶ added in v0.5.0
func (m *DestinationPlugin) LifecycleOnDeleted(arg0 context.Context, arg1 cpluginv1.DestinationLifecycleOnDeletedRequest) (cpluginv1.DestinationLifecycleOnDeletedResponse, error)
LifecycleOnDeleted mocks base method.
func (*DestinationPlugin) LifecycleOnUpdated ¶ added in v0.5.0
func (m *DestinationPlugin) LifecycleOnUpdated(arg0 context.Context, arg1 cpluginv1.DestinationLifecycleOnUpdatedRequest) (cpluginv1.DestinationLifecycleOnUpdatedResponse, error)
LifecycleOnUpdated mocks base method.
func (*DestinationPlugin) Run ¶
func (m *DestinationPlugin) Run(arg0 context.Context, arg1 cpluginv1.DestinationRunStream) error
Run mocks base method.
func (*DestinationPlugin) Start ¶
func (m *DestinationPlugin) Start(arg0 context.Context, arg1 cpluginv1.DestinationStartRequest) (cpluginv1.DestinationStartResponse, error)
Start mocks base method.
func (*DestinationPlugin) Stop ¶
func (m *DestinationPlugin) Stop(arg0 context.Context, arg1 cpluginv1.DestinationStopRequest) (cpluginv1.DestinationStopResponse, error)
Stop mocks base method.
func (*DestinationPlugin) Teardown ¶
func (m *DestinationPlugin) Teardown(arg0 context.Context, arg1 cpluginv1.DestinationTeardownRequest) (cpluginv1.DestinationTeardownResponse, error)
Teardown mocks base method.
type DestinationPluginMockRecorder ¶
type DestinationPluginMockRecorder struct {
// contains filtered or unexported fields
}
DestinationPluginMockRecorder is the mock recorder for DestinationPlugin.
func (*DestinationPluginMockRecorder) Configure ¶
func (mr *DestinationPluginMockRecorder) Configure(arg0, arg1 any) *gomock.Call
Configure indicates an expected call of Configure.
func (*DestinationPluginMockRecorder) LifecycleOnCreated ¶ added in v0.5.0
func (mr *DestinationPluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *gomock.Call
LifecycleOnCreated indicates an expected call of LifecycleOnCreated.
func (*DestinationPluginMockRecorder) LifecycleOnDeleted ¶ added in v0.5.0
func (mr *DestinationPluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *gomock.Call
LifecycleOnDeleted indicates an expected call of LifecycleOnDeleted.
func (*DestinationPluginMockRecorder) LifecycleOnUpdated ¶ added in v0.5.0
func (mr *DestinationPluginMockRecorder) LifecycleOnUpdated(arg0, arg1 any) *gomock.Call
LifecycleOnUpdated indicates an expected call of LifecycleOnUpdated.
func (*DestinationPluginMockRecorder) Run ¶
func (mr *DestinationPluginMockRecorder) Run(arg0, arg1 any) *gomock.Call
Run indicates an expected call of Run.
func (*DestinationPluginMockRecorder) Start ¶
func (mr *DestinationPluginMockRecorder) Start(arg0, arg1 any) *gomock.Call
Start indicates an expected call of Start.
type DestinationRunStream ¶ added in v0.3.0
type DestinationRunStream struct {
// contains filtered or unexported fields
}
DestinationRunStream is a mock of DestinationRunStream interface.
func NewDestinationRunStream ¶ added in v0.3.0
func NewDestinationRunStream(ctrl *gomock.Controller) *DestinationRunStream
NewDestinationRunStream creates a new mock instance.
func (*DestinationRunStream) EXPECT ¶ added in v0.3.0
func (m *DestinationRunStream) EXPECT() *DestinationRunStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*DestinationRunStream) Recv ¶ added in v0.3.0
func (m *DestinationRunStream) Recv() (cpluginv1.DestinationRunRequest, error)
Recv mocks base method.
func (*DestinationRunStream) Send ¶ added in v0.3.0
func (m *DestinationRunStream) Send(arg0 cpluginv1.DestinationRunResponse) error
Send mocks base method.
type DestinationRunStreamMockRecorder ¶ added in v0.3.0
type DestinationRunStreamMockRecorder struct {
// contains filtered or unexported fields
}
DestinationRunStreamMockRecorder is the mock recorder for DestinationRunStream.
func (*DestinationRunStreamMockRecorder) Recv ¶ added in v0.3.0
func (mr *DestinationRunStreamMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
type SourcePlugin ¶
type SourcePlugin struct {
// contains filtered or unexported fields
}
SourcePlugin is a mock of SourcePlugin interface.
func NewSourcePlugin ¶
func NewSourcePlugin(ctrl *gomock.Controller) *SourcePlugin
NewSourcePlugin creates a new mock instance.
func (*SourcePlugin) Configure ¶
func (m *SourcePlugin) Configure(arg0 context.Context, arg1 cpluginv1.SourceConfigureRequest) (cpluginv1.SourceConfigureResponse, error)
Configure mocks base method.
func (*SourcePlugin) EXPECT ¶
func (m *SourcePlugin) EXPECT() *SourcePluginMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*SourcePlugin) LifecycleOnCreated ¶ added in v0.5.0
func (m *SourcePlugin) LifecycleOnCreated(arg0 context.Context, arg1 cpluginv1.SourceLifecycleOnCreatedRequest) (cpluginv1.SourceLifecycleOnCreatedResponse, error)
LifecycleOnCreated mocks base method.
func (*SourcePlugin) LifecycleOnDeleted ¶ added in v0.5.0
func (m *SourcePlugin) LifecycleOnDeleted(arg0 context.Context, arg1 cpluginv1.SourceLifecycleOnDeletedRequest) (cpluginv1.SourceLifecycleOnDeletedResponse, error)
LifecycleOnDeleted mocks base method.
func (*SourcePlugin) LifecycleOnUpdated ¶ added in v0.5.0
func (m *SourcePlugin) LifecycleOnUpdated(arg0 context.Context, arg1 cpluginv1.SourceLifecycleOnUpdatedRequest) (cpluginv1.SourceLifecycleOnUpdatedResponse, error)
LifecycleOnUpdated mocks base method.
func (*SourcePlugin) Run ¶
func (m *SourcePlugin) Run(arg0 context.Context, arg1 cpluginv1.SourceRunStream) error
Run mocks base method.
func (*SourcePlugin) Start ¶
func (m *SourcePlugin) Start(arg0 context.Context, arg1 cpluginv1.SourceStartRequest) (cpluginv1.SourceStartResponse, error)
Start mocks base method.
func (*SourcePlugin) Stop ¶
func (m *SourcePlugin) Stop(arg0 context.Context, arg1 cpluginv1.SourceStopRequest) (cpluginv1.SourceStopResponse, error)
Stop mocks base method.
func (*SourcePlugin) Teardown ¶
func (m *SourcePlugin) Teardown(arg0 context.Context, arg1 cpluginv1.SourceTeardownRequest) (cpluginv1.SourceTeardownResponse, error)
Teardown mocks base method.
type SourcePluginMockRecorder ¶
type SourcePluginMockRecorder struct {
// contains filtered or unexported fields
}
SourcePluginMockRecorder is the mock recorder for SourcePlugin.
func (*SourcePluginMockRecorder) Configure ¶
func (mr *SourcePluginMockRecorder) Configure(arg0, arg1 any) *gomock.Call
Configure indicates an expected call of Configure.
func (*SourcePluginMockRecorder) LifecycleOnCreated ¶ added in v0.5.0
func (mr *SourcePluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *gomock.Call
LifecycleOnCreated indicates an expected call of LifecycleOnCreated.
func (*SourcePluginMockRecorder) LifecycleOnDeleted ¶ added in v0.5.0
func (mr *SourcePluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *gomock.Call
LifecycleOnDeleted indicates an expected call of LifecycleOnDeleted.
func (*SourcePluginMockRecorder) LifecycleOnUpdated ¶ added in v0.5.0
func (mr *SourcePluginMockRecorder) LifecycleOnUpdated(arg0, arg1 any) *gomock.Call
LifecycleOnUpdated indicates an expected call of LifecycleOnUpdated.
func (*SourcePluginMockRecorder) Run ¶
func (mr *SourcePluginMockRecorder) Run(arg0, arg1 any) *gomock.Call
Run indicates an expected call of Run.
func (*SourcePluginMockRecorder) Start ¶
func (mr *SourcePluginMockRecorder) Start(arg0, arg1 any) *gomock.Call
Start indicates an expected call of Start.
type SourceRunStream ¶ added in v0.3.0
type SourceRunStream struct {
// contains filtered or unexported fields
}
SourceRunStream is a mock of SourceRunStream interface.
func NewSourceRunStream ¶ added in v0.3.0
func NewSourceRunStream(ctrl *gomock.Controller) *SourceRunStream
NewSourceRunStream creates a new mock instance.
func (*SourceRunStream) EXPECT ¶ added in v0.3.0
func (m *SourceRunStream) EXPECT() *SourceRunStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*SourceRunStream) Recv ¶ added in v0.3.0
func (m *SourceRunStream) Recv() (cpluginv1.SourceRunRequest, error)
Recv mocks base method.
func (*SourceRunStream) Send ¶ added in v0.3.0
func (m *SourceRunStream) Send(arg0 cpluginv1.SourceRunResponse) error
Send mocks base method.
type SourceRunStreamMockRecorder ¶ added in v0.3.0
type SourceRunStreamMockRecorder struct {
// contains filtered or unexported fields
}
SourceRunStreamMockRecorder is the mock recorder for SourceRunStream.
func (*SourceRunStreamMockRecorder) Recv ¶ added in v0.3.0
func (mr *SourceRunStreamMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
type SpecifierPlugin ¶
type SpecifierPlugin struct {
// contains filtered or unexported fields
}
SpecifierPlugin is a mock of SpecifierPlugin interface.
func NewSpecifierPlugin ¶
func NewSpecifierPlugin(ctrl *gomock.Controller) *SpecifierPlugin
NewSpecifierPlugin creates a new mock instance.
func (*SpecifierPlugin) EXPECT ¶
func (m *SpecifierPlugin) EXPECT() *SpecifierPluginMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*SpecifierPlugin) Specify ¶
func (m *SpecifierPlugin) Specify(arg0 context.Context, arg1 cpluginv1.SpecifierSpecifyRequest) (cpluginv1.SpecifierSpecifyResponse, error)
Specify mocks base method.
type SpecifierPluginMockRecorder ¶
type SpecifierPluginMockRecorder struct {
// contains filtered or unexported fields
}
SpecifierPluginMockRecorder is the mock recorder for SpecifierPlugin.