toproto

package

v0.8.0-nightly.20231019 Latest Latest Go to latest Published: Oct 18, 2023 License: Apache-2.0 Imports: 6 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 Data(in record.Data) (*opencdcv1.Data, error)
func DestinationConfigureRequest(in map[string]string) *connectorv1.Destination_Configure_Request
func DestinationLifecycleOnCreatedRequest(cfg map[string]string) *connectorv1.Destination_Lifecycle_OnCreated_Request
func DestinationLifecycleOnDeletedRequest(cfg map[string]string) *connectorv1.Destination_Lifecycle_OnDeleted_Request
func DestinationLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) *connectorv1.Destination_Lifecycle_OnUpdated_Request
func DestinationRunRequest(in record.Record) (*connectorv1.Destination_Run_Request, error)
func DestinationStartRequest() *connectorv1.Destination_Start_Request
func DestinationStopRequest(in record.Position) *connectorv1.Destination_Stop_Request
func DestinationTeardownRequest() *connectorv1.Destination_Teardown_Request
func Record(in record.Record) (*opencdcv1.Record, error)
func SourceConfigureRequest(in map[string]string) *connectorv1.Source_Configure_Request
func SourceLifecycleOnCreatedRequest(cfg map[string]string) *connectorv1.Source_Lifecycle_OnCreated_Request
func SourceLifecycleOnDeletedRequest(cfg map[string]string) *connectorv1.Source_Lifecycle_OnDeleted_Request
func SourceLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) *connectorv1.Source_Lifecycle_OnUpdated_Request
func SourceRunRequest(in record.Position) *connectorv1.Source_Run_Request
func SourceStartRequest(in record.Position) *connectorv1.Source_Start_Request
func SourceStopRequest() *connectorv1.Source_Stop_Request
func SourceTeardownRequest() *connectorv1.Source_Teardown_Request
func SpecifierSpecifyRequest() *connectorv1.Specifier_Specify_Request

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Change ¶ added in v0.3.0

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

func Data ¶

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

func DestinationConfigureRequest ¶

func DestinationConfigureRequest(in map[string]string) *connectorv1.Destination_Configure_Request

func DestinationLifecycleOnCreatedRequest ¶ added in v0.6.0

func DestinationLifecycleOnCreatedRequest(cfg map[string]string) *connectorv1.Destination_Lifecycle_OnCreated_Request

func DestinationLifecycleOnDeletedRequest ¶ added in v0.6.0

func DestinationLifecycleOnDeletedRequest(cfg map[string]string) *connectorv1.Destination_Lifecycle_OnDeleted_Request

func DestinationLifecycleOnUpdatedRequest ¶ added in v0.6.0

func DestinationLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) *connectorv1.Destination_Lifecycle_OnUpdated_Request

func DestinationRunRequest ¶

func DestinationRunRequest(in record.Record) (*connectorv1.Destination_Run_Request, error)

func DestinationStartRequest ¶

func DestinationStartRequest() *connectorv1.Destination_Start_Request

func DestinationStopRequest ¶

func DestinationStopRequest(in record.Position) *connectorv1.Destination_Stop_Request

func DestinationTeardownRequest ¶

func DestinationTeardownRequest() *connectorv1.Destination_Teardown_Request

func Record ¶

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

func SourceConfigureRequest ¶

func SourceConfigureRequest(in map[string]string) *connectorv1.Source_Configure_Request

func SourceLifecycleOnCreatedRequest ¶ added in v0.6.0

func SourceLifecycleOnCreatedRequest(cfg map[string]string) *connectorv1.Source_Lifecycle_OnCreated_Request

func SourceLifecycleOnDeletedRequest ¶ added in v0.6.0

func SourceLifecycleOnDeletedRequest(cfg map[string]string) *connectorv1.Source_Lifecycle_OnDeleted_Request

func SourceLifecycleOnUpdatedRequest ¶ added in v0.6.0

func SourceLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) *connectorv1.Source_Lifecycle_OnUpdated_Request

func SourceRunRequest ¶

func SourceRunRequest(in record.Position) *connectorv1.Source_Run_Request

func SourceStartRequest ¶

func SourceStartRequest(in record.Position) *connectorv1.Source_Start_Request

func SourceStopRequest ¶

func SourceStopRequest() *connectorv1.Source_Stop_Request

func SourceTeardownRequest ¶

func SourceTeardownRequest() *connectorv1.Source_Teardown_Request

func SpecifierSpecifyRequest ¶

func SpecifierSpecifyRequest() *connectorv1.Specifier_Specify_Request

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