Class ModifyMetricUpdater
- java.lang.Object
-
- org.apache.jackrabbit.oak.plugins.document.util.ModifyMetricUpdater
-
public final class ModifyMetricUpdater extends java.lang.Object
Base class to update the metrics forDocumentStoreStatsCollector.doneFindAndModify(long, Collection, String, boolean, boolean, int)
for underlyingDocumentStore
Users provide instances of
MeterStats
,TimerStats
based on whether throttling is ongoing or not
-
-
Constructor Summary
Constructors Constructor Description ModifyMetricUpdater(MeterStats createNodeUpsertMeter, TimerStats createNodeUpsertTimer, MeterStats updateNodeMeter, TimerStats updateNodeTimer, MeterStats updateNodeRetryCountMeter, MeterStats updateNodeFailureMeter)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
update(Collection<? extends Document> collection, int retryCount, long timeTakenNanos, boolean isSuccess, boolean newEntry, java.util.List<java.lang.String> ids, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, BiStatsConsumer createBiStatsConsumer, BiStatsConsumer updateBiStatsConsumer, java.util.function.ObjIntConsumer<MeterStats> retryNodesConsumer, java.util.function.Consumer<MeterStats> failureNodesConsumer)
-
-
-
Constructor Detail
-
ModifyMetricUpdater
public ModifyMetricUpdater(MeterStats createNodeUpsertMeter, TimerStats createNodeUpsertTimer, MeterStats updateNodeMeter, TimerStats updateNodeTimer, MeterStats updateNodeRetryCountMeter, MeterStats updateNodeFailureMeter)
-
-
Method Detail
-
update
public void update(Collection<? extends Document> collection, int retryCount, long timeTakenNanos, boolean isSuccess, boolean newEntry, java.util.List<java.lang.String> ids, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, BiStatsConsumer createBiStatsConsumer, BiStatsConsumer updateBiStatsConsumer, java.util.function.ObjIntConsumer<MeterStats> retryNodesConsumer, java.util.function.Consumer<MeterStats> failureNodesConsumer)
-
-