Documentation ¶
Index ¶
- func Data(in record.Data) (cpluginv1.Data, error)
- func DestinationConfigureRequest(in map[string]string) (cpluginv1.DestinationConfigureRequest, error)
- func DestinationRunRequest(in record.Record) (cpluginv1.DestinationRunRequest, error)
- func DestinationStartRequest() cpluginv1.DestinationStartRequest
- func DestinationStopRequest() cpluginv1.DestinationStopRequest
- func DestinationTeardownRequest() cpluginv1.DestinationTeardownRequest
- func Record(in record.Record) (cpluginv1.Record, error)
- func SourceConfigureRequest(in map[string]string) (cpluginv1.SourceConfigureRequest, error)
- func SourceRunRequest(in record.Position) (cpluginv1.SourceRunRequest, error)
- func SourceStartRequest(in record.Position) (cpluginv1.SourceStartRequest, error)
- func SourceStopRequest() cpluginv1.SourceStopRequest
- func SourceTeardownRequest() cpluginv1.SourceTeardownRequest
- func SpecifierSpecifyRequest() cpluginv1.SpecifierSpecifyRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DestinationConfigureRequest ¶
func DestinationConfigureRequest(in map[string]string) (cpluginv1.DestinationConfigureRequest, error)
func DestinationRunRequest ¶
func DestinationRunRequest(in record.Record) (cpluginv1.DestinationRunRequest, error)
func DestinationStartRequest ¶
func DestinationStartRequest() cpluginv1.DestinationStartRequest
func DestinationStopRequest ¶
func DestinationStopRequest() cpluginv1.DestinationStopRequest
func DestinationTeardownRequest ¶
func DestinationTeardownRequest() cpluginv1.DestinationTeardownRequest
func SourceConfigureRequest ¶
func SourceConfigureRequest(in map[string]string) (cpluginv1.SourceConfigureRequest, error)
func SourceRunRequest ¶
func SourceRunRequest(in record.Position) (cpluginv1.SourceRunRequest, error)
func SourceStartRequest ¶
func SourceStartRequest(in record.Position) (cpluginv1.SourceStartRequest, error)
func SourceStopRequest ¶
func SourceStopRequest() cpluginv1.SourceStopRequest
func SourceTeardownRequest ¶
func SourceTeardownRequest() cpluginv1.SourceTeardownRequest
func SpecifierSpecifyRequest ¶
func SpecifierSpecifyRequest() cpluginv1.SpecifierSpecifyRequest
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.