Skip to content

Commit f58bfab

Browse files
committed
fix(disk-buffering): Add missing EventName to disk-buffering LogRecord data mapper
1 parent 0a37bb9 commit f58bfab

File tree

3 files changed

+13
-0
lines changed

3 files changed

+13
-0
lines changed

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/serialization/mapping/logs/LogRecordDataMapper.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,9 @@ public LogRecord mapToProto(LogRecordData source) {
4747
if (source.getBodyValue() != null) {
4848
logRecord.body(bodyToAnyValue(source.getBodyValue()));
4949
}
50+
if (source.getEventName() != null) {
51+
logRecord.event_name(source.getEventName());
52+
}
5053

5154
byte flags = source.getSpanContext().getTraceFlags().asByte();
5255
logRecord.flags(toUnsignedInt(flags));
@@ -77,6 +80,9 @@ public LogRecordData mapToSdk(
7780
if (source.body != null) {
7881
logRecordData.setBodyValue(anyValueToBody(source.body));
7982
}
83+
if (source.event_name != null) {
84+
logRecordData.setEventName(source.event_name);
85+
}
8086

8187
addExtrasToSdkItemBuilder(source, logRecordData, resource, scopeInfo);
8288

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/serialization/mapping/logs/models/LogRecordDataImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,10 @@ public ExtendedAttributes getExtendedAttributes() {
4646
@Nullable
4747
public abstract Value<?> getBodyValue();
4848

49+
@Override
50+
@Nullable
51+
public abstract String getEventName();
52+
4953
@AutoValue.Builder
5054
public abstract static class Builder {
5155
public abstract Builder setResource(Resource value);
@@ -68,6 +72,8 @@ public abstract static class Builder {
6872

6973
public abstract Builder setTotalAttributeCount(Integer value);
7074

75+
public abstract Builder setEventName(String value);
76+
7177
public abstract LogRecordDataImpl build();
7278
}
7379
}

disk-buffering/src/test/java/io/opentelemetry/contrib/disk/buffering/internal/serialization/mapping/logs/LogRecordDataMapperTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@ class LogRecordDataMapperTest {
3131
.setTimestampEpochNanos(100L)
3232
.setObservedTimestampEpochNanos(200L)
3333
.setTotalAttributeCount(3)
34+
.setEventName("my.event.name")
3435
.build();
3536

3637
@Test

0 commit comments

Comments
 (0)