Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for not_ready (0.24 sec)

  1. guava/src/com/google/common/base/AbstractIterator.java

     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    abstract class AbstractIterator<T extends @Nullable Object> implements Iterator<T> {
      private State state = State.NOT_READY;
    
      protected AbstractIterator() {}
    
      private enum State {
        READY,
        NOT_READY,
        DONE,
        FAILED,
      }
    
      @CheckForNull private T next;
    
      @CheckForNull
      protected abstract T computeNext();
    
      @CanIgnoreReturnValue
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jul 09 17:31:04 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/base/AbstractIterator.java

     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    abstract class AbstractIterator<T extends @Nullable Object> implements Iterator<T> {
      private State state = State.NOT_READY;
    
      protected AbstractIterator() {}
    
      private enum State {
        READY,
        NOT_READY,
        DONE,
        FAILED,
      }
    
      @CheckForNull private T next;
    
      @CheckForNull
      protected abstract T computeNext();
    
      @CanIgnoreReturnValue
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jul 09 17:31:04 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/AbstractIterator.java

      private State state = State.NOT_READY;
    
      /** Constructor for use by subclasses. */
      protected AbstractIterator() {}
    
      private enum State {
        /** We have computed the next element and haven't returned it yet. */
        READY,
    
        /** We haven't yet computed or have already returned the element. */
        NOT_READY,
    
        /** We have reached the end of the data and are finished. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Mar 18 02:04:10 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/AbstractIterator.java

      private State state = State.NOT_READY;
    
      /** Constructor for use by subclasses. */
      protected AbstractIterator() {}
    
      private enum State {
        /** We have computed the next element and haven't returned it yet. */
        READY,
    
        /** We haven't yet computed or have already returned the element. */
        NOT_READY,
    
        /** We have reached the end of the data and are finished. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Mar 18 02:04:10 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  5. plugin/pkg/admission/nodetaint/admission_test.go

    		name           string
    		node           api.Node
    		oldNode        api.Node
    		operation      admission.Operation
    		options        runtime.Object
    		expectedTaints []api.Taint
    	}{
    		{
    			name:           "notReady taint is added on creation",
    			node:           myNodeObj,
    			operation:      admission.Create,
    			options:        &metav1.CreateOptions{},
    			expectedTaints: []api.Taint{notReadyTaint},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 06 04:56:21 UTC 2019
    - 3.1K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/phases/upgrade/health.go

    }
    
    // getNotReadyNodes returns a string slice of nodes in the cluster that are NotReady
    func getNotReadyNodes(nodes []v1.Node) []string {
    	var notReadyNodes []string
    	for _, node := range nodes {
    		for _, condition := range node.Status.Conditions {
    			if condition.Type == v1.NodeReady && condition.Status != v1.ConditionTrue {
    				notReadyNodes = append(notReadyNodes, node.ObjectMeta.Name)
    			}
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 09:18:02 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  7. plugin/pkg/admission/nodetaint/admission.go

    	}
    
    	node, ok := a.GetObject().(*api.Node)
    	if !ok {
    		return admission.NewForbidden(a, fmt.Errorf("unexpected type %T", a.GetObject()))
    	}
    
    	// Taint node with NotReady taint at creation. This is needed to make sure
    	// that nodes are added to the cluster with the NotReady taint. Otherwise,
    	// a new node may receive the taint with some delay causing pods to be
    	// scheduled on a not-ready node. Node controller will remove the taint
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 06 04:56:21 UTC 2019
    - 2.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/core/v1/well_known_taints.go

    	// and removed when node becomes ready.
    	TaintNodeNotReady = "node.kubernetes.io/not-ready"
    
    	// TaintNodeUnreachable will be added when node becomes unreachable
    	// (corresponding to NodeReady status ConditionUnknown)
    	// and removed when node becomes reachable (NodeReady status ConditionTrue).
    	TaintNodeUnreachable = "node.kubernetes.io/unreachable"
    
    	// TaintNodeUnschedulable will be added when node becomes unschedulable
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 26 16:23:21 UTC 2022
    - 2K bytes
    - Viewed (0)
  9. pkg/kubelet/events/event.go

    	FailedToInspectImage    = "InspectFailed"
    	ErrImageNeverPullPolicy = "ErrImageNeverPull"
    	BackOffPullImage        = "BackOff"
    )
    
    // kubelet event reason list
    const (
    	NodeReady                            = "NodeReady"
    	NodeNotReady                         = "NodeNotReady"
    	NodeSchedulable                      = "NodeSchedulable"
    	NodeNotSchedulable                   = "NodeNotSchedulable"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/admission/configuration/configuration_manager.go

    		bootstrapGracePeriod: defaultBootstrapGraceperiod,
    	}
    	return &p
    }
    
    func (a *poller) lastError(err error) {
    	a.lock.Lock()
    	defer a.lock.Unlock()
    	a.lastErr = err
    }
    
    func (a *poller) notReady() {
    	a.lock.Lock()
    	defer a.lock.Unlock()
    	a.ready = false
    }
    
    func (a *poller) bootstrapping() {
    	// bootstrapGracePeriod is read-only, so no lock is required
    	timer := time.NewTimer(a.bootstrapGracePeriod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 06 02:02:38 UTC 2017
    - 4.3K bytes
    - Viewed (0)
Back to top