Remove MetricEvent::SnapshotStarted

Author: gotocoding-DB

kernel/src/metrics/events.rs

@@ -36,12 +36,6 @@ impl fmt::Display for MetricId {
 /// instance. This allows correlating multiple events from the same operation.
 #[derive(Debug, Clone)]
 pub enum MetricEvent {
-    /// A snapshot creation operation has started.
-    SnapshotStarted {
-        operation_id: MetricId,
-        table_path: String,
-    },
-
     /// Log segment loading completed (listing and organizing log files).
     LogSegmentLoaded {
         operation_id: MetricId,
@@ -89,14 +83,6 @@ pub enum MetricEvent {
 impl fmt::Display for MetricEvent {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         match self {
-            MetricEvent::SnapshotStarted {
-                operation_id,
-                table_path,
-            } => write!(
-                f,
-                "SnapshotStarted(id={}, table={})",
-                operation_id, table_path
-            ),
             MetricEvent::LogSegmentLoaded {
                 operation_id,
                 duration,

kernel/src/metrics/mod.rs

@@ -20,11 +20,8 @@
 //! impl MetricsReporter for LoggingReporter {
 //!     fn report(&self, event: MetricEvent) {
 //!         match event {
-//!             MetricEvent::SnapshotStarted { operation_id, table_path } => {
-//!                 println!("Snapshot started: {} for table {}", operation_id, table_path);
-//!             }
 //!             MetricEvent::LogSegmentLoaded { operation_id, duration, num_commit_files, .. } => {
-//!                 println!("  Log segment loaded in {:?}: {} commits", duration, num_commit_files);
+//!                 println!("Log segment loaded in {:?}: {} commits", duration, num_commit_files);
 //!             }
 //!             MetricEvent::SnapshotCompleted { operation_id, version, total_duration } => {
 //!                 println!("Snapshot completed: v{} in {:?}", version, total_duration);

kernel/src/snapshot/builder.rs

@@ -89,24 +89,6 @@ impl SnapshotBuilder {
         let operation_id = MetricId::new();
         let reporter = engine.get_metrics_reporter();
 
-        let table_path = self
-            .table_root
-            .as_ref()
-            .map(|url| url.to_string())
-            .or_else(|| {
-                self.existing_snapshot
-                    .as_ref()
-                    .map(|s| s.table_root().to_string())
-            })
-            .unwrap_or_else(|| "unknown".to_string());
-
-        reporter.as_ref().inspect(|r| {
-            r.report(MetricEvent::SnapshotStarted {
-                operation_id,
-                table_path,
-            });
-        });
-
         if let Some(table_root) = self.table_root {
             let start = Instant::now();
             let log_segment_result = LogSegment::for_snapshot(