Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 105 for newobj (0.16 sec)

  1. pkg/registry/resource/resourceclassparameters/strategy_test.go

    		ctx := genericapirequest.NewDefaultContext()
    		resourceClassParameters := resourceClassParameters.DeepCopy()
    		newObj := resourceClassParameters.DeepCopy()
    		newObj.Name += "-2"
    		newObj.ResourceVersion = "4"
    
    		Strategy.PrepareForUpdate(ctx, newObj, resourceClassParameters)
    		errs := Strategy.ValidateUpdate(ctx, newObj, resourceClassParameters)
    		if len(errs) == 0 {
    			t.Errorf("expected a validation error")
    		}
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 15:15:31 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  2. plugin/pkg/admission/gc/gc_admission_test.go

    		resource    schema.GroupVersionResource
    		subresource string
    		oldObj      runtime.Object
    		newObj      runtime.Object
    
    		checkError func(error) bool
    	}{
    		{
    			name:       "super-user, create, no objectref change",
    			username:   "super",
    			resource:   api.SchemeGroupVersion.WithResource("pods"),
    			newObj:     &api.Pod{},
    			checkError: expectNoError,
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  3. pkg/scheduler/util/assumecache/assume_cache_test.go

    	verify(ktesting.WithStep(tCtx, "after nop add"), cache, key, newObj, newObj)
    	informer.add(nil)
    	verify(ktesting.WithStep(tCtx, "after nil add"), cache, key, newObj, newObj)
    	informer.update(oldObj)
    	verify(ktesting.WithStep(tCtx, "after nop update"), cache, key, newObj, newObj)
    	informer.update(nil)
    	verify(ktesting.WithStep(tCtx, "after nil update"), cache, key, newObj, newObj)
    	informer.delete(nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. pkg/registry/networking/servicecidr/strategy_test.go

    	newObj := &networking.ServiceCIDR{
    		Spec: networking.ServiceCIDRSpec{
    			CIDRs: []string{"10.10.0.0/16"},
    		},
    	}
    	StatusStrategy.PrepareForUpdate(context.TODO(), newObj, oldObj)
    	if !reflect.DeepEqual(newObj.Spec, networking.ServiceCIDRSpec{}) {
    		t.Errorf("Expected spec field to be preserved from old object during status update")
    	}
    
    	newObj = &networking.ServiceCIDR{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 04 15:09:29 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. pkg/registry/resource/resourceclaimparameters/strategy_test.go

    		ctx := genericapirequest.NewDefaultContext()
    		resourceClaimParameters := resourceClaimParameters.DeepCopy()
    		newObj := resourceClaimParameters.DeepCopy()
    		newObj.Name += "-2"
    		newObj.ResourceVersion = "4"
    
    		Strategy.PrepareForUpdate(ctx, newObj, resourceClaimParameters)
    		errs := Strategy.ValidateUpdate(ctx, newObj, resourceClaimParameters)
    		if len(errs) == 0 {
    			t.Errorf("expected a validation error")
    		}
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 15:15:31 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  6. pkg/registry/core/persistentvolume/strategy_test.go

    	defer func() {
    		NowFunc = metav1.Now
    	}()
    	tests := []struct {
    		name        string
    		fg          bool
    		newObj      *api.PersistentVolume
    		expectedObj *api.PersistentVolume
    	}{
    		{
    			name: "feature enabled: pv is in pending phase and has a timestamp",
    			fg:   true,
    			newObj: &api.PersistentVolume{
    				ObjectMeta: metav1.ObjectMeta{
    					Name: "foo",
    				},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 11K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

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

    			if oldObj == nil {
    				return
    			}
    			newObj := ExtractObject(newInterface)
    			if newObj == nil {
    				return
    			}
    			if onlyIncludeSpecChanges && oldObj.GetResourceVersion() == newObj.GetResourceVersion() {
    				return
    			}
    			newer := filter(newObj)
    			older := filter(oldObj)
    			if !newer && !older {
    				return
    			}
    			handler(newObj)
    		},
    		DeleteFunc: single,
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 11 08:27:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  9. 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)
  10. pkg/proxy/config/config.go

    func (c *EndpointSliceConfig) handleUpdateEndpointSlice(oldObj, newObj interface{}) {
    	oldEndpointSlice, ok := oldObj.(*discoveryv1.EndpointSlice)
    	if !ok {
    		utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", newObj))
    		return
    	}
    	newEndpointSlice, ok := newObj.(*discoveryv1.EndpointSlice)
    	if !ok {
    		utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", newObj))
    		return
    	}
    	for _, h := range c.eventHandlers {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
Back to top