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
• func DestinationLifecycleOnCreatedRequest(cfg map[string]string) *connectorv1.Destination_Lifecycle_OnCreated_Request
• func DestinationLifecycleOnDeletedRequest(cfg map[string]string) *connectorv1.Destination_Lifecycle_OnDeleted_Request
• func DestinationLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) *connectorv1.Destination_Lifecycle_OnUpdated_Request
• 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
• func SourceLifecycleOnCreatedRequest(cfg map[string]string) *connectorv1.Source_Lifecycle_OnCreated_Request
• func SourceLifecycleOnDeletedRequest(cfg map[string]string) *connectorv1.Source_Lifecycle_OnDeleted_Request
• func SourceLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) *connectorv1.Source_Lifecycle_OnUpdated_Request
• func SourceRunRequest(in record.Position) *connectorv1.Source_Run_Request
• func SourceStartRequest(in record.Position) *connectorv1.Source_Start_Request
• 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

func DestinationLifecycleOnCreatedRequest

func DestinationLifecycleOnCreatedRequest(cfg map[string]string) *connectorv1.Destination_Lifecycle_OnCreated_Request

func DestinationLifecycleOnDeletedRequest

func DestinationLifecycleOnDeletedRequest(cfg map[string]string) *connectorv1.Destination_Lifecycle_OnDeleted_Request

func DestinationLifecycleOnUpdatedRequest

func DestinationLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) *connectorv1.Destination_Lifecycle_OnUpdated_Request

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

func SourceLifecycleOnCreatedRequest

func SourceLifecycleOnCreatedRequest(cfg map[string]string) *connectorv1.Source_Lifecycle_OnCreated_Request

func SourceLifecycleOnDeletedRequest

func SourceLifecycleOnDeletedRequest(cfg map[string]string) *connectorv1.Source_Lifecycle_OnDeleted_Request

func SourceLifecycleOnUpdatedRequest

func SourceLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) *connectorv1.Source_Lifecycle_OnUpdated_Request

func SourceRunRequest

func SourceRunRequest(in record.Position) *connectorv1.Source_Run_Request

func SourceStartRequest

func SourceStartRequest(in record.Position) *connectorv1.Source_Start_Request

func SourceStopRequest

func SourceStopRequest() *connectorv1.Source_Stop_Request

func SourceTeardownRequest

func SourceTeardownRequest() *connectorv1.Source_Teardown_Request

func SpecifierSpecifyRequest

func SpecifierSpecifyRequest() *connectorv1.Specifier_Specify_Request