chore(cubestore): make trace_id and span_id suitable for open telemetry.

Author: KSDaemon

rust/cubestore/cubestore/src/cluster/mod.rs

@@ -41,7 +41,7 @@ use crate::queryplanner::query_executor::{QueryExecutor, SerializedRecordBatchSt
 use crate::queryplanner::serialized_plan::SerializedPlan;
 use crate::remotefs::RemoteFs;
 use crate::store::ChunkDataStore;
-use crate::telemetry::tracing::TracingHelper;
+use crate::telemetry::tracing::{TraceIdAndSpanId, TracingHelper};
 use crate::CubeError;
 use async_trait::async_trait;
 use datafusion::arrow::datatypes::SchemaRef;
@@ -215,7 +215,7 @@ pub enum WorkerMessage {
         SerializedPlan,
         HashMap<String, String>,
         HashMap<u64, Vec<SerializedRecordBatchStream>>,
-        Option<(u64, u64)>,
+        Option<TraceIdAndSpanId>,
     ),
 }
 

rust/cubestore/cubestore/src/telemetry/tracing.rs

@@ -2,14 +2,16 @@ use crate::config::injection::DIService;
 use crate::CubeError;
 use std::sync::Arc;
 
+pub type TraceIdAndSpanId = (u128, u64);
+
 pub trait TracingHelper: DIService + Send + Sync {
-    fn trace_and_span_id(&self) -> Option<(u64, u64)>;
+    fn trace_and_span_id(&self) -> Option<TraceIdAndSpanId>;
 }
 
 pub struct TracingHelperImpl;
 
 impl TracingHelper for TracingHelperImpl {
-    fn trace_and_span_id(&self) -> Option<(u64, u64)> {
+    fn trace_and_span_id(&self) -> Option<TraceIdAndSpanId> {
         None
     }
 }