Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 79 for DeleteFunc (1 sec)

  1. pkg/controller/cronjob/cronjob_controllerv2.go

    		AddFunc:    jm.addJob,
    		UpdateFunc: jm.updateJob,
    		DeleteFunc: jm.deleteJob,
    	})
    
    	cronJobsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			jm.enqueueController(obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			jm.updateCronJob(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			jm.enqueueController(obj)
    		},
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  2. pkg/controller/volume/pvcprotection/pvc_protection_controller.go

    	}
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			e.podAddedDeletedUpdated(logger, nil, obj, false)
    		},
    		DeleteFunc: func(obj interface{}) {
    			e.podAddedDeletedUpdated(logger, nil, obj, true)
    		},
    		UpdateFunc: func(old, new interface{}) {
    			e.podAddedDeletedUpdated(logger, old, new, false)
    		},
    	})
    
    	return e, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 14K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go

    	s.notify()
    	s.refreshPolicies()
    
    	notifyFuncs := cache.ResourceEventHandlerFuncs{
    		AddFunc: func(_ interface{}) {
    			s.notify()
    		},
    		UpdateFunc: func(_, _ interface{}) {
    			s.notify()
    		},
    		DeleteFunc: func(_ interface{}) {
    			s.notify()
    		},
    	}
    	handle, err := s.policyInformer.AddEventHandler(notifyFuncs)
    	if err != nil {
    		return err
    	}
    	defer func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 21 23:07:34 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  4. pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go

    			// so we don't have to be choosy about our key.
    			AddFunc: func(obj interface{}) {
    				c.queue.Add(keyFn())
    			},
    			UpdateFunc: func(oldObj, newObj interface{}) {
    				c.queue.Add(keyFn())
    			},
    			DeleteFunc: func(obj interface{}) {
    				c.queue.Add(keyFn())
    			},
    		},
    	})
    
    	return c
    }
    
    func (c *Controller) syncConfigMap() error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  5. pkg/controller/nodeipam/ipam/range_allocator.go

    			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{}) {
    			// The informer cache no longer has the object, and since Node doesn't have a finalizer,
    			// we don't see the Update with DeletionTimestamp != 0.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. pkg/controller/disruption/disruption.go

    		AddFunc: func(obj interface{}) {
    			dc.addPod(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			dc.updatePod(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			dc.deletePod(logger, obj)
    		},
    	})
    	dc.podLister = podInformer.Lister()
    	dc.podListerSynced = podInformer.Informer().HasSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top