Documentation ¶
Index ¶
- func ConnectorConfig(in *apiv1.Connector_Config) connector.Config
- func ConnectorType(in apiv1.Connector_Type) connector.Type
- func PipelineConfig(in *apiv1.Pipeline_Config) pipeline.Config
- func PipelineDLQ(in *apiv1.Pipeline_DLQ) pipeline.DLQ
- func ProcessorConfig(in *apiv1.Processor_Config) processor.Config
- func ProcessorParent(in *apiv1.Processor_Parent) processor.Parent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConnectorConfig ¶
func ConnectorConfig(in *apiv1.Connector_Config) connector.Config
func ConnectorType ¶
func ConnectorType(in apiv1.Connector_Type) connector.Type
func PipelineConfig ¶
func PipelineConfig(in *apiv1.Pipeline_Config) pipeline.Config
func PipelineDLQ ¶ added in v0.5.0
func PipelineDLQ(in *apiv1.Pipeline_DLQ) pipeline.DLQ
func ProcessorConfig ¶
func ProcessorConfig(in *apiv1.Processor_Config) processor.Config
func ProcessorParent ¶
func ProcessorParent(in *apiv1.Processor_Parent) processor.Parent
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.