Package org.elasticsearch.cluster.action.shard

Class ShardStateAction.StartedShardUpdateTask

java.lang.Object

org.elasticsearch.cluster.action.shard.ShardStateAction.StartedShardUpdateTask

All Implemented Interfaces:

ClusterStateTaskListener

Enclosing class:

ShardStateAction

public static class ShardStateAction.StartedShardUpdateTask
extends Object
implements ClusterStateTaskListener

Constructor Summary

Constructors

Constructor	Description
StartedShardUpdateTask(ShardStateAction.StartedShardEntry entry, ActionListener<TransportResponse.Empty> listener)

Method Summary

Modifier and Type	Method	Description
void	clusterStateProcessed(ClusterState oldState, ClusterState newState)	Called when the result of the ClusterStateTaskExecutor.execute(ClusterState, List) have been processed properly by all listeners.
ShardStateAction.StartedShardEntry	getEntry()
void	onFailure(Exception e)	A callback for when task execution fails.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.cluster.ClusterStateTaskListener

onNoLongerMaster

Constructor Details

StartedShardUpdateTask

public StartedShardUpdateTask(ShardStateAction.StartedShardEntry entry,
 ActionListener<TransportResponse.Empty> listener)

Method Details

getEntry

public ShardStateAction.StartedShardEntry getEntry()

onFailure

public void onFailure(Exception e)

Description copied from interface: ClusterStateTaskListener

A callback for when task execution fails. Implementations of this callback must not throw exceptions: an exception thrown here is logged by the master service at ERROR level and otherwise ignored, except in tests where it raises an AssertionError. If log-and-ignore is the right behaviour then implementations must do so themselves, typically using a more specific logger and at a less dramatic log level.

Specified by:

onFailure in interface ClusterStateTaskListener

clusterStateProcessed

public void clusterStateProcessed(ClusterState oldState,
 ClusterState newState)

Description copied from interface: ClusterStateTaskListener

Called when the result of the ClusterStateTaskExecutor.execute(ClusterState, List) have been processed properly by all listeners. Implementations of this callback must not throw exceptions: an exception thrown here is logged by the master service at ERROR level and otherwise ignored, except in tests where it raises an AssertionError. If log-and-ignore is the right behaviour then implementations must do so themselves, typically using a more specific logger and at a less dramatic log level.

Specified by:

clusterStateProcessed in interface ClusterStateTaskListener

toString

public String toString()

Overrides:

toString in class Object