pub async fn create_source( source: SourceType, source_address: String, ) -> Result<Box<dyn LogSource + Send + Sync>>