Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for TypedDelayingInterface (0.62 sec)

  1. pkg/controller/podgc/gc_controller.go

    	podLister        corelisters.PodLister
    	podListerSynced  cache.InformerSynced
    	nodeLister       corelisters.NodeLister
    	nodeListerSynced cache.InformerSynced
    
    	nodeQueue workqueue.TypedDelayingInterface[string]
    
    	terminatedPodThreshold int
    	gcCheckPeriod          time.Duration
    	quarantineTime         time.Duration
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. pkg/controller/podgc/gc_controller_test.go

    			Name:      name,
    			Namespace: metav1.NamespaceDefault,
    		},
    		Spec:   v1.PodSpec{NodeName: nodeName},
    		Status: v1.PodStatus{Phase: phase},
    	}
    }
    
    func waitForAdded(q workqueue.TypedDelayingInterface[string], depth int) error {
    	return wait.Poll(1*time.Millisecond, 10*time.Second, func() (done bool, err error) {
    		if q.Len() == depth {
    			return true, nil
    		}
    
    		return false, nil
    	})
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 08:16:48 UTC 2024
    - 29K bytes
    - Viewed (0)
  3. pkg/controller/disruption/disruption.go

    	ssListerSynced cache.InformerSynced
    
    	// PodDisruptionBudget keys that need to be synced.
    	queue        workqueue.TypedRateLimitingInterface[string]
    	recheckQueue workqueue.TypedDelayingInterface[string]
    
    	// pod keys that need to be synced due to a stale DisruptionTarget condition.
    	stalePodDisruptionQueue   workqueue.TypedRateLimitingInterface[string]
    	stalePodDisruptionTimeout time.Duration
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
Back to top