- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for DeletionHandlingMetaNamespaceKeyFunc (0.7 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
klog.V(7).Infof("No trigger API priority and fairness config reloading in %s due to spec non-change of PLC %s", cfgCtlr.name, newPL.Name) } }, DeleteFunc: func(obj interface{}) { name, _ := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) klog.V(7).Infof("Triggered API priority and fairness config reloading in %s due to deletion of PLC %s", cfgCtlr.name, name) cfgCtlr.configQueue.Add(0) }})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
controller := &PersistentVolumeController{ volumes: newPersistentVolumeOrderedIndex(), claims: cache.NewStore(cache.DeletionHandlingMetaNamespaceKeyFunc), kubeClient: p.KubeClient, eventBroadcaster: eventBroadcaster, eventRecorder: eventRecorder,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
} adc.processVolumesInUse(logger, nodeName, node.Status.VolumesInUse) } func (adc *attachDetachController) enqueuePVC(obj interface{}) { key, err := kcache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err != nil { runtime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err)) return } adc.pvcQueue.Add(key) } // pvcWorker processes items from pvcQueue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/controller/controller_utils.go
Jitter: 1.0, } var UpdateLabelBackoff = wait.Backoff{ Steps: 5, Duration: 100 * time.Millisecond, Jitter: 1.0, } var ( KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc podPhaseToOrdinal = map[v1.PodPhase]int{v1.PodPending: 0, v1.PodUnknown: 1, v1.PodRunning: 2} ) type ResyncPeriodFunc func() time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
ClusterIP: "3000::1", }, }, expectError: true, }, } for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { podStore := cache.NewStore(cache.DeletionHandlingMetaNamespaceKeyFunc) ns := "test" addPods(podStore, ns, 1, 1, 0, tc.ipFamilies) pods := podStore.List() if len(pods) != 1 { t.Fatalf("podStore size: expected: %d, got: %d", 1, len(pods)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
} fakeRecorder := record.NewFakeRecorder(100) dsc.eventRecorder = fakeRecorder fakePodControl := newFakePodControl() fakePodControl.podStore = cache.NewStore(cache.DeletionHandlingMetaNamespaceKeyFunc) // fake store that we don't use fakePodControl.expectations = controller.NewControllerExpectations() // fake expectations that we don't use dsc.podControl = fakePodControl
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0)