java.lang.Object
org.elasticsearch.node.Node
- All Implemented Interfaces:
Closeable,AutoCloseable
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionNode(Environment environment, PluginsLoader pluginsLoader) Constructs a node -
Method Summary
Modifier and TypeMethodDescriptionbooleanawaitClose(long timeout, TimeUnit timeUnit) Wait for this node to be effectively closed.client()A client that can be used to execute actions (operations) against the cluster.voidclose()protected voidconfigureNodeAndClusterIdStateListener(ClusterService clusterService) static voiddeleteTemporaryApmConfig(JvmInfo jvmInfo, BiConsumer<Exception, Path> errorHandler) If the JVM was started with the Elastic APM agent and a config file argument was specified, then delete the config file.Returns the environment of the nodeReturns theNodeEnvironmentinstance of this nodeprotected PluginsServiceThePluginsServiceused to build this node's components.injector()booleanisClosed()Returnstrueif the node is closed.voidInvokes hooks to prepare this node to be closed.settings()The settings that are used by this node.start()Start the node.protected voidvalidateNodeBeforeAcceptingRequests(BootstrapContext context, BoundTransportAddress boundTransportAddress, List<BootstrapCheck> bootstrapChecks) Hook for validating the node after network services are started but before the cluster service is started and before the network service starts accepting incoming network requests.
-
Field Details
-
WRITE_PORTS_FILE_SETTING
-
NODE_NAME_SETTING
-
NODE_EXTERNAL_ID_SETTING
-
NODE_ATTRIBUTES
-
BREAKER_TYPE_KEY
-
INITIAL_STATE_TIMEOUT_SETTING
-
MAXIMUM_SHUTDOWN_TIMEOUT_SETTING
-
-
Constructor Details
-
Node
Constructs a node- Parameters:
environment- the initial environment for this node, which will be added to by plugins
-
-
Method Details
-
deleteTemporaryApmConfig
public static void deleteTemporaryApmConfig(JvmInfo jvmInfo, BiConsumer<Exception, Path> errorHandler) If the JVM was started with the Elastic APM agent and a config file argument was specified, then delete the config file. The agent only reads it once, when supplied in this fashion, and it may contain a secret token.Public for testing only
-
settings
The settings that are used by this node. Contains original settings as well as additional settings provided by plugins. -
client
A client that can be used to execute actions (operations) against the cluster. -
getEnvironment
Returns the environment of the node -
getNodeEnvironment
Returns theNodeEnvironmentinstance of this node -
start
Start the node. If the node is already started, this method is no-op.- Throws:
NodeValidationException
-
configureNodeAndClusterIdStateListener
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-
prepareForClose
public void prepareForClose()Invokes hooks to prepare this node to be closed. This should be called when Elasticsearch receives a request to shut down gracefully from the underlying operating system, before system resources are closed. This method will block until the node is ready to shut down.Note that this class is part of infrastructure to react to signals from the operating system - most graceful shutdown logic should use Node Shutdown, see
NodesShutdownMetadata. -
awaitClose
Wait for this node to be effectively closed.- Throws:
InterruptedException
-
isClosed
public boolean isClosed()Returnstrueif the node is closed. -
injector
-
validateNodeBeforeAcceptingRequests
protected void validateNodeBeforeAcceptingRequests(BootstrapContext context, BoundTransportAddress boundTransportAddress, List<BootstrapCheck> bootstrapChecks) throws NodeValidationException Hook for validating the node after network services are started but before the cluster service is started and before the network service starts accepting incoming network requests.- Parameters:
context- the bootstrap context for this nodeboundTransportAddress- the network addresses the node is bound and publishing to- Throws:
NodeValidationException
-
getPluginsService
ThePluginsServiceused to build this node's components.
-