mock

package
v0.13.0-nightly.20241019 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2024 License: Apache-2.0 Imports: 8 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 ConnectorPluginService added in v0.9.0 

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

ConnectorPluginService is a mock of ConnectorPluginService interface.

func NewConnectorPluginService added in v0.9.0 

func NewConnectorPluginService(ctrl *gomock.Controller) *ConnectorPluginService

NewConnectorPluginService creates a new mock instance.

func (*ConnectorPluginService) EXPECT added in v0.9.0 

func (m *ConnectorPluginService) EXPECT() *ConnectorPluginServiceMockRecorder

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

func (*ConnectorPluginService) NewDispenser added in v0.9.0 

func (m *ConnectorPluginService) NewDispenser(ctx log.CtxLogger, name, connectorID string) (connector0.Dispenser, error)

NewDispenser mocks base method.

type ConnectorPluginServiceMockRecorder added in v0.9.0 

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

ConnectorPluginServiceMockRecorder is the mock recorder for ConnectorPluginService.

func (*ConnectorPluginServiceMockRecorder) NewDispenser added in v0.9.0 

func (mr *ConnectorPluginServiceMockRecorder) NewDispenser(ctx, name, connectorID any) *ConnectorPluginServiceNewDispenserCall

NewDispenser indicates an expected call of NewDispenser.

type ConnectorPluginServiceNewDispenserCall added in v0.11.0 

type ConnectorPluginServiceNewDispenserCall struct {
	*gomock.Call
}

ConnectorPluginServiceNewDispenserCall wrap *gomock.Call

func (*ConnectorPluginServiceNewDispenserCall) Do added in v0.11.0 

func (c *ConnectorPluginServiceNewDispenserCall) Do(f func(log.CtxLogger, string, string) (connector0.Dispenser, error)) *ConnectorPluginServiceNewDispenserCall

Do rewrite *gomock.Call.Do

func (*ConnectorPluginServiceNewDispenserCall) DoAndReturn added in v0.11.0 

func (c *ConnectorPluginServiceNewDispenserCall) DoAndReturn(f func(log.CtxLogger, string, string) (connector0.Dispenser, error)) *ConnectorPluginServiceNewDispenserCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorPluginServiceNewDispenserCall) Return added in v0.11.0 

func (c *ConnectorPluginServiceNewDispenserCall) Return(arg0 connector0.Dispenser, arg1 error) *ConnectorPluginServiceNewDispenserCall

Return rewrite *gomock.Call.Return

type ConnectorService 

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

ConnectorService is a mock of ConnectorService interface.

func NewConnectorService 

func NewConnectorService(ctrl *gomock.Controller) *ConnectorService

NewConnectorService creates a new mock instance.

func (*ConnectorService) AddProcessor 

func (m *ConnectorService) AddProcessor(ctx context.Context, connectorID, processorID string) (*connector.Instance, error)

AddProcessor mocks base method.

func (*ConnectorService) Create 

func (m *ConnectorService) Create(ctx context.Context, id string, t connector.Type, plugin, pipelineID string, c connector.Config, p connector.ProvisionType) (*connector.Instance, error)

Create mocks base method.

func (*ConnectorService) Delete 

func (m *ConnectorService) Delete(ctx context.Context, id string, dispenserFetcher connector.PluginDispenserFetcher) error

Delete mocks base method.

func (*ConnectorService) EXPECT 

func (m *ConnectorService) EXPECT() *ConnectorServiceMockRecorder

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

func (*ConnectorService) Get 

func (m *ConnectorService) Get(ctx context.Context, id string) (*connector.Instance, error)

Get mocks base method.

func (*ConnectorService) RemoveProcessor 

func (m *ConnectorService) RemoveProcessor(ctx context.Context, connectorID, processorID string) (*connector.Instance, error)

RemoveProcessor mocks base method.

func (*ConnectorService) Update added in v0.6.0 

func (m *ConnectorService) Update(ctx context.Context, id string, c connector.Config) (*connector.Instance, error)

Update mocks base method.

type ConnectorServiceAddProcessorCall added in v0.11.0 

type ConnectorServiceAddProcessorCall struct {
	*gomock.Call
}

ConnectorServiceAddProcessorCall wrap *gomock.Call

func (*ConnectorServiceAddProcessorCall) Do added in v0.11.0 

func (c *ConnectorServiceAddProcessorCall) Do(f func(context.Context, string, string) (*connector.Instance, error)) *ConnectorServiceAddProcessorCall

