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

Class CreateMetricUpdater

java.lang.Object

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

public final class CreateMetricUpdater
extends java.lang.Object

Base class to update the metrics for DocumentStoreStatsCollector.doneCreate(long, Collection, List, boolean) for underlying DocumentStore

Users provide instances of MeterStats, TimerStats based on whether throttling is ongoing or not

Constructor Summary

Constructors

Constructor	Description
CreateMetricUpdater(MeterStats createNodeMeter, MeterStats createSplitNodeMeter, TimerStats createNodeTimer, MeterStats createJournal, TimerStats createJournalTimer)

Method Summary

Modifier and Type	Method	Description
void	update(Collection<? extends Document> collection, long timeTakenNanos, java.util.List<java.lang.String> ids, boolean insertSuccess, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, TriStatsConsumer triStatsConsumer, java.util.function.Predicate<Collection<? extends Document>> isJournalCollection, BiStatsConsumer journalBiStatsConsumer)

Methods inherited from class java.lang.Object

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

Constructor Detail

CreateMetricUpdater

public CreateMetricUpdater(MeterStats createNodeMeter,
                           MeterStats createSplitNodeMeter,
                           TimerStats createNodeTimer,
                           MeterStats createJournal,
                           TimerStats createJournalTimer)

Method Detail

update

public void update(Collection<? extends Document> collection,
                   long timeTakenNanos,
                   java.util.List<java.lang.String> ids,
                   boolean insertSuccess,
                   java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated,
                   TriStatsConsumer triStatsConsumer,
                   java.util.function.Predicate<Collection<? extends Document>> isJournalCollection,
                   BiStatsConsumer journalBiStatsConsumer)