Module org.elasticsearch.server
Class PendingListenersQueue
java.lang.Object
org.elasticsearch.cluster.routing.allocation.allocator.PendingListenersQueue
Registers listeners with an `index` number (
add(long, ActionListener)) and then completes them whenever the latest index number
is greater or equal to a listener's index value (complete(long)).-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidadd(long index, ActionListener<Void> listener) voidcomplete(long convergedIndex) voidlong
-
Constructor Details
-
PendingListenersQueue
public PendingListenersQueue()
-
-
Method Details
-
add
-
complete
public void complete(long convergedIndex) -
completeAllAsNotMaster
public void completeAllAsNotMaster() -
getCompletedIndex
public long getCompletedIndex()
-