java.lang.Object
org.elasticsearch.cluster.routing.allocation.allocator.PendingListenersQueue

public class PendingListenersQueue extends Object
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 Details

    • PendingListenersQueue

      public PendingListenersQueue()
  • Method Details

    • add

      public void add(long index, ActionListener<Void> listener)
    • complete

      public void complete(long convergedIndex)
    • completeAllAsNotMaster

      public void completeAllAsNotMaster()
    • getCompletedIndex

      public long getCompletedIndex()