diff --git a/CHANGELOG.md b/CHANGELOG.md index 0764a1d9705..0fa3e8c95df 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -16,6 +16,8 @@ This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.htm - `AssertRecordEqual` in `go.opentelemetry.io/otel/log/logtest` checks `Record.EventName`. (#6187) - Add `EventName` and `SetEventName` to `Record` in `go.opentelemetry.io/otel/sdk/log`. (#6193) - Add `EventName` to `RecordFactory` in `go.opentelemetry.io/otel/sdk/log/logtest`. (#6193) +- Emit `Record.EventName` field in `go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc`. (#6211) +- Emit `Record.EventName` field in `go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploghttp`. (#6211) ### Changed diff --git a/exporters/otlp/otlplog/otlploggrpc/internal/transform/log.go b/exporters/otlp/otlplog/otlploggrpc/internal/transform/log.go index 03e9d8c71cd..dfeecf59662 100644 --- a/exporters/otlp/otlplog/otlploggrpc/internal/transform/log.go +++ b/exporters/otlp/otlplog/otlploggrpc/internal/transform/log.go @@ -91,6 +91,7 @@ func LogRecord(record log.Record) *lpb.LogRecord { r := &lpb.LogRecord{ TimeUnixNano: timeUnixNano(record.Timestamp()), ObservedTimeUnixNano: timeUnixNano(record.ObservedTimestamp()), + EventName: record.EventName(), SeverityNumber: SeverityNumber(record.Severity()), SeverityText: record.SeverityText(), Body: LogAttrValue(record.Body()), diff --git a/exporters/otlp/otlplog/otlploggrpc/internal/transform/log_test.go b/exporters/otlp/otlplog/otlploggrpc/internal/transform/log_test.go index ead467814ef..f9af477dc6a 100644 --- a/exporters/otlp/otlplog/otlploggrpc/internal/transform/log_test.go +++ b/exporters/otlp/otlplog/otlploggrpc/internal/transform/log_test.go @@ -153,6 +153,7 @@ var ( out = append(out, logtest.RecordFactory{ Timestamp: ts, ObservedTimestamp: obs, + EventName: "evnt", Severity: sevC, SeverityText: "C", Body: bodyC, @@ -229,6 +230,7 @@ var ( { TimeUnixNano: uint64(ts.UnixNano()), ObservedTimeUnixNano: uint64(obs.UnixNano()), + EventName: "evnt", SeverityNumber: pbSevC, SeverityText: "C", Body: pbBodyC, diff --git a/exporters/otlp/otlplog/otlploghttp/internal/transform/log.go b/exporters/otlp/otlplog/otlploghttp/internal/transform/log.go index 4b52a14ebc6..adf407800c9 100644 --- a/exporters/otlp/otlplog/otlploghttp/internal/transform/log.go +++ b/exporters/otlp/otlplog/otlploghttp/internal/transform/log.go @@ -91,6 +91,7 @@ func LogRecord(record log.Record) *lpb.LogRecord { r := &lpb.LogRecord{ TimeUnixNano: timeUnixNano(record.Timestamp()), ObservedTimeUnixNano: timeUnixNano(record.ObservedTimestamp()), + EventName: record.EventName(), SeverityNumber: SeverityNumber(record.Severity()), SeverityText: record.SeverityText(), Body: LogAttrValue(record.Body()), diff --git a/exporters/otlp/otlplog/otlploghttp/internal/transform/log_test.go b/exporters/otlp/otlplog/otlploghttp/internal/transform/log_test.go index ead467814ef..f9af477dc6a 100644 --- a/exporters/otlp/otlplog/otlploghttp/internal/transform/log_test.go +++ b/exporters/otlp/otlplog/otlploghttp/internal/transform/log_test.go @@ -153,6 +153,7 @@ var ( out = append(out, logtest.RecordFactory{ Timestamp: ts, ObservedTimestamp: obs, + EventName: "evnt", Severity: sevC, SeverityText: "C", Body: bodyC, @@ -229,6 +230,7 @@ var ( { TimeUnixNano: uint64(ts.UnixNano()), ObservedTimeUnixNano: uint64(obs.UnixNano()), + EventName: "evnt", SeverityNumber: pbSevC, SeverityText: "C", Body: pbBodyC, diff --git a/internal/shared/otlp/otlplog/transform/log.go.tmpl b/internal/shared/otlp/otlplog/transform/log.go.tmpl index 4b52a14ebc6..adf407800c9 100644 --- a/internal/shared/otlp/otlplog/transform/log.go.tmpl +++ b/internal/shared/otlp/otlplog/transform/log.go.tmpl @@ -91,6 +91,7 @@ func LogRecord(record log.Record) *lpb.LogRecord { r := &lpb.LogRecord{ TimeUnixNano: timeUnixNano(record.Timestamp()), ObservedTimeUnixNano: timeUnixNano(record.ObservedTimestamp()), + EventName: record.EventName(), SeverityNumber: SeverityNumber(record.Severity()), SeverityText: record.SeverityText(), Body: LogAttrValue(record.Body()), diff --git a/internal/shared/otlp/otlplog/transform/log_test.go.tmpl b/internal/shared/otlp/otlplog/transform/log_test.go.tmpl index ead467814ef..f9af477dc6a 100644 --- a/internal/shared/otlp/otlplog/transform/log_test.go.tmpl +++ b/internal/shared/otlp/otlplog/transform/log_test.go.tmpl @@ -153,6 +153,7 @@ var ( out = append(out, logtest.RecordFactory{ Timestamp: ts, ObservedTimestamp: obs, + EventName: "evnt", Severity: sevC, SeverityText: "C", Body: bodyC, @@ -229,6 +230,7 @@ var ( { TimeUnixNano: uint64(ts.UnixNano()), ObservedTimeUnixNano: uint64(obs.UnixNano()), + EventName: "evnt", SeverityNumber: pbSevC, SeverityText: "C", Body: pbBodyC,