Documentation
¶
Index ¶
- func Data(in record.Data) (*connectorv1.Data, error)
- func DestinationConfigureRequest(in map[string]string) (*connectorv1.Destination_Configure_Request, error)
- 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) (*connectorv1.Record, error)
- func SourceConfigureRequest(in map[string]string) (*connectorv1.Source_Configure_Request, error)
- func SourceRunRequest(in record.Position) (*connectorv1.Source_Run_Request, error)
- func SourceStartRequest(in record.Position) (*connectorv1.Source_Start_Request, error)
- 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 DestinationConfigureRequest ¶
func DestinationConfigureRequest(in map[string]string) (*connectorv1.Destination_Configure_Request, error)
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 SourceConfigureRequest ¶
func SourceConfigureRequest(in map[string]string) (*connectorv1.Source_Configure_Request, error)
func SourceRunRequest ¶
func SourceRunRequest(in record.Position) (*connectorv1.Source_Run_Request, error)
func SourceStartRequest ¶
func SourceStartRequest(in record.Position) (*connectorv1.Source_Start_Request, error)
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
Click to show internal directories.
Click to hide internal directories.