本文整理了Java中org.elasticsearch.action.admin.cluster.health.ClusterHealthRequestBuilder.get()方法的一些代码示例，展示了ClusterHealthRequestBuilder.get()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ClusterHealthRequestBuilder.get()方法的具体详情如下：
包路径：org.elasticsearch.action.admin.cluster.health.ClusterHealthRequestBuilder
类名称：ClusterHealthRequestBuilder
方法名：get

ClusterHealthRequestBuilder.get介绍

暂无

代码示例

代码示例来源：origin: SonarSource/sonarqube

public void waitForStatus(ClusterHealthStatus status) {
 prepareHealth().setWaitForEvents(Priority.LANGUID).setWaitForStatus(status).get();
}

代码示例来源：origin: SonarSource/sonarqube

private void waitForIndexYellow(String index) {
 Client nativeClient = esClient.nativeClient();
 ClusterHealthAction.INSTANCE.newRequestBuilder(nativeClient).setIndices(index).setWaitForYellowStatus().get(TimeValue.timeValueMinutes(10));
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void get_with_string_timeout_is_not_yet_implemented() {
 try {
  es.client().prepareHealth().get("1");
  fail();
 } catch (Exception e) {
  assertThat(e).isInstanceOf(IllegalStateException.class).hasMessage("Not yet implemented");
 }
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void state() {
 ClusterHealthRequestBuilder requestBuilder = es.client().prepareHealth();
 ClusterHealthResponse state = requestBuilder.get();
 assertThat(state.getStatus()).isEqualTo(ClusterHealthStatus.GREEN);
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void trace_logs() {
 logTester.setLevel(LoggerLevel.TRACE);
 ClusterHealthRequestBuilder requestBuilder = es.client().prepareHealth();
 ClusterHealthResponse state = requestBuilder.get();
 assertThat(state.getStatus()).isEqualTo(ClusterHealthStatus.GREEN);
 assertThat(logTester.logs()).hasSize(1);
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void get_with_time_value_timeout_is_not_yet_implemented() {
 try {
  es.client().prepareHealth().get(TimeValue.timeValueMinutes(1));
  fail();
 } catch (Exception e) {
  assertThat(e).isInstanceOf(IllegalStateException.class).hasMessage("Not yet implemented");
 }
}

代码示例来源：origin: stagemonitor/stagemonitor

private static void startElasticsearch() throws Exception {
  try {
    FileUtils.deleteDirectory(new File("build/elasticsearch"));
  } catch (IOException e) {
    // ignore
  }
  final Settings settings = Settings.builder()
      .put("path.home", "build/elasticsearch")
      .put("node.name", "junit-es-node")
      .put("path.logs", "build/elasticsearch/logs")
      .put("path.data", "build/elasticsearch/data")
      .put("transport.type", "local")
      .put("http.type", "netty4")
      .build();
  node = new TestNode(settings, Collections.singletonList(Netty4Plugin.class));
  node.start();
  node.client().admin().cluster().prepareHealth().setWaitForGreenStatus().get();
}

代码示例来源：origin: stagemonitor/stagemonitor

node.client().admin().cluster().prepareHealth().setWaitForGreenStatus().get();

代码示例来源：origin: SonarSource/sonarqube

throw new IllegalStateException("Failed to create index " + index.getName());
SHARED_NODE.client().admin().cluster().prepareHealth(index.getName()).setWaitForStatus(ClusterHealthStatus.YELLOW).get();
SHARED_NODE.client().admin().cluster().prepareHealth(index.getName()).setWaitForStatus(ClusterHealthStatus.YELLOW).get();
result.add(index);

代码示例来源：origin: testcontainers/testcontainers-java

@Test
public void transportClientClusterHealth() {
  try (ElasticsearchContainer container = new ElasticsearchContainer()) {
    container.start();
    TransportAddress transportAddress = new TransportAddress(container.getTcpHost());
    String expectedClusterName = "docker-cluster";
    Settings settings = Settings.builder().put("cluster.name", expectedClusterName).build();
    try (TransportClient transportClient = new PreBuiltTransportClient(settings)
      .addTransportAddress(transportAddress)) {
      ClusterHealthResponse healths = transportClient.admin().cluster().prepareHealth().get();
      String clusterName = healths.getClusterName();
      assertThat(clusterName, is(expectedClusterName));
    }
  }
}

代码示例来源：origin: yacy/yacy_grid_mcp

public boolean clusterReady() {
  if (clusterReadyCache) return true;
  ClusterHealthResponse chr = elasticsearchClient.admin().cluster().prepareHealth().get();
  clusterReadyCache = chr.getStatus() != ClusterHealthStatus.RED;
  return clusterReadyCache;
}

代码示例来源：origin: org.nuxeo.elasticsearch/nuxeo-elasticsearch-core

@Override
public ClusterHealthStatus getHealthStatus(String[] indexNames) {
  return client.admin().cluster().prepareHealth(indexNames).get().getStatus();
}

代码示例来源：origin: mbok/logsniffer

@Override
  public Boolean execute(final Client client) {
    switch (client.admin().cluster().prepareHealth().get().getStatus()) {
    case GREEN:
    case YELLOW:
      esas.status = EsStatus.GREEN;
      break;
    case RED:
      esas.status = EsStatus.RED;
      break;
    }
    return null;
  }
});

代码示例来源：origin: com.strapdata.elasticsearch.test/framework

protected void ensureNodeCount(InternalTestCluster cluster) {
  assertFalse("cluster failed to form after disruption was healed", cluster.client().admin().cluster().prepareHealth()
    .setWaitForNodes(String.valueOf(cluster.size()))
    .setWaitForNoRelocatingShards(true)
    .get().isTimedOut());
}

代码示例来源：origin: com.strapdata.elasticsearch.test/framework

protected void ensureNodeCount(InternalTestCluster cluster) {
    assertFalse("cluster failed to form after disruption was healed", cluster.client().admin().cluster().prepareHealth()
        .setWaitForNodes(String.valueOf(cluster.size()))
        .setWaitForNoRelocatingShards(true)
        .get().isTimedOut());
  }
}

代码示例来源：origin: org.codehaus.sonar/sonar-search

@Override
public boolean isReady() {
 return node != null && node.client().admin().cluster().prepareHealth()
  .setWaitForYellowStatus()
  .setTimeout(TimeValue.timeValueSeconds(30L))
  .get()
  .getStatus() != ClusterHealthStatus.RED;
}

代码示例来源：origin: org.sonarsource.sonarqube/sonar-server

private void waitForIndexYellow(String index) {
 Client nativeClient = esClient.nativeClient();
 ClusterHealthAction.INSTANCE.newRequestBuilder(nativeClient).setIndices(index).setWaitForYellowStatus().get(TimeValue.timeValueMinutes(10));
}

代码示例来源：origin: com.strapdata.elasticsearch.test/framework

protected void ensureClusterSizeConsistency() {
  if (cluster() != null && cluster().size() > 0) { // if static init fails the cluster can be null
    logger.trace("Check consistency for [{}] nodes", cluster().size());
    assertNoTimeout(client().admin().cluster().prepareHealth().setWaitForNodes(Integer.toString(cluster().size())).get());
  }
}

代码示例来源：origin: com.strapdata.elasticsearch.test/framework

protected void startNode(long seed) throws Exception {
  ElassandraDaemon.instance.node(RandomizedContext.current().runWithPrivateRandomness(seed, this::newNode));
  // we must wait for the node to actually be up and running. otherwise the node might have started,
  // elected itself master but might not yet have removed the
  // SERVICE_UNAVAILABLE/1/state not recovered / initialized block
  ClusterAdminClient clusterAdminClient = client().admin().cluster();
  ClusterHealthRequestBuilder builder = clusterAdminClient.prepareHealth();
  ClusterHealthResponse clusterHealthResponse = builder.setWaitForGreenStatus().get();
  assertFalse(clusterHealthResponse.isTimedOut());
}

代码示例来源：origin: com.strapdata.elasticsearch.test/framework

protected IndexService createIndex(String index, CreateIndexRequestBuilder createIndexRequestBuilder) {
  assertAcked(createIndexRequestBuilder.get());
  // Wait for the index to be allocated so that cluster state updates don't override
  // changes that would have been done locally
  ClusterHealthRequestBuilder builder = client().admin().cluster().prepareHealth(index);
  builder.setWaitForYellowStatus()
    .setWaitForEvents(Priority.LANGUID)
    .setWaitForNoRelocatingShards(true);
  ClusterHealthResponse health = builder.get();
  assertThat(health.getStatus(), lessThanOrEqualTo(ClusterHealthStatus.YELLOW));
  assertThat("Cluster must be a single node cluster", health.getNumberOfDataNodes(), equalTo(1));
  IndicesService instanceFromNode = getInstanceFromNode(IndicesService.class);
  return instanceFromNode.indexServiceSafe(resolveIndex(index));
}