Package org.elasticsearch.cluster

Interface ClusterStateTaskListener

All Known Subinterfaces:
AckedClusterStateTaskListener
All Known Implementing Classes:
AckedClusterStateUpdateTask, ClusterStateUpdateTask, LocalClusterUpdateTask, MigrationResultsUpdateTask, NodeRemovalClusterStateTaskExecutor, ShardStateAction.ShardStartedClusterStateTaskExecutor, SystemIndexMetadataUpgradeService.SystemIndexMetadataUpdateTask
public interface ClusterStateTaskListener

  • Method Details

    • onFailure

      void onFailure(String source, Exception e)
      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.

    • onNoLongerMaster

      default void onNoLongerMaster(String source)
      A callback for when the task was rejected because the processing node is no longer the elected master. 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.

    • clusterStateProcessed

      default 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. 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.