Documentation
¶
Index ¶
- func Data(in *connectorv1.Data) (record.Data, error)
- func DestinationRunResponse(in *connectorv1.Destination_Run_Response) (record.Position, string)
- func Record(in *connectorv1.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) (plugin.Parameter, error)
- func SpecifierSpecifyResponse(in *connectorv1.Specifier_Specify_Response) (plugin.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 ¶ added in v0.3.0
func SourceStopResponse(in *connectorv1.Source_Stop_Response) (record.Position, error)
func SpecifierParameter ¶
func SpecifierParameter(in *connectorv1.Specifier_Parameter) (plugin.Parameter, error)
func SpecifierSpecifyResponse ¶
func SpecifierSpecifyResponse(in *connectorv1.Specifier_Specify_Response) (plugin.Specification, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.