Module org.elasticsearch.server
Package org.elasticsearch.cluster
package org.elasticsearch.cluster
-
ClassDescriptionAbstractNamedDiffable<T extends NamedDiffable<T>>Abstract diffable object with simple diffs implementation that sends the entire object if object has changed or nothing is object remained the same.This class models a cluster state update task that notifies an AcknowledgedResponse listener when all the nodes have acknowledged the cluster state update request.An extension interface to
ClusterStateUpdateTaskthat allows the caller to be notified after the master has computed, published, accepted, committed, and applied the cluster state update AND only after the rest of the nodes (or a specified subset) have also accepted and applied the cluster state update.An event received by the local node, signaling that the cluster state has changed.Stores information on what features are present throughout the clusterClusterInfo is an object representing a map of nodes toDiskUsageand a map of shard ids to shard sizes and shard write-loads, seeInternalClusterInfoService.shardIdentifierFromRouting(String)for the key used in the shardSizes mapRepresents a data path on a nodeRepresents the total amount of "reserved" space on a particular data path, together with the set of shards considered.Interface for a class used to gather information about a cluster periodically.Configures classes and services that affect the entire cluster.Represents the state of the cluster, held in memory on all nodes in the cluster with updates coordinated by the elected master.Interface that a cluster state update task can implement to indicate that it wishes to be notified when the update has been acked by (some subset of) the nodes in the cluster.A component that is in charge of applying an incoming cluster state to the node internal data structures.A listener to be notified when a cluster state changes.A utility class which simplifies interacting with the cluster state in cases where one tries to take action based on the current state but may want to wait for a new state and retry upon failure.Represents a cluster state update computed by theMasterServicefor publication to the cluster.Utility to accessClusterStateonly when it is "ready", with a fallback if it's not.ClusterStateTaskExecutor<T extends ClusterStateTaskListener>An executor for batches of cluster state update tasks.Encapsulates the context in which a batch of tasks executes.A task to be executed, along with callbacks for the executor to record the outcome of this task's execution.A task that can update the cluster state.Diff<T>Represents difference between states of cluster state partsDiffable<T>Cluster state part, changes in which can be serializedDiffableUtils.DiffableValueReader<K,V extends Diffable<V>> Implementation of the ValueSerializer that wraps value and diff readers.DiffableUtils.DiffableValueSerializer<K,V extends Diffable<V>> Serializer for Diffable map values.Provides read and write operations to serialize keys of mapDiffableUtils.MapDiff<K,T, M extends Map<K, T>> Represents differences between two maps of objects and is used as base class for different map implementations.Serializer for non-diffable map valuesImplementation of ValueSerializer that serializes immutable setsProvides read and write operations to serialize map values.Encapsulation class used to represent the amount of disk used on a node.ClusterInfoServicethat provides empty maps for disk usage and shard sizesRecord representing an estimate of the heap used by allocated shards and ongoing merges on a particular nodeCollect the estimated heap usage for each node in the cluster.Thrown byDiff.apply(T)methodInternalClusterInfoService provides the ClusterInfoService interface, routinely updated on a timer.Used to execute things on the master service thread on nodes that are not necessarily masterEnables listening to master changes events of the local node (when the local node becomes the master, and when the local node cease being a master).Diff that also support NamedWriteable interfaceDiff that also supportVersionedNamedWriteableinterfaceNamedDiffableValueSerializer<T extends NamedDiffable<T>>Value Serializer for named diffablesThis component is responsible for maintaining connections from this node to all the nodes listed in the cluster state, and for disconnecting from nodes once they are removed from the cluster state.Record of a node's thread pool usage stats (operation load).Record of usage stats for a thread pool.Collects the thread pool usage stats for each node in the cluster.Exception which indicates that an operation failed because the node stopped being the elected master.Encapsulates all the information for a single projectA utility class for interacting with a project state.Represents an error that occurred on a remote node.A repository cleanup request entry.Meta data about restore processes that are currently executingRestore metadataRepresents status of a restored shardShard restore process stateUtility to accessClusterStateonly when it is "ready", where "ready" means that we received a first clusterChanged event with no global block of typeSTATE_NOT_RECOVERED_BLOCKThis guarantees that: - the initial cluster state has been set (seeClusterApplierService.setInitialState(ClusterState)); - the initial recovery process has completed.A task executor that executes tasks sequentially, allowing each task to acknowledge the cluster state update.SimpleBatchedAckListenerTaskExecutor<Task extends ClusterStateTaskListener>A basic batch executor implementation for tasks that can listen for acks themselves by providing aClusterStateAckListener.A basic implementation for batch executors that simply need to execute the tasks in the batch iteratively.SimpleDiffable<T extends Diffable<T>>Simple diffable object with simple diffs implementation that sends the entire object if object has changed or nothing if object remained the same.SimpleDiffable.CompleteDiff<T extends Diffable<T>>Represents the in-progress snapshot deletions in the cluster state.A class representing a snapshot deletion request entry in the cluster state.Meta data about snapshots that are currently executingThe current stage/phase of the shard snapshot, and whether it has completed or failed.An exception to cluster state listener that allows for timeouts and for post added notifications.