toproto

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 8, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DestinationConfigureRequest 

func DestinationConfigureRequest(in pconnector.DestinationConfigureRequest) *connectorv2.Destination_Configure_Request

func DestinationConfigureResponse 

func DestinationConfigureResponse(_ pconnector.DestinationConfigureResponse) *connectorv2.Destination_Configure_Response

func DestinationLifecycleOnCreatedRequest 

func DestinationLifecycleOnCreatedRequest(in pconnector.DestinationLifecycleOnCreatedRequest) *connectorv2.Destination_Lifecycle_OnCreated_Request

func DestinationLifecycleOnCreatedResponse 

func DestinationLifecycleOnCreatedResponse(_ pconnector.DestinationLifecycleOnCreatedResponse) *connectorv2.Destination_Lifecycle_OnCreated_Response

func DestinationLifecycleOnDeletedRequest 

func DestinationLifecycleOnDeletedRequest(in pconnector.DestinationLifecycleOnDeletedRequest) *connectorv2.Destination_Lifecycle_OnDeleted_Request

func DestinationLifecycleOnDeletedResponse 

func DestinationLifecycleOnDeletedResponse(_ pconnector.DestinationLifecycleOnDeletedResponse) *connectorv2.Destination_Lifecycle_OnDeleted_Response

func DestinationLifecycleOnUpdatedRequest 

func DestinationLifecycleOnUpdatedRequest(in pconnector.DestinationLifecycleOnUpdatedRequest) *connectorv2.Destination_Lifecycle_OnUpdated_Request

func DestinationLifecycleOnUpdatedResponse 

func DestinationLifecycleOnUpdatedResponse(_ pconnector.DestinationLifecycleOnUpdatedResponse) *connectorv2.Destination_Lifecycle_OnUpdated_Response

func DestinationOpenRequest 

func DestinationOpenRequest(_ pconnector.DestinationOpenRequest) *connectorv2.Destination_Open_Request

func DestinationOpenResponse 

func DestinationOpenResponse(_ pconnector.DestinationOpenResponse) *connectorv2.Destination_Open_Response

func DestinationRunRequest 

func DestinationRunRequest(in pconnector.DestinationRunRequest) (*connectorv2.Destination_Run_Request, error)

func DestinationRunResponse 

func DestinationRunResponse(in pconnector.DestinationRunResponse) *connectorv2.Destination_Run_Response

func DestinationRunResponseAck 

func DestinationRunResponseAck(in pconnector.DestinationRunResponseAck) *connectorv2.Destination_Run_Response_Ack

func DestinationStopRequest 

func DestinationStopRequest(in pconnector.DestinationStopRequest) *connectorv2.Destination_Stop_Request

func DestinationStopResponse 

func DestinationStopResponse(_ pconnector.DestinationStopResponse) *connectorv2.Destination_Stop_Response

func DestinationTeardownRequest 

func DestinationTeardownRequest(_ pconnector.DestinationTeardownRequest) *connectorv2.Destination_Teardown_Request

func DestinationTeardownResponse 

func DestinationTeardownResponse(_ pconnector.DestinationTeardownResponse) *connectorv2.Destination_Teardown_Response

func SourceConfigureRequest 

func SourceConfigureRequest(in pconnector.SourceConfigureRequest) *connectorv2.Source_Configure_Request

func SourceConfigureResponse 

func SourceConfigureResponse(_ pconnector.SourceConfigureResponse) *connectorv2.Source_Configure_Response

func SourceLifecycleOnCreatedRequest 

func SourceLifecycleOnCreatedRequest(in pconnector.SourceLifecycleOnCreatedRequest) *connectorv2.Source_Lifecycle_OnCreated_Request

func SourceLifecycleOnCreatedResponse 

func SourceLifecycleOnCreatedResponse(_ pconnector.SourceLifecycleOnCreatedResponse) *connectorv2.Source_Lifecycle_OnCreated_Response

func SourceLifecycleOnDeletedRequest 

func SourceLifecycleOnDeletedRequest(in pconnector.SourceLifecycleOnDeletedRequest) *connectorv2.Source_Lifecycle_OnDeleted_Request

func SourceLifecycleOnDeletedResponse 

func SourceLifecycleOnDeletedResponse(_ pconnector.SourceLifecycleOnDeletedResponse) *connectorv2.Source_Lifecycle_OnDeleted_Response

func SourceLifecycleOnUpdatedRequest 

func SourceLifecycleOnUpdatedRequest(in pconnector.SourceLifecycleOnUpdatedRequest) *connectorv2.Source_Lifecycle_OnUpdated_Request

func SourceLifecycleOnUpdatedResponse 

func SourceLifecycleOnUpdatedResponse(_ pconnector.SourceLifecycleOnUpdatedResponse) *connectorv2.Source_Lifecycle_OnUpdated_Response

func SourceOpenRequest 

func SourceOpenRequest(in pconnector.SourceOpenRequest) *connectorv2.Source_Open_Request

func SourceOpenResponse 

func SourceOpenResponse(_ pconnector.SourceOpenResponse) *connectorv2.Source_Open_Response

func SourceRunRequest 

func SourceRunRequest(in pconnector.SourceRunRequest) *connectorv2.Source_Run_Request

func SourceRunResponse 

func SourceRunResponse(in pconnector.SourceRunResponse) (*connectorv2.Source_Run_Response, error)

func SourceStopRequest 

func SourceStopRequest(_ pconnector.SourceStopRequest) *connectorv2.Source_Stop_Request

func SourceStopResponse 

func SourceStopResponse(in pconnector.SourceStopResponse) *connectorv2.Source_Stop_Response

func SourceTeardownRequest 

func SourceTeardownRequest(_ pconnector.SourceTeardownRequest) *connectorv2.Source_Teardown_Request

func SourceTeardownResponse 

func SourceTeardownResponse(_ pconnector.SourceTeardownResponse) *connectorv2.Source_Teardown_Response

func Specification 

func Specification(in pconnector.Specification) *connectorv2.Specification

func SpecifierSpecifyRequest 

func SpecifierSpecifyRequest(_ pconnector.SpecifierSpecifyRequest) *connectorv2.Specifier_Specify_Request

func SpecifierSpecifyResponse 

func SpecifierSpecifyResponse(in pconnector.SpecifierSpecifyResponse) *connectorv2.Specifier_Specify_Response

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.