Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for PingResponse (0.21 sec)

  1. 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)
  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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top