Skip to content

Commit 829c688

Browse files
committed
Perform Minor Cleanups
Signed-off-by: Mahad Zaryab <[email protected]>
1 parent 4fe3dc2 commit 829c688

File tree

2 files changed

+15
-5
lines changed

2 files changed

+15
-5
lines changed

cmd/jaeger/internal/sanitizer/utf8.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -90,9 +90,6 @@ func sanitizeAttributes(attributes pcommon.Map) {
9090
newVal := attributes.PutEmptyBytes(newKey)
9191
newVal.Append(sanitized...)
9292
i++
93-
}
94-
95-
for k := range invalidKeys {
9693
attributes.Remove(k)
9794
}
9895
}

cmd/jaeger/internal/sanitizer/utf8_test.go

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -233,7 +233,8 @@ func TestUTF8Sanitizer_DoesNotSanitizeNonStringAttributeValue(t *testing.T) {
233233
ResourceSpans().
234234
AppendEmpty().
235235
Resource().
236-
Attributes().PutInt("key", 99)
236+
Attributes().
237+
PutInt("key", 99)
237238
sanitizer := NewUTF8Sanitizer()
238239
sanitized := sanitizer(traces)
239240
value, ok := sanitized.
@@ -252,7 +253,8 @@ func TestUTF8Sanitizer_SanitizesNonStringAttributeValueWithInvalidKey(t *testing
252253
ResourceSpans().
253254
AppendEmpty().
254255
Resource().
255-
Attributes().PutInt(invalidUTF8(), 99)
256+
Attributes().
257+
PutInt(invalidUTF8(), 99)
256258
sanitizer := NewUTF8Sanitizer()
257259
sanitized := sanitizer(traces)
258260
value, ok := sanitized.
@@ -268,6 +270,7 @@ func TestUTF8Sanitizer_SanitizesNonStringAttributeValueWithInvalidKey(t *testing
268270
func TestUTF8Sanitizer_SanitizesMultipleAttributesWithInvalidKeys(t *testing.T) {
269271
k1 := fmt.Sprintf("%s-%d", invalidUTF8(), 1)
270272
k2 := fmt.Sprintf("%s-%d", invalidUTF8(), 2)
273+
k3 := fmt.Sprintf("%s-%d", invalidUTF8(), 3)
271274
traces := ptrace.NewTraces()
272275
attributes := traces.
273276
ResourceSpans().
@@ -277,6 +280,7 @@ func TestUTF8Sanitizer_SanitizesMultipleAttributesWithInvalidKeys(t *testing.T)
277280

278281
attributes.PutStr(k1, "v1")
279282
attributes.PutStr(k2, "v2")
283+
attributes.PutStr(k3, "v3")
280284

281285
sanitizer := NewUTF8Sanitizer()
282286
sanitized := sanitizer(traces)
@@ -297,4 +301,13 @@ func TestUTF8Sanitizer_SanitizesMultipleAttributesWithInvalidKeys(t *testing.T)
297301
Get("invalid-tag-key-2")
298302
require.True(t, ok)
299303
require.EqualValues(t, getBytesValueFromString(fmt.Sprintf("%s:v2", k2)), value)
304+
305+
value, ok = sanitized.
306+
ResourceSpans().
307+
At(0).
308+
Resource().
309+
Attributes().
310+
Get("invalid-tag-key-3")
311+
require.True(t, ok)
312+
require.EqualValues(t, getBytesValueFromString(fmt.Sprintf("%s:v3", k3)), value)
300313
}

0 commit comments

Comments
 (0)