diff options
Diffstat (limited to 'clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMetrics.java')
| -rw-r--r-- | clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMetrics.java | 22 |
1 files changed, 1 insertions, 21 deletions
diff --git a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMetrics.java b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMetrics.java index 8a48e4ce272..a1aa5287d2f 100644 --- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMetrics.java +++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMetrics.java @@ -27,31 +27,11 @@ class ReindexingMetrics { void dump(Reindexing reindexing) { reindexing.status().forEach((type, status) -> { - Reindexing.State state = status.state(); metric.set("reindexing.progress", status.progress().map(ProgressToken::percentFinished).map(percentage -> percentage * 1e-2) .orElse(status.state() == SUCCESSFUL ? 1.0 : 0.0), - metric.createContext(Map.of("clusterid", cluster, - "documenttype", type.getName(), - "state", toString(state)))); - // Set metric value to -1 for all states not currently active, so we only have one value >= 0 at any given time. - for (Reindexing.State unset : EnumSet.complementOf(EnumSet.of(state))) - metric.set("reindexing.progress", - -1, - metric.createContext(Map.of("clusterid", cluster, - "documenttype", type.getName(), - "state", toString(unset)))); + metric.createContext(Map.of("clusterid", cluster, "documenttype", type.getName()))); }); } - private static String toString(Reindexing.State state) { - switch (state) { - case READY: return "pending"; - case RUNNING: return "running"; - case FAILED: return "failed"; - case SUCCESSFUL: return "successful"; - default: throw new IllegalArgumentException("Unknown reindexing state '" + state + "'"); - } - } - } |