- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for PingResponse (0.05 sec)
-
src/main/java/org/codelibs/fess/entity/PingResponse.java
import org.opensearch.cluster.health.ClusterHealthStatus; 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";
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.4K bytes - Viewed (2) -
src/test/java/org/codelibs/fess/job/PingSearchEngineJobTest.java
// Setup mock components SearchEngineClient searchEngineClient = new SearchEngineClient() { @Override public PingResponse ping() { PingResponse response = new PingResponse(createMockHealthResponse("test-cluster", ClusterHealthStatus.RED)) { @Override public int getStatus() {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 18.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PingSearchEngineJob.java
import static org.codelibs.core.stream.StreamUtil.stream; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.fess.entity.PingResponse; import org.codelibs.fess.helper.NotificationHelper; import org.codelibs.fess.helper.SystemHelper; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.mylasta.mail.EsStatusPostcard;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
try { final PingResponse pingResponse = searchEngineClient.ping(); writeJsonResponse(pingResponse.getStatus() == 0 ? HttpServletResponse.SC_OK : HttpServletResponse.SC_SERVICE_UNAVAILABLE, "\"data\":" + pingResponse.getMessage()); } catch (final Exception e) { if (logger.isDebugEnabled()) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 54.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/entity/PingResponseTest.java
} }; ComponentUtil.register(mockConfig, "fessConfig"); // Note: Full testing requires a running OpenSearch cluster // These tests verify the PingResponse class structure is correct assertTrue(true); } public void test_getClusterName_returnsCorrectValue() { // Test cluster name getter exists
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
* @throws SearchEngineClientException if the ping fails */ public PingResponse ping() { try { final ClusterHealthResponse response = client.admin().cluster().prepareHealth().execute().actionGet(ComponentUtil.getFessConfig().getIndexHealthTimeout()); return new PingResponse(response); } catch (final OpenSearchException e) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (0)