mock

package
v0.11.0-nightly.20240625 Latest Latest
Warning

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

 Go to latest Published: Jun 24, 2024 License: Apache-2.0 Imports: 9 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) List added in v0.9.0 

func (m *ConnectorPluginService) List(arg0 context.Context) (map[string]connector0.Specification, error)

List mocks base method.

func (*ConnectorPluginService) NewDispenser added in v0.9.0 

func (m *ConnectorPluginService) NewDispenser(arg0 log.CtxLogger, arg1 string) (connector0.Dispenser, error)

NewDispenser mocks base method.

func (*ConnectorPluginService) ValidateDestinationConfig added in v0.9.0 

func (m *ConnectorPluginService) ValidateDestinationConfig(arg0 context.Context, arg1 string, arg2 map[string]string) error

ValidateDestinationConfig mocks base method.

func (*ConnectorPluginService) ValidateSourceConfig added in v0.9.0 

func (m *ConnectorPluginService) ValidateSourceConfig(arg0 context.Context, arg1 string, arg2 map[string]string) error

ValidateSourceConfig 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) List added in v0.9.0 

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

List indicates an expected call of List.

func (*ConnectorPluginServiceMockRecorder) NewDispenser added in v0.9.0 

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

NewDispenser indicates an expected call of NewDispenser.

func (*ConnectorPluginServiceMockRecorder) ValidateDestinationConfig added in v0.9.0 

func (mr *ConnectorPluginServiceMockRecorder) ValidateDestinationConfig(arg0, arg1, arg2 any) *gomock.Call

ValidateDestinationConfig indicates an expected call of ValidateDestinationConfig.

func (*ConnectorPluginServiceMockRecorder) ValidateSourceConfig added in v0.9.0 

func (mr *ConnectorPluginServiceMockRecorder) ValidateSourceConfig(arg0, arg1, arg2 any) *gomock.Call

ValidateSourceConfig indicates an expected call of ValidateSourceConfig.

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

func (m *ConnectorService) List(arg0 context.Context) map[string]*connector.Instance

List 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 

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

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

List indicates an expected call of List.

func (*ConnectorServiceMockRecorder) RemoveProcessor 

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

RemoveProcessor indicates an expected call of RemoveProcessor.

func (*ConnectorServiceMockRecorder) Update 

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 

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.5.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) 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 

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

Update indicates an expected call of Update.

func (*PipelineServiceMockRecorder) UpdateDLQ added in v0.5.0 

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

UpdateDLQ indicates an expected call of UpdateDLQ.

type ProcessorPluginService added in v0.9.0 

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

ProcessorPluginService is a mock of ProcessorPluginService interface.

func NewProcessorPluginService added in v0.9.0 

func NewProcessorPluginService(ctrl *gomock.Controller) *ProcessorPluginService

NewProcessorPluginService creates a new mock instance.

func (*ProcessorPluginService) EXPECT added in v0.9.0 

func (m *ProcessorPluginService) EXPECT() *ProcessorPluginServiceMockRecorder

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

func (*ProcessorPluginService) List added in v0.9.0 

func (m *ProcessorPluginService) List(arg0 context.Context) (map[string]sdk.Specification, error)

List mocks base method.

func (*ProcessorPluginService) NewProcessor added in v0.9.0 

func (m *ProcessorPluginService) NewProcessor(arg0 context.Context, arg1, arg2 string) (sdk.Processor, error)

NewProcessor mocks base method.

func (*ProcessorPluginService) RegisterStandalonePlugin added in v0.9.1 

func (m *ProcessorPluginService) RegisterStandalonePlugin(arg0 context.Context, arg1 string) (string, error)

RegisterStandalonePlugin mocks base method.

type ProcessorPluginServiceMockRecorder added in v0.9.0 

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

ProcessorPluginServiceMockRecorder is the mock recorder for ProcessorPluginService.

func (*ProcessorPluginServiceMockRecorder) List added in v0.9.0 

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

List indicates an expected call of List.

func (*ProcessorPluginServiceMockRecorder) NewProcessor added in v0.9.0 

func (mr *ProcessorPluginServiceMockRecorder) NewProcessor(arg0, arg1, arg2 any) *gomock.Call

NewProcessor indicates an expected call of NewProcessor.

func (*ProcessorPluginServiceMockRecorder) RegisterStandalonePlugin added in v0.9.1 

func (mr *ProcessorPluginServiceMockRecorder) RegisterStandalonePlugin(arg0, arg1 any) *gomock.Call

RegisterStandalonePlugin indicates an expected call of RegisterStandalonePlugin.

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

func (m *ProcessorService) List(arg0 context.Context) map[string]*processor.Instance

List 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 

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

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

List indicates an expected call of List.

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 

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.