mirror of
https://github.com/Athou/commafeed.git
synced 2026-03-21 21:37:29 +00:00
more metrics
This commit is contained in:
@@ -17,6 +17,7 @@ import lombok.extern.slf4j.Slf4j;
|
|||||||
import org.apache.commons.codec.digest.DigestUtils;
|
import org.apache.commons.codec.digest.DigestUtils;
|
||||||
import org.apache.commons.lang.time.DateUtils;
|
import org.apache.commons.lang.time.DateUtils;
|
||||||
|
|
||||||
|
import com.codahale.metrics.Gauge;
|
||||||
import com.codahale.metrics.Meter;
|
import com.codahale.metrics.Meter;
|
||||||
import com.codahale.metrics.MetricRegistry;
|
import com.codahale.metrics.MetricRegistry;
|
||||||
import com.commafeed.backend.dao.FeedDAO;
|
import com.commafeed.backend.dao.FeedDAO;
|
||||||
@@ -66,6 +67,24 @@ public class FeedRefreshTaskGiver {
|
|||||||
feedRefreshed = metrics.meter(MetricRegistry.name(getClass(), "feedRefreshed"));
|
feedRefreshed = metrics.meter(MetricRegistry.name(getClass(), "feedRefreshed"));
|
||||||
threadWaited = metrics.meter(MetricRegistry.name(getClass(), "threadWaited"));
|
threadWaited = metrics.meter(MetricRegistry.name(getClass(), "threadWaited"));
|
||||||
refill = metrics.meter(MetricRegistry.name(getClass(), "refill"));
|
refill = metrics.meter(MetricRegistry.name(getClass(), "refill"));
|
||||||
|
metrics.register(MetricRegistry.name(getClass(), "addQueue"), new Gauge<Integer>() {
|
||||||
|
@Override
|
||||||
|
public Integer getValue() {
|
||||||
|
return addQueue.size();
|
||||||
|
}
|
||||||
|
});
|
||||||
|
metrics.register(MetricRegistry.name(getClass(), "takeQueue"), new Gauge<Integer>() {
|
||||||
|
@Override
|
||||||
|
public Integer getValue() {
|
||||||
|
return takeQueue.size();
|
||||||
|
}
|
||||||
|
});
|
||||||
|
metrics.register(MetricRegistry.name(getClass(), "giveBackQueue"), new Gauge<Integer>() {
|
||||||
|
@Override
|
||||||
|
public Integer getValue() {
|
||||||
|
return giveBackQueue.size();
|
||||||
|
}
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@PreDestroy
|
@PreDestroy
|
||||||
|
|||||||
@@ -14,4 +14,11 @@
|
|||||||
label="'Feed Worker active'"></metric-gauge>
|
label="'Feed Worker active'"></metric-gauge>
|
||||||
<metric-gauge metric="metrics.gauges['com.commafeed.backend.feeds.FeedRefreshExecutor.feed-refresh-worker.pending']"
|
<metric-gauge metric="metrics.gauges['com.commafeed.backend.feeds.FeedRefreshExecutor.feed-refresh-worker.pending']"
|
||||||
label="'Feed Worker queued'"></metric-gauge>
|
label="'Feed Worker queued'"></metric-gauge>
|
||||||
|
|
||||||
|
<metric-gauge metric="metrics.gauges['com.commafeed.backend.feeds.FeedRefreshTaskGiver.addQueue']"
|
||||||
|
label="'Task Giver Add Queue'"></metric-gauge>
|
||||||
|
<metric-gauge metric="metrics.gauges['com.commafeed.backend.feeds.FeedRefreshTaskGiver.takeQueue']"
|
||||||
|
label="'Task Giver Take Queue'"></metric-gauge>
|
||||||
|
<metric-gauge metric="metrics.gauges['com.commafeed.backend.feeds.FeedRefreshTaskGiver.giveBackQueue']"
|
||||||
|
label="'Task Giver Give Back Queue'"></metric-gauge>
|
||||||
</div>
|
</div>
|
||||||
Reference in New Issue
Block a user