mock

package
v0.12.0-nightly.20240822 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 21, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigurableDestinationPlugin added in v0.11.0 

type ConfigurableDestinationPlugin struct {
	*DestinationPlugin
	Stream *builtin.InMemoryDestinationRunStream
	// contains filtered or unexported fields
}

func NewConfigurableDestinationPlugin added in v0.11.0 

func NewConfigurableDestinationPlugin(
	ctrl *gomock.Controller,
	opts ...ConfigurableDestinationPluginOption,
) *ConfigurableDestinationPlugin

NewConfigurableDestinationPlugin creates a mocked destination plugin that can be configured using options.

type ConfigurableDestinationPluginOption added in v0.11.0 

type ConfigurableDestinationPluginOption interface {
	Apply(*ConfigurableDestinationPlugin)
}

func DestinationPluginWithConfigure added in v0.11.0 

func DestinationPluginWithConfigure() ConfigurableDestinationPluginOption

func DestinationPluginWithOpen added in v0.11.0 

func DestinationPluginWithOpen() ConfigurableDestinationPluginOption

func DestinationPluginWithRecords added in v0.11.0 

func DestinationPluginWithRecords(records []opencdc.Record) ConfigurableDestinationPluginOption

func DestinationPluginWithRun added in v0.11.0 

func DestinationPluginWithRun() ConfigurableDestinationPluginOption

func DestinationPluginWithStop added in v0.11.0 

func DestinationPluginWithStop(lastPosition opencdc.Position) ConfigurableDestinationPluginOption

func DestinationPluginWithTeardown added in v0.11.0 

func DestinationPluginWithTeardown() ConfigurableDestinationPluginOption

type ConfigurableSourcePlugin added in v0.11.0 

type ConfigurableSourcePlugin struct {
	*SourcePlugin
	Stream *builtin.InMemorySourceRunStream
	// contains filtered or unexported fields
}

func NewConfigurableSourcePlugin added in v0.11.0 

func NewConfigurableSourcePlugin(
	ctrl *gomock.Controller,
	opts ...ConfigurableSourcePluginOption,
) *ConfigurableSourcePlugin

NewConfigurableSourcePlugin creates a mocked source plugin that can be configured using options.

type ConfigurableSourcePluginOption added in v0.11.0 

type ConfigurableSourcePluginOption interface {
	Apply(*ConfigurableSourcePlugin)
}

func SourcePluginWithAcks added in v0.11.0 

func SourcePluginWithAcks(wantCount int, assertAckCount bool) ConfigurableSourcePluginOption

func SourcePluginWithConfigure added in v0.11.0 

func SourcePluginWithConfigure() ConfigurableSourcePluginOption

func SourcePluginWithOpen added in v0.11.0 

func SourcePluginWithOpen() ConfigurableSourcePluginOption

func SourcePluginWithRecords added in v0.11.0 

func SourcePluginWithRecords(records []opencdc.Record, wantErr error) ConfigurableSourcePluginOption

func SourcePluginWithRun added in v0.11.0 

func SourcePluginWithRun() ConfigurableSourcePluginOption

func SourcePluginWithStop added in v0.11.0 

func SourcePluginWithStop() ConfigurableSourcePluginOption

func SourcePluginWithTeardown added in v0.11.0 

