Module connector 

Core connector traits (SourceConnector, SinkConnector). Core connector traits.

Defines the async traits that all source and sink connectors implement:

• SourceConnector: Reads data from external systems
• SinkConnector: Writes data to external systems

These traits operate in Ring 1 (background) and communicate with Ring 0 through the streaming API (Source<T>::push_arrow() and subscriptions).

Structs

PartitionInfo

Information about a source partition.

SinkConnectorCapabilities

Capabilities declared by a sink connector.

SourceBatch

A batch of records read from a source connector.

WriteResult

Result of writing a batch to a sink connector.

Enums

DeliveryGuarantee

Delivery guarantee level for the pipeline.

Traits

SinkConnector

Trait for sink connectors that write data to external systems.

SourceConnector

Trait for source connectors that read data from external systems.