feat(metrics): Add destination to received metric (#412)

iambriccardo · web-flow · commit fd52ba9b4ef6 · 2025-10-24T10:14:11.000+02:00
diff --git a/etl/src/replication/apply.rs b/etl/src/replication/apply.rs
@@ -680,6 +680,7 @@ where
                     WORKER_TYPE_LABEL => "apply",
                     ACTION_LABEL => "table_streaming",
                     PIPELINE_ID_LABEL => pipeline_id.to_string(),
+                    DESTINATION_LABEL => D::name(),
                 )
                 .increment(1);
             }
diff --git a/etl/src/replication/table_sync.rs b/etl/src/replication/table_sync.rs
@@ -240,6 +240,7 @@ where
                             WORKER_TYPE_LABEL => "table_sync",
                             ACTION_LABEL => "table_copy",
                             PIPELINE_ID_LABEL => pipeline_id.to_string(),
+                            DESTINATION_LABEL => D::name(),
                         )
                         .increment(table_rows_copied_batch as u64);
 

Original file line number	Diff line number	Diff line change
`@@ -680,6 +680,7 @@ where`
`680`	`680`	`WORKER_TYPE_LABEL => "apply",`
`681`	`681`	`ACTION_LABEL => "table_streaming",`
`682`	`682`	`PIPELINE_ID_LABEL => pipeline_id.to_string(),`
	`683`	`+ DESTINATION_LABEL => D::name(),`
`683`	`684`	`)`
`684`	`685`	`.increment(1);`
`685`	`686`	`}`
Original file line number	Diff line number	Diff line change
`@@ -240,6 +240,7 @@ where`
`240`	`240`	`WORKER_TYPE_LABEL => "table_sync",`
`241`	`241`	`ACTION_LABEL => "table_copy",`
`242`	`242`	`PIPELINE_ID_LABEL => pipeline_id.to_string(),`
	`243`	`+ DESTINATION_LABEL => D::name(),`
`243`	`244`	`)`
`244`	`245`	`.increment(table_rows_copied_batch as u64);`
`245`	`246`