rdev/gossip-revisited
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

GOSSIP-87 removed WORKQUEUE_SIZE metric

Browse Source
This commit is contained in:
pxsalehi
2017-08-08 19:23:22 +02:00
parent 4572eed73d
commit 5280dc8a18
2 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java
View File

@ -68,7 +68,6 @@ public class GossipCore implements GossipCoreConstants {
perNodeData = new ConcurrentHashMap<>(); perNodeData = new ConcurrentHashMap<>();
sharedData = new ConcurrentHashMap<>(); sharedData = new ConcurrentHashMap<>();
eventManager = new DataEventManager(metrics); eventManager = new DataEventManager(metrics);
metrics.register(WORKQUEUE_SIZE, (Gauge<Integer>)() -> 0);
metrics.register(PER_NODE_DATA_SIZE, (Gauge<Integer>)() -> perNodeData.size()); metrics.register(PER_NODE_DATA_SIZE, (Gauge<Integer>)() -> perNodeData.size());
metrics.register(SHARED_DATA_SIZE, (Gauge<Integer>)() -> sharedData.size()); metrics.register(SHARED_DATA_SIZE, (Gauge<Integer>)() -> sharedData.size());
metrics.register(REQUEST_SIZE, (Gauge<Integer>)() -> requests.size()); metrics.register(REQUEST_SIZE, (Gauge<Integer>)() -> requests.size());

1
gossip-base/src/main/java/org/apache/gossip/manager/GossipCoreConstants.java
View File

@ -18,7 +18,6 @@
package org.apache.gossip.manager; package org.apache.gossip.manager;
public interface GossipCoreConstants { public interface GossipCoreConstants {
String WORKQUEUE_SIZE = "gossip.core.workqueue.size";
String PER_NODE_DATA_SIZE = "gossip.core.pernodedata.size"; String PER_NODE_DATA_SIZE = "gossip.core.pernodedata.size";
String SHARED_DATA_SIZE = "gossip.core.shareddata.size"; String SHARED_DATA_SIZE = "gossip.core.shareddata.size";
String REQUEST_SIZE = "gossip.core.requests.size"; String REQUEST_SIZE = "gossip.core.requests.size";