fix: various fixes

Author: Ganesh Jangir

Cargo.lock

@@ -467,7 +467,7 @@ pub unsafe extern "C" fn ddog_trace_exporter_new(
             }
 
             if let Some(cfg) = &config.telemetry_cfg {
-                builder.enable_telemetry(cfg.clone());
+                builder.enable_telemetry(Some(cfg.clone()));
             }
 
             if let Some(token) = &config.test_session_token {

data-pipeline-ffi/src/trace_exporter.rs

@@ -62,6 +62,8 @@ tokio = { version = "1.23", features = [
     "time",
     "test-util",
 ], default-features = false }
+clap = { version = "4.3.21", features = ["derive"] }
+datadog-log = { path = "../datadog-log" }
 
 [features]
 test-utils = []

data-pipeline/Cargo.toml

@@ -67,7 +67,7 @@ fn main() {
         .set_language_version(env!("CARGO_PKG_RUST_VERSION"))
         .set_input_format(TraceExporterInputFormat::V04)
         .set_output_format(TraceExporterOutputFormat::V04)
-        .enable_telemetry(telemetry_cfg)
+        .enable_telemetry(Some(telemetry_cfg))
         .enable_stats(Duration::from_secs(10));
     let exporter = builder.build().expect("Failed to build TraceExporter");
     let now = UNIX_EPOCH

data-pipeline/examples/send-traces-with-stats.rs

@@ -71,31 +71,39 @@ unsafe fn emit_backtrace_by_frames(
         }
         if resolve_frames == StacktraceCollection::EnabledWithInprocessSymbols {
             backtrace::resolve_frame_unsynchronized(frame, |symbol| {
+                #[allow(clippy::unwrap_used)]
                 write!(w, "{{").unwrap();
                 #[allow(clippy::unwrap_used)]
                 emit_absolute_addresses(w, frame).unwrap();
                 if let Some(column) = symbol.colno() {
+                    #[allow(clippy::unwrap_used)]
                     write!(w, ", \"column\": {column}").unwrap();
                 }
                 if let Some(file) = symbol.filename() {
                     // The debug printer for path already wraps it in `"` marks.
+                    #[allow(clippy::unwrap_used)]
                     write!(w, ", \"file\": {file:?}").unwrap();
                 }
                 if let Some(function) = symbol.name() {
+                    #[allow(clippy::unwrap_used)]
                     write!(w, ", \"function\": \"{function}\"").unwrap();
                 }
                 if let Some(line) = symbol.lineno() {
+                    #[allow(clippy::unwrap_used)]
                     write!(w, ", \"line\": {line}").unwrap();
                 }
+                #[allow(clippy::unwrap_used)]
                 writeln!(w, "}}").unwrap();
                 // Flush eagerly to ensure that each frame gets emitted even if the next one fails
                 #[allow(clippy::unwrap_used)]
                 w.flush().unwrap();
             });
         } else {
+            #[allow(clippy::unwrap_used)]
             write!(w, "{{").unwrap();
             #[allow(clippy::unwrap_used)]
             emit_absolute_addresses(w, frame).unwrap();
+            #[allow(clippy::unwrap_used)]
             writeln!(w, "}}").unwrap();
             // Flush eagerly to ensure that each frame gets emitted even if the next one fails
             #[allow(clippy::unwrap_used)]

datadog-crashtracker/src/collector/emitters.rs

@@ -109,7 +109,7 @@ pub fn from_bytes(data: tinybytes::Bytes) -> Result<(Vec<Vec<SpanBytes>>, usize)
 /// let decoded_span = &decoded_traces[0][0];
 /// assert_eq!("test-span", decoded_span.name);
 /// ```
-pub fn from_slice(mut data: &[u8]) -> Result<(Vec<Vec<SpanSlice>>, usize), DecodeError> {
+pub fn from_slice(mut data: &[u8]) -> Result<(Vec<Vec<SpanSlice<'_>>>, usize), DecodeError> {
     let trace_count = rmp::decode::read_array_len(&mut data).map_err(|_| {
         DecodeError::InvalidFormat("Unable to read array len for trace count".to_owned())
     })?;

datadog-trace-utils/src/msgpack_decoder/v04/mod.rs

@@ -139,7 +139,7 @@ pub fn from_bytes(data: tinybytes::Bytes) -> Result<(Vec<Vec<SpanBytes>>, usize)
 /// let decoded_span = &decoded_traces[0][0];
 /// assert_eq!("", decoded_span.name);
 /// ```
-pub fn from_slice(mut data: &[u8]) -> Result<(Vec<Vec<SpanSlice>>, usize), DecodeError> {
+pub fn from_slice(mut data: &[u8]) -> Result<(Vec<Vec<SpanSlice<'_>>>, usize), DecodeError> {
     let data_elem = rmp::decode::read_array_len(&mut data)
         .map_err(|_| DecodeError::InvalidFormat("Unable to read payload len".to_string()))?;