testutils

Documentation

Index

• func GetDateTime() *timestamppb.Timestamp
• func MockGetConnector(mockService *mock.MockConnectorService, connectorID, plugin, pipelineID string, ...)
• func MockGetConnectorPlugins(mockService *mock.MockConnectorService, name string, ...)
• func MockGetConnectors(mockService *mock.MockConnectorService, pipelineID string, ...)
• func MockGetDLQ(mockService *mock.MockPipelineService, pipelineID, plugin string)
• func MockGetPipeline(mockService *mock.MockPipelineService, pipelineID string, ...)
• func MockGetPipelines(mockService *mock.MockPipelineService, pipelines []*apiv1.Pipeline)
• func MockGetProcessor(mockService *mock.MockProcessorService, processorID, plugin, condition string, ...)
• func MockGetProcessorPlugins(mockservice *mock.MockProcessorService, name string, ...)
• func MockGetProcessors(mockService *mock.MockProcessorService, processors []*apiv1.Processor)

Functions

func GetDateTime

func GetDateTime() *timestamppb.Timestamp

GetDateTime returns a sample timestamppb.Timestamp that can be used by API mocks.

func MockGetConnector

func MockGetConnector(
	mockService *mock.MockConnectorService,
	connectorID, plugin, pipelineID string,
	conType apiv1.Connector_Type,
	config *apiv1.Connector_Config,
	processorIds []string,
)

func MockGetConnectorPlugins

func MockGetConnectorPlugins(
	mockService *mock.MockConnectorService,
	name string,
	plugins []*apiv1.ConnectorPluginSpecifications,
)

func MockGetConnectors

func MockGetConnectors(mockService *mock.MockConnectorService, pipelineID string, connectors []*apiv1.Connector)

func MockGetDLQ

func MockGetDLQ(mockService *mock.MockPipelineService, pipelineID, plugin string)

func MockGetPipeline

func MockGetPipeline(mockService *mock.MockPipelineService, pipelineID string, connectorIds, processorIds []string)

func MockGetPipelines

func MockGetPipelines(mockService *mock.MockPipelineService, pipelines []*apiv1.Pipeline)

func MockGetProcessor

func MockGetProcessor(
	mockService *mock.MockProcessorService,
	processorID, plugin, condition string,
	parent *apiv1.Processor_Parent,
	settings map[string]string,
)

func MockGetProcessorPlugins

func MockGetProcessorPlugins(mockservice *mock.MockProcessorService, name string, plugins []*apiv1.ProcessorPluginSpecifications)

func MockGetProcessors

func MockGetProcessors(mockService *mock.MockProcessorService, processors []*apiv1.Processor)