Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type DestinationPlugin
- func (m *DestinationPlugin) Ack(arg0 context.Context) (record.Position, error)
- func (m *DestinationPlugin) Configure(arg0 context.Context, arg1 map[string]string) error
- func (m *DestinationPlugin) EXPECT() *DestinationPluginMockRecorder
- func (m *DestinationPlugin) LifecycleOnCreated(arg0 context.Context, arg1 map[string]string) error
- func (m *DestinationPlugin) LifecycleOnDeleted(arg0 context.Context, arg1 map[string]string) error
- func (m *DestinationPlugin) LifecycleOnUpdated(arg0 context.Context, arg1, arg2 map[string]string) error
- func (m *DestinationPlugin) Start(arg0 context.Context) error
- func (m *DestinationPlugin) Stop(arg0 context.Context, arg1 record.Position) error
- func (m *DestinationPlugin) Teardown(arg0 context.Context) error
- func (m *DestinationPlugin) Write(arg0 context.Context, arg1 record.Record) error
- type DestinationPluginMockRecorder
- func (mr *DestinationPluginMockRecorder) Ack(arg0 any) *gomock.Call
- 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, arg2 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) Start(arg0 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) Stop(arg0, arg1 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) Teardown(arg0 any) *gomock.Call
- func (mr *DestinationPluginMockRecorder) Write(arg0, arg1 any) *gomock.Call
- type Dispenser
- type DispenserMockRecorder
- type SourcePlugin
- func (m *SourcePlugin) Ack(arg0 context.Context, arg1 record.Position) error
- func (m *SourcePlugin) Configure(arg0 context.Context, arg1 map[string]string) error
- func (m *SourcePlugin) EXPECT() *SourcePluginMockRecorder
- func (m *SourcePlugin) LifecycleOnCreated(arg0 context.Context, arg1 map[string]string) error
- func (m *SourcePlugin) LifecycleOnDeleted(arg0 context.Context, arg1 map[string]string) error
- func (m *SourcePlugin) LifecycleOnUpdated(arg0 context.Context, arg1, arg2 map[string]string) error
- func (m *SourcePlugin) Read(arg0 context.Context) (record.Record, error)
- func (m *SourcePlugin) Start(arg0 context.Context, arg1 record.Position) error
- func (m *SourcePlugin) Stop(arg0 context.Context) (record.Position, error)
- func (m *SourcePlugin) Teardown(arg0 context.Context) error
- type SourcePluginMockRecorder
- func (mr *SourcePluginMockRecorder) Ack(arg0, arg1 any) *gomock.Call
- 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, arg2 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) Read(arg0 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) Start(arg0, arg1 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) Stop(arg0 any) *gomock.Call
- func (mr *SourcePluginMockRecorder) Teardown(arg0 any) *gomock.Call
- 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) EXPECT ¶
func (m *DestinationPlugin) EXPECT() *DestinationPluginMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*DestinationPlugin) LifecycleOnCreated ¶
LifecycleOnCreated mocks base method.
func (*DestinationPlugin) LifecycleOnDeleted ¶
LifecycleOnDeleted mocks base method.
func (*DestinationPlugin) LifecycleOnUpdated ¶
func (m *DestinationPlugin) LifecycleOnUpdated(arg0 context.Context, arg1, arg2 map[string]string) error
LifecycleOnUpdated mocks base method.
func (*DestinationPlugin) Start ¶
func (m *DestinationPlugin) Start(arg0 context.Context) error
Start mocks base method.
type DestinationPluginMockRecorder ¶
type DestinationPluginMockRecorder struct {
// contains filtered or unexported fields
}
DestinationPluginMockRecorder is the mock recorder for DestinationPlugin.
func (*DestinationPluginMockRecorder) Ack ¶
func (mr *DestinationPluginMockRecorder) Ack(arg0 any) *gomock.Call
Ack indicates an expected call of Ack.
func (*DestinationPluginMockRecorder) Configure ¶
func (mr *DestinationPluginMockRecorder) Configure(arg0, arg1 any) *gomock.Call
Configure indicates an expected call of Configure.
func (*DestinationPluginMockRecorder) LifecycleOnCreated ¶
func (mr *DestinationPluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *gomock.Call
LifecycleOnCreated indicates an expected call of LifecycleOnCreated.
func (*DestinationPluginMockRecorder) LifecycleOnDeleted ¶
func (mr *DestinationPluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *gomock.Call
LifecycleOnDeleted indicates an expected call of LifecycleOnDeleted.
func (*DestinationPluginMockRecorder) LifecycleOnUpdated ¶
func (mr *DestinationPluginMockRecorder) LifecycleOnUpdated(arg0, arg1, arg2 any) *gomock.Call
LifecycleOnUpdated indicates an expected call of LifecycleOnUpdated.
func (*DestinationPluginMockRecorder) Start ¶
func (mr *DestinationPluginMockRecorder) Start(arg0 any) *gomock.Call
Start indicates an expected call of Start.
func (*DestinationPluginMockRecorder) Stop ¶
func (mr *DestinationPluginMockRecorder) Stop(arg0, arg1 any) *gomock.Call
Stop indicates an expected call of Stop.
type Dispenser ¶
type Dispenser struct {
// contains filtered or unexported fields
}
Dispenser is a mock of Dispenser interface.
func NewDispenser ¶
func NewDispenser(ctrl *gomock.Controller) *Dispenser
NewDispenser creates a new mock instance.
func (*Dispenser) DispenseDestination ¶
func (m *Dispenser) DispenseDestination() (connector.DestinationPlugin, error)
DispenseDestination mocks base method.
func (*Dispenser) DispenseSource ¶
func (m *Dispenser) DispenseSource() (connector.SourcePlugin, error)
DispenseSource mocks base method.
func (*Dispenser) DispenseSpecifier ¶
func (m *Dispenser) DispenseSpecifier() (connector.SpecifierPlugin, error)
DispenseSpecifier mocks base method.
func (*Dispenser) EXPECT ¶
func (m *Dispenser) EXPECT() *DispenserMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type DispenserMockRecorder ¶
type DispenserMockRecorder struct {
// contains filtered or unexported fields
}
DispenserMockRecorder is the mock recorder for Dispenser.
func (*DispenserMockRecorder) DispenseDestination ¶
func (mr *DispenserMockRecorder) DispenseDestination() *gomock.Call
DispenseDestination indicates an expected call of DispenseDestination.
func (*DispenserMockRecorder) DispenseSource ¶
func (mr *DispenserMockRecorder) DispenseSource() *gomock.Call
DispenseSource indicates an expected call of DispenseSource.
func (*DispenserMockRecorder) DispenseSpecifier ¶
func (mr *DispenserMockRecorder) DispenseSpecifier() *gomock.Call
DispenseSpecifier indicates an expected call of DispenseSpecifier.
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) EXPECT ¶
func (m *SourcePlugin) EXPECT() *SourcePluginMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*SourcePlugin) LifecycleOnCreated ¶
LifecycleOnCreated mocks base method.
func (*SourcePlugin) LifecycleOnDeleted ¶
LifecycleOnDeleted mocks base method.
func (*SourcePlugin) LifecycleOnUpdated ¶
LifecycleOnUpdated mocks base method.
type SourcePluginMockRecorder ¶
type SourcePluginMockRecorder struct {
// contains filtered or unexported fields
}
SourcePluginMockRecorder is the mock recorder for SourcePlugin.
func (*SourcePluginMockRecorder) Ack ¶
func (mr *SourcePluginMockRecorder) Ack(arg0, arg1 any) *gomock.Call
Ack indicates an expected call of Ack.
func (*SourcePluginMockRecorder) Configure ¶
func (mr *SourcePluginMockRecorder) Configure(arg0, arg1 any) *gomock.Call
Configure indicates an expected call of Configure.
func (*SourcePluginMockRecorder) LifecycleOnCreated ¶
func (mr *SourcePluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *gomock.Call
LifecycleOnCreated indicates an expected call of LifecycleOnCreated.
func (*SourcePluginMockRecorder) LifecycleOnDeleted ¶
func (mr *SourcePluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *gomock.Call
LifecycleOnDeleted indicates an expected call of LifecycleOnDeleted.
func (*SourcePluginMockRecorder) LifecycleOnUpdated ¶
func (mr *SourcePluginMockRecorder) LifecycleOnUpdated(arg0, arg1, arg2 any) *gomock.Call
LifecycleOnUpdated indicates an expected call of LifecycleOnUpdated.
func (*SourcePluginMockRecorder) Read ¶
func (mr *SourcePluginMockRecorder) Read(arg0 any) *gomock.Call
Read indicates an expected call of Read.
func (*SourcePluginMockRecorder) Start ¶
func (mr *SourcePluginMockRecorder) Start(arg0, arg1 any) *gomock.Call
Start indicates an expected call of Start.
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() (connector.Specification, error)
Specify mocks base method.
type SpecifierPluginMockRecorder ¶
type SpecifierPluginMockRecorder struct {
// contains filtered or unexported fields
}
SpecifierPluginMockRecorder is the mock recorder for SpecifierPlugin.
func (*SpecifierPluginMockRecorder) Specify ¶
func (mr *SpecifierPluginMockRecorder) Specify() *gomock.Call
Specify indicates an expected call of Specify.