Package org.elasticsearch.indices.recovery

Class RecoveryRequestTracker

java.lang.Object
org.elasticsearch.indices.recovery.RecoveryRequestTracker
public class RecoveryRequestTracker
extends java.lang.Object

  • Constructor Summary

    Constructors
    Constructor Description
    RecoveryRequestTracker()  

  • Method Summary

    Modifier and Type Method Description
    ActionListener<java.lang.Void> markReceivedAndCreateListener​(long requestSeqNo, ActionListener<java.lang.Void> listener)
    This method will mark that a request with a unique sequence number has been received.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • RecoveryRequestTracker

      public RecoveryRequestTracker()

  • Method Details

    • markReceivedAndCreateListener

      @Nullable public ActionListener<java.lang.Void> markReceivedAndCreateListener​(long requestSeqNo, ActionListener<java.lang.Void> listener)
      This method will mark that a request with a unique sequence number has been received. If this is the first time the unique request has been received, this method will return a listener to be completed. The caller should then perform the requested action and complete the returned listener. If the unique request has already been received, this method will either complete the provided listener or attach that listener to the listener returned in the first call. In this case, the method will return null and the caller should not perform the requested action as a prior caller is already performing the action.