Skip to content

Commit ac4be12

Browse files
authored
Change how the forwarder detects inferred spans (#522)
* Change it to tag_source:self * Fix test json input * Update test snapshots
1 parent 2b28937 commit ac4be12

File tree

5 files changed

+13
-13
lines changed

5 files changed

+13
-13
lines changed

aws/logs_monitoring/trace_forwarder/internal/apm/model.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ func AddTagsToTracePayloads(tracePayloads []*pb.TracePayload, tags string) {
186186
for _, span := range trace.Spans {
187187
// do not add tags from Lambda function if it's an inferred span and
188188
// it does not belong to the AWS Lambda service
189-
if value, ok := span.Meta["inferred_span.inherit_lambda"]; ok && value == "False" {
189+
if value, ok := span.Meta["_inferred_span.tag_source"]; ok && value == "self" {
190190
continue
191191
}
192192
if serviceLookup[span.Service] != "" {

aws/logs_monitoring/trace_forwarder/internal/apm/testdata/inferred_span.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@
2323
"http.method": "GET",
2424
"resource_names": "ialbefmodl.execute-api.sa-east-1.amazonaws.com/",
2525
"request_id": "9f09f496-83c7-441b-bc59-9741107b0683",
26-
"inferred_span.inherit_lambda": "False",
27-
"inferred_span.is_async": "False",
26+
"_inferred_span.tag_source": "self",
27+
"_inferred_span.synchronisity": "sync",
2828
"http.status_code": "200"
2929
},
3030
"metrics": {

aws/logs_monitoring/trace_forwarder/internal/apm/testdata/inferred_span.json~snapshot

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,12 +19,12 @@
1919
Meta: (map[string]string) (len=12) {
2020
(string) (len=17) "_dd.compute_stats": (string) (len=1) "1",
2121
(string) (len=10) "_dd.origin": (string) (len=6) "lambda",
22+
(string) (len=28) "_inferred_span.synchronisity": (string) (len=4) "sync",
23+
(string) (len=25) "_inferred_span.tag_source": (string) (len=4) "self",
2224
(string) (len=8) "endpoint": (string) (len=1) "/",
2325
(string) (len=11) "http.method": (string) (len=3) "GET",
2426
(string) (len=16) "http.status_code": (string) (len=3) "200",
2527
(string) (len=8) "http.url": (string) (len=2) "?/",
26-
(string) (len=28) "inferred_span.inherit_lambda": (string) (len=5) "False",
27-
(string) (len=22) "inferred_span.is_async": (string) (len=5) "False",
2828
(string) (len=14) "operation_name": (string) (len=19) "aws.apigateway.rest",
2929
(string) (len=10) "request_id": (string) (len=36) "9f09f496-83c7-441b-bc59-9741107b0683",
3030
(string) (len=14) "resource_names": (string) (len=47) "ialbefmodl.execute-api.sa-east-1.amazonaws.com/",
@@ -310,12 +310,12 @@
310310
Meta: (map[string]string) (len=12) {
311311
(string) (len=17) "_dd.compute_stats": (string) (len=1) "1",
312312
(string) (len=10) "_dd.origin": (string) (len=6) "lambda",
313+
(string) (len=28) "_inferred_span.synchronisity": (string) (len=4) "sync",
314+
(string) (len=25) "_inferred_span.tag_source": (string) (len=4) "self",
313315
(string) (len=8) "endpoint": (string) (len=1) "/",
314316
(string) (len=11) "http.method": (string) (len=3) "GET",
315317
(string) (len=16) "http.status_code": (string) (len=3) "200",
316318
(string) (len=8) "http.url": (string) (len=2) "?/",
317-
(string) (len=28) "inferred_span.inherit_lambda": (string) (len=5) "False",
318-
(string) (len=22) "inferred_span.is_async": (string) (len=5) "False",
319319
(string) (len=14) "operation_name": (string) (len=19) "aws.apigateway.rest",
320320
(string) (len=10) "request_id": (string) (len=36) "9f09f496-83c7-441b-bc59-9741107b0683",
321321
(string) (len=14) "resource_names": (string) (len=47) "ialbefmodl.execute-api.sa-east-1.amazonaws.com/",

aws/logs_monitoring/trace_forwarder/internal/apm/testdata/inferred_span_service_tag.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@
2323
"http.method": "GET",
2424
"resource_names": "ialbefmodl.execute-api.sa-east-1.amazonaws.com/",
2525
"request_id": "9f09f496-83c7-441b-bc59-9741107b0683",
26-
"inferred_span.inherit_lambda": "False",
27-
"inferred_span.is_async": "False",
26+
"_inferred_span.tag_source": "self",
27+
"_inferred_span.syncronicity": "sync",
2828
"http.status_code": "200"
2929
},
3030
"metrics": {

aws/logs_monitoring/trace_forwarder/internal/apm/testdata/inferred_span_service_tag.json~snapshot

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,12 +19,12 @@
1919
Meta: (map[string]string) (len=12) {
2020
(string) (len=17) "_dd.compute_stats": (string) (len=1) "1",
2121
(string) (len=10) "_dd.origin": (string) (len=6) "lambda",
22+
(string) (len=27) "_inferred_span.syncronicity": (string) (len=4) "sync",
23+
(string) (len=25) "_inferred_span.tag_source": (string) (len=4) "self",
2224
(string) (len=8) "endpoint": (string) (len=1) "/",
2325
(string) (len=11) "http.method": (string) (len=3) "GET",
2426
(string) (len=16) "http.status_code": (string) (len=3) "200",
2527
(string) (len=8) "http.url": (string) (len=2) "?/",
26-
(string) (len=28) "inferred_span.inherit_lambda": (string) (len=5) "False",
27-
(string) (len=22) "inferred_span.is_async": (string) (len=5) "False",
2828
(string) (len=14) "operation_name": (string) (len=19) "aws.apigateway.rest",
2929
(string) (len=10) "request_id": (string) (len=36) "9f09f496-83c7-441b-bc59-9741107b0683",
3030
(string) (len=14) "resource_names": (string) (len=47) "ialbefmodl.execute-api.sa-east-1.amazonaws.com/",
@@ -318,12 +318,12 @@
318318
Meta: (map[string]string) (len=12) {
319319
(string) (len=17) "_dd.compute_stats": (string) (len=1) "1",
320320
(string) (len=10) "_dd.origin": (string) (len=6) "lambda",
321+
(string) (len=27) "_inferred_span.syncronicity": (string) (len=4) "sync",
322+
(string) (len=25) "_inferred_span.tag_source": (string) (len=4) "self",
321323
(string) (len=8) "endpoint": (string) (len=1) "/",
322324
(string) (len=11) "http.method": (string) (len=3) "GET",
323325
(string) (len=16) "http.status_code": (string) (len=3) "200",
324326
(string) (len=8) "http.url": (string) (len=2) "?/",
325-
(string) (len=28) "inferred_span.inherit_lambda": (string) (len=5) "False",
326-
(string) (len=22) "inferred_span.is_async": (string) (len=5) "False",
327327
(string) (len=14) "operation_name": (string) (len=19) "aws.apigateway.rest",
328328
(string) (len=10) "request_id": (string) (len=36) "9f09f496-83c7-441b-bc59-9741107b0683",
329329
(string) (len=14) "resource_names": (string) (len=47) "ialbefmodl.execute-api.sa-east-1.amazonaws.com/",

0 commit comments

Comments
 (0)