mock

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

• type MockConnectorService
  • func NewMockConnectorService(ctrl *gomock.Controller) *MockConnectorService
  • func (m *MockConnectorService) EXPECT() *MockConnectorServiceMockRecorder
  • func (m *MockConnectorService) GetConnector(ctx context.Context, in *apiv1.GetConnectorRequest, opts ...grpc.CallOption) (*apiv1.GetConnectorResponse, error)
  • func (m *MockConnectorService) ListConnectorPlugins(ctx context.Context, in *apiv1.ListConnectorPluginsRequest, ...) (*apiv1.ListConnectorPluginsResponse, error)
  • func (m *MockConnectorService) ListConnectors(ctx context.Context, in *apiv1.ListConnectorsRequest, opts ...grpc.CallOption) (*apiv1.ListConnectorsResponse, error)
• type MockConnectorServiceMockRecorder
  • func (mr *MockConnectorServiceMockRecorder) GetConnector(ctx, in any, opts ...any) *gomock.Call
  • func (mr *MockConnectorServiceMockRecorder) ListConnectorPlugins(ctx, in any, opts ...any) *gomock.Call
  • func (mr *MockConnectorServiceMockRecorder) ListConnectors(ctx, in any, opts ...any) *gomock.Call
• type MockPipelineService
  • func NewMockPipelineService(ctrl *gomock.Controller) *MockPipelineService
  • func (m *MockPipelineService) EXPECT() *MockPipelineServiceMockRecorder
  • func (m *MockPipelineService) GetDLQ(ctx context.Context, in *apiv1.GetDLQRequest, opts ...grpc.CallOption) (*apiv1.GetDLQResponse, error)
  • func (m *MockPipelineService) GetPipeline(ctx context.Context, in *apiv1.GetPipelineRequest, opts ...grpc.CallOption) (*apiv1.GetPipelineResponse, error)
  • func (m *MockPipelineService) ListPipelines(ctx context.Context, in *apiv1.ListPipelinesRequest, opts ...grpc.CallOption) (*apiv1.ListPipelinesResponse, error)
• type MockPipelineServiceMockRecorder
  • func (mr *MockPipelineServiceMockRecorder) GetDLQ(ctx, in any, opts ...any) *gomock.Call
  • func (mr *MockPipelineServiceMockRecorder) GetPipeline(ctx, in any, opts ...any) *gomock.Call
  • func (mr *MockPipelineServiceMockRecorder) ListPipelines(ctx, in any, opts ...any) *gomock.Call
• type MockProcessorService
  • func NewMockProcessorService(ctrl *gomock.Controller) *MockProcessorService
  • func (m *MockProcessorService) EXPECT() *MockProcessorServiceMockRecorder
  • func (m *MockProcessorService) GetProcessor(ctx context.Context, in *apiv1.GetProcessorRequest, opts ...grpc.CallOption) (*apiv1.GetProcessorResponse, error)
  • func (m *MockProcessorService) ListProcessorPlugins(ctx context.Context, in *apiv1.ListProcessorPluginsRequest, ...) (*apiv1.ListProcessorPluginsResponse, error)
  • func (m *MockProcessorService) ListProcessors(ctx context.Context, in *apiv1.ListProcessorsRequest, opts ...grpc.CallOption) (*apiv1.ListProcessorsResponse, error)
• type MockProcessorServiceMockRecorder
  • func (mr *MockProcessorServiceMockRecorder) GetProcessor(ctx, in any, opts ...any) *gomock.Call
  • func (mr *MockProcessorServiceMockRecorder) ListProcessorPlugins(ctx, in any, opts ...any) *gomock.Call
  • func (mr *MockProcessorServiceMockRecorder) ListProcessors(ctx, in any, opts ...any) *gomock.Call

Types

type MockConnectorService

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

MockConnectorService is a mock of ConnectorService interface.

func NewMockConnectorService

func NewMockConnectorService(ctrl *gomock.Controller) *MockConnectorService

NewMockConnectorService creates a new mock instance.

func (*MockConnectorService) EXPECT

func (m *MockConnectorService) EXPECT() *MockConnectorServiceMockRecorder

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

func (*MockConnectorService) GetConnector

func (m *MockConnectorService) GetConnector(ctx context.Context, in *apiv1.GetConnectorRequest, opts ...grpc.CallOption) (*apiv1.GetConnectorResponse, error)

GetConnector mocks base method.

func (*MockConnectorService) ListConnectorPlugins

func (m *MockConnectorService) ListConnectorPlugins(ctx context.Context, in *apiv1.ListConnectorPluginsRequest, opts ...grpc.CallOption) (*apiv1.ListConnectorPluginsResponse, error)

ListConnectorPlugins mocks base method.

func (*MockConnectorService) ListConnectors

func (m *MockConnectorService) ListConnectors(ctx context.Context, in *apiv1.ListConnectorsRequest, opts ...grpc.CallOption) (*apiv1.ListConnectorsResponse, error)

ListConnectors mocks base method.

type MockConnectorServiceMockRecorder

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

