mock

package
v0.13.0-nightly.20241221 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

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 AuthManager added in v0.12.3 

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

AuthManager is a mock of authManager interface.

func NewAuthManager added in v0.12.3 

func NewAuthManager(ctrl *gomock.Controller) *AuthManager

NewAuthManager creates a new mock instance.

func (*AuthManager) Deregister added in v0.12.3 

func (m *AuthManager) Deregister(token string)

Deregister mocks base method.

func (*AuthManager) EXPECT added in v0.12.3 

func (m *AuthManager) EXPECT() *AuthManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*AuthManager) GenerateNew added in v0.12.3 

func (m *AuthManager) GenerateNew(connectorID string) string

GenerateNew mocks base method.

type AuthManagerDeregisterCall added in v0.12.3 

type AuthManagerDeregisterCall struct {
	*gomock.Call
}

AuthManagerDeregisterCall wrap *gomock.Call

func (*AuthManagerDeregisterCall) Do added in v0.12.3 

func (c *AuthManagerDeregisterCall) Do(f func(string)) *AuthManagerDeregisterCall

Do rewrite *gomock.Call.Do

func (*AuthManagerDeregisterCall) DoAndReturn added in v0.12.3 

func (c *AuthManagerDeregisterCall) DoAndReturn(f func(string)) *AuthManagerDeregisterCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AuthManagerDeregisterCall) Return added in v0.12.3 

func (c *AuthManagerDeregisterCall) Return() *AuthManagerDeregisterCall

Return rewrite *gomock.Call.Return

type AuthManagerGenerateNewCall added in v0.12.3 

type AuthManagerGenerateNewCall struct {
	*gomock.Call
}

AuthManagerGenerateNewCall wrap *gomock.Call

func (*AuthManagerGenerateNewCall) Do added in v0.12.3 

func (c *AuthManagerGenerateNewCall) Do(f func(string) string) *AuthManagerGenerateNewCall

Do rewrite *gomock.Call.Do

func (*AuthManagerGenerateNewCall) DoAndReturn added in v0.12.3 

func (c *AuthManagerGenerateNewCall) DoAndReturn(f func(string) string) *AuthManagerGenerateNewCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AuthManagerGenerateNewCall) Return added in v0.12.3 

func (c *AuthManagerGenerateNewCall) Return(arg0 string) *AuthManagerGenerateNewCall

Return rewrite *gomock.Call.Return

type AuthManagerMockRecorder added in v0.12.3 

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

AuthManagerMockRecorder is the mock recorder for AuthManager.

func (*AuthManagerMockRecorder) Deregister added in v0.12.3 

func (mr *AuthManagerMockRecorder) Deregister(token any) *AuthManagerDeregisterCall

Deregister indicates an expected call of Deregister.

func (*AuthManagerMockRecorder) GenerateNew added in v0.12.3 

func (mr *AuthManagerMockRecorder) GenerateNew(connectorID any) *AuthManagerGenerateNewCall

GenerateNew indicates an expected call of GenerateNew.

type BuiltinReg added in v0.12.3 

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

BuiltinReg is a mock of builtinReg interface.

func NewBuiltinReg added in v0.12.3 

func NewBuiltinReg(ctrl *gomock.Controller) *BuiltinReg

NewBuiltinReg creates a new mock instance.

func (*BuiltinReg) EXPECT added in v0.12.3 

func (m *BuiltinReg) EXPECT() *BuiltinRegMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*BuiltinReg) Init added in v0.12.3 

func (m *BuiltinReg) Init(arg0 context.Context)

Init mocks base method.

func (*BuiltinReg) List added in v0.12.3 

func (m *BuiltinReg) List() map[plugin.FullName]pconnector.Specification

List mocks base method.

func (*BuiltinReg) NewDispenser added in v0.12.3 

func (m *BuiltinReg) NewDispenser(logger log.CtxLogger, name plugin.FullName, cfg pconnector.PluginConfig) (connector.Dispenser, error)

NewDispenser mocks base method.

type BuiltinRegInitCall added in v0.12.3 

type BuiltinRegInitCall struct {
	*gomock.Call
}

BuiltinRegInitCall wrap *gomock.Call

func (*BuiltinRegInitCall) Do added in v0.12.3 

func (c *BuiltinRegInitCall) Do(f func(context.Context)) *BuiltinRegInitCall

Do rewrite *gomock.Call.Do

func (*BuiltinRegInitCall) DoAndReturn added in v0.12.3 

func (c *BuiltinRegInitCall) DoAndReturn(f func(context.Context)) *BuiltinRegInitCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*BuiltinRegInitCall) Return added in v0.12.3 

func (c *BuiltinRegInitCall) Return() *BuiltinRegInitCall

Return rewrite *gomock.Call.Return

type BuiltinRegListCall added in v0.12.3 

type BuiltinRegListCall struct {
	*gomock.Call
}

BuiltinRegListCall wrap *gomock.Call

func (*BuiltinRegListCall) Do added in v0.12.3 

func (c *BuiltinRegListCall) Do(f func() map[plugin.FullName]pconnector.Specification) *BuiltinRegListCall

