diff options
Diffstat (limited to 'configserver/src/main/java/com/yahoo/vespa/config/server/http/v2/MetricsResponse.java')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/http/v2/MetricsResponse.java | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/http/v2/MetricsResponse.java b/configserver/src/main/java/com/yahoo/vespa/config/server/http/v2/MetricsResponse.java index 237a1e6dccb..c18608f5f64 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/http/v2/MetricsResponse.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/http/v2/MetricsResponse.java @@ -7,7 +7,7 @@ import com.yahoo.slime.Cursor; import com.yahoo.slime.JsonFormat; import com.yahoo.slime.Slime; import com.yahoo.vespa.config.server.http.HttpConfigResponse; -import com.yahoo.vespa.config.server.metrics.Metrics; +import com.yahoo.vespa.config.server.metrics.MetricsAggregator; import java.io.IOException; import java.io.OutputStream; @@ -20,23 +20,24 @@ public class MetricsResponse extends HttpResponse { private final Slime slime = new Slime(); - public MetricsResponse(int status, Map<ApplicationId, Map<String, Metrics>> aggregatedMetrics) { + public MetricsResponse(int status, Map<ApplicationId, Map<String, MetricsAggregator>> aggregatedMetrics) { super(status); Cursor array = slime.setArray(); - for (Map.Entry<ApplicationId, Map<String, Metrics>> entry : aggregatedMetrics.entrySet()) { + for (Map.Entry<ApplicationId, Map<String, MetricsAggregator>> entry : aggregatedMetrics.entrySet()) { Cursor object = array.addObject(); object.setString("applicationId", entry.getKey().serializedForm()); Cursor clusterArray = object.setArray("clusters"); - for (Map.Entry<String, Metrics> clusterMetrics : entry.getValue().entrySet()) { + for (Map.Entry<String, MetricsAggregator> clusterMetrics : entry.getValue().entrySet()) { Cursor clusterCursor = clusterArray.addObject(); - Metrics metrics = clusterMetrics.getValue(); + MetricsAggregator metrics = clusterMetrics.getValue(); clusterCursor.setString("clusterName", clusterMetrics.getKey()); - metrics.aggregateQueryRate().ifPresent(queryrate -> clusterCursor.setDouble("queriesPerSecond", queryrate)); - metrics.aggregateFeedRate().ifPresent(feedRate -> clusterCursor.setDouble("writesPerSecond", feedRate)); - metrics.aggregateDocumentCount().ifPresent(documentCount -> clusterCursor.setDouble("documentCount", documentCount)); - metrics.aggregateQueryLatency().ifPresent(queryLatency -> clusterCursor.setDouble("queryLatencyMillis",queryLatency)); - metrics.aggregateFeedLatency().ifPresent(feedLatency -> clusterCursor.setDouble("feedLatency", feedLatency)); + Cursor metricsCursor = clusterCursor.setObject("metrics"); + metrics.aggregateQueryRate().ifPresent(queryrate -> metricsCursor.setDouble("queriesPerSecond", queryrate)); + metrics.aggregateFeedRate().ifPresent(feedRate -> metricsCursor.setDouble("writesPerSecond", feedRate)); + metrics.aggregateDocumentCount().ifPresent(documentCount -> metricsCursor.setDouble("documentCount", documentCount)); + metrics.aggregateQueryLatency().ifPresent(queryLatency -> metricsCursor.setDouble("queryLatencyMillis",queryLatency)); + metrics.aggregateFeedLatency().ifPresent(feedLatency -> metricsCursor.setDouble("feedLatency", feedLatency)); clusterCursor.setLong("timestamp", metrics.getTimestamp().getEpochSecond()); } } |