func SourcePluginWithTeardown() ConfigurableSourcePluginOption

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 pconnector.DestinationConfigureRequest) (pconnector.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 

func (m *DestinationPlugin) LifecycleOnCreated(arg0 context.Context, arg1 pconnector.DestinationLifecycleOnCreatedRequest) (pconnector.DestinationLifecycleOnCreatedResponse, error)

LifecycleOnCreated mocks base method.

func (*DestinationPlugin) LifecycleOnDeleted 

func (m *DestinationPlugin) LifecycleOnDeleted(arg0 context.Context, arg1 pconnector.DestinationLifecycleOnDeletedRequest) (pconnector.DestinationLifecycleOnDeletedResponse, error)

LifecycleOnDeleted mocks base method.

func (*DestinationPlugin) LifecycleOnUpdated 

func (m *DestinationPlugin) LifecycleOnUpdated(arg0 context.Context, arg1 pconnector.DestinationLifecycleOnUpdatedRequest) (pconnector.DestinationLifecycleOnUpdatedResponse, error)

LifecycleOnUpdated mocks base method.

func (*DestinationPlugin) NewStream added in v0.11.0 

func (m *DestinationPlugin) NewStream() pconnector.DestinationRunStream

NewStream mocks base method.

func (*DestinationPlugin) Open added in v0.11.0 

func (m *DestinationPlugin) Open(arg0 context.Context, arg1 pconnector.DestinationOpenRequest) (pconnector.DestinationOpenResponse, error)

Open mocks base method.

func (*DestinationPlugin) Run added in v0.11.0 

func (m *DestinationPlugin) Run(arg0 context.Context, arg1 pconnector.DestinationRunStream) error

Run mocks base method.

func (*DestinationPlugin) Stop 

func (m *DestinationPlugin) Stop(arg0 context.Context, arg1 pconnector.DestinationStopRequest) (pconnector.DestinationStopResponse, error)

Stop mocks base method.

func (*DestinationPlugin) Teardown 

func (m *DestinationPlugin) Teardown(arg0 context.Context, arg1 pconnector.DestinationTeardownRequest) (pconnector.DestinationTeardownResponse, error)

Teardown mocks base method.

type DestinationPluginConfigureCall added in v0.11.0 

type DestinationPluginConfigureCall struct {
	*gomock.Call
}

DestinationPluginConfigureCall wrap *gomock.Call

func (*DestinationPluginConfigureCall) Do added in v0.11.0 

func (c *DestinationPluginConfigureCall) Do(f func(context.Context, pconnector.DestinationConfigureRequest) (pconnector.DestinationConfigureResponse, error)) *DestinationPluginConfigureCall

Do rewrite *gomock.Call.Do

func (*DestinationPluginConfigureCall) DoAndReturn added in v0.11.0 

func (c *DestinationPluginConfigureCall) DoAndReturn(f func(context.Context, pconnector.DestinationConfigureRequest) (pconnector.DestinationConfigureResponse, error)) *DestinationPluginConfigureCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationPluginConfigureCall) Return added in v0.11.0 

func (c *DestinationPluginConfigureCall) Return(arg0 pconnector.DestinationConfigureResponse, arg1 error) *DestinationPluginConfigureCall

Return rewrite *gomock.Call.Return

type DestinationPluginLifecycleOnCreatedCall added in v0.11.0 

type DestinationPluginLifecycleOnCreatedCall struct {
	*gomock.Call
}

DestinationPluginLifecycleOnCreatedCall wrap *gomock.Call

func (*DestinationPluginLifecycleOnCreatedCall) Do added in v0.11.0 

func (c *DestinationPluginLifecycleOnCreatedCall) Do(f func(context.Context, pconnector.DestinationLifecycleOnCreatedRequest) (pconnector.DestinationLifecycleOnCreatedResponse, error)) *DestinationPluginLifecycleOnCreatedCall

Do rewrite *gomock.Call.Do

func (*DestinationPluginLifecycleOnCreatedCall) DoAndReturn added in v0.11.0 

func (c *DestinationPluginLifecycleOnCreatedCall) DoAndReturn(f func(context.Context, pconnector.DestinationLifecycleOnCreatedRequest) (pconnector.DestinationLifecycleOnCreatedResponse, error)) *DestinationPluginLifecycleOnCreatedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationPluginLifecycleOnCreatedCall) Return added in v0.11.0 

func (c *DestinationPluginLifecycleOnCreatedCall) Return(arg0 pconnector.DestinationLifecycleOnCreatedResponse, arg1 error) *DestinationPluginLifecycleOnCreatedCall

Return rewrite *gomock.Call.Return

type DestinationPluginLifecycleOnDeletedCall added in v0.11.0 

type DestinationPluginLifecycleOnDeletedCall struct {
	*gomock.Call
}

DestinationPluginLifecycleOnDeletedCall wrap *gomock.Call

func (*DestinationPluginLifecycleOnDeletedCall) Do added in v0.11.0 

func (c *DestinationPluginLifecycleOnDeletedCall) Do(f func(context.Context, pconnector.DestinationLifecycleOnDeletedRequest) (pconnector.DestinationLifecycleOnDeletedResponse, error)) *DestinationPluginLifecycleOnDeletedCall

Do rewrite *gomock.Call.Do

func (*DestinationPluginLifecycleOnDeletedCall) DoAndReturn added in v0.11.0 

func (c *DestinationPluginLifecycleOnDeletedCall) DoAndReturn(f func(context.Context, pconnector.DestinationLifecycleOnDeletedRequest) (pconnector.DestinationLifecycleOnDeletedResponse, error)) *DestinationPluginLifecycleOnDeletedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationPluginLifecycleOnDeletedCall) Return added in v0.11.0 

func (c *DestinationPluginLifecycleOnDeletedCall) Return(arg0 pconnector.DestinationLifecycleOnDeletedResponse, arg1 error) *DestinationPluginLifecycleOnDeletedCall

