Class ElasticsearchNodeCommand
java.lang.Object
org.elasticsearch.cli.Command
org.elasticsearch.cli.EnvironmentAwareCommand
org.elasticsearch.cluster.coordination.ElasticsearchNodeCommand
- All Implemented Interfaces:
Closeable
,AutoCloseable
- Direct Known Subclasses:
DetachClusterCommand
,NodeRepurposeCommand
,OverrideNodeVersionCommand
,RemoveCorruptedShardDataCommand
,RemoveCustomsCommand
,RemoveSettingsCommand
,UnsafeBootstrapMasterCommand
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
static class
-
Field Summary
Modifier and TypeFieldDescriptionprotected static final String
protected static final String
protected static final String
protected static final String
static final NamedXContentRegistry
Fields inherited from class org.elasticsearch.cli.Command
description, parser
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic ClusterState
clusterState
(Environment environment, PersistedClusterStateService.OnDiskState onDiskState) protected void
static PersistedClusterStateService
createPersistedClusterStateService
(Settings settings, Path[] dataPaths) final void
execute
(Terminal terminal, joptsimple.OptionSet options, Environment env) Execute the command with the initializedEnvironment
.static Tuple<Long,
ClusterState> protected abstract void
processDataPaths
(Terminal terminal, Path[] dataPaths, int nodeLockId, joptsimple.OptionSet options, Environment env) Process the paths.protected void
processDataPaths
(Terminal terminal, joptsimple.OptionSet options, Environment env) protected NodeEnvironment.DataPath[]
toDataPaths
(Path[] dataPaths) protected boolean
validateBeforeLock
(Terminal terminal, Environment env) Validate that the command can run before taking any locks.Methods inherited from class org.elasticsearch.cli.EnvironmentAwareCommand
createEnv, createEnv, execute
Methods inherited from class org.elasticsearch.cli.Command
addShutdownHook, close, exit, main, printAdditionalHelp, printUserException
-
Field Details
-
DELIMITER
- See Also:
-
FAILED_TO_OBTAIN_NODE_LOCK_MSG
- See Also:
-
ABORTED_BY_USER_MSG
- See Also:
-
CS_MISSING_MSG
- See Also:
-
namedXContentRegistry
-
-
Constructor Details
-
ElasticsearchNodeCommand
-
-
Method Details
-
createPersistedClusterStateService
public static PersistedClusterStateService createPersistedClusterStateService(Settings settings, Path[] dataPaths) throws IOException - Throws:
IOException
-
clusterState
public static ClusterState clusterState(Environment environment, PersistedClusterStateService.OnDiskState onDiskState) -
loadTermAndClusterState
public static Tuple<Long,ClusterState> loadTermAndClusterState(PersistedClusterStateService psf, Environment env) throws IOException - Throws:
IOException
-
processDataPaths
protected void processDataPaths(Terminal terminal, joptsimple.OptionSet options, Environment env) throws IOException, UserException - Throws:
IOException
UserException
-
confirm
-
execute
public final void execute(Terminal terminal, joptsimple.OptionSet options, Environment env) throws Exception Description copied from class:EnvironmentAwareCommand
Execute the command with the initializedEnvironment
.- Specified by:
execute
in classEnvironmentAwareCommand
- Throws:
Exception
-
validateBeforeLock
Validate that the command can run before taking any locks.- Parameters:
terminal
- the terminal to print toenv
- the env to validate.- Returns:
- true to continue, false to stop (must print message in validate).
-
processDataPaths
protected abstract void processDataPaths(Terminal terminal, Path[] dataPaths, int nodeLockId, joptsimple.OptionSet options, Environment env) throws IOException, UserException Process the paths. Locks for the paths is held during this method invocation.- Parameters:
terminal
- the terminal to use for messagesdataPaths
- the paths of the node to processoptions
- the command line optionsenv
- the env of the node to process- Throws:
IOException
UserException
-
toDataPaths
-