Use resource attribute data_stream.*

elastic · Jan 16, 2024 · 1f133b0 · 1f133b0
1 parent 37f7909
commit 1f133b0
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/input/otlp/logs_test.go b/input/otlp/logs_test.go
@@ -435,6 +435,8 @@ func TestConsumerConsumeOTelEventLogs(t *testing.T) {
 	resourceLogs := logs.ResourceLogs().AppendEmpty()
 	resourceAttrs := logs.ResourceLogs().At(0).Resource().Attributes()
 	resourceAttrs.PutStr(semconv.AttributeTelemetrySDKLanguage, "swift")
+	resourceAttrs.PutStr("data_stream.dataset", "dataset")
+	resourceAttrs.PutStr("data_stream.namespace", "namespace")
 	scopeLogs := resourceLogs.ScopeLogs().AppendEmpty()
 
 	record1 := newLogRecord("") // no log body

diff --git a/input/otlp/metadata.go b/input/otlp/metadata.go
@@ -290,6 +290,18 @@ func translateResourceMetadata(resource pcommon.Resource, out *modelpb.APMEvent)
 		case "telemetry.sdk.elastic_export_timestamp":
 			// Do nothing.
 
+		// data_stream.*
+		case attributeDataStreamDataset:
+			if out.DataStream == nil {
+				out.DataStream = modelpb.DataStreamFromVTPool()
+			}
+			out.DataStream.Dataset = v.Str()
+		case attributeDataStreamNamespace:
+			if out.DataStream == nil {
+				out.DataStream = modelpb.DataStreamFromVTPool()
+			}
+			out.DataStream.Namespace = v.Str()
+
 		default:
 			if out.Labels == nil {
 				out.Labels = make(modelpb.Labels)