org.elasticsearch.cluster

Class TimeoutClusterStateUpdateTask

java.lang.Object

org.elasticsearch.cluster.ClusterStateUpdateTask

org.elasticsearch.cluster.ProcessedClusterStateUpdateTask

org.elasticsearch.cluster.TimeoutClusterStateUpdateTask

Direct Known Subclasses:

AckedClusterStateUpdateTask

public abstract class TimeoutClusterStateUpdateTask
extends ProcessedClusterStateUpdateTask

An extension interface to ClusterStateUpdateTask that allows to associate a timeout.

Constructor Summary

Constructors

Constructor and Description
TimeoutClusterStateUpdateTask()

Method Summary

Modifier and Type	Method and Description
abstract TimeValue	timeout() If the cluster state update task wasn't processed by the provided timeout, call ClusterStateUpdateTask.onFailure(String, Throwable)

Methods inherited from class org.elasticsearch.cluster.ProcessedClusterStateUpdateTask

clusterStateProcessed

Methods inherited from class org.elasticsearch.cluster.ClusterStateUpdateTask

execute, onFailure, onNoLongerMaster, runOnlyOnMaster

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeoutClusterStateUpdateTask

public TimeoutClusterStateUpdateTask()

Method Detail

timeout

public abstract TimeValue timeout()

If the cluster state update task wasn't processed by the provided timeout, call ClusterStateUpdateTask.onFailure(String, Throwable)