Module org.elasticsearch.server

Package org.elasticsearch.cluster.routing.allocation.allocator

Class PendingListenersQueue

java.lang.Object

org.elasticsearch.cluster.routing.allocation.allocator.PendingListenersQueue

public class PendingListenersQueue
extends Object

Constructor Summary

Constructors

Constructor	Description
PendingListenersQueue()

Method Summary

Modifier and Type	Method	Description
void	add(long index, ActionListener<Void> listener)
void	complete(long convergedIndex)
void	completeAllAsNotMaster()
long	getCompletedIndex()

Methods inherited from class java.lang.Object

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

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()