Module connector_service

Modules

• cdc_message
  Nested message and enum types in CdcMessage.
• connector_service_client
  Generated client implementations.
• connector_service_server
  Generated server implementations.
• coordinate_request
  Nested message and enum types in CoordinateRequest.
• coordinate_response
  Nested message and enum types in CoordinateResponse.
• get_event_stream_response
  Nested message and enum types in GetEventStreamResponse.
• sink_coordination_service_client
  Generated client implementations.
• sink_coordination_service_server
  Generated server implementations.
• sink_coordinator_stream_request
  Nested message and enum types in SinkCoordinatorStreamRequest.
• sink_coordinator_stream_response
  Nested message and enum types in SinkCoordinatorStreamResponse.
• sink_metadata
  Nested message and enum types in SinkMetadata.
• sink_writer_stream_request
  Nested message and enum types in SinkWriterStreamRequest.
• sink_writer_stream_response
  Nested message and enum types in SinkWriterStreamResponse.

Structs

• CdcMessage
• CoordinateRequest
• CoordinateResponse
• GetEventStreamRequest
• GetEventStreamResponse
• SinkCoordinatorStreamRequest
• SinkCoordinatorStreamResponse
• SinkMetadata
• SinkParam
• SinkWriterStreamRequest
• SinkWriterStreamResponse
• TableSchema
• ValidateSinkRequest
• ValidateSinkResponse
• ValidateSourceRequest
• ValidateSourceResponse
• ValidationError

Enums

• SourceType

Type Aliases

• PbCdcMessage
  Alias for CdcMessage.
• PbCoordinateRequest
  Alias for CoordinateRequest.
• PbCoordinateResponse
  Alias for CoordinateResponse.
• PbGetEventStreamRequest
  Alias for GetEventStreamRequest.
• PbGetEventStreamResponse
  Alias for GetEventStreamResponse.
• PbSinkCoordinatorStreamRequest
  Alias for SinkCoordinatorStreamRequest.
• PbSinkCoordinatorStreamResponse
  Alias for SinkCoordinatorStreamResponse.
• PbSinkMetadata
  Alias for SinkMetadata.
• PbSinkParam
  Alias for SinkParam.
• PbSinkWriterStreamRequest
  Alias for SinkWriterStreamRequest.
• PbSinkWriterStreamResponse
  Alias for SinkWriterStreamResponse.
• PbSourceType
  Alias for SourceType.
• PbTableSchema
  Alias for TableSchema.
• PbValidateSinkRequest
  Alias for ValidateSinkRequest.
• PbValidateSinkResponse
  Alias for ValidateSinkResponse.
• PbValidateSourceRequest
  Alias for ValidateSourceRequest.
• PbValidateSourceResponse
  Alias for ValidateSourceResponse.
• PbValidationError
  Alias for ValidationError.