Return rewrite *gomock.Call.Return

type DestinationPluginLifecycleOnUpdatedCall added in v0.11.0 

type DestinationPluginLifecycleOnUpdatedCall struct {
	*gomock.Call
}

DestinationPluginLifecycleOnUpdatedCall wrap *gomock.Call

func (*DestinationPluginLifecycleOnUpdatedCall) Do added in v0.11.0 

func (c *DestinationPluginLifecycleOnUpdatedCall) Do(f func(context.Context, pconnector.DestinationLifecycleOnUpdatedRequest) (pconnector.DestinationLifecycleOnUpdatedResponse, error)) *DestinationPluginLifecycleOnUpdatedCall

Do rewrite *gomock.Call.Do

func (*DestinationPluginLifecycleOnUpdatedCall) DoAndReturn added in v0.11.0 

func (c *DestinationPluginLifecycleOnUpdatedCall) DoAndReturn(f func(context.Context, pconnector.DestinationLifecycleOnUpdatedRequest) (pconnector.DestinationLifecycleOnUpdatedResponse, error)) *DestinationPluginLifecycleOnUpdatedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationPluginLifecycleOnUpdatedCall) Return added in v0.11.0 

func (c *DestinationPluginLifecycleOnUpdatedCall) Return(arg0 pconnector.DestinationLifecycleOnUpdatedResponse, arg1 error) *DestinationPluginLifecycleOnUpdatedCall

Return rewrite *gomock.Call.Return

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) *DestinationPluginConfigureCall

Configure indicates an expected call of Configure.

func (*DestinationPluginMockRecorder) LifecycleOnCreated 

func (mr *DestinationPluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *DestinationPluginLifecycleOnCreatedCall

LifecycleOnCreated indicates an expected call of LifecycleOnCreated.

func (*DestinationPluginMockRecorder) LifecycleOnDeleted 

func (mr *DestinationPluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *DestinationPluginLifecycleOnDeletedCall

LifecycleOnDeleted indicates an expected call of LifecycleOnDeleted.

func (*DestinationPluginMockRecorder) LifecycleOnUpdated 

func (mr *DestinationPluginMockRecorder) LifecycleOnUpdated(arg0, arg1 any) *DestinationPluginLifecycleOnUpdatedCall

LifecycleOnUpdated indicates an expected call of LifecycleOnUpdated.

func (*DestinationPluginMockRecorder) NewStream added in v0.11.0 

func (mr *DestinationPluginMockRecorder) NewStream() *DestinationPluginNewStreamCall

NewStream indicates an expected call of NewStream.

func (*DestinationPluginMockRecorder) Open added in v0.11.0 

func (mr *DestinationPluginMockRecorder) Open(arg0, arg1 any) *DestinationPluginOpenCall

Open indicates an expected call of Open.

func (*DestinationPluginMockRecorder) Run added in v0.11.0 

func (mr *DestinationPluginMockRecorder) Run(arg0, arg1 any) *DestinationPluginRunCall

Run indicates an expected call of Run.

func (*DestinationPluginMockRecorder) Stop 

func (mr *DestinationPluginMockRecorder) Stop(arg0, arg1 any) *DestinationPluginStopCall

Stop indicates an expected call of Stop.

func (*DestinationPluginMockRecorder) Teardown 

func (mr *DestinationPluginMockRecorder) Teardown(arg0, arg1 any) *DestinationPluginTeardownCall

Teardown indicates an expected call of Teardown.

type DestinationPluginNewStreamCall added in v0.11.0 

type DestinationPluginNewStreamCall struct {
	*gomock.Call
}

DestinationPluginNewStreamCall wrap *gomock.Call

func (*DestinationPluginNewStreamCall) Do added in v0.11.0 

func (c *DestinationPluginNewStreamCall) Do(f func() pconnector.DestinationRunStream) *DestinationPluginNewStreamCall

Do rewrite *gomock.Call.Do

func (*DestinationPluginNewStreamCall) DoAndReturn added in v0.11.0 

func (c *DestinationPluginNewStreamCall) DoAndReturn(f func() pconnector.DestinationRunStream) *DestinationPluginNewStreamCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationPluginNewStreamCall) Return added in v0.11.0 

func (c *DestinationPluginNewStreamCall) Return(arg0 pconnector.DestinationRunStream) *DestinationPluginNewStreamCall

Return rewrite *gomock.Call.Return

type DestinationPluginOpenCall added in v0.11.0 

type DestinationPluginOpenCall struct {
	*gomock.Call
}

DestinationPluginOpenCall wrap *gomock.Call

func (*DestinationPluginOpenCall) Do added in v0.11.0 

func (c *DestinationPluginOpenCall) Do(f func(context.Context, pconnector.DestinationOpenRequest) (pconnector.DestinationOpenResponse, error)) *DestinationPluginOpenCall

Do rewrite *gomock.Call.Do

func (*DestinationPluginOpenCall) DoAndReturn added in v0.11.0 

func (c *DestinationPluginOpenCall) DoAndReturn(f func(context.Context, pconnector.DestinationOpenRequest) (pconnector.DestinationOpenResponse, error)) *DestinationPluginOpenCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationPluginOpenCall) Return added in v0.11.0 

