Module org.elasticsearch.xcore

Package org.elasticsearch.xpack.core.ilm

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.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.xpack.core.ilm.AsyncWaitStep

AsyncWaitStep.Listener

Nested classes/interfaces inherited from class org.elasticsearch.xpack.core.ilm.Step

Step.StepKey

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAME

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
void	evaluateCondition(ProjectState state, IndexMetadata indexMetadata, AsyncWaitStep.Listener listener, TimeValue masterTimeout)
TimeValue	getReplicateFor()
int	hashCode()
boolean	isRetryable()	Indicates if the step can be automatically retried when it encounters an execution error.

Methods inherited from class org.elasticsearch.xpack.core.ilm.AsyncWaitStep

getClient

Methods inherited from class org.elasticsearch.xpack.core.ilm.Step

getCurrentStepKey, getKey, getNextStepKey, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

Method Details

getReplicateFor

public 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,
 IndexMetadata indexMetadata,
 AsyncWaitStep.Listener listener,
 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