Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for DeleteFunc (0.19 sec)

  1. pkg/controller/daemon/daemon_controller.go

    		AddFunc: func(obj interface{}) {
    			dsc.addDaemonset(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			dsc.updateDaemonset(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			dsc.deleteDaemonset(logger, obj)
    		},
    	})
    	dsc.dsLister = daemonSetInformer.Lister()
    	dsc.dsStoreSynced = daemonSetInformer.Informer().HasSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    	}
    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    ret.createCustomResourceDefinition,
    		UpdateFunc: ret.updateCustomResourceDefinition,
    		DeleteFunc: func(obj interface{}) {
    			ret.removeDeadStorage()
    		},
    	})
    	crConverterFactory, err := conversion.NewCRConverterFactory(serviceResolver, authResolverWrapper)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
  6. pkg/controller/podautoscaler/horizontal.go

    	}
    
    	hpaInformer.Informer().AddEventHandlerWithResyncPeriod(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc:    hpaController.enqueueHPA,
    			UpdateFunc: hpaController.updateHPA,
    			DeleteFunc: hpaController.deleteHPA,
    		},
    		resyncPeriod,
    	)
    	hpaController.hpaLister = hpaInformer.Lister()
    	hpaController.hpaListerSynced = hpaInformer.Informer().HasSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
Back to top