Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 152 for healCh (0.08 sec)

  1. compat/maven-model-builder/src/test/resources/dag.txt

    quarkus/extensions/smallrye-health/deployment/pom.xml
    	quarkus/core/deployment/pom.xml
    	quarkus/extensions/arc/deployment/pom.xml
    	quarkus/extensions/vertx-http/deployment/pom.xml
    	quarkus/extensions/jsonp/deployment/pom.xml
    	quarkus/extensions/smallrye-health/spi/pom.xml
    	quarkus/extensions/smallrye-openapi/spi/pom.xml
    	quarkus/extensions/smallrye-health/runtime/pom.xml
    	quarkus/test-framework/junit5-internal/pom.xml
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 224K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

         if (all disks return format.json not found)
            return error
         else (some disks return format.json not found)
            (heal format)
            return
         fi
       fi
    else
       if (some disks return format.json not found)
            // Offline disks are marked as dead.
            (heal format) // Offline disks should be marked as dead.
            return success
       fi
    fi
    */
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/entity/PingResponse.java

    import org.codelibs.fess.util.ComponentUtil;
    import org.codelibs.fess.util.SearchEngineUtil;
    import org.lastaflute.di.exception.IORuntimeException;
    import org.opensearch.action.admin.cluster.health.ClusterHealthResponse;
    import org.opensearch.cluster.health.ClusterHealthStatus;
    import org.opensearch.common.xcontent.XContentType;
    
    public class PingResponse {
        private static final String CLUSTER_NAME = "cluster_name";
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. src/test/resources/before_script.sh

    ./fess-*/bin/fess > ${temp_log_file} 2>&1 &
    
    temp_json_file=/tmp/fess-log.$$
    touch ${temp_json_file}
    error_count=0
    while true ; do
      status=$(curl -w '%{http_code}\n' -s -o ${temp_json_file} "http://localhost:8080/api/v1/health")
      cat ${temp_json_file}
      if [[ x"${status}" = x200 ]] ; then
        break
      else
        error_count=$((error_count + 1))
      fi
      if [[ ${error_count} -ge 60 ]] ; then
        echo "Fess is not available."
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Feb 10 03:25:34 UTC 2024
    - 863 bytes
    - Viewed (0)
  5. cmd/bucket-targets.go

    		Online:   true,
    	}
    	sys.hMutex.Unlock()
    }
    
    // newHCClient initializes an anonymous client for performing health check on the remote endpoints
    func newHCClient() *madmin.AnonymousClient {
    	clnt, e := madmin.NewAnonymousClientNoEndpoint()
    	if e != nil {
    		bugLogIf(GlobalContext, errors.New("Unable to initialize health check client"))
    		return nil
    	}
    	clnt.SetCustomTransport(globalRemoteTargetTransport)
    	return clnt
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

      /**
       * Waits for the {@link ServiceManager} to become {@linkplain #isHealthy() healthy}. The manager
       * will become healthy after all the component services have reached the {@linkplain State#RUNNING
       * running} state.
       *
       * @throws IllegalStateException if the service manager reaches a state from which it cannot
       *     become {@linkplain #isHealthy() healthy}.
       */
      public void awaitHealthy() {
        state.awaitHealthy();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/ServiceManager.java

      /**
       * Waits for the {@link ServiceManager} to become {@linkplain #isHealthy() healthy}. The manager
       * will become healthy after all the component services have reached the {@linkplain State#RUNNING
       * running} state.
       *
       * @throws IllegalStateException if the service manager reaches a state from which it cannot
       *     become {@linkplain #isHealthy() healthy}.
       */
      public void awaitHealthy() {
        state.awaitHealthy();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. cmd/admin-router.go

    		if globalIsDistErasure || globalIsErasure {
    			// Heal operations
    
    			// Heal processing endpoint.
    			adminRouter.Methods(http.MethodPost).Path(adminVersion + "/heal/").HandlerFunc(adminMiddleware(adminAPI.HealHandler, traceAllFlag))
    			adminRouter.Methods(http.MethodPost).Path(adminVersion + "/heal/{bucket}").HandlerFunc(adminMiddleware(adminAPI.HealHandler, traceAllFlag))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  9. cmd/peer-s3-client.go

    		// of such a bucket. This is needed here as we identify such
    		// buckets here while listing buckets. As part of regular
    		// globalBucketMetadataSys.Init() call would get a valid
    		// buckets only and not the quourum lost ones like this, so
    		// explicit call
    		for bktName, count := range bucketsMap {
    			if count < quorum {
    				// Queue a bucket heal task
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. cmd/metrics.go

    			float64(v), string(k),
    		)
    	}
    	for k, v := range bgSeq.getHealedItemsMap() {
    		ch <- prometheus.MustNewConstMetric(
    			prometheus.NewDesc(
    				prometheus.BuildFQName(healMetricsNamespace, "objects", "healed"),
    				"Objects healed since uptime",
    				[]string{"type"}, nil),
    			prometheus.CounterValue,
    			float64(v), string(k),
    		)
    	}
    	for k, v := range bgSeq.getHealFailedItemsMap() {
    		ch <- prometheus.MustNewConstMetric(
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
Back to top