Class WaitUntilReplicateForTimePassesStep

java.lang.Object
org.elasticsearch.xpack.core.ilm.Step
org.elasticsearch.xpack.core.ilm.AsyncWaitStep
org.elasticsearch.xpack.core.ilm.WaitUntilReplicateForTimePassesStep

public class WaitUntilReplicateForTimePassesStep extends AsyncWaitStep
This Step waits until the `replicate_for` time of a searchable_snapshot action to pass.

It's an AsyncWaitStep rather than a ClusterStateWaitStep because we aren't guaranteed to receive a new cluster state in timely fashion when the waiting finishes -- by extending AsyncWaitStep we are guaranteed to check the condition on each ILM execution.

  • Field Details

  • Method Details

    • getReplicateFor

      public org.elasticsearch.core.TimeValue getReplicateFor()
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Step
    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Step
    • evaluateCondition

      public void evaluateCondition(ProjectState state, Index index, AsyncWaitStep.Listener listener, org.elasticsearch.core.TimeValue masterTimeout)
      Specified by:
      evaluateCondition in class AsyncWaitStep
    • isRetryable

      public boolean isRetryable()
      Description copied from class: Step
      Indicates if the step can be automatically retried when it encounters an execution error.
      Specified by:
      isRetryable in class Step