Module connector 

Core connector traits (SourceConnector, SinkConnector). Connector traits — async SourceConnector / SinkConnector.

Structs

PartitionInfo

Source partition identity + current offset (Kafka partition number, CDC slot name, etc.).

SinkConnectorCapabilities

Capabilities declared by a sink connector.

SourceBatch

A batch of records read from a source connector.

WriteResult

Summary of a successful write_batch call.

Enums

DeliveryGuarantee

Delivery guarantee level for the pipeline.

PostgresSslMode

SSL connection mode for PostgreSQL-compatible connectors.

Traits

SinkConnector

Trait for sink connectors that write data to external systems.

SourceConnector

Trait for source connectors that read data from external systems.