refactor(storage-manager): improve logging

* plugins/zenoh-plugin-storage-manager/src/replication/core.rs:
  - Log the `DigestDiff` when a misalignment is detected.
  - Removed the log indicated that an alignment query is received as it
    is redundant with later logs.

* plugins/zenoh-plugin-storage-manager/src/replication/log.rs: added a
  trace when an event is added to the Replication Log.

* plugins/zenoh-plugin-storage-manager/src/storages_mgt/service.rs:
  - Only print the key expression of the sample being processed.
  - Remove the redundant log indicating the the sample is being
    processed.

Signed-off-by: Julien Loudet <julien.loudet@zettascale.tech>

plugins/zenoh-plugin-storage-manager/src/replication/core.rs

@@ -379,7 +379,7 @@ impl Replication {
                         };
 
                         if let Some(digest_diff) = digest.diff(other_digest) {
-                            tracing::debug!("Potential misalignment detected");
+                            tracing::debug!("Potential misalignment detected: {digest_diff:?}");
 
                             let replica_aligner_ke = match keformat!(
                                 aligner_key_expr_formatter::formatter(),
@@ -465,8 +465,6 @@ impl Replication {
                     continue;
                 }
 
-                tracing::trace!("Received Alignment Query");
-
                 let replication = replication.clone();
                 tokio::task::spawn(async move { replication.aligner(query).await });
             }

plugins/zenoh-plugin-storage-manager/src/replication/log.rs

@@ -282,6 +282,8 @@ impl LogLatest {
             return;
         };
 
+        tracing::trace!("Inserting < {:?} > in Replication Log", event.key_expr());
+
         self.bloom_filter_event.set(event.key_expr());
 
         self.intervals

plugins/zenoh-plugin-storage-manager/src/storages_mgt/service.rs

@@ -218,7 +218,7 @@ impl StorageService {
     // The storage should only simply save the key, sample pair while put and retrieve the same
     // during get the trimming during PUT and GET should be handled by the plugin
     pub(crate) async fn process_sample(&self, sample: Sample) -> ZResult<()> {
-        tracing::trace!("[STORAGE] Processing sample: {:?}", sample);
+        tracing::trace!("[STORAGE] Processing sample: {:?}", sample.key_expr());
 
         // A Sample, in theory, will not arrive to a Storage without a Timestamp. This check (which,
         // again, should never enter the `None` branch) ensures that the Storage Manager
@@ -254,12 +254,6 @@ impl StorageService {
                 continue;
             }
 
-            tracing::trace!(
-                "Sample `{:?}` identified as needed processing for key {}",
-                sample,
-                k
-            );
-
             // there might be the case that the actual update was outdated due to a wild card
             // update, but not stored yet in the storage. get the relevant wild
             // card entry and use that value and timestamp to update the storage