Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 75 for oldObj (0.1 sec)

  1. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    	testcases := map[string]struct {
    		pod                             *v1.Pod
    		oldObj, newObj                  interface{}
    		enableInPlacePodVerticalScaling bool
    		expectedHint                    framework.QueueingHint
    		expectedErr                     bool
    	}{
    		"backoff-wrong-old-object": {
    			pod:                             &v1.Pod{},
    			oldObj:                          "not-a-pod",
    			enableInPlacePodVerticalScaling: true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/interpodaffinity/plugin.go

    	return
    }
    
    func (pl *InterPodAffinity) 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: Fri Apr 12 03:08:44 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue.go

    	PluginName     string
    	QueueingHintFn framework.QueueingHintFn
    }
    
    // clusterEvent has the event and involved objects.
    type clusterEvent struct {
    	event framework.ClusterEvent
    	// oldObj is the object that involved this event.
    	oldObj interface{}
    	// newObj is the object that involved this event.
    	newObj interface{}
    }
    
    type priorityQueueOptions struct {
    	clock                             clock.Clock
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/validation/validation.go

    		requireOpenAPISchema:                     requireOpenAPISchema(&oldObj.Spec),
    		requireValidPropertyType:                 requireValidPropertyType(&oldObj.Spec),
    		requireStructuralSchema:                  requireStructuralSchema(&oldObj.Spec),
    		requirePrunedDefaults:                    requirePrunedDefaults(&oldObj.Spec),
    		requireAtomicSetType:                     requireAtomicSetType(&oldObj.Spec),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 82.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top