OTLP: add support for summaries

Author: felixbarny

x-pack/plugin/otel-data/src/main/java/org/elasticsearch/xpack/oteldata/otlp/datapoint/DataPoint.java

@@ -10,6 +10,7 @@
 import io.opentelemetry.proto.common.v1.KeyValue;
 import io.opentelemetry.proto.metrics.v1.Metric;
 import io.opentelemetry.proto.metrics.v1.NumberDataPoint;
+import io.opentelemetry.proto.metrics.v1.SummaryDataPoint;
 
 import java.util.List;
 import java.util.Set;
@@ -134,4 +135,42 @@ public boolean isValid(Set<String> errors) {
             return true;
         }
     }
+
+    record Summary(SummaryDataPoint dataPoint, Metric metric) implements DataPoint {
+
+        @Override
+        public long getTimestampUnixNano() {
+            return dataPoint.getTimeUnixNano();
+        }
+
+        @Override
+        public List<KeyValue> getAttributes() {
+            return dataPoint.getAttributesList();
+        }
+
+        @Override
+        public long getStartTimestampUnixNano() {
+            return dataPoint.getStartTimeUnixNano();
+        }
+
+        @Override
+        public String getUnit() {
+            return metric.getUnit();
+        }
+
+        @Override
+        public String getMetricName() {
+            return metric.getName();
+        }
+
+        @Override
+        public String getDynamicTemplate() {
+            return "summary";
+        }
+
+        @Override
+        public boolean isValid(Set<String> errors) {
+            return true;
+        }
+    }
 }

x-pack/plugin/otel-data/src/main/java/org/elasticsearch/xpack/oteldata/otlp/datapoint/DataPointGroupingContext.java

@@ -76,8 +76,7 @@ public void groupDataPoints(ExportMetricsServiceRequest exportMetricsServiceRequ
                             ignoredDataPointMessages.add("Histogram is not supported yet. Dropping " + metric.getName());
                             break;
                         case SUMMARY:
-                            ignoredDataPoints += metric.getSummary().getDataPointsList().size();
-                            ignoredDataPointMessages.add("Summary is not supported yet. Dropping " + metric.getName());
+                            scopeGroup.addDataPoints(metric, metric.getSummary().getDataPointsList(), DataPoint.Summary::new);
                             break;
                         default:
                             ignoredDataPoints++;

x-pack/plugin/otel-data/src/test/java/org/elasticsearch/xpack/oteldata/otlp/OtlpUtils.java

@@ -19,6 +19,8 @@
 import io.opentelemetry.proto.metrics.v1.ResourceMetrics;
 import io.opentelemetry.proto.metrics.v1.ScopeMetrics;
 import io.opentelemetry.proto.metrics.v1.Sum;
+import io.opentelemetry.proto.metrics.v1.Summary;
+import io.opentelemetry.proto.metrics.v1.SummaryDataPoint;
 import io.opentelemetry.proto.resource.v1.Resource;
 
 import java.util.ArrayList;
@@ -105,6 +107,14 @@ public static Metric createSumMetric(
             .build();
     }
 
+    public static Metric createSummaryMetric(String name, String unit, List<SummaryDataPoint> dataPoints) {
+        return Metric.newBuilder()
+            .setName(name)
+            .setUnit(unit)
+            .setSummary(Summary.newBuilder().addAllDataPoints(dataPoints).build())
+            .build();
+    }
+
     public static NumberDataPoint createDoubleDataPoint(long timestamp, List<KeyValue> attributes) {
         return NumberDataPoint.newBuilder()
             .setTimeUnixNano(timestamp)
@@ -123,6 +133,16 @@ public static NumberDataPoint createLongDataPoint(long timestamp, List<KeyValue>
             .build();
     }
 
+    public static SummaryDataPoint createSummaryDataPoint(long timestamp, List<KeyValue> attributes) {
+        return SummaryDataPoint.newBuilder()
+            .setTimeUnixNano(timestamp)
+            .setStartTimeUnixNano(timestamp)
+            .addAllAttributes(attributes)
+            .setCount(randomLong())
+            .setSum(randomDouble())
+            .build();
+    }
+
     public static ExportMetricsServiceRequest createMetricsRequest(List<Metric> metrics) {
 
         List<ResourceMetrics> resourceMetrics = new ArrayList<>();

x-pack/plugin/otel-data/src/test/java/org/elasticsearch/xpack/oteldata/otlp/datapoint/DataPointGroupingContextTests.java

@@ -24,6 +24,8 @@
 import static org.elasticsearch.xpack.oteldata.otlp.OtlpUtils.createResourceMetrics;
 import static org.elasticsearch.xpack.oteldata.otlp.OtlpUtils.createScopeMetrics;
 import static org.elasticsearch.xpack.oteldata.otlp.OtlpUtils.createSumMetric;
+import static org.elasticsearch.xpack.oteldata.otlp.OtlpUtils.createSummaryDataPoint;
+import static org.elasticsearch.xpack.oteldata.otlp.OtlpUtils.createSummaryMetric;
 import static org.elasticsearch.xpack.oteldata.otlp.OtlpUtils.keyValue;
 
 public class DataPointGroupingContextTests extends ESTestCase {
@@ -43,11 +45,12 @@ public void testGroupingSameGroup() throws Exception {
                     List.of(createLongDataPoint(nowUnixNanos, List.of())),
                     true,
                     AGGREGATION_TEMPORALITY_CUMULATIVE
-                )
+                ),
+                createSummaryMetric("summary", "", List.of(createSummaryDataPoint(nowUnixNanos, List.of())))
             )
         );
         context.groupDataPoints(metricsRequest);
-        assertEquals(3, context.totalDataPoints());
+        assertEquals(4, context.totalDataPoints());
         assertEquals(0, context.getIgnoredDataPoints());
         assertEquals("", context.getIgnoredDataPointsMessage());