Class ClusterService

    • Field Detail

      • CLUSTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD_SETTING

        public static final Setting<TimeValue> CLUSTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD_SETTING
      • USER_DEFINED_META_DATA

        public static final Setting.AffixSetting<java.lang.String> USER_DEFINED_META_DATA
    • Method Detail

      • newClusterStateBuilder

        public ClusterState.Builder newClusterStateBuilder()
        Creates a new cluster state builder that is initialized with the cluster name and all initial cluster state customs.
      • setNodeConnectionsService

        public void setNodeConnectionsService​(NodeConnectionsService nodeConnectionsService)
      • state

        public ClusterState state()
        The currently applied cluster state. TODO: Should be renamed to appliedState / appliedClusterState
      • addHighPriorityApplier

        public void addHighPriorityApplier​(ClusterStateApplier applier)
        Adds a high priority applier of updated cluster states.
      • addLowPriorityApplier

        public void addLowPriorityApplier​(ClusterStateApplier applier)
        Adds an applier which will be called after all high priority and normal appliers have been called.
      • addStateApplier

        public void addStateApplier​(ClusterStateApplier applier)
        Adds a applier of updated cluster states.
      • removeApplier

        public void removeApplier​(ClusterStateApplier applier)
        Removes an applier of updated cluster states.
      • addListener

        public void addListener​(ClusterStateListener listener)
        Add a listener for updated cluster states
      • removeListener

        public void removeListener​(ClusterStateListener listener)
        Removes a listener for updated cluster states.
      • addLocalNodeMasterListener

        public void addLocalNodeMasterListener​(LocalNodeMasterListener listener)
        Add a listener for on/off local node master events
      • assertClusterOrMasterStateThread

        public static boolean assertClusterOrMasterStateThread()
      • getSettings

        public Settings getSettings()
        The node's settings.
      • getNodeName

        public final java.lang.String getNodeName()
        The name of this node.
      • submitStateUpdateTask

        public <T> void submitStateUpdateTask​(java.lang.String source,
                                              T task,
                                              ClusterStateTaskConfig config,
                                              ClusterStateTaskExecutor<T> executor,
                                              ClusterStateTaskListener listener)
        Submits a cluster state update task; submitted updates will be batched across the same instance of executor. The exact batching semantics depend on the underlying implementation but a rough guideline is that if the update task is submitted while there are pending update tasks for the same executor, these update tasks will all be executed on the executor in a single batch
        Type Parameters:
        T - the type of the cluster state update task state
        Parameters:
        source - the source of the cluster state update task
        task - the state needed for the cluster state update task
        config - the cluster state update task configuration
        executor - the cluster state update task executor; tasks that share the same executor will be executed batches on this executor
        listener - callback after the cluster state update task completes
      • submitStateUpdateTasks

        public <T> void submitStateUpdateTasks​(java.lang.String source,
                                               java.util.Map<T,​ClusterStateTaskListener> tasks,
                                               ClusterStateTaskConfig config,
                                               ClusterStateTaskExecutor<T> executor)
        Submits a batch of cluster state update tasks; submitted updates are guaranteed to be processed together, potentially with more tasks of the same executor.
        Type Parameters:
        T - the type of the cluster state update task state
        Parameters:
        source - the source of the cluster state update task
        tasks - a map of update tasks and their corresponding listeners
        config - the cluster state update task configuration
        executor - the cluster state update task executor; tasks that share the same executor will be executed batches on this executor