- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for TypedDelayingInterface (0.62 sec)
-
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) -
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) -
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)