- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Healthy (0.12 sec)
-
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc_test.go
return false, fmt.Errorf("authenticator reported healthy when it should not") } if strings.HasPrefix(healthErr.Error(), c.wantHealthErrPrefix) { return true, nil } t.Logf("saw health error prefix that did not match: want=%q got=%q", c.wantHealthErrPrefix, healthErr.Error()) return false, nil }); err != nil { t.Fatalf("authenticator did not match wanted health error: %v", err) } return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 97.7K bytes - Viewed (0) -
pkg/printers/internalversion/printers_test.go
expected: []metav1.TableRow{{Cells: []interface{}{"cs2", "Healthy", "test message", "test error"}}}, }, // Basic component status with healthy condition. { componentStatus: api.ComponentStatus{ ObjectMeta: metav1.ObjectMeta{ Name: "cs3", }, Conditions: []api.ComponentCondition{ { Type: "Healthy", Status: api.ConditionFalse, Message: "test message",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
cmd/metrics-v2.go
opts := HealthOptions{} result := objLayer.Health(ctx, opts) metrics = make([]MetricV2, 0, 2+4*len(result.ESHealth)) metrics = append(metrics, MetricV2{ Description: getClusterWriteQuorumMD(), Value: float64(result.WriteQuorum), }) health := 1 if !result.Healthy { health = 0 } metrics = append(metrics, MetricV2{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
} klet.runtimeState = newRuntimeState(maxWaitForContainerRuntime) klet.runtimeState.addHealthCheck("PLEG", klet.pleg.Healthy) if utilfeature.DefaultFeatureGate.Enabled(features.EventedPLEG) { klet.runtimeState.addHealthCheck("EventedPLEG", klet.eventedPleg.Healthy) } if _, err := klet.updatePodCIDR(ctx, kubeCfg.PodCIDR); err != nil { klog.ErrorS(err, "Pod CIDR update failed") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/printers/internalversion/printers.go
} status := "Unknown" message := "" error := "" for _, condition := range obj.Conditions { if condition.Type == api.ComponentHealthy { if condition.Status == api.ConditionTrue { status = "Healthy" } else { status = "Unhealthy" } message = condition.Message error = condition.Error break } } row.Cells = append(row.Cells, obj.Name, status, message, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 128.3K bytes - Viewed (0) -
cluster/gce/gci/configure-helper.sh
fi if ! sudo modprobe -a ip_vs ip_vs_rr ip_vs_wrr ip_vs_sh ${conntrack_module}; then # If IPVS modules are not present, make sure the node does not come up as # healthy. exit 1 fi params+=" --proxy-mode=ipvs --ipvs-sync-period=1m --ipvs-min-sync-period=10s" ;; nftables) # Pass --conntrack-tcp-be-liberal so we can test that this makes the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 22:07:47 UTC 2024 - 141.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
assert.NotNil(t, fp.ipsetList["KUBE-HEALTH-CHECK-NODE-PORT"]) activeEntries1 := fp.ipsetList["KUBE-HEALTH-CHECK-NODE-PORT"].activeEntries assert.Equal(t, 1, activeEntries1.Len(), "Expected 1 active entry in KUBE-HEALTH-CHECK-NODE-PORT") assert.Equal(t, true, activeEntries1.Has("30000"), "Expected activeEntries to reference hc node port in spec") // Update health check node port in the spec newSvc := svc
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
cmd/admin-handlers.go
} deadline := 10 * time.Second // Default deadline is 10secs for health diagnostics. if dstr := query.Get("deadline"); dstr != "" { var err error deadline, err = time.ParseDuration(dstr) if err != nil { errResp(err) return } } nsLock := objectAPI.NewNSLock(minioMetaBucket, "health-check-in-progress") lkctx, err := nsLock.GetLock(ctx, newDynamicTimeout(deadline, deadline))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
cluster/gce/util.sh
gcloud compute health-checks --project "${PROJECT}" create tcp "${MASTER_NAME}-hc" --port=443 gcloud compute backend-services create "${MASTER_NAME}" \ --project "${PROJECT}" \ --region "${REGION}" \ --protocol tcp \ --region "${REGION}" \ --load-balancing-scheme internal \ --health-checks "${MASTER_NAME}-hc"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.6K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
if len(healthCheckNodePorts) != 1 { t.Errorf("expected healthcheck ports length 1, got %v", healthCheckNodePorts) } // No change; make sure the service map stays the same and there are // no health-check changes fp.OnServiceUpdate(servicev2, servicev2) result = fp.svcPortMap.Update(fp.serviceChanges) if len(fp.svcPortMap) != 2 { t.Errorf("expected service map length 2, got %v", fp.svcPortMap) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0)