Module pipeline 

Thread-per-core connector pipeline. Streaming connector pipeline. Each source connector runs as a tokio task pushing batches via crossfire mpsc to the StreamingCoordinator, which drives SQL execution cycles, routes results to sinks, and manages checkpoint barriers. See the streaming_coordinator submodule for the runtime topology.

Re-exports

pub use callback::PipelineCallback;

pub use callback::SourceRegistration;

pub use config::PipelineConfig;

pub use streaming_coordinator::StreamingCoordinator;

Modules

callback

Pipeline callback trait and source registration types.

config

Pipeline configuration.

streaming_coordinator

Simplified pipeline coordinator.

Enums

ControlMsg

Control message sent from LaminarDB DDL handlers to the running StreamingCoordinator for live schema changes (add/drop streams).