func (c *DestinationPluginOpenCall) Return(arg0 pconnector.DestinationOpenResponse, arg1 error) *DestinationPluginOpenCall

Return rewrite *gomock.Call.Return

type DestinationPluginRunCall added in v0.11.0 

type DestinationPluginRunCall struct {
	*gomock.Call
}

DestinationPluginRunCall wrap *gomock.Call

func (*DestinationPluginRunCall) Do added in v0.11.0 

func (c *DestinationPluginRunCall) Do(f func(context.Context, pconnector.DestinationRunStream) error) *DestinationPluginRunCall

Do rewrite *gomock.Call.Do

func (*DestinationPluginRunCall) DoAndReturn added in v0.11.0 

func (c *DestinationPluginRunCall) DoAndReturn(f func(context.Context, pconnector.DestinationRunStream) error) *DestinationPluginRunCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationPluginRunCall) Return added in v0.11.0 

func (c *DestinationPluginRunCall) Return(arg0 error) *DestinationPluginRunCall

Return rewrite *gomock.Call.Return

type DestinationPluginStopCall added in v0.11.0 

type DestinationPluginStopCall struct {
	*gomock.Call
}

DestinationPluginStopCall wrap *gomock.Call

func (*DestinationPluginStopCall) Do added in v0.11.0 

func (c *DestinationPluginStopCall) Do(f func(context.Context, pconnector.DestinationStopRequest) (pconnector.DestinationStopResponse, error)) *DestinationPluginStopCall

Do rewrite *gomock.Call.Do

func (*DestinationPluginStopCall) DoAndReturn added in v0.11.0 

func (c *DestinationPluginStopCall) DoAndReturn(f func(context.Context, pconnector.DestinationStopRequest) (pconnector.DestinationStopResponse, error)) *DestinationPluginStopCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationPluginStopCall) Return added in v0.11.0 

func (c *DestinationPluginStopCall) Return(arg0 pconnector.DestinationStopResponse, arg1 error) *DestinationPluginStopCall

Return rewrite *gomock.Call.Return

type DestinationPluginTeardownCall added in v0.11.0 

type DestinationPluginTeardownCall struct {
	*gomock.Call
}

DestinationPluginTeardownCall wrap *gomock.Call

func (*DestinationPluginTeardownCall) Do added in v0.11.0 

func (c *DestinationPluginTeardownCall) Do(f func(context.Context, pconnector.DestinationTeardownRequest) (pconnector.DestinationTeardownResponse, error)) *DestinationPluginTeardownCall

Do rewrite *gomock.Call.Do

func (*DestinationPluginTeardownCall) DoAndReturn added in v0.11.0 

func (c *DestinationPluginTeardownCall) DoAndReturn(f func(context.Context, pconnector.DestinationTeardownRequest) (pconnector.DestinationTeardownResponse, error)) *DestinationPluginTeardownCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationPluginTeardownCall) Return added in v0.11.0 

func (c *DestinationPluginTeardownCall) Return(arg0 pconnector.DestinationTeardownResponse, arg1 error) *DestinationPluginTeardownCall

Return rewrite *gomock.Call.Return

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 DispenserDispenseDestinationCall added in v0.11.0 

type DispenserDispenseDestinationCall struct {
	*gomock.Call
}

DispenserDispenseDestinationCall wrap *gomock.Call

func (*DispenserDispenseDestinationCall) Do added in v0.11.0 

func (c *DispenserDispenseDestinationCall) Do(f func() (connector.DestinationPlugin, error)) *DispenserDispenseDestinationCall

Do rewrite *gomock.Call.Do

func (*DispenserDispenseDestinationCall) DoAndReturn added in v0.11.0 

func (c *DispenserDispenseDestinationCall) DoAndReturn(f func() (connector.DestinationPlugin, error)) *DispenserDispenseDestinationCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DispenserDispenseDestinationCall) Return added in v0.11.0 