Do rewrite *gomock.Call.Do

func (*BuiltinRegListCall) DoAndReturn added in v0.12.3 

func (c *BuiltinRegListCall) DoAndReturn(f func() map[plugin.FullName]pconnector.Specification) *BuiltinRegListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*BuiltinRegListCall) Return added in v0.12.3 

func (c *BuiltinRegListCall) Return(arg0 map[plugin.FullName]pconnector.Specification) *BuiltinRegListCall

Return rewrite *gomock.Call.Return

type BuiltinRegMockRecorder added in v0.12.3 

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

BuiltinRegMockRecorder is the mock recorder for BuiltinReg.

func (*BuiltinRegMockRecorder) Init added in v0.12.3 

func (mr *BuiltinRegMockRecorder) Init(arg0 any) *BuiltinRegInitCall

Init indicates an expected call of Init.

func (*BuiltinRegMockRecorder) List added in v0.12.3 

func (mr *BuiltinRegMockRecorder) List() *BuiltinRegListCall

List indicates an expected call of List.

func (*BuiltinRegMockRecorder) NewDispenser added in v0.12.3 

func (mr *BuiltinRegMockRecorder) NewDispenser(logger, name, cfg any) *BuiltinRegNewDispenserCall

NewDispenser indicates an expected call of NewDispenser.

type BuiltinRegNewDispenserCall added in v0.12.3 

type BuiltinRegNewDispenserCall struct {
	*gomock.Call
}

BuiltinRegNewDispenserCall wrap *gomock.Call

func (*BuiltinRegNewDispenserCall) Do added in v0.12.3 

func (c *BuiltinRegNewDispenserCall) Do(f func(log.CtxLogger, plugin.FullName, pconnector.PluginConfig) (connector.Dispenser, error)) *BuiltinRegNewDispenserCall

Do rewrite *gomock.Call.Do

func (*BuiltinRegNewDispenserCall) DoAndReturn added in v0.12.3 

func (c *BuiltinRegNewDispenserCall) DoAndReturn(f func(log.CtxLogger, plugin.FullName, pconnector.PluginConfig) (connector.Dispenser, error)) *BuiltinRegNewDispenserCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*BuiltinRegNewDispenserCall) Return added in v0.12.3 

func (c *BuiltinRegNewDispenserCall) Return(arg0 connector.Dispenser, arg1 error) *BuiltinRegNewDispenserCall

Return rewrite *gomock.Call.Return

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 Mockregistry added in v0.12.3 

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

Mockregistry is a mock of registry interface.

func NewMockregistry added in v0.12.3 

func NewMockregistry(ctrl *gomock.Controller) *Mockregistry

NewMockregistry creates a new mock instance.

func (*Mockregistry) EXPECT added in v0.12.3 

func (m *Mockregistry) EXPECT() *MockregistryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*Mockregistry) List added in v0.12.3 

func (m *Mockregistry) List() map[plugin.FullName]pconnector.Specification

List mocks base method.

func (*Mockregistry) NewDispenser added in v0.12.3 

func (m *Mockregistry) NewDispenser(logger log.CtxLogger, name plugin.FullName, cfg pconnector.PluginConfig) (connector.Dispenser, error)

NewDispenser mocks base method.

type MockregistryListCall added in v0.12.3 

type MockregistryListCall struct {
	*gomock.Call
}

MockregistryListCall wrap *gomock.Call

func (*MockregistryListCall) Do added in v0.12.3 

func (c *MockregistryListCall) Do(f func() map[plugin.FullName]pconnector.Specification) *MockregistryListCall

Do rewrite *gomock.Call.Do

func (*MockregistryListCall) DoAndReturn added in v0.12.3 

func (c *MockregistryListCall) DoAndReturn(f func() map[plugin.FullName]pconnector.Specification) *MockregistryListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockregistryListCall) Return added in v0.12.3 

func (c *MockregistryListCall) Return(arg0 map[plugin.FullName]pconnector.Specification) *MockregistryListCall

Return rewrite *gomock.Call.Return

type MockregistryMockRecorder added in v0.12.3 

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

MockregistryMockRecorder is the mock recorder for Mockregistry.

func (*MockregistryMockRecorder) List added in v0.12.3 

func (mr *MockregistryMockRecorder) List() *MockregistryListCall

List indicates an expected call of List.

func (*MockregistryMockRecorder) NewDispenser added in v0.12.3 

func (mr *MockregistryMockRecorder) NewDispenser(logger, name, cfg any) *MockregistryNewDispenserCall

NewDispenser indicates an expected call of NewDispenser.

type MockregistryNewDispenserCall added in v0.12.3 

type MockregistryNewDispenserCall struct {
	*gomock.Call
}

MockregistryNewDispenserCall wrap *gomock.Call

func (*MockregistryNewDispenserCall) Do added in v0.12.3 

func (c *MockregistryNewDispenserCall) Do(f func(log.CtxLogger, plugin.FullName, pconnector.PluginConfig) (connector.Dispenser, error)) *MockregistryNewDispenserCall

Do rewrite *gomock.Call.Do

