- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 131 for UpdateFunc (0.26 sec)
-
pkg/controller/servicecidrs/servicecidrs_controller.go
), tree: iptree.New[sets.Set[string]](), workerLoopPeriod: time.Second, } _, _ = serviceCIDRInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addServiceCIDR, UpdateFunc: c.updateServiceCIDR, DeleteFunc: c.deleteServiceCIDR, }) c.serviceCIDRLister = serviceCIDRInformer.Lister() c.serviceCIDRsSynced = serviceCIDRInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
nodeInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { key, err := cache.MetaNamespaceKeyFunc(obj) if err == nil { ra.queue.Add(key) } }, UpdateFunc: func(old, new interface{}) { key, err := cache.MetaNamespaceKeyFunc(new) if err == nil { ra.queue.Add(key) } }, DeleteFunc: func(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
slice, ok := obj.(*resourceapi.ResourceSlice) if !ok { return } logger.V(5).Info("ResourceSlice add", "slice", klog.KObj(slice)) c.queue.Add(slice.DriverName) }, UpdateFunc: func(old, new any) { oldSlice, ok := old.(*resourceapi.ResourceSlice) if !ok { return } newSlice, ok := new.(*resourceapi.ResourceSlice) if !ok { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
} metrics.RegisterMetrics() if _, err := podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { ec.enqueuePod(logger, obj, false) }, UpdateFunc: func(old, updated interface{}) { ec.enqueuePod(logger, updated, false) }, DeleteFunc: func(obj interface{}) { ec.enqueuePod(logger, obj, true) }, }); err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
options.ResourceQuotaInformer.Informer().AddEventHandlerWithResyncPeriod( cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { rq.addQuota(logger, obj) }, UpdateFunc: func(old, cur interface{}) { // We are only interested in observing updates to quota.spec to drive updates to quota.status. // We ignore all updates to quota.Status because they are all driven by this controller.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { pod := obj.(*v1.Pod) nc.podUpdated(nil, pod) }, UpdateFunc: func(prev, obj interface{}) { prevPod := prev.(*v1.Pod) newPod := obj.(*v1.Pod) nc.podUpdated(prevPod, newPod) }, DeleteFunc: func(obj interface{}) { pod, isPod := obj.(*v1.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
pl := obj.(*flowcontrol.PriorityLevelConfiguration) klog.V(7).Infof("Triggered API priority and fairness config reloading in %s due to creation of PLC %s", cfgCtlr.name, pl.Name) cfgCtlr.configQueue.Add(0) }, UpdateFunc: func(oldObj, newObj interface{}) { newPL := newObj.(*flowcontrol.PriorityLevelConfiguration) oldPL := oldObj.(*flowcontrol.PriorityLevelConfiguration) if !apiequality.Semantic.DeepEqual(oldPL.Spec, newPL.Spec) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
t.Errorf("Unexpected error: %v", err) } updateFunc := func(input runtime.Object, res storage.ResponseMeta) (runtime.Object, *uint64, error) { return input, nil, nil } // GuaranteedUpdate without suggestion should return an error if err := store.GuaranteedUpdate(ctx, preset[1].key, &example.Pod{}, false, nil, updateFunc, nil); !storage.IsInternalError(err) { t.Errorf("Unexpected error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
AddFunc: func(obj interface{}) { event := &event{ eventType: addEvent, obj: obj, gvk: kind, } gb.graphChanges.Add(event) }, UpdateFunc: func(oldObj, newObj interface{}) { // TODO: check if there are differences in the ownerRefs, // finalizers, and DeletionTimestamp; if not, ignore the update. event := &event{ eventType: updateEvent,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
storage, _, _, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestUpdate( // valid validNewPod(), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*api.Pod) object.Labels = map[string]string{"a": "b"} return object }, ) } func TestDelete(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0)