@@ -12,6 +12,7 @@ use std::str::FromStr;
12
12
use std:: sync:: Arc ;
13
13
14
14
use crate :: config;
15
+ use crate :: span_pointers:: SpanPointer ;
15
16
use crate :: traces:: {
16
17
AWS_XRAY_DAEMON_ADDRESS_URL_PREFIX , DNS_LOCAL_HOST_ADDRESS_URL_PREFIX ,
17
18
DNS_NON_ROUTABLE_ADDRESS_URL_PREFIX , INVOCATION_SPAN_RESOURCE , LAMBDA_EXTENSION_URL_PREFIX ,
@@ -22,7 +23,6 @@ use datadog_trace_protobuf::pb::Span;
22
23
use datadog_trace_utils:: trace_utils:: SendData ;
23
24
use datadog_trace_utils:: trace_utils:: { self } ;
24
25
use serde_json:: { json, Value } ;
25
- use crate :: span_pointers:: SpanPointer ;
26
26
27
27
#[ derive( Clone ) ]
28
28
#[ allow( clippy:: module_name_repetitions) ]
@@ -58,20 +58,21 @@ impl TraceChunkProcessor for ChunkProcessor {
58
58
. iter ( )
59
59
. map ( |sp| {
60
60
json ! ( {
61
- "attributes" : {
62
- "link.kind" : "span-pointer" ,
63
- "ptr.dir" : "u" ,
64
- "ptr.hash" : sp. hash,
65
- "ptr.kind" : sp. kind,
66
- } ,
67
- "span_id" : "0" ,
68
- "trace_id" : "0"
69
- } )
61
+ "attributes" : {
62
+ "link.kind" : "span-pointer" ,
63
+ "ptr.dir" : "u" ,
64
+ "ptr.hash" : sp. hash,
65
+ "ptr.kind" : sp. kind,
66
+ } ,
67
+ "span_id" : "0" ,
68
+ "trace_id" : "0"
69
+ } )
70
70
} )
71
71
. collect ( ) ;
72
72
73
73
if let Ok ( span_links_json) = serde_json:: to_string ( & span_links) {
74
- span. meta . insert ( "_dd.span_links" . to_string ( ) , span_links_json) ;
74
+ span. meta
75
+ . insert ( "_dd.span_links" . to_string ( ) , span_links_json) ;
75
76
}
76
77
}
77
78
}
@@ -301,8 +302,14 @@ mod tests {
301
302
} ;
302
303
let config = create_test_config ( ) ;
303
304
let tags_provider = create_tags_provider ( config. clone ( ) ) ;
304
- let tracer_payload =
305
- trace_processor. process_traces ( config, tags_provider. clone ( ) , header_tags, traces, 100 , None ) ;
305
+ let tracer_payload = trace_processor. process_traces (
306
+ config,
307
+ tags_provider. clone ( ) ,
308
+ header_tags,
309
+ traces,
310
+ 100 ,
311
+ None
312
+ ) ;
306
313
307
314
let expected_tracer_payload = pb:: TracerPayload {
308
315
container_id : "33" . to_string ( ) ,
0 commit comments