Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 79 of 79 for DeleteFunc (0.28 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go

    		{"LOG_WARNING", Const, 0},
    		{"New", Func, 0},
    		{"NewLogger", Func, 0},
    		{"Priority", Type, 0},
    		{"Writer", Type, 0},
    	},
    	"maps": {
    		{"Clone", Func, 21},
    		{"Copy", Func, 21},
    		{"DeleteFunc", Func, 21},
    		{"Equal", Func, 21},
    		{"EqualFunc", Func, 21},
    	},
    	"math": {
    		{"Abs", Func, 0},
    		{"Acos", Func, 0},
    		{"Acosh", Func, 0},
    		{"Asin", Func, 0},
    		{"Asinh", Func, 0},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 534.2K bytes
    - Viewed (0)
Back to top