Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 61 for DeleteFunc (0.36 sec)

  1. pkg/controller/replicaset/replica_set.go

    		AddFunc: func(obj interface{}) {
    			rsc.addRS(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			rsc.updateRS(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			rsc.deleteRS(logger, obj)
    		},
    	})
    	rsInformer.Informer().AddIndexers(cache.Indexers{
    		controllerUIDIndex: func(obj interface{}) ([]string, error) {
    			rs, ok := obj.(*apps.ReplicaSet)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/dra/plugin/noderesources.go

    			} else {
    				logger.V(5).Info("ResourceSlice update", "slice", klog.KObj(newSlice))
    			}
    			c.queue.Add(newSlice.DriverName)
    		},
    		DeleteFunc: func(obj any) {
    			if tombstone, ok := obj.(cache.DeletedFinalStateUnknown); ok {
    				obj = tombstone.Obj
    			}
    			slice, ok := obj.(*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)
  3. pkg/controller/resourceclaim/controller.go

    		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
    	}
    	if _, err := claimInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  4. src/crypto/tls/common.go

    		if needFIPS() {
    			return slices.DeleteFunc(curvePreferences, func(c CurveID) bool {
    				return !slices.Contains(defaultCurvePreferencesFIPS, c)
    			})
    		}
    	} else if needFIPS() {
    		curvePreferences = slices.Clone(defaultCurvePreferencesFIPS)
    	} else {
    		curvePreferences = defaultCurvePreferences()
    	}
    	if version < VersionTLS13 {
    		return slices.DeleteFunc(curvePreferences, func(c CurveID) bool {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 59.1K bytes
    - Viewed (0)
  5. pkg/controller/resourcequota/resource_quota_controller.go

    			// Note that deleting a controller immediately after scaling it to 0 will not work. The recommended
    			// way of achieving this is by performing a `stop` operation on the controller.
    			DeleteFunc: func(obj interface{}) {
    				rq.enqueueResourceQuota(logger, obj)
    			},
    		},
    		rq.resyncPeriod(),
    	)
    
    	if options.DiscoveryFunc != nil {
    		qm := NewMonitor(
    			options.InformersStarted,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  6. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    			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)
    			// We can get DeletedFinalStateUnknown instead of *v1.Pod here and we need to handle that correctly.
    			if !isPod {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    				cfgCtlr.configQueue.Add(0)
    			} else {
    				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)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  8. pkg/controller/garbagecollector/graph_builder.go

    			event := &event{
    				eventType: updateEvent,
    				obj:       newObj,
    				oldObj:    oldObj,
    				gvk:       kind,
    			}
    			gb.graphChanges.Add(event)
    		},
    		DeleteFunc: func(obj interface{}) {
    			// delta fifo may wrap the object in a cache.DeletedFinalStateUnknown, unwrap it
    			if deletedFinalStateUnknown, ok := obj.(cache.DeletedFinalStateUnknown); ok {
    				obj = deletedFinalStateUnknown.Obj
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  9. pkg/controller/job/job_controller.go

    		AddFunc: func(obj interface{}) {
    			jm.addJob(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			jm.updateJob(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			jm.deleteJob(logger, obj)
    		},
    	}); err != nil {
    		return nil, fmt.Errorf("adding Job event handler: %w", err)
    	}
    	jm.jobLister = jobInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/kube/controller/controller.go

    						updatesames.Increment()
    						return
    					}
    				}
    				updates.Increment()
    				c.queue.Push(func() error {
    					return wrappedHandler(old, cur, model.EventUpdate)
    				})
    			},
    			DeleteFunc: func(obj T) {
    				deletes.Increment()
    				c.queue.Push(func() error {
    					return handler(ptr.Empty[T](), obj, model.EventDelete)
    				})
    			},
    		})
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top