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

ArcStreamingClient

Type alias for a shared CheckpointStreamingClient trait object, the form IngestionService stores and the broadcaster consumes. Arc’d (rather than Box’d) because CheckpointStreamingClient’s methods take &self, so the client can be cheaply cloned and shared across owners – each cohort’s IngestionService gets its own clone. The Send + Sync bounds let it move across task boundaries and be shared behind a reference when an enclosing IngestionService is held across threads.