ame", hostname); L108: } L109: L110: /** L111: * Set the value of clustername, used in parameter comment. <br> L112: * Even if empty string, treated as empty plainly. So "IF pmb != null" is false if empty. L113: * @param clustername The parameter value of clustername. (NotNull) L114: */ L115: public void setClustername(String clustername) { L116: registerVariable("clustername", clustername); L117: } L118: L119: /** L120: * Set the value of clusterstatus,...

UNASSIGNED_SHARDS = "unassigned_shards"; L49: L50: private final int status; L51: L52: private final String clusterName; L53: L54: private final String clusterStatus; L55: L56: private String message = StringUtil.EMPTY; L57: L58: public PingResponse(final ClusterHealthResponse response) { L59: status = response.getStatus() == ClusterHealthStatus.RED ? 1 : 0; L60: clusterName = response.getClusterName(); L61: clusterStatus = response.getStatus().toString(); L62: final...

ComponentUtil.getSearchEngineClient(); L170: final ClusterHealthResponse response = L171: esClient.admin().cluster().prepareHealth().execute().actionGet(fessConfig.getIndexHealthTimeout()); L172: engineObj.clusterName = response.getClusterName(); L173: engineObj.numberOfNodes = response.getNumberOfNodes(); L174: engineObj.numberOfDataNodes = response.getNumberOfDataNodes(); L175: engineObj.activePrimaryShards = response.getAc...

execTime, OptionalEntity<R> response); L1579: } L1580: L1581: public interface EntityCreator<T, R, H> { L1582: T build(R response, H hit); L1583: } L1584: L1585: public void setClusterName(final String clusterName) { L1586: this.clusterName = clusterName; L1587: } L1588: L1589: public EngineInfo getEngineInfo() { L1590: if (client instanceof final HttpClient httpClient) { L1591: return httpClient.getEngineInfo(); L1592: } L1593: throw...

esClient.admin().cluster().prepareNodesHotThreads().setIgnoreIdleThreads(ignoreIdleThreads).setInterval(interval) L52: .setThreads(threads).setTimeout(timeout).setType(type).execute().actionGet(timeout); L53: append(buf, "cluster_name", () -> response.getClusterName().value()).append(','); L54: final String hotThreads = response.getNodesMap().entrySet().stream().map(e -> { L55: final StringBuilder tempBuf = new StringBuilder(); L56: append(tempBuf,...