Package org.apache.jackrabbit.oak.plugins.document.util

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 for DocumentStoreStatsCollector.doneFindAndModify(long, Collection, String, boolean, boolean, int) for underlying DocumentStore

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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)