mock

package
v0.11.0-nightly.20240627 Latest Latest
Warning

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

 Go to latest Published: Jun 25, 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(arg0 log.CtxLogger, arg1 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(arg0, arg1 any) *gomock.Call

NewDispenser indicates an expected call of NewDispenser.

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.ProcessorService, 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 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, arg6 string) (*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) MakeRunnableProcessor added in v0.9.0 

func (m *ProcessorService) MakeRunnableProcessor(arg0 context.Context, arg1 *processor.Instance) (*processor.RunnableProcessor, error)

MakeRunnableProcessor 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, arg6 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) MakeRunnableProcessor added in v0.9.0 

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

MakeRunnableProcessor indicates an expected call of MakeRunnableProcessor.

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.