mock

package
v0.6.0-nightly.20230302 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2023 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 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) 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) SetState added in v0.5.0 

func (m *ConnectorService) SetState(arg0 context.Context, arg1 string, arg2 interface{}) (*connector.Instance, error)

SetState 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 interface{}) *gomock.Call

AddProcessor indicates an expected call of AddProcessor.

func (*ConnectorServiceMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*ConnectorServiceMockRecorder) Delete 

func (mr *ConnectorServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*ConnectorServiceMockRecorder) Get 

func (mr *ConnectorServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*ConnectorServiceMockRecorder) RemoveProcessor 

func (mr *ConnectorServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call

RemoveProcessor indicates an expected call of RemoveProcessor.

func (*ConnectorServiceMockRecorder) SetState added in v0.5.0 

func (mr *ConnectorServiceMockRecorder) SetState(arg0, arg1, arg2 interface{}) *gomock.Call

SetState indicates an expected call of SetState.

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) 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 interface{}) *gomock.Call

AddConnector indicates an expected call of AddConnector.

func (*PipelineServiceMockRecorder) AddProcessor 

func (mr *PipelineServiceMockRecorder) AddProcessor(arg0, arg1, arg2 interface{}) *gomock.Call

AddProcessor indicates an expected call of AddProcessor.

func (*PipelineServiceMockRecorder) Create 

func (mr *PipelineServiceMockRecorder) Create(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*PipelineServiceMockRecorder) Delete 

func (mr *PipelineServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*PipelineServiceMockRecorder) Get 

func (mr *PipelineServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*PipelineServiceMockRecorder) List 

func (mr *PipelineServiceMockRecorder) List(arg0 interface{}) *gomock.Call

List indicates an expected call of List.

func (*PipelineServiceMockRecorder) RemoveConnector 

func (mr *PipelineServiceMockRecorder) RemoveConnector(arg0, arg1, arg2 interface{}) *gomock.Call

RemoveConnector indicates an expected call of RemoveConnector.

func (*PipelineServiceMockRecorder) RemoveProcessor 

func (mr *PipelineServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call

RemoveProcessor indicates an expected call of RemoveProcessor.

func (*PipelineServiceMockRecorder) Start 

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

Start indicates an expected call of Start.

func (*PipelineServiceMockRecorder) Stop 

func (mr *PipelineServiceMockRecorder) Stop(arg0, arg1, arg2 interface{}) *gomock.Call

Stop indicates an expected call of Stop.

func (*PipelineServiceMockRecorder) UpdateDLQ added in v0.4.0 

func (mr *PipelineServiceMockRecorder) UpdateDLQ(arg0, arg1, arg2 interface{}) *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 interface{}) *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.

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 interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*ProcessorServiceMockRecorder) Delete 

func (mr *ProcessorServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*ProcessorServiceMockRecorder) Get 

func (mr *ProcessorServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call

Get indicates an expected call of Get.

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.