Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 75 for oldObj (0.58 sec)

  1. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

    		pod            *v1.Pod
    		oldObj, newObj interface{}
    		expectedHint   framework.QueueingHint
    		expectedErr    bool
    	}{
    		"backoff-wrong-new-object": {
    			pod:          &v1.Pod{},
    			newObj:       "not-a-pod",
    			expectedHint: framework.Queue,
    			expectedErr:  true,
    		},
    		"backoff-wrong-old-object": {
    			pod:          &v1.Pod{},
    			oldObj:       "not-a-pod",
    			newObj:       &v1.Pod{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  2. pkg/scheduler/eventhandlers.go

    }
    
    func (sched *Scheduler) updateNodeInCache(oldObj, newObj interface{}) {
    	logger := sched.logger
    	oldNode, ok := oldObj.(*v1.Node)
    	if !ok {
    		logger.Error(nil, "Cannot convert oldObj to *v1.Node", "oldObj", oldObj)
    		return
    	}
    	newNode, ok := newObj.(*v1.Node)
    	if !ok {
    		logger.Error(nil, "Cannot convert newObj to *v1.Node", "newObj", newObj)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    		claims         []*resourcev1alpha2.ResourceClaim
    		oldObj, newObj interface{}
    		expectedHint   framework.QueueingHint
    		expectedErr    bool
    	}{
    		"skip-deleted": {
    			pod:          podWithClaimTemplate,
    			oldObj:       scheduling,
    			expectedHint: framework.QueueSkip,
    		},
    		"skip-missed-deleted": {
    			pod: podWithClaimTemplate,
    			oldObj: cache.DeletedFinalStateUnknown{
    				Obj: scheduling,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  4. pkg/controller/garbagecollector/graph_builder.go

    				gvk:       kind,
    			}
    			gb.graphChanges.Add(event)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			// TODO: check if there are differences in the ownerRefs,
    			// finalizers, and DeletionTimestamp; if not, ignore the update.
    			event := &event{
    				eventType: updateEvent,
    				obj:       newObj,
    				oldObj:    oldObj,
    				gvk:       kind,
    			}
    			gb.graphChanges.Add(event)
    		},
    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/storageversionmigrator/resourceversion.go

    		),
    	}
    
    	_, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			rvController.addSVM(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			rvController.updateSVM(logger, oldObj, newObj)
    		},
    	})
    
    	return rvController
    }
    
    func (rv *ResourceVersionController) addSVM(logger klog.Logger, obj interface{}) {
    	svm := obj.(*svmv1alpha1.StorageVersionMigration)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. pkg/controller/resourcequota/resource_quota_monitor.go

    func (qm *QuotaMonitor) controllerFor(ctx context.Context, resource schema.GroupVersionResource) (cache.Controller, error) {
    	logger := klog.FromContext(ctx)
    
    	handlers := cache.ResourceEventHandlerFuncs{
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			if qm.updateFilter != nil && qm.updateFilter(resource, oldObj, newObj) {
    				event := &event{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/validation_test.go

    			name:   "integer",
    			obj:    1,
    			oldObj: 2,
    			schema: withRule(integerType, `
    				!oldSelf.hasValue() || self == 1
    			`),
    		},
    		{
    			name:   "number",
    			obj:    1.1,
    			oldObj: 2.2,
    			schema: withRule(numberType, `
    				!oldSelf.hasValue() || self == 1.1
    			`),
    		},
    		{
    			name:   "boolean",
    			obj:    true,
    			oldObj: false,
    			schema: withRule(booleanType, `
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 17:14:10 UTC 2024
    - 159.9K bytes
    - Viewed (0)
  8. pkg/controller/storageversionmigrator/storageversionmigrator.go

    	}
    
    	_, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			svmController.addSVM(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			svmController.updateSVM(logger, oldObj, newObj)
    		},
    	})
    
    	return svmController
    }
    
    func (svmc *SVMController) Name() string {
    	return svmc.controllerName
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go

    // pod schedulable.
    func (pl *TaintToleration) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	originalNode, modifiedNode, err := util.As[*v1.Node](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    	wasUntolerated := true
    	if originalNode != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go

    		enableSchedulingQueueHint: fts.EnableSchedulingQueueHint,
    	}, nil
    }
    
    func (pl *SchedulingGates) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	_, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    	if modifiedPod.UID != pod.UID {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top