Do rewrite *gomock.Call.Do

func (*ConnectorServiceAddProcessorCall) DoAndReturn added in v0.11.0 

func (c *ConnectorServiceAddProcessorCall) DoAndReturn(f func(context.Context, string, string) (*connector.Instance, error)) *ConnectorServiceAddProcessorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorServiceAddProcessorCall) Return added in v0.11.0 

func (c *ConnectorServiceAddProcessorCall) Return(arg0 *connector.Instance, arg1 error) *ConnectorServiceAddProcessorCall

Return rewrite *gomock.Call.Return

type ConnectorServiceCreateCall added in v0.11.0 

type ConnectorServiceCreateCall struct {
	*gomock.Call
}

ConnectorServiceCreateCall wrap *gomock.Call

func (*ConnectorServiceCreateCall) Do added in v0.11.0 

func (c_2 *ConnectorServiceCreateCall) Do(f func(context.Context, string, connector.Type, string, string, connector.Config, connector.ProvisionType) (*connector.Instance, error)) *ConnectorServiceCreateCall

Do rewrite *gomock.Call.Do

func (*ConnectorServiceCreateCall) DoAndReturn added in v0.11.0 

func (c_2 *ConnectorServiceCreateCall) DoAndReturn(f func(context.Context, string, connector.Type, string, string, connector.Config, connector.ProvisionType) (*connector.Instance, error)) *ConnectorServiceCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorServiceCreateCall) Return added in v0.11.0 

func (c_2 *ConnectorServiceCreateCall) Return(arg0 *connector.Instance, arg1 error) *ConnectorServiceCreateCall

Return rewrite *gomock.Call.Return

type ConnectorServiceDeleteCall added in v0.11.0 

type ConnectorServiceDeleteCall struct {
	*gomock.Call
}

ConnectorServiceDeleteCall wrap *gomock.Call

func (*ConnectorServiceDeleteCall) Do added in v0.11.0 

func (c *ConnectorServiceDeleteCall) Do(f func(context.Context, string, connector.PluginDispenserFetcher) error) *ConnectorServiceDeleteCall

Do rewrite *gomock.Call.Do

func (*ConnectorServiceDeleteCall) DoAndReturn added in v0.11.0 

func (c *ConnectorServiceDeleteCall) DoAndReturn(f func(context.Context, string, connector.PluginDispenserFetcher) error) *ConnectorServiceDeleteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorServiceDeleteCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ConnectorServiceGetCall added in v0.11.0 

type ConnectorServiceGetCall struct {
	*gomock.Call
}

ConnectorServiceGetCall wrap *gomock.Call

func (*ConnectorServiceGetCall) Do added in v0.11.0 

func (c *ConnectorServiceGetCall) Do(f func(context.Context, string) (*connector.Instance, error)) *ConnectorServiceGetCall

Do rewrite *gomock.Call.Do

func (*ConnectorServiceGetCall) DoAndReturn added in v0.11.0 

func (c *ConnectorServiceGetCall) DoAndReturn(f func(context.Context, string) (*connector.Instance, error)) *ConnectorServiceGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorServiceGetCall) Return added in v0.11.0 

func (c *ConnectorServiceGetCall) Return(arg0 *connector.Instance, arg1 error) *ConnectorServiceGetCall

Return rewrite *gomock.Call.Return

type ConnectorServiceMockRecorder 

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

ConnectorServiceMockRecorder is the mock recorder for ConnectorService.

func (*ConnectorServiceMockRecorder) AddProcessor 

func (mr *ConnectorServiceMockRecorder) AddProcessor(ctx, connectorID, processorID any) *ConnectorServiceAddProcessorCall

AddProcessor indicates an expected call of AddProcessor.

func (*ConnectorServiceMockRecorder) Create 

func (mr *ConnectorServiceMockRecorder) Create(ctx, id, t, plugin, pipelineID, c, p any) *ConnectorServiceCreateCall

Create indicates an expected call of Create.

func (*ConnectorServiceMockRecorder) CreateWithInstance added in v0.6.0 

func (mr *ConnectorServiceMockRecorder) CreateWithInstance(ctx interface{}, instance *connector.Instance) *ConnectorServiceCreateCall

CreateWithInstance is a utility function that lets you declare an expected call to Create with arguments taken from the supplied instance.

func (*ConnectorServiceMockRecorder) Delete 

func (mr *ConnectorServiceMockRecorder) Delete(ctx, id, dispenserFetcher any) *ConnectorServiceDeleteCall

