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
- Coordinate
Request - Coordinate
Response - GetEvent
Stream Request - GetEvent
Stream Response - Sink
Coordinator Stream Request - Sink
Coordinator Stream Response - Sink
Metadata - Sink
Param - Sink
Writer Stream Request - Sink
Writer Stream Response - Table
Schema - Validate
Sink Request - Validate
Sink Response - Validate
Source Request - Validate
Source Response - Validation
Error
Enums§
Type Aliases§
- PbCdc
Message - PbCoordinate
Request - PbCoordinate
Response - PbGet
Event Stream Request - PbGet
Event Stream Response - PbSink
Coordinator Stream Request - PbSink
Coordinator Stream Response - PbSink
Metadata - PbSink
Param - PbSink
Writer Stream Request - PbSink
Writer Stream Response - PbSource
Type - PbTable
Schema - PbValidate
Sink Request - PbValidate
Sink Response - PbValidate
Source Request - PbValidate
Source Response - PbValidation
Error