diff options
author | gjoranv <gv@verizonmedia.com> | 2020-03-17 17:11:14 +0100 |
---|---|---|
committer | gjoranv <gv@verizonmedia.com> | 2020-03-17 17:23:53 +0100 |
commit | 1d1c1a2d52be87944f960375ccd8b17c21bea8c7 (patch) | |
tree | 623120f84ecf5e98c05a496da4c0b3ac634f6f4e | |
parent | 1f6ca96d4ee3081faa9f14bb69b72faebf25d212 (diff) |
Use a ConcurrentHashMap for metrics snapshots for each node.
-rw-r--r-- | metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/NodeMetricsClient.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/NodeMetricsClient.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/NodeMetricsClient.java index 01cf6b19836..145eef3f745 100644 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/NodeMetricsClient.java +++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/NodeMetricsClient.java @@ -13,9 +13,11 @@ import java.io.IOException; import java.time.Clock; import java.time.Duration; import java.time.Instant; +import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; import java.util.logging.Logger; import static com.yahoo.log.LogLevel.DEBUG; @@ -41,7 +43,7 @@ public class NodeMetricsClient { private final HttpClient httpClient; private final Clock clock; - private final Map<ConsumerId, Snapshot> snapshots = new HashMap<>(); + private final Map<ConsumerId, Snapshot> snapshots = new ConcurrentHashMap<>(); private long snapshotsRetrieved = 0; NodeMetricsClient(HttpClient httpClient, Node node, Clock clock) { |