Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for IsServiceUnavailable (0.46 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top