func (c *DispenserDispenseDestinationCall) Return(arg0 connector.DestinationPlugin, arg1 error) *DispenserDispenseDestinationCall

Return rewrite *gomock.Call.Return

type DispenserDispenseSourceCall added in v0.11.0 

type DispenserDispenseSourceCall struct {
	*gomock.Call
}

DispenserDispenseSourceCall wrap *gomock.Call

func (*DispenserDispenseSourceCall) Do added in v0.11.0 

func (c *DispenserDispenseSourceCall) Do(f func() (connector.SourcePlugin, error)) *DispenserDispenseSourceCall

Do rewrite *gomock.Call.Do

func (*DispenserDispenseSourceCall) DoAndReturn added in v0.11.0 

func (c *DispenserDispenseSourceCall) DoAndReturn(f func() (connector.SourcePlugin, error)) *DispenserDispenseSourceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DispenserDispenseSourceCall) Return added in v0.11.0 

func (c *DispenserDispenseSourceCall) Return(arg0 connector.SourcePlugin, arg1 error) *DispenserDispenseSourceCall

Return rewrite *gomock.Call.Return

type DispenserDispenseSpecifierCall added in v0.11.0 

type DispenserDispenseSpecifierCall struct {
	*gomock.Call
}

DispenserDispenseSpecifierCall wrap *gomock.Call

func (*DispenserDispenseSpecifierCall) Do added in v0.11.0 

func (c *DispenserDispenseSpecifierCall) Do(f func() (connector.SpecifierPlugin, error)) *DispenserDispenseSpecifierCall

Do rewrite *gomock.Call.Do

func (*DispenserDispenseSpecifierCall) DoAndReturn added in v0.11.0 

func (c *DispenserDispenseSpecifierCall) DoAndReturn(f func() (connector.SpecifierPlugin, error)) *DispenserDispenseSpecifierCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DispenserDispenseSpecifierCall) Return added in v0.11.0 

func (c *DispenserDispenseSpecifierCall) Return(arg0 connector.SpecifierPlugin, arg1 error) *DispenserDispenseSpecifierCall

Return rewrite *gomock.Call.Return

type DispenserMockRecorder 

type DispenserMockRecorder struct {
	// contains filtered or unexported fields
}

DispenserMockRecorder is the mock recorder for Dispenser.

func (*DispenserMockRecorder) DispenseDestination 

func (mr *DispenserMockRecorder) DispenseDestination() *DispenserDispenseDestinationCall

DispenseDestination indicates an expected call of DispenseDestination.

func (*DispenserMockRecorder) DispenseSource 

func (mr *DispenserMockRecorder) DispenseSource() *DispenserDispenseSourceCall

DispenseSource indicates an expected call of DispenseSource.

func (*DispenserMockRecorder) DispenseSpecifier 

func (mr *DispenserMockRecorder) DispenseSpecifier() *DispenserDispenseSpecifierCall

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) Configure 

func (m *SourcePlugin) Configure(arg0 context.Context, arg1 pconnector.SourceConfigureRequest) (pconnector.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 

func (m *SourcePlugin) LifecycleOnCreated(arg0 context.Context, arg1 pconnector.SourceLifecycleOnCreatedRequest) (pconnector.SourceLifecycleOnCreatedResponse, error)

LifecycleOnCreated mocks base method.

func (*SourcePlugin) LifecycleOnDeleted 

func (m *SourcePlugin) LifecycleOnDeleted(arg0 context.Context, arg1 pconnector.SourceLifecycleOnDeletedRequest) (pconnector.SourceLifecycleOnDeletedResponse, error)

LifecycleOnDeleted mocks base method.

func (*SourcePlugin) LifecycleOnUpdated 

func (m *SourcePlugin) LifecycleOnUpdated(arg0 context.Context, arg1 pconnector.SourceLifecycleOnUpdatedRequest) (pconnector.SourceLifecycleOnUpdatedResponse, error)

LifecycleOnUpdated mocks base method.

func (*SourcePlugin) NewStream added in v0.11.0 

func (m *SourcePlugin) NewStream() pconnector.SourceRunStream

NewStream mocks base method.

func (*SourcePlugin) Open added in v0.11.0 

func (m *SourcePlugin) Open(arg0 context.Context, arg1 pconnector.SourceOpenRequest) (pconnector.SourceOpenResponse, error)

Open mocks base method.

func (*SourcePlugin) Run added in v0.11.0 

func (m *SourcePlugin) Run(arg0 context.Context, arg1 pconnector.SourceRunStream) error

Run mocks base method.

func (*SourcePlugin) Stop 

func (m *SourcePlugin) Stop(arg0 context.Context, arg1 pconnector.SourceStopRequest) (pconnector.SourceStopResponse, error)

Stop mocks base method.

func (*SourcePlugin) Teardown 

func (m *SourcePlugin) Teardown(arg0 context.Context, arg1 pconnector.SourceTeardownRequest) (pconnector.SourceTeardownResponse, error)

Teardown mocks base method.

type SourcePluginConfigureCall added in v0.11.0 

type SourcePluginConfigureCall struct {
	*gomock.Call
}

SourcePluginConfigureCall wrap *gomock.Call

func (*SourcePluginConfigureCall) Do added in v0.11.0 

func (c *SourcePluginConfigureCall) Do(f func(context.Context, pconnector.SourceConfigureRequest) (pconnector.SourceConfigureResponse, error)) *SourcePluginConfigureCall

Do rewrite *gomock.Call.Do

func (*SourcePluginConfigureCall) DoAndReturn added in v0.11.0 

func (c *SourcePluginConfigureCall) DoAndReturn(f func(context.Context, pconnector.SourceConfigureRequest) (pconnector.SourceConfigureResponse, error)) *SourcePluginConfigureCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourcePluginConfigureCall) Return added in v0.11.0 

