Class ClusterServiceUtils

java.lang.Object
org.opensearch.test.ClusterServiceUtils

public class ClusterServiceUtils extends Object
  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • Method Summary

    Modifier and Type
    Method
    Description
    static org.opensearch.cluster.service.ClusterManagerService
    createClusterManagerService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.ClusterState initialClusterState)
     
    static org.opensearch.cluster.service.ClusterManagerService
    createClusterManagerService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.node.DiscoveryNode localNode)
     
    static org.opensearch.cluster.service.ClusterService
    createClusterService(org.opensearch.cluster.ClusterState initialState, org.opensearch.threadpool.ThreadPool threadPool)
     
    static org.opensearch.cluster.service.ClusterService
    createClusterService(org.opensearch.common.settings.Settings settings, org.opensearch.common.settings.ClusterSettings clusterSettings, org.opensearch.threadpool.ThreadPool threadPool)
     
    static org.opensearch.cluster.service.ClusterService
    createClusterService(org.opensearch.threadpool.ThreadPool threadPool)
     
    static org.opensearch.cluster.service.ClusterService
    createClusterService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.node.DiscoveryNode localNode)
     
    static org.opensearch.cluster.service.ClusterService
    createClusterService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.settings.ClusterSettings clusterSettings)
     
    static org.opensearch.cluster.service.ClusterService
    createClusterService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.settings.ClusterSettings clusterSettings, org.opensearch.telemetry.metrics.MetricsRegistry metricsRegistry)
     
    static org.opensearch.cluster.coordination.ClusterStatePublisher
    createClusterStatePublisher(org.opensearch.cluster.service.ClusterApplier clusterApplier)
     
    static org.opensearch.cluster.NodeConnectionsService
     
    static void
    setState(org.opensearch.cluster.service.ClusterApplierService executor, org.opensearch.cluster.ClusterState clusterState)
     
    static void
    setState(org.opensearch.cluster.service.ClusterManagerService executor, org.opensearch.cluster.ClusterState clusterState)
     
    static void
    setState(org.opensearch.cluster.service.ClusterService clusterService, org.opensearch.cluster.ClusterState clusterState)
    Sets the state on the cluster applier service
    static void
    setState(org.opensearch.cluster.service.ClusterService clusterService, org.opensearch.cluster.ClusterState.Builder clusterStateBuilder)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • ClusterServiceUtils

      public ClusterServiceUtils()
  • Method Details

    • createClusterManagerService

      public static org.opensearch.cluster.service.ClusterManagerService createClusterManagerService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.ClusterState initialClusterState)
    • createClusterManagerService

      public static org.opensearch.cluster.service.ClusterManagerService createClusterManagerService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.node.DiscoveryNode localNode)
    • setState

      public static void setState(org.opensearch.cluster.service.ClusterApplierService executor, org.opensearch.cluster.ClusterState clusterState)
    • setState

      public static void setState(org.opensearch.cluster.service.ClusterManagerService executor, org.opensearch.cluster.ClusterState clusterState)
    • createClusterService

      public static org.opensearch.cluster.service.ClusterService createClusterService(org.opensearch.threadpool.ThreadPool threadPool)
    • createClusterService

      public static org.opensearch.cluster.service.ClusterService createClusterService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.node.DiscoveryNode localNode)
    • createClusterService

      public static org.opensearch.cluster.service.ClusterService createClusterService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.settings.ClusterSettings clusterSettings)
    • createClusterService

      public static org.opensearch.cluster.service.ClusterService createClusterService(org.opensearch.threadpool.ThreadPool threadPool, org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.settings.ClusterSettings clusterSettings, org.opensearch.telemetry.metrics.MetricsRegistry metricsRegistry)
    • createClusterService

      public static org.opensearch.cluster.service.ClusterService createClusterService(org.opensearch.common.settings.Settings settings, org.opensearch.common.settings.ClusterSettings clusterSettings, org.opensearch.threadpool.ThreadPool threadPool)
    • createNoOpNodeConnectionsService

      public static org.opensearch.cluster.NodeConnectionsService createNoOpNodeConnectionsService()
    • createClusterStatePublisher

      public static org.opensearch.cluster.coordination.ClusterStatePublisher createClusterStatePublisher(org.opensearch.cluster.service.ClusterApplier clusterApplier)
    • createClusterService

      public static org.opensearch.cluster.service.ClusterService createClusterService(org.opensearch.cluster.ClusterState initialState, org.opensearch.threadpool.ThreadPool threadPool)
    • setState

      public static void setState(org.opensearch.cluster.service.ClusterService clusterService, org.opensearch.cluster.ClusterState.Builder clusterStateBuilder)
    • setState

      public static void setState(org.opensearch.cluster.service.ClusterService clusterService, org.opensearch.cluster.ClusterState clusterState)
      Sets the state on the cluster applier service