func (*MockregistryNewDispenserCall) DoAndReturn added in v0.12.3 

func (c *MockregistryNewDispenserCall) DoAndReturn(f func(log.CtxLogger, plugin.FullName, pconnector.PluginConfig) (connector.Dispenser, error)) *MockregistryNewDispenserCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockregistryNewDispenserCall) Return added in v0.12.3 

func (c *MockregistryNewDispenserCall) Return(arg0 connector.Dispenser, arg1 error) *MockregistryNewDispenserCall

Return rewrite *gomock.Call.Return

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

type StandaloneReg added in v0.12.3 

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

StandaloneReg is a mock of standaloneReg interface.

func NewStandaloneReg added in v0.12.3 

func NewStandaloneReg(ctrl *gomock.Controller) *StandaloneReg

NewStandaloneReg creates a new mock instance.

func (*StandaloneReg) EXPECT added in v0.12.3 

func (m *StandaloneReg) EXPECT() *StandaloneRegMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*StandaloneReg) Init added in v0.12.3 

func (m *StandaloneReg) Init(ctx context.Context, connUtilsAddr string)

Init mocks base method.

func (*StandaloneReg) List added in v0.12.3 

func (m *StandaloneReg) List() map[plugin.FullName]pconnector.Specification

List mocks base method.

func (*StandaloneReg) NewDispenser added in v0.12.3 

func (m *StandaloneReg) NewDispenser(logger log.CtxLogger, name plugin.FullName, cfg pconnector.PluginConfig) (connector.Dispenser, error)

NewDispenser mocks base method.

type StandaloneRegInitCall added in v0.12.3 

type StandaloneRegInitCall struct {
	*gomock.Call
}

StandaloneRegInitCall wrap *gomock.Call

func (*StandaloneRegInitCall) Do added in v0.12.3 

func (c *StandaloneRegInitCall) Do(f func(context.Context, string)) *StandaloneRegInitCall

Do rewrite *gomock.Call.Do

func (*StandaloneRegInitCall) DoAndReturn added in v0.12.3 

func (c *StandaloneRegInitCall) DoAndReturn(f func(context.Context, string)) *StandaloneRegInitCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*StandaloneRegInitCall) Return added in v0.12.3 

func (c *StandaloneRegInitCall) Return() *StandaloneRegInitCall

Return rewrite *gomock.Call.Return

type StandaloneRegListCall added in v0.12.3 

type StandaloneRegListCall struct {
	*gomock.Call
}

StandaloneRegListCall wrap *gomock.Call

func (*StandaloneRegListCall) Do added in v0.12.3 

func (c *StandaloneRegListCall) Do(f func() map[plugin.FullName]pconnector.Specification) *StandaloneRegListCall

Do rewrite *gomock.Call.Do

func (*StandaloneRegListCall) DoAndReturn added in v0.12.3 

func (c *StandaloneRegListCall) DoAndReturn(f func() map[plugin.FullName]pconnector.Specification) *StandaloneRegListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*StandaloneRegListCall) Return added in v0.12.3 

func (c *StandaloneRegListCall) Return(arg0 map[plugin.FullName]pconnector.Specification) *StandaloneRegListCall

Return rewrite *gomock.Call.Return

type StandaloneRegMockRecorder added in v0.12.3 

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

StandaloneRegMockRecorder is the mock recorder for StandaloneReg.

func (*StandaloneRegMockRecorder) Init added in v0.12.3 

func (mr *StandaloneRegMockRecorder) Init(ctx, connUtilsAddr any) *StandaloneRegInitCall

Init indicates an expected call of Init.

func (*StandaloneRegMockRecorder) List added in v0.12.3 

func (mr *StandaloneRegMockRecorder) List() *StandaloneRegListCall

List indicates an expected call of List.

func (*StandaloneRegMockRecorder) NewDispenser added in v0.12.3 

func (mr *StandaloneRegMockRecorder) NewDispenser(logger, name, cfg any) *StandaloneRegNewDispenserCall

NewDispenser indicates an expected call of NewDispenser.

type StandaloneRegNewDispenserCall added in v0.12.3 

type StandaloneRegNewDispenserCall struct {
	*gomock.Call
}

StandaloneRegNewDispenserCall wrap *gomock.Call

func (*StandaloneRegNewDispenserCall) Do added in v0.12.3 

func (c *StandaloneRegNewDispenserCall) Do(f func(log.CtxLogger, plugin.FullName, pconnector.PluginConfig) (connector.Dispenser, error)) *StandaloneRegNewDispenserCall

Do rewrite *gomock.Call.Do

func (*StandaloneRegNewDispenserCall) DoAndReturn added in v0.12.3 

func (c *StandaloneRegNewDispenserCall) DoAndReturn(f func(log.CtxLogger, plugin.FullName, pconnector.PluginConfig) (connector.Dispenser, error)) *StandaloneRegNewDispenserCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*StandaloneRegNewDispenserCall) Return added in v0.12.3 

func (c *StandaloneRegNewDispenserCall) Return(arg0 connector.Dispenser, arg1 error) *StandaloneRegNewDispenserCall

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.