Delete indicates an expected call of Delete.

func (*ConnectorServiceMockRecorder) Get 

func (mr *ConnectorServiceMockRecorder) Get(ctx, id any) *ConnectorServiceGetCall

Get indicates an expected call of Get.

func (*ConnectorServiceMockRecorder) RemoveProcessor 

func (mr *ConnectorServiceMockRecorder) RemoveProcessor(ctx, connectorID, processorID any) *ConnectorServiceRemoveProcessorCall

RemoveProcessor indicates an expected call of RemoveProcessor.

func (*ConnectorServiceMockRecorder) Update added in v0.6.0 

func (mr *ConnectorServiceMockRecorder) Update(ctx, id, c any) *ConnectorServiceUpdateCall

Update indicates an expected call of Update.

type ConnectorServiceRemoveProcessorCall added in v0.11.0 

type ConnectorServiceRemoveProcessorCall struct {
	*gomock.Call
}

ConnectorServiceRemoveProcessorCall wrap *gomock.Call

func (*ConnectorServiceRemoveProcessorCall) Do added in v0.11.0 

func (c *ConnectorServiceRemoveProcessorCall) Do(f func(context.Context, string, string) (*connector.Instance, error)) *ConnectorServiceRemoveProcessorCall

Do rewrite *gomock.Call.Do

func (*ConnectorServiceRemoveProcessorCall) DoAndReturn added in v0.11.0 

func (c *ConnectorServiceRemoveProcessorCall) DoAndReturn(f func(context.Context, string, string) (*connector.Instance, error)) *ConnectorServiceRemoveProcessorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorServiceRemoveProcessorCall) Return added in v0.11.0 

func (c *ConnectorServiceRemoveProcessorCall) Return(arg0 *connector.Instance, arg1 error) *ConnectorServiceRemoveProcessorCall

Return rewrite *gomock.Call.Return

type ConnectorServiceUpdateCall added in v0.11.0 

type ConnectorServiceUpdateCall struct {
	*gomock.Call
}

ConnectorServiceUpdateCall wrap *gomock.Call

func (*ConnectorServiceUpdateCall) Do added in v0.11.0 

func (c_2 *ConnectorServiceUpdateCall) Do(f func(context.Context, string, connector.Config) (*connector.Instance, error)) *ConnectorServiceUpdateCall

Do rewrite *gomock.Call.Do

func (*ConnectorServiceUpdateCall) DoAndReturn added in v0.11.0 

func (c_2 *ConnectorServiceUpdateCall) DoAndReturn(f func(context.Context, string, connector.Config) (*connector.Instance, error)) *ConnectorServiceUpdateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorServiceUpdateCall) Return added in v0.11.0 

func (c_2 *ConnectorServiceUpdateCall) Return(arg0 *connector.Instance, arg1 error) *ConnectorServiceUpdateCall

Return rewrite *gomock.Call.Return

type LifecycleService added in v0.12.0 

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

LifecycleService is a mock of LifecycleService interface.

func NewLifecycleService added in v0.12.0 

func NewLifecycleService(ctrl *gomock.Controller) *LifecycleService

NewLifecycleService creates a new mock instance.

func (*LifecycleService) EXPECT added in v0.12.0 

func (m *LifecycleService) EXPECT() *LifecycleServiceMockRecorder

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

func (*LifecycleService) Start added in v0.12.0 

func (m *LifecycleService) Start(ctx context.Context, pipelineID string) error

Start mocks base method.

func (*LifecycleService) Stop added in v0.12.0 

func (m *LifecycleService) Stop(ctx context.Context, pipelineID string, force bool) error

Stop mocks base method.

type LifecycleServiceMockRecorder added in v0.12.0 

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

LifecycleServiceMockRecorder is the mock recorder for LifecycleService.

func (*LifecycleServiceMockRecorder) Start added in v0.12.0 

func (mr *LifecycleServiceMockRecorder) Start(ctx, pipelineID any) *LifecycleServiceStartCall

Start indicates an expected call of Start.

func (*LifecycleServiceMockRecorder) Stop added in v0.12.0 

func (mr *LifecycleServiceMockRecorder) Stop(ctx, pipelineID, force any) *LifecycleServiceStopCall

Stop indicates an expected call of Stop.

type LifecycleServiceStartCall added in v0.12.0 

type LifecycleServiceStartCall struct {
	*gomock.Call
}

LifecycleServiceStartCall wrap *gomock.Call

