Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 82 for wealth (0.18 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go

    			}
    		}
    		if excluded.Len() > 0 {
    			fmt.Fprintf(&individualCheckOutput, "warn: some health checks cannot be excluded: no matches for %s\n", formatQuoted(excluded.List()...))
    			klog.V(6).Infof("cannot exclude some health checks, no health checks are installed matching %s",
    				formatQuoted(excluded.List()...))
    		}
    		// always be verbose on failure
    		if len(failedChecks) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go

    }
    
    func (h *kmsPluginProbe) toHealthzCheck(idx int) healthz.HealthChecker {
    	return healthz.NamedCheck(fmt.Sprintf("kms-provider-%d", idx), func(r *http.Request) error {
    		return h.check()
    	})
    }
    
    func (h *kmsv2PluginProbe) toHealthzCheck(idx int) healthz.HealthChecker {
    	return healthz.NamedCheck(fmt.Sprintf("kms-provider-%d", idx), func(r *http.Request) error {
    		return h.check(r.Context())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/util/apiclient/wait.go

    			w.client.Discovery().RESTClient().Get().AbsPath("/healthz").Do(ctx).StatusCode(&healthStatus)
    			if healthStatus != http.StatusOK {
    				return false, nil
    			}
    			return true, nil
    		})
    	if err != nil {
    		fmt.Printf("[api-check] The API server is not healthy after %v\n", time.Since(start))
    		return err
    	}
    
    	fmt.Printf("[api-check] The API server is healthy after %v\n", time.Since(start))
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. docs/metrics/v3.md

    | `minio_cluster_erasure_set_read_health`          | `gauge` | Health of the erasure set in a pool for read operations (1=healthy, 0=unhealthy)  | `pool_id,set_id` |
    | `minio_cluster_erasure_set_write_health`         | `gauge` | Health of the erasure set in a pool for write operations (1=healthy, 0=unhealthy) | `pool_id,set_id` |
    
    ### `/cluster/iam`
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 06 09:36:25 UTC 2024
    - 40.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/config.go

    	*completedConfig
    }
    
    // AddHealthChecks adds a health check to our config to be exposed by the health endpoints
    // of our configured apiserver. We should prefer this to adding healthChecks directly to
    // the config unless we explicitly want to add a healthcheck only to a specific health endpoint.
    func (c *Config) AddHealthChecks(healthChecks ...healthz.HealthChecker) {
    	c.HealthzChecks = append(c.HealthzChecks, healthChecks...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
  6. cmd/kube-scheduler/app/server.go

    // newHealthEndpointsAndMetricsHandler creates an API health server from the config, and will also
    // embed the metrics handler.
    // TODO: healthz check is deprecated, please use livez and readyz instead. Will be removed in the future.
    func newHealthEndpointsAndMetricsHandler(config *kubeschedulerconfig.KubeSchedulerConfiguration, informers informers.SharedInformerFactory, isLeader func() bool, healthzChecks, readyzChecks []healthz.HealthChecker) http.Handler {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  7. pilot/cmd/pilot-agent/status/server_test.go

    "/app-health/business/livez": {"httpGet": {"port": 9090}}}`,
    		},
    		// A valid gRPC probe.
    		{
    			probe: `{"/app-health/hello-world/readyz": {"gRPC": {"port": 8080}}}`,
    		},
    		// A valid gRPC probe with null service.
    		{
    			probe: `{"/app-health/hello-world/readyz": {"gRPC": {"port": 8080, "service": null}}}`,
    		},
    		// A valid gRPC probe with service.
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  8. platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/SystemApplicationClassLoaderWorker.java

    import org.gradle.process.internal.health.memory.DefaultJvmMemoryInfo;
    import org.gradle.process.internal.health.memory.DefaultMemoryManager;
    import org.gradle.process.internal.health.memory.DisabledOsMemoryInfo;
    import org.gradle.process.internal.health.memory.JvmMemoryInfo;
    import org.gradle.process.internal.health.memory.JvmMemoryStatus;
    import org.gradle.process.internal.health.memory.JvmMemoryStatusListener;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  9. pilot/cmd/pilot-agent/status/server.go

    // app probers.
    func FormatProberURL(container string) (string, string, string) {
    	return fmt.Sprintf("/app-health/%v/readyz", container),
    		fmt.Sprintf("/app-health/%v/livez", container),
    		fmt.Sprintf("/app-health/%v/startupz", container)
    }
    
    // Run opens a the status port and begins accepting probes.
    func (s *Server) Run(ctx context.Context) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 31.1K bytes
    - Viewed (1)
  10. cmd/xl-storage-disk-id-check.go

    		return ctx, done, ctx.Err()
    	}
    
    	atomic.StoreInt64(&p.health.lastStarted, time.Now().UnixNano())
    	p.health.waiting.Add(1)
    
    	ctx = context.WithValue(ctx, healthDiskCtxKey{}, &healthDiskCtxValue{lastSuccess: &p.health.lastSuccess})
    	si := p.updateStorageMetrics(s, paths...)
    	var once sync.Once
    	return ctx, func(sz int64, errp *error) {
    		p.health.waiting.Add(-1)
    		once.Do(func() {
    			if errp != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.4K bytes
    - Viewed (0)
Back to top