Reintroduce the InstrumentationLibrary to Scope translation for logs

partially reverts d7b097c
fluxninja · Oct 14, 2022 · b82d435 · b82d435
1 parent 9cf80fc
commit b82d435
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/pdata/internal/otlp/logs.go b/pdata/internal/otlp/logs.go
@@ -20,4 +20,11 @@ import (
 
 // MigrateLogs implements any translation needed due to deprecation in OTLP logs protocol.
 // Any plog.Unmarshaler implementation from OTLP (proto/json) MUST call this, and the gRPC Server implementation.
-func MigrateLogs(_ []*otlplogs.ResourceLogs) {}
+func MigrateLogs(rls []*otlplogs.ResourceLogs) {
+	for _, rl := range rls {
+		if len(rl.ScopeLogs) == 0 {
+			rl.ScopeLogs = rl.InstrumentationLibraryLogs
+			rl.InstrumentationLibraryLogs = nil
+		}
+	}
+}