MockConnectorServiceMockRecorder is the mock recorder for MockConnectorService.

func (*MockConnectorServiceMockRecorder) GetConnector

func (mr *MockConnectorServiceMockRecorder) GetConnector(ctx, in any, opts ...any) *gomock.Call

GetConnector indicates an expected call of GetConnector.

func (*MockConnectorServiceMockRecorder) ListConnectorPlugins

func (mr *MockConnectorServiceMockRecorder) ListConnectorPlugins(ctx, in any, opts ...any) *gomock.Call

ListConnectorPlugins indicates an expected call of ListConnectorPlugins.

func (*MockConnectorServiceMockRecorder) ListConnectors

func (mr *MockConnectorServiceMockRecorder) ListConnectors(ctx, in any, opts ...any) *gomock.Call

ListConnectors indicates an expected call of ListConnectors.

type MockPipelineService

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

MockPipelineService is a mock of PipelineService interface.

func NewMockPipelineService

func NewMockPipelineService(ctrl *gomock.Controller) *MockPipelineService

NewMockPipelineService creates a new mock instance.

func (*MockPipelineService) EXPECT

func (m *MockPipelineService) EXPECT() *MockPipelineServiceMockRecorder

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

func (*MockPipelineService) GetDLQ

func (m *MockPipelineService) GetDLQ(ctx context.Context, in *apiv1.GetDLQRequest, opts ...grpc.CallOption) (*apiv1.GetDLQResponse, error)

GetDLQ mocks base method.

func (*MockPipelineService) GetPipeline

func (m *MockPipelineService) GetPipeline(ctx context.Context, in *apiv1.GetPipelineRequest, opts ...grpc.CallOption) (*apiv1.GetPipelineResponse, error)

GetPipeline mocks base method.

func (*MockPipelineService) ListPipelines

func (m *MockPipelineService) ListPipelines(ctx context.Context, in *apiv1.ListPipelinesRequest, opts ...grpc.CallOption) (*apiv1.ListPipelinesResponse, error)

ListPipelines mocks base method.

type MockPipelineServiceMockRecorder

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

MockPipelineServiceMockRecorder is the mock recorder for MockPipelineService.

func (*MockPipelineServiceMockRecorder) GetDLQ

func (mr *MockPipelineServiceMockRecorder) GetDLQ(ctx, in any, opts ...any) *gomock.Call

GetDLQ indicates an expected call of GetDLQ.

func (*MockPipelineServiceMockRecorder) GetPipeline

func (mr *MockPipelineServiceMockRecorder) GetPipeline(ctx, in any, opts ...any) *gomock.Call

GetPipeline indicates an expected call of GetPipeline.

func (*MockPipelineServiceMockRecorder) ListPipelines

func (mr *MockPipelineServiceMockRecorder) ListPipelines(ctx, in any, opts ...any) *gomock.Call

ListPipelines indicates an expected call of ListPipelines.

type MockProcessorService

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

MockProcessorService is a mock of ProcessorService interface.

func NewMockProcessorService

func NewMockProcessorService(ctrl *gomock.Controller) *MockProcessorService

NewMockProcessorService creates a new mock instance.

func (*MockProcessorService) EXPECT

func (m *MockProcessorService) EXPECT() *MockProcessorServiceMockRecorder

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

func (*MockProcessorService) GetProcessor

func (m *MockProcessorService) GetProcessor(ctx context.Context, in *apiv1.GetProcessorRequest, opts ...grpc.CallOption) (*apiv1.GetProcessorResponse, error)

GetProcessor mocks base method.

func (*MockProcessorService) ListProcessorPlugins

func (m *MockProcessorService) ListProcessorPlugins(ctx context.Context, in *apiv1.ListProcessorPluginsRequest, opts ...grpc.CallOption) (*apiv1.ListProcessorPluginsResponse, error)

ListProcessorPlugins mocks base method.

func (*MockProcessorService) ListProcessors

func (m *MockProcessorService) ListProcessors(ctx context.Context, in *apiv1.ListProcessorsRequest, opts ...grpc.CallOption) (*apiv1.ListProcessorsResponse, error)

ListProcessors mocks base method.

type MockProcessorServiceMockRecorder

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

MockProcessorServiceMockRecorder is the mock recorder for MockProcessorService.

func (*MockProcessorServiceMockRecorder) GetProcessor

func (mr *MockProcessorServiceMockRecorder) GetProcessor(ctx, in any, opts ...any) *gomock.Call

GetProcessor indicates an expected call of GetProcessor.

func (*MockProcessorServiceMockRecorder) ListProcessorPlugins

func (mr *MockProcessorServiceMockRecorder) ListProcessorPlugins(ctx, in any, opts ...any) *gomock.Call

ListProcessorPlugins indicates an expected call of ListProcessorPlugins.

func (*MockProcessorServiceMockRecorder) ListProcessors

func (mr *MockProcessorServiceMockRecorder) ListProcessors(ctx, in any, opts ...any) *gomock.Call

ListProcessors indicates an expected call of ListProcessors.