func (*LifecycleServiceStartCall) Do added in v0.12.0 

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

Do rewrite *gomock.Call.Do

func (*LifecycleServiceStartCall) DoAndReturn added in v0.12.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*LifecycleServiceStartCall) Return added in v0.12.0 

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

Return rewrite *gomock.Call.Return

type LifecycleServiceStopCall added in v0.12.0 

type LifecycleServiceStopCall struct {
	*gomock.Call
}

LifecycleServiceStopCall wrap *gomock.Call

func (*LifecycleServiceStopCall) Do added in v0.12.0 

func (c *LifecycleServiceStopCall) Do(f func(context.Context, string, bool) error) *LifecycleServiceStopCall

Do rewrite *gomock.Call.Do

func (*LifecycleServiceStopCall) DoAndReturn added in v0.12.0 

func (c *LifecycleServiceStopCall) DoAndReturn(f func(context.Context, string, bool) error) *LifecycleServiceStopCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*LifecycleServiceStopCall) Return added in v0.12.0 

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

Return rewrite *gomock.Call.Return

type PipelineService 

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

PipelineService is a mock of PipelineService interface.

func NewPipelineService 

func NewPipelineService(ctrl *gomock.Controller) *PipelineService

NewPipelineService creates a new mock instance.

func (*PipelineService) AddConnector 

func (m *PipelineService) AddConnector(ctx context.Context, pipelineID, connectorID string) (*pipeline.Instance, error)

AddConnector mocks base method.

func (*PipelineService) AddProcessor 

func (m *PipelineService) AddProcessor(ctx context.Context, pipelineID, processorID string) (*pipeline.Instance, error)

AddProcessor mocks base method.

func (*PipelineService) Create 

func (m *PipelineService) Create(ctx context.Context, id string, cfg pipeline.Config, p pipeline.ProvisionType) (*pipeline.Instance, error)

Create mocks base method.

func (*PipelineService) Delete 

func (m *PipelineService) Delete(ctx context.Context, pipelineID string) error

Delete mocks base method.

func (*PipelineService) EXPECT 

func (m *PipelineService) EXPECT() *PipelineServiceMockRecorder

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

func (*PipelineService) Get 

func (m *PipelineService) Get(ctx context.Context, id string) (*pipeline.Instance, error)

Get mocks base method.

func (*PipelineService) List 

func (m *PipelineService) List(ctx context.Context) map[string]*pipeline.Instance

List mocks base method.

func (*PipelineService) RemoveConnector 

func (m *PipelineService) RemoveConnector(ctx context.Context, pipelineID, connectorID string) (*pipeline.Instance, error)

RemoveConnector mocks base method.

func (*PipelineService) RemoveProcessor 

func (m *PipelineService) RemoveProcessor(ctx context.Context, pipelineID, processorID string) (*pipeline.Instance, error)

RemoveProcessor mocks base method.

func (*PipelineService) Update added in v0.6.0 

func (m *PipelineService) Update(ctx context.Context, pipelineID string, cfg pipeline.Config) (*pipeline.Instance, error)

Update mocks base method.

func (*PipelineService) UpdateDLQ added in v0.4.0 

func (m *PipelineService) UpdateDLQ(ctx context.Context, pipelineID string, cfg pipeline.DLQ) (*pipeline.Instance, error)

UpdateDLQ mocks base method.

type PipelineServiceAddConnectorCall added in v0.11.0 

type PipelineServiceAddConnectorCall struct {
	*gomock.Call
}

PipelineServiceAddConnectorCall wrap *gomock.Call

func (*PipelineServiceAddConnectorCall) Do added in v0.11.0 

func (c *PipelineServiceAddConnectorCall) Do(f func(context.Context, string, string) (*pipeline.Instance, error)) *PipelineServiceAddConnectorCall

Do rewrite *gomock.Call.Do

func (*PipelineServiceAddConnectorCall) DoAndReturn added in v0.11.0 

func (c *PipelineServiceAddConnectorCall) DoAndReturn(f func(context.Context, string, string) (*pipeline.Instance, error)) *PipelineServiceAddConnectorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceAddConnectorCall) Return added in v0.11.0 

func (c *PipelineServiceAddConnectorCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineServiceAddConnectorCall

Return rewrite *gomock.Call.Return

type PipelineServiceAddProcessorCall added in v0.11.0 

type PipelineServiceAddProcessorCall struct {
	*gomock.Call
}

PipelineServiceAddProcessorCall wrap *gomock.Call

func (*PipelineServiceAddProcessorCall) Do added in v0.11.0 

func (c *PipelineServiceAddProcessorCall) Do(f func(context.Context, string, string) (*pipeline.Instance, error)) *PipelineServiceAddProcessorCall

Do rewrite *gomock.Call.Do

func (*PipelineServiceAddProcessorCall) DoAndReturn added in v0.11.0 

func (c *PipelineServiceAddProcessorCall) DoAndReturn(f func(context.Context, string, string) (*pipeline.Instance, error)) *PipelineServiceAddProcessorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceAddProcessorCall) Return added in v0.11.0 

func (c *PipelineServiceAddProcessorCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineServiceAddProcessorCall

Return rewrite *gomock.Call.Return

type PipelineServiceCreateCall added in v0.11.0 

type PipelineServiceCreateCall struct {
	*gomock.Call
}

PipelineServiceCreateCall wrap *gomock.Call

func (*PipelineServiceCreateCall) Do added in v0.11.0 

func (c *PipelineServiceCreateCall) Do(f func(context.Context, string, pipeline.Config, pipeline.ProvisionType) (*pipeline.Instance, error)) *PipelineServiceCreateCall

Do rewrite *gomock.Call.Do

func (*PipelineServiceCreateCall) DoAndReturn added in v0.11.0 

func (c *PipelineServiceCreateCall) DoAndReturn(f func(context.Context, string, pipeline.Config, pipeline.ProvisionType) (*pipeline.Instance, error)) *PipelineServiceCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceCreateCall) Return added in v0.11.0 

func (c *PipelineServiceCreateCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineServiceCreateCall

Return rewrite *gomock.Call.Return

type PipelineServiceDeleteCall added in v0.11.0 

type PipelineServiceDeleteCall struct {
	*gomock.Call
}

PipelineServiceDeleteCall wrap *gomock.Call

func (*PipelineServiceDeleteCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*PipelineServiceDeleteCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceDeleteCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type PipelineServiceGetCall added in v0.11.0 

type PipelineServiceGetCall struct {
	*gomock.Call
}

PipelineServiceGetCall wrap *gomock.Call

func (*PipelineServiceGetCall) Do added in v0.11.0 

func (c *PipelineServiceGetCall) Do(f func(context.Context, string) (*pipeline.Instance, error)) *PipelineServiceGetCall

Do rewrite *gomock.Call.Do

func (*PipelineServiceGetCall) DoAndReturn added in v0.11.0 

func (c *PipelineServiceGetCall) DoAndReturn(f func(context.Context, string) (*pipeline.Instance, error)) *PipelineServiceGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceGetCall) Return added in v0.11.0 

func (c *PipelineServiceGetCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineServiceGetCall

Return rewrite *gomock.Call.Return

type PipelineServiceListCall added in v0.11.0 

type PipelineServiceListCall struct {
	*gomock.Call
}

PipelineServiceListCall wrap *gomock.Call

func (*PipelineServiceListCall) Do added in v0.11.0 

func (c *PipelineServiceListCall) Do(f func(context.Context) map[string]*pipeline.Instance) *PipelineServiceListCall

Do rewrite *gomock.Call.Do

func (*PipelineServiceListCall) DoAndReturn added in v0.11.0 

func (c *PipelineServiceListCall) DoAndReturn(f func(context.Context) map[string]*pipeline.Instance) *PipelineServiceListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceListCall) Return added in v0.11.0 

func (c *PipelineServiceListCall) Return(arg0 map[string]*pipeline.Instance) *PipelineServiceListCall

Return rewrite *gomock.Call.Return

type PipelineServiceMockRecorder 

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

PipelineServiceMockRecorder is the mock recorder for PipelineService.

func (*PipelineServiceMockRecorder) AddConnector 

func (mr *PipelineServiceMockRecorder) AddConnector(ctx, pipelineID, connectorID any) *PipelineServiceAddConnectorCall

AddConnector indicates an expected call of AddConnector.

func (*PipelineServiceMockRecorder) AddProcessor 

func (mr *PipelineServiceMockRecorder) AddProcessor(ctx, pipelineID, processorID any) *PipelineServiceAddProcessorCall

AddProcessor indicates an expected call of AddProcessor.

func (*PipelineServiceMockRecorder) Create 

func (mr *PipelineServiceMockRecorder) Create(ctx, id, cfg, p any) *PipelineServiceCreateCall

Create indicates an expected call of Create.

func (*PipelineServiceMockRecorder) CreateWithInstance added in v0.6.0 

func (mr *PipelineServiceMockRecorder) CreateWithInstance(ctx interface{}, instance *pipeline.Instance) *PipelineServiceCreateCall

CreateWithInstance is a utility function that lets you declare an expected call to Create with arguments taken from the supplied instance.

func (*PipelineServiceMockRecorder) Delete 

func (mr *PipelineServiceMockRecorder) Delete(ctx, pipelineID any) *PipelineServiceDeleteCall

Delete indicates an expected call of Delete.

func (*PipelineServiceMockRecorder) Get 

func (mr *PipelineServiceMockRecorder) Get(ctx, id any) *PipelineServiceGetCall

Get indicates an expected call of Get.

func (*PipelineServiceMockRecorder) List 

func (mr *PipelineServiceMockRecorder) List(ctx any) *PipelineServiceListCall

List indicates an expected call of List.

func (*PipelineServiceMockRecorder) RemoveConnector 

func (mr *PipelineServiceMockRecorder) RemoveConnector(ctx, pipelineID, connectorID any) *PipelineServiceRemoveConnectorCall

RemoveConnector indicates an expected call of RemoveConnector.

func (*PipelineServiceMockRecorder) RemoveProcessor 

func (mr *PipelineServiceMockRecorder) RemoveProcessor(ctx, pipelineID, processorID any) *PipelineServiceRemoveProcessorCall

RemoveProcessor indicates an expected call of RemoveProcessor.

func (*PipelineServiceMockRecorder) Update added in v0.6.0 

func (mr *PipelineServiceMockRecorder) Update(ctx, pipelineID, cfg any) *PipelineServiceUpdateCall

Update indicates an expected call of Update.

func (*PipelineServiceMockRecorder) UpdateDLQ added in v0.4.0 

func (mr *PipelineServiceMockRecorder) UpdateDLQ(ctx, pipelineID, cfg any) *PipelineServiceUpdateDLQCall

UpdateDLQ indicates an expected call of UpdateDLQ.

type PipelineServiceRemoveConnectorCall added in v0.11.0 

type PipelineServiceRemoveConnectorCall struct {
	*gomock.Call
}

PipelineServiceRemoveConnectorCall wrap *gomock.Call

func (*PipelineServiceRemoveConnectorCall) Do added in v0.11.0 

func (c *PipelineServiceRemoveConnectorCall) Do(f func(context.Context, string, string) (*pipeline.Instance, error)) *PipelineServiceRemoveConnectorCall

Do rewrite *gomock.Call.Do

func (*PipelineServiceRemoveConnectorCall) DoAndReturn added in v0.11.0 

func (c *PipelineServiceRemoveConnectorCall) DoAndReturn(f func(context.Context, string, string) (*pipeline.Instance, error)) *PipelineServiceRemoveConnectorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceRemoveConnectorCall) Return added in v0.11.0 

func (c *PipelineServiceRemoveConnectorCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineServiceRemoveConnectorCall

Return rewrite *gomock.Call.Return

type PipelineServiceRemoveProcessorCall added in v0.11.0 

type PipelineServiceRemoveProcessorCall struct {
	*gomock.Call
}

PipelineServiceRemoveProcessorCall wrap *gomock.Call

func (*PipelineServiceRemoveProcessorCall) Do added in v0.11.0 

func (c *PipelineServiceRemoveProcessorCall) Do(f func(context.Context, string, string) (*pipeline.Instance, error)) *PipelineServiceRemoveProcessorCall

Do rewrite *gomock.Call.Do

func (*PipelineServiceRemoveProcessorCall) DoAndReturn added in v0.11.0 

func (c *PipelineServiceRemoveProcessorCall) DoAndReturn(f func(context.Context, string, string) (*pipeline.Instance, error)) *PipelineServiceRemoveProcessorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceRemoveProcessorCall) Return added in v0.11.0 

func (c *PipelineServiceRemoveProcessorCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineServiceRemoveProcessorCall

Return rewrite *gomock.Call.Return

type PipelineServiceUpdateCall added in v0.11.0 

type PipelineServiceUpdateCall struct {
	*gomock.Call
}

PipelineServiceUpdateCall wrap *gomock.Call

func (*PipelineServiceUpdateCall) Do added in v0.11.0 

func (c *PipelineServiceUpdateCall) Do(f func(context.Context, string, pipeline.Config) (*pipeline.Instance, error)) *PipelineServiceUpdateCall

Do rewrite *gomock.Call.Do

func (*PipelineServiceUpdateCall) DoAndReturn added in v0.11.0 

func (c *PipelineServiceUpdateCall) DoAndReturn(f func(context.Context, string, pipeline.Config) (*pipeline.Instance, error)) *PipelineServiceUpdateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceUpdateCall) Return added in v0.11.0 

