- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for cluster_name (0.08 seconds)
-
src/main/java/org/codelibs/fess/entity/PingResponse.java
import org.opensearch.common.xcontent.XContentType; /** * Response entity for ping operations. */ public class PingResponse { private static final String CLUSTER_NAME = "cluster_name"; private static final String STATUS = "status"; private static final String TIMED_OUT = "timed_out"; private static final String NUMBER_OF_NODES = "number_of_nodes";Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 6.4K bytes - Click Count (2) -
src/test/java/org/codelibs/fess/entity/PingResponseTest.java
} @Test public void test_fieldSetConfiguration() { // Test that field set configuration is properly handled Set<String> fieldSet = new HashSet<>(); fieldSet.add("cluster_name"); fieldSet.add("status"); FessConfig mockConfig = new FessConfig.SimpleImpl() { private static final long serialVersionUID = 1L; @OverrideCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 7.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java
.setThreads(threads) .setTimeout(timeout) .setType(type) .execute() .actionGet(timeout); append(buf, "cluster_name", () -> response.getClusterName().value()).append(','); final String hotThreads = response.getNodesMap().entrySet().stream().map(e -> { final StringBuilder tempBuf = new StringBuilder();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 3.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/PingSearchEngineJobTest.java
// Helper method to create mock ClusterHealthResponse private ClusterHealthResponse createMockHealthResponse(String clusterName, ClusterHealthStatus status) { return new ClusterHealthResponse() { @Override public String getClusterName() { return clusterName; } @Override public ClusterHealthStatus getStatus() {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 18.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
final ClusterHealthResponse response = esClient.admin().cluster().prepareHealth().execute().actionGet(fessConfig.getIndexHealthTimeout()); engineObj.clusterName = response.getClusterName(); engineObj.numberOfNodes = response.getNumberOfNodes(); engineObj.numberOfDataNodes = response.getNumberOfDataNodes();Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 19.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
T build(R response, H hit); } /** * Sets the name of the search engine cluster. * * @param clusterName the cluster name */ public void setClusterName(final String clusterName) { this.clusterName = clusterName; } /** * Gets information about the search engine. * * @return the engine information
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 14:36:23 GMT 2026 - 138.6K bytes - Click Count (1)