java strings_Java Strings.capitalize方法代码示例

import org.elasticsearch.common.Strings; //导入方法依赖的package包/类

private ClusterHealthStatus ensureColor(ClusterHealthStatus clusterHealthStatus, TimeValue timeout, String... indices) {

String color = clusterHealthStatus.name().toLowerCase(Locale.ROOT);

String method = "ensure" + Strings.capitalize(color);

ClusterHealthRequest healthRequest = Requests.clusterHealthRequest(indices)

.timeout(timeout)

.waitForStatus(clusterHealthStatus)

.waitForEvents(Priority.LANGUID)

.waitForNoRelocatingShards(true)

// We currently often use ensureGreen or ensureYellow to check whether the cluster is back in a good state after shutting down

// a node. If the node that is stopped is the master node, another node will become master and publish a cluster state where it

// is master but where the node that was stopped hasn't been removed yet from the cluster state. It will only subsequently

// publish a second state where the old master is removed. If the ensureGreen/ensureYellow is timed just right, it will get to

// execute before the second cluster state update removes the old master and the condition ensureGreen / ensureYellow will

// trivially hold if it held before the node was shut down. The following "waitForNodes" condition ensures that the node has

// been removed by the master so that the health check applies to the set of nodes we expect to be part of the cluster.

.waitForNodes(Integer.toString(cluster().size()));

ClusterHealthResponse actionGet = client().admin().cluster().health(healthRequest).actionGet();

if (actionGet.isTimedOut()) {

logger.info("{} timed out, cluster state:\n{}\n{}",

method,

client().admin().cluster().prepareState().get().getState(),

client().admin().cluster().preparePendingClusterTasks().get());

fail("timed out waiting for " + color + " state");

}

assertThat("Expected at least " + clusterHealthStatus + " but got " + actionGet.getStatus(),

actionGet.getStatus().value(), lessThanOrEqualTo(clusterHealthStatus.value()));

logger.debug("indices {} are {}", indices.length == 0 ? "[_all]" : indices, color);

return actionGet.getStatus();

}


本文来自互联网用户投稿,文章观点仅代表作者本人,不代表本站立场,不承担相关法律责任。如若转载,请注明出处。 如若内容造成侵权/违法违规/事实不符,请点击【内容举报】进行投诉反馈!

相关文章

立即
投稿

微信公众账号

微信扫一扫加关注

返回
顶部