- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for healCh (0.18 sec)
-
cmd/bucket-replication.go
} return } var ch, healCh chan<- ReplicationWorkerOperation switch ri.OpType { case replication.HealReplicationType, replication.ExistingObjectReplicationType: ch = p.mrfReplicaCh healCh = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size) default: ch = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size) } if ch == nil && healCh == nil { return } select {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K 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) -
cmd/admin-handlers.go
} // HealHandler - POST /minio/admin/v3/heal/ // ----------- // Start heal processing and return heal status items. // // On a successful heal sequence start, a unique client token is // returned. Subsequent requests to this endpoint providing the client // token will receive heal status records from the running heal // sequence. // // If no client token is provided, and a heal sequence is in progress
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
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: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Jan 15 16:49:26 UTC 2024 - 224K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller_test.go
t.Errorf("unexpected error: %v", err) } // 1. monitor node health twice, add untainted node once if err := nodeController.monitorNodeHealth(ctx); err != nil { t.Errorf("unexpected error: %v", err) } if err := nodeController.monitorNodeHealth(ctx); err != nil { t.Errorf("unexpected error: %v", err) } // 2. mark node0 healthy node0, err := fakeNodeHandler.Get(ctx, "node0", metav1.GetOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
operator/cmd/mesh/testdata/manifest-generate/data-snapshot.tar.gz
istio-ingressgateway: autoscaleEnabled: false ports: ## You can add custom gateway ports in user values overrides, but it must include those ports since helm replaces. # Note that AWS ELB will by default perform health checks on the first port # on this list. Setting this to the health check port will ensure that health # checks always work. https://github.com/istio/istio/issues/12503 - port: 15021 targetPort: 15021 name: status-port - port: 80 targetPort: 8080 name: http2 - port: 443 targetPort: 8443 name: https...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 05:10:03 UTC 2024 - 198.1K bytes - Viewed (0) -
operator/cmd/mesh/testdata/manifest-generate/output/pilot_default.golden.yaml
httpGet: path: /healthz/ready port: 15021 initialDelaySeconds: 0 periodSeconds: 1 timeoutSeconds: 3 failureThreshold: {{ .Values.global.proxy.startupProbe.failureThreshold }} {{ end }} readinessProbe: httpGet: path: /healthz/ready port: 15021
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 05:10:03 UTC 2024 - 102.6K 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) -
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) -
cmd/site-replication.go
select { case <-healTimer.C: c.RLock() enabled := c.enabled c.RUnlock() if enabled { refreshStart := time.Now() c.healIAMSystem(ctx, objAPI) // heal IAM system first c.healBuckets(ctx, objAPI) // heal buckets subsequently took := time.Since(refreshStart).Seconds() if took > maxRefreshDurationSecondsForLog { // Log if we took a lot of time.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0)