Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 38 for oldObj (0.43 sec)

  1. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    }
    
    func (pl *PodTopologySpread) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/controller/endpointslice/endpointslice_controller.go

    	logger := klog.FromContext(ctx)
    	endpointSliceInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: c.onEndpointSliceAdd,
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			c.onEndpointSliceUpdate(logger, oldObj, newObj)
    		},
    		DeleteFunc: c.onEndpointSliceDelete,
    	})
    
    	c.endpointSliceLister = endpointSliceInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/strategy.go

    	}
    
    	return fields
    }
    
    func (statusStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) {
    	newObj := obj.(*apiextensions.CustomResourceDefinition)
    	oldObj := old.(*apiextensions.CustomResourceDefinition)
    	newObj.Spec = oldObj.Spec
    
    	// Status updates are for only for updating status, not objectmeta.
    	metav1.ResetObjectMetaForStatus(&newObj.ObjectMeta, &newObj.ObjectMeta)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    		c.enqueue(castObj)
    	}
    }
    
    func (c *CRDFinalizer) updateCustomResourceDefinition(oldObj, newObj interface{}) {
    	oldCRD := oldObj.(*apiextensionsv1.CustomResourceDefinition)
    	newCRD := newObj.(*apiextensionsv1.CustomResourceDefinition)
    	// only queue deleted things that haven't been finalized by us
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go

    	klog.V(4).Infof("Adding customresourcedefinition %s", castObj.Name)
    	c.enqueue(castObj)
    }
    
    func (c *DiscoveryController) updateCustomResourceDefinition(oldObj, newObj interface{}) {
    	castNewObj := newObj.(*apiextensionsv1.CustomResourceDefinition)
    	castOldObj := oldObj.(*apiextensionsv1.CustomResourceDefinition)
    	klog.V(4).Infof("Updating customresourcedefinition %s", castOldObj.Name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 21 11:40:03 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  9. pkg/controller/deployment/deployment_controller.go

    	}
    
    	dInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			dc.addDeployment(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			dc.updateDeployment(logger, oldObj, newObj)
    		},
    		// This will enter the sync loop and no-op, because the deployment has been deleted from the store.
    		DeleteFunc: func(obj interface{}) {
    			dc.deleteDeployment(logger, obj)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  10. pkg/controller/volume/persistentvolume/pv_controller_base.go

    	}
    
    	p.VolumeInformer.Informer().AddEventHandler(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc:    func(obj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, obj) },
    			UpdateFunc: func(oldObj, newObj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, newObj) },
    			DeleteFunc: func(obj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, obj) },
    		},
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
Back to top