mock

package
v0.8.0-nightly.20231026 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: github.com/conduitio/conduit/pkg/provisioning (interfaces: PipelineService,ConnectorService,ProcessorService,PluginService)

Generated by this command: 

mockgen -destination=mock/provisioning.go -package=mock -mock_names=PipelineService=PipelineService,ConnectorService=ConnectorService,ProcessorService=ProcessorService,PluginService=PluginService . PipelineService,ConnectorService,ProcessorService,PluginService

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 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(arg0 context.Context, arg1, arg2 string) (*connector.Instance, error)

AddProcessor mocks base method.

func (*ConnectorService) Create 

func (m *ConnectorService) Create(arg0 context.Context, arg1 string, arg2 connector.Type, arg3, arg4 string, arg5 connector.Config, arg6 connector.ProvisionType) (*connector.Instance, error)

Create mocks base method.

func (*ConnectorService) Delete 

func (m *ConnectorService) Delete(arg0 context.Context, arg1 string, arg2 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(arg0 context.Context, arg1 string) (*connector.Instance, error)

Get mocks base method.

func (*ConnectorService) RemoveProcessor 

func (m *ConnectorService) RemoveProcessor(arg0 context.Context, arg1, arg2 string) (*connector.Instance, error)

RemoveProcessor mocks base method.

func (*ConnectorService) Update added in v0.6.0 

func (m *ConnectorService) Update(arg0 context.Context, arg1 string, arg2 connector.Config) (*connector.Instance, error)

Update mocks base method.

type ConnectorServiceMockRecorder 

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

ConnectorServiceMockRecorder is the mock recorder for ConnectorService.

func (*ConnectorServiceMockRecorder) AddProcessor 

func (mr *ConnectorServiceMockRecorder) AddProcessor(arg0, arg1, arg2 any) *gomock.Call

AddProcessor indicates an expected call of AddProcessor.

func (*ConnectorServiceMockRecorder) Create 

func (mr *ConnectorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5, arg6 any) *gomock.Call

Create indicates an expected call of Create.

func (*ConnectorServiceMockRecorder) CreateWithInstance added in v0.6.0 

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

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(arg0, arg1, arg2 any) *gomock.Call

Delete indicates an expected call of Delete.

func (*ConnectorServiceMockRecorder) Get 

func (mr *ConnectorServiceMockRecorder) Get(arg0, arg1 any) *gomock.Call

Get indicates an expected call of Get.

func (*ConnectorServiceMockRecorder) RemoveProcessor 

func (mr *ConnectorServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 any) *gomock.Call

RemoveProcessor indicates an expected call of RemoveProcessor.

func (*ConnectorServiceMockRecorder) Update added in v0.6.0 

func (mr *ConnectorServiceMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call

Update indicates an expected call of Update.

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(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)

AddConnector mocks base method.

func (*PipelineService) AddProcessor 

func (m *PipelineService) AddProcessor(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)

AddProcessor mocks base method.

func (*PipelineService) Create 

func (m *PipelineService) Create(arg0 context.Context, arg1 string, arg2 pipeline.Config, arg3 pipeline.ProvisionType) (*pipeline.Instance, error)

Create mocks base method.

func (*PipelineService) Delete 

func (m *PipelineService) Delete(arg0 context.Context, arg1 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(arg0 context.Context, arg1 string) (*pipeline.Instance, error)

Get mocks base method.

func (*PipelineService) List 

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

List mocks base method.

func (*PipelineService) RemoveConnector 

func (m *PipelineService) RemoveConnector(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)

RemoveConnector mocks base method.

func (*PipelineService) RemoveProcessor 

func (m *PipelineService) RemoveProcessor(arg0 context.Context, arg1, arg2 string) (*pipeline.Instance, error)

RemoveProcessor mocks base method.

func (*PipelineService) Start 

func (m *PipelineService) Start(arg0 context.Context, arg1 pipeline.ConnectorFetcher, arg2 pipeline.ProcessorFetcher, arg3 pipeline.PluginDispenserFetcher, arg4 string) error

Start mocks base method.

func (*PipelineService) Stop 

func (m *PipelineService) Stop(arg0 context.Context, arg1 string, arg2 bool) error

Stop mocks base method.

func (*PipelineService) Update added in v0.6.0 

func (m *PipelineService) Update(arg0 context.Context, arg1 string, arg2 pipeline.Config) (*pipeline.Instance, error)

Update mocks base method.

func (*PipelineService) UpdateDLQ added in v0.4.0 

func (m *PipelineService) UpdateDLQ(arg0 context.Context, arg1 string, arg2 pipeline.DLQ) (*pipeline.Instance, error)

UpdateDLQ mocks base method.

type PipelineServiceMockRecorder 

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

PipelineServiceMockRecorder is the mock recorder for PipelineService.

func (*PipelineServiceMockRecorder) AddConnector 

func (mr *PipelineServiceMockRecorder) AddConnector(arg0, arg1, arg2 any) *gomock.Call

AddConnector indicates an expected call of AddConnector.

func (*PipelineServiceMockRecorder) AddProcessor 

func (mr *PipelineServiceMockRecorder) AddProcessor(arg0, arg1, arg2 any) *gomock.Call

AddProcessor indicates an expected call of AddProcessor.

func (*PipelineServiceMockRecorder) Create 

func (mr *PipelineServiceMockRecorder) Create(arg0, arg1, arg2, arg3 any) *gomock.Call

Create indicates an expected call of Create.

func (*PipelineServiceMockRecorder) CreateWithInstance added in v0.6.0 

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

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(arg0, arg1 any) *gomock.Call

Delete indicates an expected call of Delete.

func (*PipelineServiceMockRecorder) Get 

func (mr *PipelineServiceMockRecorder) Get(arg0, arg1 any) *gomock.Call

Get indicates an expected call of Get.

func (*PipelineServiceMockRecorder) List 

func (mr *PipelineServiceMockRecorder) List(arg0 any) *gomock.Call

List indicates an expected call of List.

func (*PipelineServiceMockRecorder) RemoveConnector 

func (mr *PipelineServiceMockRecorder) RemoveConnector(arg0, arg1, arg2 any) *gomock.Call

RemoveConnector indicates an expected call of RemoveConnector.

func (*PipelineServiceMockRecorder) RemoveProcessor 

func (mr *PipelineServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 any) *gomock.Call

RemoveProcessor indicates an expected call of RemoveProcessor.

func (*PipelineServiceMockRecorder) Start 

func (mr *PipelineServiceMockRecorder) Start(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call

Start indicates an expected call of Start.

func (*PipelineServiceMockRecorder) Stop 

func (mr *PipelineServiceMockRecorder) Stop(arg0, arg1, arg2 any) *gomock.Call

Stop indicates an expected call of Stop.

func (*PipelineServiceMockRecorder) Update added in v0.6.0 

func (mr *PipelineServiceMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call

Update indicates an expected call of Update.

func (*PipelineServiceMockRecorder) UpdateDLQ added in v0.4.0 

func (mr *PipelineServiceMockRecorder) UpdateDLQ(arg0, arg1, arg2 any) *gomock.Call

UpdateDLQ indicates an expected call of UpdateDLQ.

type PluginService added in v0.5.0 

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

PluginService is a mock of PluginService interface.

func NewPluginService added in v0.5.0 

func NewPluginService(ctrl *gomock.Controller) *PluginService

NewPluginService creates a new mock instance.

func (*PluginService) EXPECT added in v0.5.0 

func (m *PluginService) EXPECT() *PluginServiceMockRecorder

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

func (*PluginService) NewDispenser added in v0.5.0 

func (m *PluginService) NewDispenser(arg0 log.CtxLogger, arg1 string) (plugin.Dispenser, error)

NewDispenser mocks base method.

type PluginServiceMockRecorder added in v0.5.0 

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

PluginServiceMockRecorder is the mock recorder for PluginService.

func (*PluginServiceMockRecorder) NewDispenser added in v0.5.0 

func (mr *PluginServiceMockRecorder) NewDispenser(arg0, arg1 any) *gomock.Call

NewDispenser indicates an expected call of NewDispenser.

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(arg0 context.Context, arg1, arg2 string, arg3 processor.Parent, arg4 processor.Config, arg5 processor.ProvisionType) (*processor.Instance, error)

Create mocks base method.

func (*ProcessorService) Delete 

func (m *ProcessorService) Delete(arg0 context.Context, arg1 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(arg0 context.Context, arg1 string) (*processor.Instance, error)

Get mocks base method.

func (*ProcessorService) Update added in v0.6.0 

func (m *ProcessorService) Update(arg0 context.Context, arg1 string, arg2 processor.Config) (*processor.Instance, error)

Update mocks base method.

type ProcessorServiceMockRecorder 

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

ProcessorServiceMockRecorder is the mock recorder for ProcessorService.

func (*ProcessorServiceMockRecorder) Create 

func (mr *ProcessorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5 any) *gomock.Call

Create indicates an expected call of Create.

func (*ProcessorServiceMockRecorder) CreateWithInstance added in v0.6.0 

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

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(arg0, arg1 any) *gomock.Call

Delete indicates an expected call of Delete.

func (*ProcessorServiceMockRecorder) Get 

func (mr *ProcessorServiceMockRecorder) Get(arg0, arg1 any) *gomock.Call

Get indicates an expected call of Get.

func (*ProcessorServiceMockRecorder) Update added in v0.6.0 

func (mr *ProcessorServiceMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call

Update indicates an expected call of Update.

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.