Module ingestion 

Re-exports

pub use crate::config::ConcurrencyConfig as IngestConcurrencyConfig;

Modules

error

ingestion_client

store_client

streaming_client

Structs

ClientArgs

Combined arguments for both ingestion and streaming clients. This is a convenience wrapper that flattens both argument types.

IngestionConfig

IngestionService

Type Aliases

BoxedStreamingClient

Type alias for a boxed CheckpointStreamingClient trait object, the form IngestionService stores and the broadcaster consumes. Boxed (rather than Arc’d) because CheckpointStreamingClient’s methods take &mut self, so unique ownership is required. The Send + Sync bounds let the boxed client move across task boundaries and be shared behind a reference when an enclosing IngestionService is held across threads.