Package org.elasticsearch.shutdown

Class PluginShutdownService

java.lang.Object

org.elasticsearch.shutdown.PluginShutdownService

All Implemented Interfaces:

ClusterStateListener

public class PluginShutdownService
extends Object
implements ClusterStateListener

The PluginShutdownService is used for the node shutdown infrastructure to signal to plugins that a shutdown is occurring, and to check whether it is safe to shut down.

Field Summary

Fields

Modifier and Type	Field	Description
List<ShutdownAwarePlugin>	plugins

Constructor Summary

Constructors

Constructor	Description
PluginShutdownService(List<ShutdownAwarePlugin> plugins)

Method Summary

Modifier and Type	Method	Description
void	clusterChanged(ClusterChangedEvent event)	Called when cluster state changes.
boolean	readyToShutdown(String nodeId, SingleNodeShutdownMetadata.Type shutdownType)	Check with registered plugins whether the shutdown is safe for the given node id and type
static Set<String>	shutdownNodes(ClusterState clusterState)	Return all nodes shutting down from the given cluster state
static Set<String>	shutdownTypeNodes(ClusterState clusterState, SingleNodeShutdownMetadata.Type shutdownType)	Return all nodes shutting down with the given shutdown type from the given cluster state
void	signalShutdown(ClusterState state)	Signal to plugins the nodes that are currently shutting down

Methods inherited from class java.lang.Object

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

Field Details

plugins

public List<ShutdownAwarePlugin> plugins

Constructor Details

PluginShutdownService

public PluginShutdownService(@Nullable
 List<ShutdownAwarePlugin> plugins)

Method Details

shutdownNodes

public static Set<String> shutdownNodes(ClusterState clusterState)

Return all nodes shutting down from the given cluster state

shutdownTypeNodes

public static Set<String> shutdownTypeNodes(ClusterState clusterState,
 SingleNodeShutdownMetadata.Type shutdownType)

Return all nodes shutting down with the given shutdown type from the given cluster state

readyToShutdown

public boolean readyToShutdown(String nodeId,
 SingleNodeShutdownMetadata.Type shutdownType)

Check with registered plugins whether the shutdown is safe for the given node id and type

signalShutdown

public void signalShutdown(ClusterState state)

Signal to plugins the nodes that are currently shutting down

clusterChanged

public void clusterChanged(ClusterChangedEvent event)

Description copied from interface: ClusterStateListener

Called when cluster state changes.

Specified by:

clusterChanged in interface ClusterStateListener