- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for IsServiceUnavailable (0.46 sec)
-
pkg/registry/scheduling/rest/storage_scheduling.go
continue } // ServiceUnavailble error is returned when the API server is blocked by storage version updates if apierrors.IsServiceUnavailable(err) { klog.Infof("going to retry, unable to create PriorityClass %s: %v", pc.Name, err) return false, nil } return false, err } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 18:36:33 UTC 2022 - 4.7K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
return GetPodStartTime(pod1).Before(GetPodStartTime(pod2)) } // Retriable defines the retriable errors during a scheduling cycle. func Retriable(err error) bool { return apierrors.IsInternalError(err) || apierrors.IsServiceUnavailable(err) || net.IsConnectionRefused(err) } // PatchPodStatus calculates the delta bytes change from <old.Status> to <newStatus>, // and then submit a request to API server to patch the pod changes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/errors/errors.go
if _, ok := knownReasons[reason]; !ok && code == http.StatusMethodNotAllowed { return true } return false } // IsServiceUnavailable is true if the error indicates the underlying service is no longer available. // It supports wrapped errors and returns false when the error is nil. func IsServiceUnavailable(err error) bool { reason, code := reasonAndCodeForError(err) if reason == metav1.StatusReasonServiceUnavailable { return true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 21 03:41:32 UTC 2022 - 30.5K bytes - Viewed (0) -
pkg/registry/rbac/rest/storage_rbac.go
ClusterRoleBindingsToSplit map[string]rbacapiv1.ClusterRoleBinding } func isConflictOrServiceUnavailable(err error) bool { return apierrors.IsConflict(err) || apierrors.IsServiceUnavailable(err) } func retryOnConflictOrServiceUnavailable(backoff wait.Backoff, fn func() error) error { return retry.OnError(backoff, isConflictOrServiceUnavailable, fn) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 14 03:25:19 UTC 2022 - 18.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/idempotency.go
*lastError = errors.Wrapf(err, "error patching Node %q", n.Name) if apierrors.IsTimeout(err) || apierrors.IsConflict(err) || apierrors.IsServerTimeout(err) || apierrors.IsServiceUnavailable(err) { return false, nil } return false, *lastError } return true, nil } } // PatchNode tries to patch a node using patchFn for the actual mutating logic.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 18.4K bytes - Viewed (0)