toproto

Documentation

Index

• func Change(in record.Change) (*opencdcv1.Change, error)
• func Data(in record.Data) (*opencdcv1.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) (*opencdcv1.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

Functions

func Change

func Change(in record.Change) (*opencdcv1.Change, error)

func Data

func Data(in record.Data) (*opencdcv1.Data, error)

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 Record

func Record(in record.Record) (*opencdcv1.Record, error)

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