Skip to content

Commit ca41b47

Browse files
authored
Align proto field types, tag names (#8293)
1 parent 3231443 commit ca41b47

5 files changed

Lines changed: 10 additions & 10 deletions

File tree

exporters/otlp/common/src/main/java/io/opentelemetry/exporter/internal/otlp/AttributeKeyValueStatelessMarshaler.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,8 +58,9 @@ public int getBinarySerializedSize(
5858
byte[] keyUtf8 = ((InternalAttributeKeyImpl<?>) attributeKey).getKeyUtf8();
5959
size += MarshalerUtil.sizeBytes(KeyValue.KEY, keyUtf8);
6060
} else {
61-
return StatelessMarshalerUtil.sizeStringWithContext(
62-
KeyValue.KEY, attributeKey.getKey(), context);
61+
size +=
62+
StatelessMarshalerUtil.sizeStringWithContext(
63+
KeyValue.KEY, attributeKey.getKey(), context);
6364
}
6465
}
6566
size +=

exporters/otlp/common/src/main/java/io/opentelemetry/exporter/internal/otlp/metrics/InstrumentationScopeMetricsStatelessMarshaler.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
import io.opentelemetry.exporter.internal.marshal.StatelessMarshalerUtil;
1313
import io.opentelemetry.exporter.internal.otlp.InstrumentationScopeMarshaler;
1414
import io.opentelemetry.proto.metrics.v1.internal.ScopeMetrics;
15-
import io.opentelemetry.proto.trace.v1.internal.ScopeSpans;
1615
import io.opentelemetry.sdk.common.InstrumentationScopeInfo;
1716
import io.opentelemetry.sdk.metrics.data.MetricData;
1817
import java.io.IOException;
@@ -59,7 +58,7 @@ public int getBinarySerializedSize(
5958
ScopeMetrics.METRICS, metrics, MetricStatelessMarshaler.INSTANCE, context);
6059
size +=
6160
StatelessMarshalerUtil.sizeStringWithContext(
62-
ScopeSpans.SCHEMA_URL, instrumentationScope.getSchemaUrl(), context);
61+
ScopeMetrics.SCHEMA_URL, instrumentationScope.getSchemaUrl(), context);
6362

6463
return size;
6564
}

exporters/otlp/profiles/src/main/java/io/opentelemetry/exporter/otlp/profiles/KeyValueAndUnitMarshaler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ private KeyValueAndUnitMarshaler(
6363
protected void writeTo(Serializer output) throws IOException {
6464
output.serializeInt32(KeyValueAndUnit.KEY_STRINDEX, keyStringIndex);
6565
output.serializeMessage(KeyValueAndUnit.VALUE, valueMarshaler);
66-
output.serializeInt64(KeyValueAndUnit.UNIT_STRINDEX, unitStringIndex);
66+
output.serializeInt32(KeyValueAndUnit.UNIT_STRINDEX, unitStringIndex);
6767
}
6868

6969
private static int calculateSize(

exporters/otlp/profiles/src/main/java/io/opentelemetry/exporter/otlp/profiles/ProfileMarshaler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ protected void writeTo(Serializer output) throws IOException {
9393
output.serializeMessage(Profile.SAMPLE_TYPE, sampleTypeMarshaler);
9494
output.serializeRepeatedMessage(Profile.SAMPLES, sampleMarshalers);
9595
output.serializeFixed64(Profile.TIME_UNIX_NANO, timeNanos);
96-
output.serializeInt64(Profile.DURATION_NANO, durationNanos);
96+
output.serializeUInt64(Profile.DURATION_NANO, durationNanos);
9797
output.serializeMessage(Profile.PERIOD_TYPE, periodTypeMarshaler);
9898
output.serializeInt64(Profile.PERIOD, period);
9999

@@ -121,12 +121,12 @@ private static int calculateSize(
121121
size += MarshalerUtil.sizeMessage(Profile.SAMPLE_TYPE, sampleTypeMarshaler);
122122
size += MarshalerUtil.sizeRepeatedMessage(Profile.SAMPLES, sampleMarshalers);
123123
size += MarshalerUtil.sizeFixed64(Profile.TIME_UNIX_NANO, timeNanos);
124-
size += MarshalerUtil.sizeInt64(Profile.DURATION_NANO, durationNanos);
124+
size += MarshalerUtil.sizeUInt64(Profile.DURATION_NANO, durationNanos);
125125
size += MarshalerUtil.sizeMessage(Profile.PERIOD_TYPE, periodTypeMarshaler);
126126
size += MarshalerUtil.sizeInt64(Profile.PERIOD, period);
127127

128128
size += MarshalerUtil.sizeBytes(Profile.PROFILE_ID, profileId);
129-
size += MarshalerUtil.sizeInt32(Profile.DROPPED_ATTRIBUTES_COUNT, droppedAttributesCount);
129+
size += MarshalerUtil.sizeUInt32(Profile.DROPPED_ATTRIBUTES_COUNT, droppedAttributesCount);
130130
size += MarshalerUtil.sizeBytes(Profile.ORIGINAL_PAYLOAD_FORMAT, originalPayloadFormat);
131131
size += MarshalerUtil.sizeByteBuffer(Profile.ORIGINAL_PAYLOAD, originalPayload);
132132
size += MarshalerUtil.sizeRepeatedInt32(Profile.ATTRIBUTE_INDICES, attributeIndices);

exporters/otlp/profiles/src/main/java/io/opentelemetry/exporter/otlp/profiles/ValueTypeMarshaler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,8 @@ private ValueTypeMarshaler(int typeStringIndex, int unitStringIndex) {
5151

5252
@Override
5353
protected void writeTo(Serializer output) throws IOException {
54-
output.serializeInt64(ValueType.TYPE_STRINDEX, typeStringIndex);
55-
output.serializeInt64(ValueType.UNIT_STRINDEX, unitStringIndex);
54+
output.serializeInt32(ValueType.TYPE_STRINDEX, typeStringIndex);
55+
output.serializeInt32(ValueType.UNIT_STRINDEX, unitStringIndex);
5656
}
5757

5858
private static int calculateSize(int typeStringIndex, int unitStringIndex) {

0 commit comments

Comments
 (0)