Class ActiveShardsObserver


  • public class ActiveShardsObserver
    extends java.lang.Object
    This class provides primitives for waiting for a configured number of shards to become active before sending a response on an ActionListener.
    • Method Summary

      Modifier and Type Method Description
      void waitForActiveShards​(java.lang.String[] indexNames, ActiveShardCount activeShardCount, TimeValue timeout, java.util.function.Consumer<java.lang.Boolean> onResult, java.util.function.Consumer<java.lang.Exception> onFailure)
      Waits on the specified number of active shards to be started before executing the
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • waitForActiveShards

        public void waitForActiveShards​(java.lang.String[] indexNames,
                                        ActiveShardCount activeShardCount,
                                        TimeValue timeout,
                                        java.util.function.Consumer<java.lang.Boolean> onResult,
                                        java.util.function.Consumer<java.lang.Exception> onFailure)
        Waits on the specified number of active shards to be started before executing the
        Parameters:
        indexNames - the indices to wait for active shards on
        activeShardCount - the number of active shards to wait on before returning
        timeout - the timeout value
        onResult - a function that is executed in response to the requisite shards becoming active or a timeout (whichever comes first)
        onFailure - a function that is executed in response to an error occurring during waiting for the active shards