toproto

package

v0.10.0-nightly.20240423 Latest Latest Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/conduitio/conduit

Documentation ¶

Index ¶

func Change(in record.Change) (*opencdcv1.Change, error)
func Connector(in *connector.Instance) *apiv1.Connector
func ConnectorConfig(in connector.Config) *apiv1.Connector_Config
func ConnectorDestinationState(in connector.DestinationState) *apiv1.Connector_DestinationState_
func ConnectorPluginParamValidations(in []connector.Validation) []*configv1.Validation
func ConnectorPluginParamsMap(in map[string]connector.Parameter) map[string]*configv1.Parameter
func ConnectorPluginSpecifications(name string, in connector.Specification) *apiv1.ConnectorPluginSpecifications
func ConnectorSourceState(in connector.SourceState) *apiv1.Connector_SourceState_
func ConnectorType(in connector.Type) apiv1.Connector_Type
func Data(in record.Data) (*opencdcv1.Data, error)
func Pipeline(in *pipeline.Instance) *apiv1.Pipeline
func PipelineConfig(in pipeline.Config) *apiv1.Pipeline_Config
func PipelineDLQ(in pipeline.DLQ) *apiv1.Pipeline_DLQ
func PipelineStatus(in pipeline.Status) apiv1.Pipeline_Status
func PluginParamValidations(in []connector.Validation) []*apiv1.PluginSpecifications_Parameter_Validationdeprecated
func PluginParamsMap(in map[string]connector.Parameter) map[string]*apiv1.PluginSpecifications_Parameterdeprecated
func PluginSpecifications(name string, in connector.Specification) *apiv1.PluginSpecificationsdeprecated
func Processor(in *processor.Instance) *apiv1.Processor
func ProcessorConfig(in processor.Config) *apiv1.Processor_Config
func ProcessorParent(in processor.Parent) *apiv1.Processor_Parent
func ProcessorPluginSpecifications(name string, in processorSdk.Specification) *apiv1.ProcessorPluginSpecifications
func Record(in record.Record) (*opencdcv1.Record, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Change ¶ added in v0.4.0

func Change(in record.Change) (*opencdcv1.Change, error)

func Connector ¶

func Connector(in *connector.Instance) *apiv1.Connector

func ConnectorConfig ¶

func ConnectorConfig(in connector.Config) *apiv1.Connector_Config

func ConnectorDestinationState ¶

func ConnectorDestinationState(in connector.DestinationState) *apiv1.Connector_DestinationState_

func ConnectorPluginParamValidations ¶ added in v0.9.0

func ConnectorPluginParamValidations(in []connector.Validation) []*configv1.Validation

func ConnectorPluginParamsMap ¶ added in v0.9.0

func ConnectorPluginParamsMap(in map[string]connector.Parameter) map[string]*configv1.Parameter

func ConnectorPluginSpecifications ¶ added in v0.9.0

func ConnectorPluginSpecifications(name string, in connector.Specification) *apiv1.ConnectorPluginSpecifications

func ConnectorSourceState ¶

func ConnectorSourceState(in connector.SourceState) *apiv1.Connector_SourceState_

func ConnectorType ¶

func ConnectorType(in connector.Type) apiv1.Connector_Type

func Data ¶ added in v0.4.0

func Data(in record.Data) (*opencdcv1.Data, error)

func Pipeline ¶

func Pipeline(in *pipeline.Instance) *apiv1.Pipeline

func PipelineConfig ¶

func PipelineConfig(in pipeline.Config) *apiv1.Pipeline_Config

func PipelineDLQ ¶ added in v0.5.0

func PipelineDLQ(in pipeline.DLQ) *apiv1.Pipeline_DLQ

func PipelineStatus ¶

func PipelineStatus(in pipeline.Status) apiv1.Pipeline_Status

func PluginParamValidations deprecated added in v0.2.0

func PluginParamValidations(in []connector.Validation) []*apiv1.PluginSpecifications_Parameter_Validation

Deprecated: this is here for backwards compatibility with the old plugin API.

func PluginParamsMap deprecated added in v0.2.0

func PluginParamsMap(in map[string]connector.Parameter) map[string]*apiv1.PluginSpecifications_Parameter

Deprecated: this is here for backwards compatibility with the old plugin API.

func PluginSpecifications deprecated added in v0.9.0

func PluginSpecifications(name string, in connector.Specification) *apiv1.PluginSpecifications

Deprecated: this is here for backwards compatibility with the old plugin API.

func Processor ¶

func Processor(in *processor.Instance) *apiv1.Processor

func ProcessorConfig ¶

func ProcessorConfig(in processor.Config) *apiv1.Processor_Config

func ProcessorParent ¶

func ProcessorParent(in processor.Parent) *apiv1.Processor_Parent

func ProcessorPluginSpecifications ¶ added in v0.9.0

func ProcessorPluginSpecifications(name string, in processorSdk.Specification) *apiv1.ProcessorPluginSpecifications

func Record ¶ added in v0.4.0

func Record(in record.Record) (*opencdcv1.Record, error)

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL