-
Notifications
You must be signed in to change notification settings - Fork 1
/
span_status.go
73 lines (64 loc) · 2.18 KB
/
span_status.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
package sentry
import (
sdk "github.com/getsentry/sentry-go"
"go.opentelemetry.io/otel/codes"
"go.opentelemetry.io/otel/sdk/trace"
semConv "go.opentelemetry.io/otel/semconv/v1.20.0"
)
// Maps some HTTP codes to Sentry's span statuses.
// https://develop.sentry.dev/sdk/event-payloads/span/
var canonicalCodesHTTPMap = map[string]sdk.SpanStatus{
"400": sdk.SpanStatusFailedPrecondition, // SpanStatusInvalidArgument, SpanStatusOutOfRange
"401": sdk.SpanStatusUnauthenticated,
"403": sdk.SpanStatusPermissionDenied,
"404": sdk.SpanStatusNotFound,
"409": sdk.SpanStatusAborted, // SpanStatusAlreadyExists
"429": sdk.SpanStatusResourceExhausted,
"499": sdk.SpanStatusCanceled,
"500": sdk.SpanStatusInternalError, // SpanStatusDataLoss, SpanStatusUnknown
"501": sdk.SpanStatusUnimplemented,
"503": sdk.SpanStatusUnavailable,
"504": sdk.SpanStatusDeadlineExceeded,
}
// Maps some GRPC codes to Sentry's span statuses.
var canonicalCodesGrpcMap = map[string]sdk.SpanStatus{
"1": sdk.SpanStatusCanceled,
"2": sdk.SpanStatusUnknown,
"3": sdk.SpanStatusInvalidArgument,
"4": sdk.SpanStatusDeadlineExceeded,
"5": sdk.SpanStatusNotFound,
"6": sdk.SpanStatusAlreadyExists,
"7": sdk.SpanStatusPermissionDenied,
"8": sdk.SpanStatusResourceExhausted,
"9": sdk.SpanStatusFailedPrecondition,
"10": sdk.SpanStatusAborted,
"11": sdk.SpanStatusOutOfRange,
"12": sdk.SpanStatusUnimplemented,
"13": sdk.SpanStatusInternalError,
"14": sdk.SpanStatusUnavailable,
"15": sdk.SpanStatusDataLoss,
"16": sdk.SpanStatusUnauthenticated,
}
// Get a suitable span status from an OTEL span.
func getStatus(s trace.ReadOnlySpan) sdk.SpanStatus {
statusCode := s.Status().Code
for _, attribute := range s.Attributes() {
if attribute.Key == semConv.HTTPStatusCodeKey {
if status, ok := canonicalCodesHTTPMap[attribute.Value.AsString()]; ok {
return status
}
}
if attribute.Key == semConv.RPCGRPCStatusCodeKey {
if status, ok := canonicalCodesGrpcMap[attribute.Value.AsString()]; ok {
return status
}
}
}
if statusCode == codes.Unset || statusCode == codes.Ok {
return sdk.SpanStatusOK
}
if statusCode == codes.Error {
return sdk.SpanStatusInternalError
}
return sdk.SpanStatusUnknown
}