open-telemetry
/
opentelemetry-java
mirror of https://github.com/open-telemetry/opentelemetry-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Migrate exemplar data to interface (#4253) 

* Migrate exemplar data to interface

* internal
This commit is contained in:
Anuraag Agrawal 2022-03-10 12:08:38 +09:00 committed by GitHub
parent ef427f69ce
commit b0cdfdb78b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
18 changed files with 151 additions and 114 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
exporters/otlp/common/src/test/java/io/opentelemetry/exporter/internal/otlp/metrics/MetricsRequestMarshalerTest.java
View File

@ -41,16 +41,16 @@ import io.opentelemetry.proto.metrics.v1.Summary;
import io.opentelemetry.proto.metrics.v1.SummaryDataPoint;
import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.HistogramPointData;
import io.opentelemetry.sdk.metrics.data.LongExemplarData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.data.PointData;
import io.opentelemetry.sdk.metrics.data.SummaryPointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoublePointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableGaugeData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableHistogramData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableHistogramPointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongPointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableSumData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableSummaryData;
@ -92,7 +92,7 @@ class MetricsRequestMarshalerTest {
KV_ATTR,
0,
singletonList(
LongExemplarData.create(
ImmutableLongExemplarData.create(
Attributes.of(stringKey("test"), "value"),
2,
SpanContext.create(
@ -134,7 +134,7 @@ class MetricsRequestMarshalerTest {
KV_ATTR,
0,
singletonList(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.of(stringKey("test"), "value"),
2,
SpanContext.create(
@ -180,7 +180,7 @@ class MetricsRequestMarshalerTest {
KV_ATTR,
5,
singletonList(
LongExemplarData.create(
ImmutableLongExemplarData.create(
Attributes.of(stringKey("test"), "value"),
2,
SpanContext.create(
@ -353,7 +353,7 @@ class MetricsRequestMarshalerTest {
ImmutableList.of(),
ImmutableList.of(7L),
ImmutableList.of(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.of(stringKey("test"), "value"),
2,
SpanContext.create(
@ -413,7 +413,7 @@ class MetricsRequestMarshalerTest {
456,
Attributes.of(stringKey("key"), "value"),
ImmutableList.of(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.of(stringKey("test"), "value"),
2,
SpanContext.create(

8
exporters/prometheus/src/test/java/io/opentelemetry/exporter/prometheus/MetricAdapterTest.java
View File

@ -15,13 +15,13 @@ import io.opentelemetry.api.trace.TraceFlags;
import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.LongExemplarData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.data.MetricDataType;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoublePointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableGaugeData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableHistogramData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableHistogramPointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongPointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableSumData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableSummaryData;
@ -211,7 +211,7 @@ class MetricAdapterTest {
Collections.emptyList(),
Collections.singletonList(2L),
Collections.singletonList(
LongExemplarData.create(
ImmutableLongExemplarData.create(
Attributes.empty(),
TimeUnit.MILLISECONDS.toNanos(1L),
SpanContext.create(
@ -545,7 +545,7 @@ class MetricAdapterTest {
ImmutableList.of(1.0),
ImmutableList.of(4L, 9L),
ImmutableList.of(
LongExemplarData.create(
ImmutableLongExemplarData.create(
Attributes.empty(),
/*recordTime=*/ 0,
SpanContext.create(
@ -554,7 +554,7 @@ class MetricAdapterTest {
TraceFlags.getDefault(),
TraceState.getDefault()),
/*value=*/ 0),
LongExemplarData.create(
ImmutableLongExemplarData.create(
Attributes.empty(),
/*recordTime=*/ TimeUnit.MILLISECONDS.toNanos(2),
SpanContext.create(

4
exporters/prometheus/src/test/java/io/opentelemetry/exporter/prometheus/SerializerTest.java
View File

@ -14,12 +14,12 @@ import io.opentelemetry.api.trace.TraceFlags;
import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.LongExemplarData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoublePointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableGaugeData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableHistogramData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableHistogramPointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongPointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableSumData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableSummaryData;
@ -201,7 +201,7 @@ class SerializerTest {
Collections.emptyList(),
Collections.singletonList(2L),
Collections.singletonList(
LongExemplarData.create(
ImmutableLongExemplarData.create(
Attributes.empty(),
TimeUnit.MILLISECONDS.toNanos(1L),
SpanContext.create(

4
opencensus-shim/src/main/java/io/opentelemetry/opencensusshim/internal/metrics/MetricAdapter.java
View File

@ -22,7 +22,6 @@ import io.opentelemetry.api.trace.TraceFlags;
import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.DoublePointData;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.data.GaugeData;
@ -34,6 +33,7 @@ import io.opentelemetry.sdk.metrics.data.SumData;
import io.opentelemetry.sdk.metrics.data.SummaryData;
import io.opentelemetry.sdk.metrics.data.SummaryPointData;
import io.opentelemetry.sdk.metrics.data.ValueAtQuantile;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoublePointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableGaugeData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableHistogramData;
@ -355,7 +355,7 @@ public final class MetricAdapter {
SpanContext.create(traceId, spanId, TraceFlags.getDefault(), TraceState.getDefault());
}
}
return DoubleExemplarData.create(
return ImmutableDoubleExemplarData.create(
Attributes.empty(),
mapTimestamp(exemplar.getTimestamp()),
spanContext,

10
opencensus-shim/src/test/java/io/opentelemetry/opencensusshim/internal/metrics/MetricAdapterTest.java
View File

@ -24,7 +24,7 @@ import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.trace.SpanContext;
import io.opentelemetry.api.trace.TraceFlags;
import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableValueAtQuantile;
import io.opentelemetry.sdk.resources.Resource;
import java.util.Arrays;
@ -246,9 +246,9 @@ class MetricAdapterTest {
.hasBucketBoundaries(2.0, 5.0)
.hasBucketCounts(2, 6, 2)
.hasExemplars(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.empty(), 2000000, SpanContext.getInvalid(), 1.0),
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.empty(),
1000000,
SpanContext.create(
@ -361,9 +361,9 @@ class MetricAdapterTest {
.hasBucketBoundaries(2.0, 5.0)
.hasBucketCounts(2, 6, 2)
.hasExemplars(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.empty(), 2000000, SpanContext.getInvalid(), 1.0),
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.empty(),
1000000,
SpanContext.create(

10
sdk/metrics-testing/src/test/java/io/opentelemetry/sdk/testing/assertj/MetricAssertionsTest.java
View File

@ -23,10 +23,12 @@ import io.opentelemetry.sdk.metrics.data.LongPointData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.data.SummaryPointData;
import io.opentelemetry.sdk.metrics.data.ValueAtQuantile;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoublePointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableGaugeData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableHistogramData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableHistogramPointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongPointData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableSumData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableSummaryData;
@ -140,7 +142,7 @@ public class MetricAssertionsTest {
Collections.emptyList()));
private static final DoubleExemplarData DOUBLE_EXEMPLAR =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.empty(),
0,
SpanContext.create(
@ -195,7 +197,7 @@ public class MetricAssertionsTest {
Collections.emptyList()));
private static final LongExemplarData LONG_EXEMPLAR =
LongExemplarData.create(
ImmutableLongExemplarData.create(
Attributes.empty(),
0,
SpanContext.create(
@ -369,7 +371,7 @@ public class MetricAssertionsTest {
() ->
assertThat(DOUBLE_POINT_DATA)
.hasExemplars(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.empty(),
0,
SpanContext.create(
@ -412,7 +414,7 @@ public class MetricAssertionsTest {
() ->
assertThat(LONG_POINT_DATA)
.hasExemplars(
LongExemplarData.create(
ImmutableLongExemplarData.create(
Attributes.empty(),
0,
SpanContext.create(

29
sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/data/DoubleExemplarData.java
View File

@ -5,33 +5,8 @@
package io.opentelemetry.sdk.metrics.data;
import com.google.auto.value.AutoValue;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.trace.SpanContext;
import javax.annotation.concurrent.Immutable;
/** An {@link ExemplarData} with {@code double} measurements. */
@Immutable
@AutoValue
public abstract class DoubleExemplarData implements ExemplarData {
/**
* Construct a new exemplar.
*
* @param filteredAttributes The set of {@link Attributes} not already associated with the {@link
* PointData}.
* @param recordTimeNanos The time when the sample qas recorded in nanoseconds.
* @param spanContext The associated span context.
* @param value The value recorded.
*/
public static DoubleExemplarData create(
Attributes filteredAttributes, long recordTimeNanos, SpanContext spanContext, double value) {
return new AutoValue_DoubleExemplarData(
filteredAttributes, recordTimeNanos, spanContext, value);
}
DoubleExemplarData() {}
public interface DoubleExemplarData extends ExemplarData {
/** Numerical value of the measurement that was recorded. */
public abstract double getValue();
double getValue();
}

28
sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/data/LongExemplarData.java
View File

@ -5,32 +5,8 @@
package io.opentelemetry.sdk.metrics.data;
import com.google.auto.value.AutoValue;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.trace.SpanContext;
import javax.annotation.concurrent.Immutable;
/** An {@link ExemplarData} with {@code long} measurements. */
@Immutable
@AutoValue
public abstract class LongExemplarData implements ExemplarData {
/**
* Construct a new exemplar.
*
* @param filteredAttributes The set of {@link Attributes} not already associated with the {@link
* PointData}.
* @param recordTimeNanos The time when the sample qas recorded in nanoseconds.
* @param spanContext The associated span context.
* @param value The value recorded.
*/
public static LongExemplarData create(
Attributes filteredAttributes, long recordTimeNanos, SpanContext spanContext, long value) {
return new AutoValue_LongExemplarData(filteredAttributes, recordTimeNanos, spanContext, value);
}
LongExemplarData() {}
public interface LongExemplarData extends ExemplarData {
/** Numerical value of the measurement that was recorded. */
public abstract long getValue();
long getValue();
}

4
sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/exemplar/AbstractFixedSizeExemplarReservoir.java
View File

@ -11,8 +11,8 @@ import io.opentelemetry.api.trace.Span;
import io.opentelemetry.api.trace.SpanContext;
import io.opentelemetry.context.Context;
import io.opentelemetry.sdk.common.Clock;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
@ -118,7 +118,7 @@ abstract class AbstractFixedSizeExemplarReservoir implements ExemplarReservoir {
Attributes attributes = this.attributes;
if (attributes != null) {
ExemplarData result =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
filtered(attributes, pointAttributes), recordTime, spanContext, value);
this.attributes = null;
this.value = 0;

42
sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/data/ImmutableDoubleExemplarData.java Normal file
View File

@ -0,0 +1,42 @@
/*
* Copyright The OpenTelemetry Authors
* SPDX-License-Identifier: Apache-2.0
*/
package io.opentelemetry.sdk.metrics.internal.data;
import com.google.auto.value.AutoValue;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.trace.SpanContext;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.data.PointData;
import javax.annotation.concurrent.Immutable;
/**
* An {@link ExemplarData} with {@code double} measurements.
*
* <p>This class is internal and is hence not for public use. Its APIs are unstable and can change
* at any time.
*/
@Immutable
@AutoValue
public abstract class ImmutableDoubleExemplarData implements DoubleExemplarData {
/**
* Construct a new exemplar.
*
* @param filteredAttributes The set of {@link Attributes} not already associated with the {@link
* PointData}.
* @param recordTimeNanos The time when the sample qas recorded in nanoseconds.
* @param spanContext The associated span context.
* @param value The value recorded.
*/
public static DoubleExemplarData create(
Attributes filteredAttributes, long recordTimeNanos, SpanContext spanContext, double value) {
return new AutoValue_ImmutableDoubleExemplarData(
filteredAttributes, recordTimeNanos, spanContext, value);
}
ImmutableDoubleExemplarData() {}
}

42
sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/data/ImmutableLongExemplarData.java Normal file
View File

@ -0,0 +1,42 @@
/*
* Copyright The OpenTelemetry Authors
* SPDX-License-Identifier: Apache-2.0
*/
package io.opentelemetry.sdk.metrics.internal.data;
import com.google.auto.value.AutoValue;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.trace.SpanContext;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.data.LongExemplarData;
import io.opentelemetry.sdk.metrics.data.PointData;
import javax.annotation.concurrent.Immutable;
/**
* An {@link ExemplarData} with {@code long} measurements.
*
* <p>This class is internal and is hence not for public use. Its APIs are unstable and can change
* at any time.
*/
@Immutable
@AutoValue
public abstract class ImmutableLongExemplarData implements LongExemplarData {
/**
* Construct a new exemplar.
*
* @param filteredAttributes The set of {@link Attributes} not already associated with the {@link
* PointData}.
* @param recordTimeNanos The time when the sample qas recorded in nanoseconds.
* @param spanContext The associated span context.
* @param value The value recorded.
*/
public static LongExemplarData create(
Attributes filteredAttributes, long recordTimeNanos, SpanContext spanContext, long value) {
return new AutoValue_ImmutableLongExemplarData(
filteredAttributes, recordTimeNanos, spanContext, value);
}
ImmutableLongExemplarData() {}
}

4
sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/aggregator/AggregatorHandleTest.java
View File

@ -13,9 +13,9 @@ import io.opentelemetry.api.trace.SpanContext;
import io.opentelemetry.api.trace.TraceFlags;
import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.context.Context;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.exemplar.ExemplarReservoir;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.atomic.AtomicLong;
@ -131,7 +131,7 @@ class AggregatorHandleTest {
TestAggregatorHandle testAggregator = new TestAggregatorHandle(reservoir);
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData result =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(

18
sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/aggregator/DoubleExponentialHistogramAggregatorTest.java
View File

@ -15,10 +15,10 @@ import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.context.Context;
import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.exemplar.ExemplarReservoir;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.exponentialhistogram.ExponentialHistogramBuckets;
import io.opentelemetry.sdk.metrics.internal.data.exponentialhistogram.ExponentialHistogramData;
import io.opentelemetry.sdk.metrics.internal.descriptor.MetricDescriptor;
@ -187,7 +187,7 @@ class DoubleExponentialHistogramAggregatorTest {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -234,7 +234,7 @@ class DoubleExponentialHistogramAggregatorTest {
void diffAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -246,7 +246,7 @@ class DoubleExponentialHistogramAggregatorTest {
List<ExemplarData> exemplars = Collections.singletonList(exemplar);
List<ExemplarData> previousExemplars =
Collections.singletonList(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
1L,
SpanContext.create(
@ -273,7 +273,7 @@ class DoubleExponentialHistogramAggregatorTest {
void diffDownScaledAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -285,7 +285,7 @@ class DoubleExponentialHistogramAggregatorTest {
List<ExemplarData> exemplars = Collections.singletonList(exemplar);
List<ExemplarData> previousExemplars =
Collections.singletonList(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
1L,
SpanContext.create(
@ -309,7 +309,7 @@ class DoubleExponentialHistogramAggregatorTest {
void testMergeAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -321,7 +321,7 @@ class DoubleExponentialHistogramAggregatorTest {
List<ExemplarData> exemplars = Collections.singletonList(exemplar);
List<ExemplarData> previousExemplars =
Collections.singletonList(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
1L,
SpanContext.create(
@ -434,7 +434,7 @@ class DoubleExponentialHistogramAggregatorTest {
void testToMetricData() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(

14
sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/aggregator/DoubleHistogramAggregatorTest.java
View File

@ -15,11 +15,11 @@ import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.context.Context;
import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.data.MetricDataType;
import io.opentelemetry.sdk.metrics.exemplar.ExemplarReservoir;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.descriptor.MetricDescriptor;
import io.opentelemetry.sdk.resources.Resource;
import java.util.Collections;
@ -69,7 +69,7 @@ class DoubleHistogramAggregatorTest {
void testExemplarsInAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -116,7 +116,7 @@ class DoubleHistogramAggregatorTest {
void mergeAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -128,7 +128,7 @@ class DoubleHistogramAggregatorTest {
List<ExemplarData> exemplars = Collections.singletonList(exemplar);
List<ExemplarData> previousExemplars =
Collections.singletonList(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
1L,
SpanContext.create(
@ -150,7 +150,7 @@ class DoubleHistogramAggregatorTest {
void diffAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -162,7 +162,7 @@ class DoubleHistogramAggregatorTest {
List<ExemplarData> exemplars = Collections.singletonList(exemplar);
List<ExemplarData> previousExemplars =
Collections.singletonList(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
1L,
SpanContext.create(
@ -206,7 +206,7 @@ class DoubleHistogramAggregatorTest {
void toMetricDataWithExemplars() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(

10
sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/aggregator/DoubleLastValueAggregatorTest.java
View File

@ -13,10 +13,10 @@ import io.opentelemetry.api.trace.TraceFlags;
import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.exemplar.ExemplarReservoir;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.descriptor.MetricDescriptor;
import io.opentelemetry.sdk.resources.Resource;
import java.util.Collections;
@ -66,7 +66,7 @@ class DoubleLastValueAggregatorTest {
void mergeAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -78,7 +78,7 @@ class DoubleLastValueAggregatorTest {
List<ExemplarData> exemplars = Collections.singletonList(exemplar);
List<ExemplarData> previousExemplars =
Collections.singletonList(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
1L,
SpanContext.create(
@ -99,7 +99,7 @@ class DoubleLastValueAggregatorTest {
void diffAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -111,7 +111,7 @@ class DoubleLastValueAggregatorTest {
List<ExemplarData> exemplars = Collections.singletonList(exemplar);
List<ExemplarData> previousExemplars =
Collections.singletonList(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
1L,
SpanContext.create(

10
sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/aggregator/DoubleSumAggregatorTest.java
View File

@ -16,10 +16,10 @@ import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.common.InstrumentType;
import io.opentelemetry.sdk.metrics.common.InstrumentValueType;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.exemplar.ExemplarReservoir;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.descriptor.InstrumentDescriptor;
import io.opentelemetry.sdk.metrics.internal.descriptor.MetricDescriptor;
import io.opentelemetry.sdk.resources.Resource;
@ -101,7 +101,7 @@ class DoubleSumAggregatorTest {
void testExemplarsInAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -131,7 +131,7 @@ class DoubleSumAggregatorTest {
void mergeAndDiff() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -143,7 +143,7 @@ class DoubleSumAggregatorTest {
List<ExemplarData> exemplars = Collections.singletonList(exemplar);
List<ExemplarData> previousExemplars =
Collections.singletonList(
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
1L,
SpanContext.create(
@ -221,7 +221,7 @@ class DoubleSumAggregatorTest {
void toMetricDataWithExemplars() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(

6
sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/aggregator/LongLastValueAggregatorTest.java
View File

@ -14,10 +14,10 @@ import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.data.LongExemplarData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.exemplar.ExemplarReservoir;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableGaugeData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongExemplarData;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableLongPointData;
import io.opentelemetry.sdk.metrics.internal.descriptor.MetricDescriptor;
import io.opentelemetry.sdk.resources.Resource;
@ -68,7 +68,7 @@ class LongLastValueAggregatorTest {
void mergeAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
LongExemplarData.create(
ImmutableLongExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -80,7 +80,7 @@ class LongLastValueAggregatorTest {
List<ExemplarData> exemplars = Collections.singletonList(exemplar);
List<ExemplarData> previousExemplars =
Collections.singletonList(
LongExemplarData.create(
ImmutableLongExemplarData.create(
attributes,
1L,
SpanContext.create(

8
sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/aggregator/LongSumAggregatorTest.java
View File

@ -16,10 +16,10 @@ import io.opentelemetry.sdk.common.InstrumentationLibraryInfo;
import io.opentelemetry.sdk.metrics.common.InstrumentType;
import io.opentelemetry.sdk.metrics.common.InstrumentValueType;
import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
import io.opentelemetry.sdk.metrics.data.ExemplarData;
import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.exemplar.ExemplarReservoir;
import io.opentelemetry.sdk.metrics.internal.data.ImmutableDoubleExemplarData;
import io.opentelemetry.sdk.metrics.internal.descriptor.InstrumentDescriptor;
import io.opentelemetry.sdk.metrics.internal.descriptor.MetricDescriptor;
import io.opentelemetry.sdk.resources.Resource;
@ -102,7 +102,7 @@ class LongSumAggregatorTest {
void testExemplarsInAccumulation() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(
@ -131,7 +131,7 @@ class LongSumAggregatorTest {
@Test
void mergeAndDiff() {
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
Attributes.empty(),
2L,
SpanContext.create(
@ -207,7 +207,7 @@ class LongSumAggregatorTest {
void toMetricDataWithExemplars() {
Attributes attributes = Attributes.builder().put("test", "value").build();
ExemplarData exemplar =
DoubleExemplarData.create(
ImmutableDoubleExemplarData.create(
attributes,
2L,
SpanContext.create(