Documentation
¶
Index ¶
- func Change(in *opencdcv1.Change) (record.Change, error)
- func Data(in *opencdcv1.Data) (record.Data, error)
- func DestinationRunResponse(in *connectorv1.Destination_Run_Response) (record.Position, string)
- func Record(in *opencdcv1.Record) (record.Record, error)
- func SourceRunResponse(in *connectorv1.Source_Run_Response) (record.Record, error)
- func SourceStopResponse(in *connectorv1.Source_Stop_Response) (record.Position, error)
- func SpecifierParameter(in *connectorv1.Specifier_Parameter) (connector.Parameter, error)
- func SpecifierSpecifyResponse(in *connectorv1.Specifier_Specify_Response) (connector.Specification, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DestinationRunResponse ¶
func DestinationRunResponse(in *connectorv1.Destination_Run_Response) (record.Position, string)
func SourceRunResponse ¶
func SourceRunResponse(in *connectorv1.Source_Run_Response) (record.Record, error)
func SourceStopResponse ¶
func SourceStopResponse(in *connectorv1.Source_Stop_Response) (record.Position, error)
func SpecifierParameter ¶
func SpecifierParameter(in *connectorv1.Specifier_Parameter) (connector.Parameter, error)
func SpecifierSpecifyResponse ¶
func SpecifierSpecifyResponse(in *connectorv1.Specifier_Specify_Response) (connector.Specification, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.