Documentation
¶
Index ¶
- func Change(in cpluginv1.Change) (record.Change, error)
- func Data(in cpluginv1.Data) (record.Data, error)
- func DestinationRunResponse(in cpluginv1.DestinationRunResponse) (record.Position, string)
- func Record(in cpluginv1.Record) (record.Record, error)
- func SourceRunResponse(in cpluginv1.SourceRunResponse) (record.Record, error)
- func SourceStopResponse(in cpluginv1.SourceStopResponse) (record.Position, error)
- func SpecifierParameter(in cpluginv1.SpecifierParameter) connectorPlugin.Parameter
- func SpecifierSpecifyResponse(in cpluginv1.SpecifierSpecifyResponse) (connectorPlugin.Specification, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DestinationRunResponse ¶
func DestinationRunResponse(in cpluginv1.DestinationRunResponse) (record.Position, string)
func SourceRunResponse ¶
func SourceRunResponse(in cpluginv1.SourceRunResponse) (record.Record, error)
func SourceStopResponse ¶
func SourceStopResponse(in cpluginv1.SourceStopResponse) (record.Position, error)
func SpecifierParameter ¶
func SpecifierParameter(in cpluginv1.SpecifierParameter) connectorPlugin.Parameter
func SpecifierSpecifyResponse ¶
func SpecifierSpecifyResponse(in cpluginv1.SpecifierSpecifyResponse) (connectorPlugin.Specification, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.