diff options
author | Jon Bratseth <bratseth@gmail.com> | 2023-12-06 16:59:33 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-12-06 16:59:33 +0100 |
commit | 10a580357998b4c750729f27d3ef2e224dd69af7 (patch) | |
tree | 3138aedec274b466ed38587977da19afc66ea02e /metrics | |
parent | b6810d469697d2fd18941adbf355282dbc370080 (diff) | |
parent | 1aa5e20620c9abddd7f8f3253455620e40487aa6 (diff) |
Merge pull request #29571 from vespa-engine/mpolden/detect-redist
Let distributor metric decide cluster stability
Diffstat (limited to 'metrics')
-rw-r--r-- | metrics/src/main/java/ai/vespa/metrics/set/AutoscalingMetrics.java | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/metrics/src/main/java/ai/vespa/metrics/set/AutoscalingMetrics.java b/metrics/src/main/java/ai/vespa/metrics/set/AutoscalingMetrics.java index 1df779c4b4d..9d8ec89f974 100644 --- a/metrics/src/main/java/ai/vespa/metrics/set/AutoscalingMetrics.java +++ b/metrics/src/main/java/ai/vespa/metrics/set/AutoscalingMetrics.java @@ -2,6 +2,7 @@ package ai.vespa.metrics.set; import ai.vespa.metrics.ContainerMetrics; +import ai.vespa.metrics.DistributorMetrics; import ai.vespa.metrics.HostedNodeAdminMetrics; import ai.vespa.metrics.SearchNodeMetrics; import ai.vespa.metrics.StorageMetrics; @@ -38,10 +39,13 @@ public class AutoscalingMetrics { metrics.add(HostedNodeAdminMetrics.DISK_UTIL.baseName()); // node level -default metrics.add(SearchNodeMetrics.CONTENT_PROTON_RESOURCE_USAGE_DISK.average()); // the basis for blocking + // Config metrics.add(ContainerMetrics.APPLICATION_GENERATION.last()); metrics.add(SearchNodeMetrics.CONTENT_PROTON_CONFIG_GENERATION.last()); + // Status metrics.add(ContainerMetrics.IN_SERVICE.last()); + metrics.add(DistributorMetrics.VDS_IDEALSTATE_MERGE_BUCKET_PENDING.last()); // Query rate metrics.add(ContainerMetrics.QUERIES.rate()); @@ -57,7 +61,7 @@ public class AutoscalingMetrics { } private static Set<Metric> toMetrics(List<String> metrics) { - return metrics.stream().map(Metric::new).collect(Collectors.toCollection(() -> new LinkedHashSet<>())); + return metrics.stream().map(Metric::new).collect(Collectors.toCollection(LinkedHashSet::new)); } } |