- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 830 for healCh (0.55 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) -
staging/src/k8s.io/apiserver/pkg/server/healthz.go
// we opt for a delay of zero here, because this entrypoint adds generic health checks // and not health checks which are specifically related to kube-apiserver boot-sequences. return s.addHealthChecks(0, checks...) } // AddBootSequenceHealthChecks adds health checks to the old healthz endpoint (for backwards compatibility reasons)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 6K bytes - Viewed (0) -
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) -
cluster/gce/gci/health-monitor.sh
if [[ "$#" -ne 1 ]]; then echo "Usage: health-monitor.sh <container-runtime/kubelet>" exit 1 fi KUBE_HOME="/home/kubernetes" KUBE_ENV="${KUBE_HOME}/kube-env" if [[ ! -e "${KUBE_ENV}" ]]; then echo "The ${KUBE_ENV} file does not exist!! Terminate health monitoring" exit 1 fi SLEEP_SECONDS=10 component=$1 echo "Start kubernetes health monitoring for ${component}" source "${KUBE_ENV}"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 20 09:19:08 UTC 2022 - 3.3K bytes - Viewed (0) -
cmd/background-heal-ops.go
"runtime" "strconv" "time" "github.com/minio/madmin-go/v3" "github.com/minio/pkg/v3/env" ) // healTask represents what to heal along with options // // path: '/' => Heal disk formats along with metadata // path: 'bucket/' or '/bucket/' => Heal bucket // path: 'bucket/object' => Heal object type healTask struct { bucket string object string versionID string opts madmin.HealOpts
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/health.go
func CheckClusterHealth(client clientset.Interface, cfg *kubeadmapi.ClusterConfiguration, ignoreChecksErrors sets.Set[string], printer output.Printer) error { _, _ = printer.Println("[upgrade] Running cluster health checks") healthChecks := []preflight.Checker{ &healthCheck{ name: "CreateJob", client: client, cfg: cfg, f: createJob, }, &healthCheck{ name: "ControlPlaneNodesReady",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 09:18:02 UTC 2024 - 8.8K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
func newHealingTracker() *healingTracker { return &healingTracker{ mu: &sync.RWMutex{}, } } func initHealingTracker(disk StorageAPI, healID string) *healingTracker { h := newHealingTracker() diskID, _ := disk.GetDiskID() h.disk = disk h.ID = diskID h.HealID = healID h.Path = disk.String() h.Endpoint = disk.Endpoint().String() h.Started = time.Now().UTC()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:32 UTC 2024 - 14.5K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/healthzadaptor.go
import ( "net/http" "sync" "time" ) // HealthzAdaptor associates the /healthz endpoint with the LeaderElection object. // It helps deal with the /healthz endpoint being set up prior to the LeaderElection. // This contains the code needed to act as an adaptor between the leader // election code the health check code. It allows us to provide health // status about the leader election. Most specifically about if the leader
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 11 16:58:48 UTC 2021 - 2.3K bytes - Viewed (0) -
cmd/admin-heal-ops.go
healFinishedStatus = "finished" ) const ( // a heal sequence with this many un-consumed heal result // items blocks until heal-status consumption resumes or is // aborted due to timeout. maxUnconsumedHealResultItems = 1000 // if no heal-results are consumed (via the heal-status API) // for this timeout duration, the heal sequence is aborted. healUnconsumedTimeout = 24 * time.Hour
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 18:04:41 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/proxy/healthcheck/proxier_health.go
) // ProxierHealthServer allows callers to: // 1. run a http server with /healthz and /livez endpoint handlers. // 2. update healthz timestamps before and after synchronizing dataplane. // 3. sync node status, for reporting unhealthy /healthz response // if the node is marked for deletion by autoscaler. // 4. get proxy health by verifying that the delay between QueuedUpdate()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0)