func (c *SourcePluginConfigureCall) Return(arg0 pconnector.SourceConfigureResponse, arg1 error) *SourcePluginConfigureCall

Return rewrite *gomock.Call.Return

type SourcePluginLifecycleOnCreatedCall added in v0.11.0 

type SourcePluginLifecycleOnCreatedCall struct {
	*gomock.Call
}

SourcePluginLifecycleOnCreatedCall wrap *gomock.Call

func (*SourcePluginLifecycleOnCreatedCall) Do added in v0.11.0 

func (c *SourcePluginLifecycleOnCreatedCall) Do(f func(context.Context, pconnector.SourceLifecycleOnCreatedRequest) (pconnector.SourceLifecycleOnCreatedResponse, error)) *SourcePluginLifecycleOnCreatedCall

Do rewrite *gomock.Call.Do

func (*SourcePluginLifecycleOnCreatedCall) DoAndReturn added in v0.11.0 

func (c *SourcePluginLifecycleOnCreatedCall) DoAndReturn(f func(context.Context, pconnector.SourceLifecycleOnCreatedRequest) (pconnector.SourceLifecycleOnCreatedResponse, error)) *SourcePluginLifecycleOnCreatedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourcePluginLifecycleOnCreatedCall) Return added in v0.11.0 

func (c *SourcePluginLifecycleOnCreatedCall) Return(arg0 pconnector.SourceLifecycleOnCreatedResponse, arg1 error) *SourcePluginLifecycleOnCreatedCall

Return rewrite *gomock.Call.Return

type SourcePluginLifecycleOnDeletedCall added in v0.11.0 

type SourcePluginLifecycleOnDeletedCall struct {
	*gomock.Call
}

SourcePluginLifecycleOnDeletedCall wrap *gomock.Call

func (*SourcePluginLifecycleOnDeletedCall) Do added in v0.11.0 

func (c *SourcePluginLifecycleOnDeletedCall) Do(f func(context.Context, pconnector.SourceLifecycleOnDeletedRequest) (pconnector.SourceLifecycleOnDeletedResponse, error)) *SourcePluginLifecycleOnDeletedCall

Do rewrite *gomock.Call.Do

func (*SourcePluginLifecycleOnDeletedCall) DoAndReturn added in v0.11.0 

func (c *SourcePluginLifecycleOnDeletedCall) DoAndReturn(f func(context.Context, pconnector.SourceLifecycleOnDeletedRequest) (pconnector.SourceLifecycleOnDeletedResponse, error)) *SourcePluginLifecycleOnDeletedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourcePluginLifecycleOnDeletedCall) Return added in v0.11.0 

func (c *SourcePluginLifecycleOnDeletedCall) Return(arg0 pconnector.SourceLifecycleOnDeletedResponse, arg1 error) *SourcePluginLifecycleOnDeletedCall

Return rewrite *gomock.Call.Return

type SourcePluginLifecycleOnUpdatedCall added in v0.11.0 

type SourcePluginLifecycleOnUpdatedCall struct {
	*gomock.Call
}

SourcePluginLifecycleOnUpdatedCall wrap *gomock.Call

func (*SourcePluginLifecycleOnUpdatedCall) Do added in v0.11.0 

