rust/worker/src/ingest/mod.rs

pub(crate) mod config;
mod ingest;
mod message_id;
mod scheduler;

// Re-export the ingest provider for use in the worker
pub(crate) use ingest::*;
pub(crate) use scheduler::*;