func (c *PipelineServiceUpdateCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineServiceUpdateCall

Return rewrite *gomock.Call.Return

type PipelineServiceUpdateDLQCall added in v0.11.0 

type PipelineServiceUpdateDLQCall struct {
	*gomock.Call
}

PipelineServiceUpdateDLQCall wrap *gomock.Call

func (*PipelineServiceUpdateDLQCall) Do added in v0.11.0 

func (c *PipelineServiceUpdateDLQCall) Do(f func(context.Context, string, pipeline.DLQ) (*pipeline.Instance, error)) *PipelineServiceUpdateDLQCall

Do rewrite *gomock.Call.Do

func (*PipelineServiceUpdateDLQCall) DoAndReturn added in v0.11.0 

func (c *PipelineServiceUpdateDLQCall) DoAndReturn(f func(context.Context, string, pipeline.DLQ) (*pipeline.Instance, error)) *PipelineServiceUpdateDLQCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineServiceUpdateDLQCall) Return added in v0.11.0 

func (c *PipelineServiceUpdateDLQCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineServiceUpdateDLQCall

Return rewrite *gomock.Call.Return

type ProcessorService 

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

ProcessorService is a mock of ProcessorService interface.

func NewProcessorService 

func NewProcessorService(ctrl *gomock.Controller) *ProcessorService

NewProcessorService creates a new mock instance.

func (*ProcessorService) Create 

func (m *ProcessorService) Create(ctx context.Context, id, plugin string, parent processor.Parent, cfg processor.Config, p processor.ProvisionType, condition string) (*processor.Instance, error)

Create mocks base method.

func (*ProcessorService) Delete 

func (m *ProcessorService) Delete(ctx context.Context, id string) error

Delete mocks base method.

func (*ProcessorService) EXPECT 

func (m *ProcessorService) EXPECT() *ProcessorServiceMockRecorder

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

func (*ProcessorService) Get 

func (m *ProcessorService) Get(ctx context.Context, id string) (*processor.Instance, error)

Get mocks base method.

func (*ProcessorService) MakeRunnableProcessor added in v0.9.0 

func (m *ProcessorService) MakeRunnableProcessor(ctx context.Context, i *processor.Instance) (*processor.RunnableProcessor, error)

MakeRunnableProcessor mocks base method.

func (*ProcessorService) Update added in v0.6.0 

func (m *ProcessorService) Update(ctx context.Context, id string, cfg processor.Config) (*processor.Instance, error)

Update mocks base method.

type ProcessorServiceCreateCall added in v0.11.0 

type ProcessorServiceCreateCall struct {
	*gomock.Call
}

ProcessorServiceCreateCall wrap *gomock.Call

func (*ProcessorServiceCreateCall) Do added in v0.11.0 

func (c *ProcessorServiceCreateCall) Do(f func(context.Context, string, string, processor.Parent, processor.Config, processor.ProvisionType, string) (*processor.Instance, error)) *ProcessorServiceCreateCall

Do rewrite *gomock.Call.Do

func (*ProcessorServiceCreateCall) DoAndReturn added in v0.11.0 

func (c *ProcessorServiceCreateCall) DoAndReturn(f func(context.Context, string, string, processor.Parent, processor.Config, processor.ProvisionType, string) (*processor.Instance, error)) *ProcessorServiceCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorServiceCreateCall) Return added in v0.11.0 

func (c *ProcessorServiceCreateCall) Return(arg0 *processor.Instance, arg1 error) *ProcessorServiceCreateCall

Return rewrite *gomock.Call.Return

type ProcessorServiceDeleteCall added in v0.11.0 

type ProcessorServiceDeleteCall struct {
	*gomock.Call
}

ProcessorServiceDeleteCall wrap *gomock.Call

func (*ProcessorServiceDeleteCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorServiceDeleteCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorServiceDeleteCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorServiceGetCall added in v0.11.0 

type ProcessorServiceGetCall struct {
	*gomock.Call
}

ProcessorServiceGetCall wrap *gomock.Call

func (*ProcessorServiceGetCall) Do added in v0.11.0 

func (c *ProcessorServiceGetCall) Do(f func(context.Context, string) (*processor.Instance, error)) *ProcessorServiceGetCall

Do rewrite *gomock.Call.Do

func (*ProcessorServiceGetCall) DoAndReturn added in v0.11.0 

func (c *ProcessorServiceGetCall) DoAndReturn(f func(context.Context, string) (*processor.Instance, error)) *ProcessorServiceGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorServiceGetCall) Return added in v0.11.0 

func (c *ProcessorServiceGetCall) Return(arg0 *processor.Instance, arg1 error) *ProcessorServiceGetCall

Return rewrite *gomock.Call.Return

type ProcessorServiceMakeRunnableProcessorCall added in v0.11.0 

type ProcessorServiceMakeRunnableProcessorCall struct {
	*gomock.Call
}

ProcessorServiceMakeRunnableProcessorCall wrap *gomock.Call

func (*ProcessorServiceMakeRunnableProcessorCall) Do added in v0.11.0 

func (c *ProcessorServiceMakeRunnableProcessorCall) Do(f func(context.Context, *processor.Instance) (*processor.RunnableProcessor, error)) *ProcessorServiceMakeRunnableProcessorCall

Do rewrite *gomock.Call.Do

func (*ProcessorServiceMakeRunnableProcessorCall) DoAndReturn added in v0.11.0 

func (c *ProcessorServiceMakeRunnableProcessorCall) DoAndReturn(f func(context.Context, *processor.Instance) (*processor.RunnableProcessor, error)) *ProcessorServiceMakeRunnableProcessorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorServiceMakeRunnableProcessorCall) Return added in v0.11.0 

func (c *ProcessorServiceMakeRunnableProcessorCall) Return(arg0 *processor.RunnableProcessor, arg1 error) *ProcessorServiceMakeRunnableProcessorCall

Return rewrite *gomock.Call.Return

type ProcessorServiceMockRecorder 

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

ProcessorServiceMockRecorder is the mock recorder for ProcessorService.

func (*ProcessorServiceMockRecorder) Create 

func (mr *ProcessorServiceMockRecorder) Create(ctx, id, plugin, parent, cfg, p, condition any) *ProcessorServiceCreateCall

Create indicates an expected call of Create.

func (*ProcessorServiceMockRecorder) CreateWithInstance added in v0.6.0 

func (mr *ProcessorServiceMockRecorder) CreateWithInstance(ctx interface{}, instance *processor.Instance) *ProcessorServiceCreateCall

CreateWithInstance is a utility function that lets you declare an expected call to Create with arguments taken from the supplied instance.

func (*ProcessorServiceMockRecorder) Delete 

func (mr *ProcessorServiceMockRecorder) Delete(ctx, id any) *ProcessorServiceDeleteCall

Delete indicates an expected call of Delete.

func (*ProcessorServiceMockRecorder) Get 

func (mr *ProcessorServiceMockRecorder) Get(ctx, id any) *ProcessorServiceGetCall

Get indicates an expected call of Get.

func (*ProcessorServiceMockRecorder) MakeRunnableProcessor added in v0.9.0 

func (mr *ProcessorServiceMockRecorder) MakeRunnableProcessor(ctx, i any) *ProcessorServiceMakeRunnableProcessorCall

MakeRunnableProcessor indicates an expected call of MakeRunnableProcessor.

func (*ProcessorServiceMockRecorder) Update added in v0.6.0 

func (mr *ProcessorServiceMockRecorder) Update(ctx, id, cfg any) *ProcessorServiceUpdateCall

Update indicates an expected call of Update.

type ProcessorServiceUpdateCall added in v0.11.0 

type ProcessorServiceUpdateCall struct {
	*gomock.Call
}

ProcessorServiceUpdateCall wrap *gomock.Call

func (*ProcessorServiceUpdateCall) Do added in v0.11.0 

func (c *ProcessorServiceUpdateCall) Do(f func(context.Context, string, processor.Config) (*processor.Instance, error)) *ProcessorServiceUpdateCall

Do rewrite *gomock.Call.Do

func (*ProcessorServiceUpdateCall) DoAndReturn added in v0.11.0 

func (c *ProcessorServiceUpdateCall) DoAndReturn(f func(context.Context, string, processor.Config) (*processor.Instance, error)) *ProcessorServiceUpdateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorServiceUpdateCall) Return added in v0.11.0 

func (c *ProcessorServiceUpdateCall) Return(arg0 *processor.Instance, arg1 error) *ProcessorServiceUpdateCall

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.