Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 191 for healCh (0.11 sec)

  1. cmd/erasure-common.go

    			if err != nil || di.Healing {
    				// - Do not consume disks which are not reachable
    				//   unformatted or simply not accessible for some reason.
    				//
    				// - Do not consume disks which are being healed
    				//
    				// - Future: skip busy disks
    				return
    			}
    
    			mu.Lock()
    			newDisks = append(newDisks, disks[i])
    			mu.Unlock()
    		}()
    	}
    	wg.Wait()
    	return newDisks
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. internal/http/transports.go

    	// https://github.com/golang/go/issues/29246
    	// if tlsConfig != nil {
    	// 	trhttp2, _ := http2.ConfigureTransports(tr)
    	// 	if trhttp2 != nil {
    	// 		// ReadIdleTimeout is the timeout after which a health check using ping
    	// 		// frame will be carried out if no frame is received on the
    	// 		// connection. 5 minutes is sufficient time for any idle connection.
    	// 		trhttp2.ReadIdleTimeout = 5 * time.Minute
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. cni/pkg/constants/constants.go

    	UDSLogPath            = "/log"
    	CNIEventSocketName    = "pluginevent.sock"
    	LogUDSSocketName      = "log.sock"
    	CNIPluginKubeconfName = "istio-cni-kubeconfig"
    	// K8s liveness and readiness endpoints
    	LivenessEndpoint   = "/healthz"
    	ReadinessEndpoint  = "/readyz"
    	ReadinessPort      = "8000"
    	ServiceAccountPath = "/var/run/secrets/kubernetes.io/serviceaccount"
    )
    
    // Exposed for testing "constants"
    var (
    	CNIBinDir     = "/opt/cni/bin"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. cmd/erasure-errors.go

    // errErasureWriteQuorum - did not meet write quorum.
    var errErasureWriteQuorum = errors.New("Write failed. Insufficient number of drives online")
    
    // errNoHealRequired - returned when healing is attempted on a previously healed disks.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 04 23:10:08 UTC 2022
    - 1.2K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/testdata/routes/k8s-gateway-http-route-path-prefix/configdump.json

          "virtual_hosts": [
           {
            "name": "backend",
            "domains": [
             "*"
            ],
            "routes": [
             {
              "match": {
               "prefix": "/healthz/ready"
              },
              "route": {
               "cluster": "agent"
              }
             }
            ]
           }
          ]
         },
         "last_updated": "2023-11-29T09:58:27.299Z"
        },
        {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 08 20:44:50 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  6. cmd/background-newdisks-heal-ops_gen_test.go

    Krishnan Parthasarathi <******@****.***> 1618853442 -0700
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  7. cmd/object-api-interface.go

    	HealObjects(ctx context.Context, bucket, prefix string, opts madmin.HealOpts, fn HealObjectFn) error
    	CheckAbandonedParts(ctx context.Context, bucket, object string, opts madmin.HealOpts) error
    
    	// Returns health of the backend
    	Health(ctx context.Context, opts HealthOptions) HealthResult
    
    	// Metadata operations
    	PutObjectMetadata(context.Context, string, string, ObjectOptions) (ObjectInfo, error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

    import org.codelibs.fess.es.client.SearchEngineClient;
    import org.codelibs.fess.util.ComponentUtil;
    import org.lastaflute.web.Execute;
    import org.lastaflute.web.response.JsonResponse;
    import org.opensearch.action.admin.cluster.health.ClusterHealthResponse;
    import org.opensearch.monitor.jvm.JvmStats;
    import org.opensearch.monitor.jvm.JvmStats.BufferPool;
    import org.opensearch.monitor.jvm.JvmStats.Classes;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  9. internal/dsync/dsync-server_test.go

    			lsrv: lsrv,
    		}
    		lockServers[i] = lsrv
    
    		router := mux.NewRouter().SkipClean(true)
    		subrouter := router.PathPrefix("/").Subrouter()
    		subrouter.Methods(http.MethodPost).Path("/v1/health").HandlerFunc(lockServer.HealthHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/refresh").HandlerFunc(lockServer.RefreshHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/lock").HandlerFunc(lockServer.LockHandler)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/ztunnel/configdump/services.go

    		}
    		allEndpoints := len(svc.Endpoints)
    		healthyEndpoints := 0
    		for _, ep := range svc.Endpoints {
    			w, f := workloadsByUID[ep.WorkloadUID]
    			if !f {
    				continue
    			}
    			if w.Status != "Healthy" {
    				continue
    			}
    			healthyEndpoints++
    		}
    		endpoints := fmt.Sprintf("%d/%d", healthyEndpoints, allEndpoints)
    
    		waypoint := serviceWaypointName(svc, zDump.Services)
    		fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\n",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 24 09:07:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top