toplugin

Documentation

Index

• func Change(in record.Change) (cpluginv1.Change, error)
• 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(in record.Position) 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

Functions

func Change

func Change(in record.Change) (cpluginv1.Change, error)

func Data

func Data(in record.Data) (cpluginv1.Data, error)

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(in record.Position) cpluginv1.DestinationStopRequest

func DestinationTeardownRequest

func DestinationTeardownRequest() cpluginv1.DestinationTeardownRequest

func Record

func Record(in record.Record) (cpluginv1.Record, error)

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