func (c *SourcePluginLifecycleOnUpdatedCall) Do(f func(context.Context, pconnector.SourceLifecycleOnUpdatedRequest) (pconnector.SourceLifecycleOnUpdatedResponse, error)) *SourcePluginLifecycleOnUpdatedCall

Do rewrite *gomock.Call.Do

func (*SourcePluginLifecycleOnUpdatedCall) DoAndReturn added in v0.11.0 

func (c *SourcePluginLifecycleOnUpdatedCall) DoAndReturn(f func(context.Context, pconnector.SourceLifecycleOnUpdatedRequest) (pconnector.SourceLifecycleOnUpdatedResponse, error)) *SourcePluginLifecycleOnUpdatedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourcePluginLifecycleOnUpdatedCall) Return added in v0.11.0 

func (c *SourcePluginLifecycleOnUpdatedCall) Return(arg0 pconnector.SourceLifecycleOnUpdatedResponse, arg1 error) *SourcePluginLifecycleOnUpdatedCall

Return rewrite *gomock.Call.Return

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) *SourcePluginConfigureCall

Configure indicates an expected call of Configure.

func (*SourcePluginMockRecorder) LifecycleOnCreated 

func (mr *SourcePluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *SourcePluginLifecycleOnCreatedCall

LifecycleOnCreated indicates an expected call of LifecycleOnCreated.

func (*SourcePluginMockRecorder) LifecycleOnDeleted 

func (mr *SourcePluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *SourcePluginLifecycleOnDeletedCall

LifecycleOnDeleted indicates an expected call of LifecycleOnDeleted.

func (*SourcePluginMockRecorder) LifecycleOnUpdated 

func (mr *SourcePluginMockRecorder) LifecycleOnUpdated(arg0, arg1 any) *SourcePluginLifecycleOnUpdatedCall

LifecycleOnUpdated indicates an expected call of LifecycleOnUpdated.

func (*SourcePluginMockRecorder) NewStream added in v0.11.0 

func (mr *SourcePluginMockRecorder) NewStream() *SourcePluginNewStreamCall

NewStream indicates an expected call of NewStream.

func (*SourcePluginMockRecorder) Open added in v0.11.0 

func (mr *SourcePluginMockRecorder) Open(arg0, arg1 any) *SourcePluginOpenCall

Open indicates an expected call of Open.

func (*SourcePluginMockRecorder) Run added in v0.11.0 

func (mr *SourcePluginMockRecorder) Run(arg0, arg1 any) *SourcePluginRunCall

Run indicates an expected call of Run.

func (*SourcePluginMockRecorder) Stop 

func (mr *SourcePluginMockRecorder) Stop(arg0, arg1 any) *SourcePluginStopCall

Stop indicates an expected call of Stop.

func (*SourcePluginMockRecorder) Teardown 

func (mr *SourcePluginMockRecorder) Teardown(arg0, arg1 any) *SourcePluginTeardownCall

Teardown indicates an expected call of Teardown.

type SourcePluginNewStreamCall added in v0.11.0 

type SourcePluginNewStreamCall struct {
	*gomock.Call
}

SourcePluginNewStreamCall wrap *gomock.Call

func (*SourcePluginNewStreamCall) Do added in v0.11.0 

func (c *SourcePluginNewStreamCall) Do(f func() pconnector.SourceRunStream) *SourcePluginNewStreamCall

Do rewrite *gomock.Call.Do

func (*SourcePluginNewStreamCall) DoAndReturn added in v0.11.0 

func (c *SourcePluginNewStreamCall) DoAndReturn(f func() pconnector.SourceRunStream) *SourcePluginNewStreamCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourcePluginNewStreamCall) Return added in v0.11.0 

func (c *SourcePluginNewStreamCall) Return(arg0 pconnector.SourceRunStream) *SourcePluginNewStreamCall

Return rewrite *gomock.Call.Return

type SourcePluginOpenCall added in v0.11.0 

type SourcePluginOpenCall struct {
	*gomock.Call
}

SourcePluginOpenCall wrap *gomock.Call

func (*SourcePluginOpenCall) Do added in v0.11.0 

func (c *SourcePluginOpenCall) Do(f func(context.Context, pconnector.SourceOpenRequest) (pconnector.SourceOpenResponse, error)) *SourcePluginOpenCall

Do rewrite *gomock.Call.Do

func (*SourcePluginOpenCall) DoAndReturn added in v0.11.0 

func (c *SourcePluginOpenCall) DoAndReturn(f func(context.Context, pconnector.SourceOpenRequest) (pconnector.SourceOpenResponse, error)) *SourcePluginOpenCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourcePluginOpenCall) Return added in v0.11.0 

