Package org.elasticsearch.cluster.metadata

Class SystemIndexMetadataUpgradeService.SystemIndexMetadataUpdateTask

java.lang.Object

org.elasticsearch.cluster.ClusterStateUpdateTask

org.elasticsearch.cluster.metadata.SystemIndexMetadataUpgradeService.SystemIndexMetadataUpdateTask

All Implemented Interfaces:

ClusterStateTaskConfig, ClusterStateTaskExecutor<ClusterStateUpdateTask>, ClusterStateTaskListener

Enclosing class:

SystemIndexMetadataUpgradeService

public class SystemIndexMetadataUpgradeService.SystemIndexMetadataUpdateTask
extends ClusterStateUpdateTask

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.cluster.ClusterStateTaskConfig

ClusterStateTaskConfig.Basic

Nested classes/interfaces inherited from interface org.elasticsearch.cluster.ClusterStateTaskExecutor

ClusterStateTaskExecutor.ClusterTasksResult<T>, ClusterStateTaskExecutor.TaskResult

Constructor Summary

Constructors

Constructor	Description
SystemIndexMetadataUpdateTask()

Method Summary

Modifier and Type	Method	Description
void	clusterStateProcessed(String source, ClusterState oldState, ClusterState newState)	Called when the result of the ClusterStateTaskExecutor.execute(ClusterState, List) have been processed properly by all listeners.
ClusterState	execute(ClusterState currentState)	Update the cluster state based on the current state.
void	onFailure(String source, Exception e)	A callback for when task execution fails.

Methods inherited from class org.elasticsearch.cluster.ClusterStateUpdateTask

clusterStatePublished, describeTasks, execute, priority, runOnlyOnMaster, timeout

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.cluster.ClusterStateTaskListener

onNoLongerMaster

Constructor Details

SystemIndexMetadataUpdateTask

public SystemIndexMetadataUpdateTask()

Method Details

execute

public ClusterState execute(ClusterState currentState)
                     throws Exception

Description copied from class: ClusterStateUpdateTask

Update the cluster state based on the current state. Return the *same instance* if no state should be changed.

Specified by:

execute in class ClusterStateUpdateTask

Throws:

Exception

onFailure

public void onFailure(String source,
 Exception e)

Description copied from class: ClusterStateUpdateTask

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

Specified by:

onFailure in interface ClusterStateTaskListener

Specified by:

onFailure in class ClusterStateUpdateTask

clusterStateProcessed

public void clusterStateProcessed(String source,
 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.