Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 117 for oldObj (0.1 sec)

  1. pkg/scheduler/framework/plugins/nodeports/node_ports.go

    // that change made a previously unschedulable pod schedulable.
    func (pl *NodePorts) isSchedulableAfterPodDeleted(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	deletedPod, _, err := util.As[*v1.Pod](oldObj, nil)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    	// If the deleted pod is unscheduled, it doesn't make the target pod schedulable.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 10:53:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. pkg/kube/krt/informer.go

    		AddExtendedFunc: func(obj I, initialSync bool) {
    			handler(Event[I]{
    				New:   &obj,
    				Event: controllers.EventAdd,
    			}, initialSync)
    		},
    		UpdateFunc: func(oldObj, newObj I) {
    			handler(Event[I]{
    				Old:   &oldObj,
    				New:   &newObj,
    				Event: controllers.EventUpdate,
    			}, false)
    		},
    		DeleteFunc: func(obj I) {
    			handler(Event[I]{
    				Old:   &obj,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 11:01:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. pkg/controller/replication/conversion.go

    		return
    	}
    	h.handler.OnAdd(rs, isInInitialList)
    }
    
    func (h conversionEventHandler) OnUpdate(oldObj, newObj interface{}) {
    	oldRS, err := convertRCtoRS(oldObj.(*v1.ReplicationController), nil)
    	if err != nil {
    		utilruntime.HandleError(fmt.Errorf("dropping RC OnUpdate event: can't convert old object %#v to RS: %v", oldObj, err))
    		return
    	}
    	newRS, err := convertRCtoRS(newObj.(*v1.ReplicationController), nil)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 14 18:43:33 UTC 2022
    - 12.7K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/noderesources/fit.go

    // that change made a previously unschedulable pod schedulable.
    func (f *Fit) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	originalPod, modifiedPod, err := schedutil.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    	if modifiedPod == nil {
    		if originalPod.Spec.NodeName == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  5. pkg/controlplane/controller/crdregistration/crdregistration_controller.go

    			cast := obj.(*apiextensionsv1.CustomResourceDefinition)
    			c.enqueueCRD(cast)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			// Enqueue both old and new object to make sure we remove and add appropriate API services.
    			// The working queue will resolve any duplicates and only changes will stay in the queue.
    			c.enqueueCRD(oldObj.(*apiextensionsv1.CustomResourceDefinition))
    			c.enqueueCRD(newObj.(*apiextensionsv1.CustomResourceDefinition))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go

    		}
    
    		c.queue.Add(key)
    	}
    
    	registration, err := c.informer.AddEventHandler(cache.ResourceEventHandlerDetailedFuncs{
    		AddFunc: enqueue,
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			oldMeta, err1 := meta.Accessor(oldObj)
    			newMeta, err2 := meta.Accessor(newObj)
    
    			if err1 != nil || err2 != nil {
    				if err1 != nil {
    					utilruntime.HandleError(err1)
    				}
    
    				if err2 != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  7. pkg/controller/volume/attachdetach/attach_detach_controller.go

    	podInformer.Informer().AddEventHandler(kcache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			adc.podAdd(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			adc.podUpdate(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			adc.podDelete(logger, obj)
    		},
    	})
    
    	// This custom indexer will index pods by its PVC keys. Then we don't need
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go

    		oldObj := getMutableObject(event.PrevObject)
    		// We know that if oldObj is cachingObject (which can only be set via
    		// setCachingObjects), its resourceVersion is already set correctly and
    		// we don't need to update it. However, since cachingObject efficiently
    		// handles noop updates, we avoid this microoptimization here.
    		updateResourceVersion(oldObj, c.versioner, event.ResourceVersion)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 12:22:41 UTC 2023
    - 18.7K bytes
    - Viewed (0)
  9. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go

    	}
    
    	endpointsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			c.onEndpointsAdd(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			c.onEndpointsUpdate(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			c.onEndpointsDelete(logger, obj)
    		},
    	})
    	c.endpointsLister = endpointsInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd.go

    }
    
    func (i *scaleUpdatedObjectInfo) Preconditions() *metav1.Preconditions {
    	return i.reqObjInfo.Preconditions()
    }
    
    func (i *scaleUpdatedObjectInfo) UpdatedObject(ctx context.Context, oldObj runtime.Object) (runtime.Object, error) {
    	cr := oldObj.DeepCopyObject().(*unstructured.Unstructured)
    	const invalidSpecReplicas = -2147483648 // smallest int32
    
    	managedFieldsHandler := managedfields.NewScaleHandler(
    		cr.GetManagedFields(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 12.4K bytes
    - Viewed (0)
Back to top