Translate OTEL log's InstrumentationScope as logger name

InstrumentationScope usually contains the name of the instrumentation
library. However, in the case of logs, it may also contain the name of the
logger if the log source defines it, see [here][1]. An instrumentation
library usually has a version set, so assume that the name without the
version is the name of the logger.

[1]: https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/logs/api.md#get-a-logger

Signed-off-by: Oldřich Jedlička <oldium.pro@gmail.com>

Author: oldium

input/otlp/logs.go

@@ -119,7 +119,7 @@ func (c *Consumer) convertLogRecord(
 	event := baseEvent.CloneVT()
 	initEventLabels(event)
 
-	translateScopeMetadata(scope, event)
+	translateLogScopeMetadata(scope, event)
 
 	if record.Timestamp() == 0 {
 		event.Timestamp = modelpb.FromTime(record.ObservedTimestamp().AsTime().Add(timeDelta))

input/otlp/metadata.go

@@ -456,7 +456,7 @@ func translateResourceMetadata(resource pcommon.Resource, out *modelpb.APMEvent)
 	}
 }
 
-func translateScopeMetadata(scope pcommon.InstrumentationScope, out *modelpb.APMEvent) {
+func translateScopeCommonMetadata(scope pcommon.InstrumentationScope, out *modelpb.APMEvent) {
 	scope.Attributes().Range(func(k string, v pcommon.Value) bool {
 		switch k {
 		// data_stream.*
@@ -473,7 +473,9 @@ func translateScopeMetadata(scope pcommon.InstrumentationScope, out *modelpb.APM
 		}
 		return true
 	})
+}
 
+func translateScopeFrameworkMetadata(scope pcommon.InstrumentationScope, out *modelpb.APMEvent) {
 	if name := scope.Name(); name != "" {
 		if out.Service == nil {
 			out.Service = &modelpb.Service{}
@@ -485,6 +487,32 @@ func translateScopeMetadata(scope pcommon.InstrumentationScope, out *modelpb.APM
 	}
 }
 
+func translateLogScopeMetadata(scope pcommon.InstrumentationScope, out *modelpb.APMEvent) {
+	translateScopeCommonMetadata(scope, out)
+	if version := scope.Version(); version != "" {
+		// If the version is set, we assume the name is an instrumentation library name
+		translateScopeFrameworkMetadata(scope, out)
+	} else {
+		// If the version is not set, we assume the name is a logger name
+		if name := scope.Name(); name != "" {
+			if out.Log == nil {
+				out.Log = &modelpb.Log{}
+			}
+			out.Log.Logger = name
+		}
+	}
+}
+
+func translateSpanScopeMetadata(scope pcommon.InstrumentationScope, out *modelpb.APMEvent) {
+	translateScopeCommonMetadata(scope, out)
+	translateScopeFrameworkMetadata(scope, out)
+}
+
+func translateMetricsScopeMetadata(scope pcommon.InstrumentationScope, out *modelpb.APMEvent) {
+	translateScopeCommonMetadata(scope, out)
+	translateScopeFrameworkMetadata(scope, out)
+}
+
 func cleanServiceName(name string) string {
 	return serviceNameInvalidRegexp.ReplaceAllString(truncate(name), "_")
 }

input/otlp/metrics.go

@@ -159,7 +159,7 @@ func (c *Consumer) handleScopeMetrics(
 	for key, ms := range ms {
 		event := baseEvent.CloneVT()
 
-		translateScopeMetadata(in.Scope(), event)
+		translateMetricsScopeMetadata(in.Scope(), event)
 
 		event.Timestamp = modelpb.FromTime(key.timestamp.Add(timeDelta))
 		metrs := make([]*modelpb.MetricsetSample, 0, len(ms.samples))

input/otlp/traces.go

@@ -178,7 +178,7 @@ func (c *Consumer) convertSpan(
 	representativeCount := getRepresentativeCountFromTracestateHeader(otelSpan.TraceState().AsRaw())
 	event := baseEvent.CloneVT()
 
-	translateScopeMetadata(otelLibrary, event)
+	translateSpanScopeMetadata(otelLibrary, event)
 
 	initEventLabels(event)
 	event.Timestamp = modelpb.FromTime(startTime.Add(timeDelta))