async fn execute_gc(manager: &Manager<'_>) -> Result<(), PersistenceError> {
    iter(manager.node().iter())
        .map(Ok)
        .try_for_each_concurrent(None, |(name, queue)| async move {
            info!("Started GC cycle on database \"{}\"", name);

            queue.log_event(name, manager, Event::Gc).await?;

            queue.database().await.gc();

            #[cfg(feature = "replication")]
            if let Some(storage) = queue.replication_storage().await.as_mut() {
                storage.map_primary(PrimaryStorage::gc);
            }

            info!("GC cycle on \"{}\" completed successfully", name);

            Ok(())
        })
        .await
}
/// Concurrently iterates over all databases in node, and executes GC on them.
Concurrently iterates over all databases in node, and executes GC on them.
Concurrently iterates over all databases in node and executes GC on them .
async fn execute_gc(manager: &Manager<'_>) -> Result<(), PersistenceError> {
    iter(manager.node().iter())
        .map(Ok)
        .try_for_each_concurrent(None, |(name, queue)| async move {
            info!("Started GC cycle on database \"{}\"", name);
            queue.log_event(name, manager, Event::Gc).await?;
            queue.database().await.gc();
            #[cfg(feature = "replication")]
            if let Some(storage) = queue.replication_storage().await.as_mut() {
                storage.map_primary(PrimaryStorage::gc);
            }
            info!("GC cycle on \"{}\" completed successfully", name);
            Ok(())
        })
        .await
}
async fn execute_gc ( manager : & Manager < ' _ > ) -> Result < ( ) , PersistenceError > { iter ( manager . node ( ) . iter ( ) ) . map ( Ok ) . try_for_each_concurrent ( None , | ( name , queue ) | async move { info ! ( " \" \" " name ) ; queue . log_event ( name , manager , Event :: Gc ) . await ? ; queue . database ( ) . await . gc ( ) ; # [ cfg ( feature " " ) ] if let Some ( storage ) = queue . replication_storage ( ) . await . as_mut ( ) { storage . map_primary ( PrimaryStorage :: gc ) ; } info ! ( " \" \" " name ) ; Ok ( ( ) ) } ) . await }
Concurrently iterates over all databases in node, and executes GC on them.
Concurrently iterates over all databases in node and executes GC on them .
manager
&Manager<'_>
manager
&Manager<'_>