func (c *SourcePluginOpenCall) Return(arg0 pconnector.SourceOpenResponse, arg1 error) *SourcePluginOpenCall

Return rewrite *gomock.Call.Return

type SourcePluginRunCall added in v0.11.0 

type SourcePluginRunCall struct {
	*gomock.Call
}

SourcePluginRunCall wrap *gomock.Call

func (*SourcePluginRunCall) Do added in v0.11.0 

func (c *SourcePluginRunCall) Do(f func(context.Context, pconnector.SourceRunStream) error) *SourcePluginRunCall

Do rewrite *gomock.Call.Do

func (*SourcePluginRunCall) DoAndReturn added in v0.11.0 

func (c *SourcePluginRunCall) DoAndReturn(f func(context.Context, pconnector.SourceRunStream) error) *SourcePluginRunCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourcePluginRunCall) Return added in v0.11.0 

func (c *SourcePluginRunCall) Return(arg0 error) *SourcePluginRunCall

Return rewrite *gomock.Call.Return

type SourcePluginStopCall added in v0.11.0 

type SourcePluginStopCall struct {
	*gomock.Call
}

SourcePluginStopCall wrap *gomock.Call

func (*SourcePluginStopCall) Do added in v0.11.0 

func (c *SourcePluginStopCall) Do(f func(context.Context, pconnector.SourceStopRequest) (pconnector.SourceStopResponse, error)) *SourcePluginStopCall

Do rewrite *gomock.Call.Do

func (*SourcePluginStopCall) DoAndReturn added in v0.11.0 

func (c *SourcePluginStopCall) DoAndReturn(f func(context.Context, pconnector.SourceStopRequest) (pconnector.SourceStopResponse, error)) *SourcePluginStopCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourcePluginStopCall) Return added in v0.11.0 

func (c *SourcePluginStopCall) Return(arg0 pconnector.SourceStopResponse, arg1 error) *SourcePluginStopCall

Return rewrite *gomock.Call.Return

type SourcePluginTeardownCall added in v0.11.0 

type SourcePluginTeardownCall struct {
	*gomock.Call
}

SourcePluginTeardownCall wrap *gomock.Call

func (*SourcePluginTeardownCall) Do added in v0.11.0 

func (c *SourcePluginTeardownCall) Do(f func(context.Context, pconnector.SourceTeardownRequest) (pconnector.SourceTeardownResponse, error)) *SourcePluginTeardownCall

Do rewrite *gomock.Call.Do

func (*SourcePluginTeardownCall) DoAndReturn added in v0.11.0 

func (c *SourcePluginTeardownCall) DoAndReturn(f func(context.Context, pconnector.SourceTeardownRequest) (pconnector.SourceTeardownResponse, error)) *SourcePluginTeardownCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourcePluginTeardownCall) Return added in v0.11.0 

func (c *SourcePluginTeardownCall) Return(arg0 pconnector.SourceTeardownResponse, arg1 error) *SourcePluginTeardownCall

Return rewrite *gomock.Call.Return

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 pconnector.SpecifierSpecifyRequest) (pconnector.SpecifierSpecifyResponse, 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(arg0, arg1 any) *SpecifierPluginSpecifyCall

Specify indicates an expected call of Specify.

type SpecifierPluginSpecifyCall added in v0.11.0 

type SpecifierPluginSpecifyCall struct {
	*gomock.Call
}

SpecifierPluginSpecifyCall wrap *gomock.Call

func (*SpecifierPluginSpecifyCall) Do added in v0.11.0 

func (c *SpecifierPluginSpecifyCall) Do(f func(context.Context, pconnector.SpecifierSpecifyRequest) (pconnector.SpecifierSpecifyResponse, error)) *SpecifierPluginSpecifyCall

Do rewrite *gomock.Call.Do

func (*SpecifierPluginSpecifyCall) DoAndReturn added in v0.11.0 

func (c *SpecifierPluginSpecifyCall) DoAndReturn(f func(context.Context, pconnector.SpecifierSpecifyRequest) (pconnector.SpecifierSpecifyResponse, error)) *SpecifierPluginSpecifyCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SpecifierPluginSpecifyCall) Return added in v0.11.0 

func (c *SpecifierPluginSpecifyCall) Return(arg0 pconnector.SpecifierSpecifyResponse, arg1 error) *SpecifierPluginSpecifyCall

Return rewrite *gomock.Call.Return

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.