Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for oldObj (0.11 sec)

  1. pkg/scheduler/util/assumecache/assume_cache_test.go

    	// Assume new object.
    	if err := cache.Assume(newObj); err != nil {
    		t.Fatalf("Assume() returned error %v", err)
    	}
    	verify(ktesting.WithStep(tCtx, "after Assume"), cache, oldObj.GetName(), newObj, oldObj)
    
    	// Restore object.
    	cache.Restore(oldObj.GetName())
    	verify(ktesting.WithStep(tCtx, "after second Restore"), cache, oldObj.GetName(), oldObj, oldObj)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates_test.go

    		})
    	}
    }
    
    func Test_isSchedulableAfterPodChange(t *testing.T) {
    	testcases := map[string]struct {
    		pod            *v1.Pod
    		oldObj, newObj interface{}
    		expectedHint   framework.QueueingHint
    		expectedErr    bool
    	}{
    		"backoff-wrong-old-object": {
    			pod:          &v1.Pod{},
    			oldObj:       "not-a-pod",
    			expectedHint: framework.Queue,
    			expectedErr:  true,
    		},
    		"backoff-wrong-new-object": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. pkg/registry/certificates/certificates/strategy_test.go

    	}()
    
    	tests := []struct {
    		name        string
    		newObj      *certapi.CertificateSigningRequest
    		oldObj      *certapi.CertificateSigningRequest
    		expectedObj *certapi.CertificateSigningRequest
    	}{
    		{
    			name:        "no-op",
    			newObj:      &certapi.CertificateSigningRequest{},
    			oldObj:      &certapi.CertificateSigningRequest{},
    			expectedObj: &certapi.CertificateSigningRequest{},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 14:34:53 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  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