(&self)
| 233 | |
| 234 | #[tracing::instrument(level = "debug", skip(self))] |
| 235 | pub async fn initialize_all_providers(&self) -> Result<()> { |
| 236 | let provider_store = self.provider_store.read().await; |
| 237 | let mut fut = vec![]; |
| 238 | for (_, provider) in provider_store.iter() { |
| 239 | let key = provider.key(); |
| 240 | fut.push(Box::pin(async move { |
| 241 | tracing::info!("Initializing {}", key); |
| 242 | let err = provider.initialize().await; |
| 243 | if let Err(err) = err { |
| 244 | tracing::error!("Error initializing {}: {:?}", provider.key(), err); |
| 245 | } else { |
| 246 | tracing::info!("Initialized {}", provider.key()); |
| 247 | } |
| 248 | })); |
| 249 | } |
| 250 | join_all(fut).await; |
| 251 | Ok(()) |
| 252 | } |
| 253 | |
| 254 | #[tracing::instrument(level = "debug", skip(self, id))] |
| 255 | pub async fn get_provider_key_by_id(&self, id: String) -> Result<String> { |
nothing calls this directly
no test coverage detected