Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 189 for newobj (0.31 sec)

  1. pkg/scheduler/util/utils.go

    // object stored in it will be converted instead.
    func As[T any](oldObj, newobj interface{}) (T, T, error) {
    	var oldTyped T
    	var newTyped T
    	var ok bool
    	if newobj != nil {
    		newTyped, ok = newobj.(T)
    		if !ok {
    			return oldTyped, newTyped, fmt.Errorf("expected %T, but got %T", newTyped, newobj)
    		}
    	}
    
    	if oldObj != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 21 01:40:44 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  2. 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)
  3. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    			if tc.expectedErr {
    				require.Error(t, err)
    				return
    			}
    			require.NoError(t, err)
    			require.Equal(t, tc.expectedHint, actualHint)
    		})
    	}
    }
    
    func Test_isSchedulableAfterNodeChange(t *testing.T) {
    	testcases := map[string]struct {
    		pod            *v1.Pod
    		oldObj, newObj interface{}
    		expectedHint   framework.QueueingHint
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  4. 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)
  5. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/typeconverter_test.go

    	if err != nil {
    		t.Fatalf("Failed to convert object to typed: %v", err)
    	}
    	newObj, err := tc.TypedToObject(typed)
    	if err != nil {
    		t.Fatalf("Failed to convert typed to object: %v", err)
    	}
    	if !reflect.DeepEqual(obj, newObj) {
    		t.Errorf(`Round-trip failed:
    Original object:
    %#v
    Final object:
    %#v`, obj, newObj)
    	}
    }
    
    var result typed.TypedValue
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  6. pkg/controller/storageversiongc/gc_controller.go

    	storageVersionInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			c.onAddStorageVersion(logger, obj)
    		},
    		UpdateFunc: func(old, newObj interface{}) {
    			c.onUpdateStorageVersion(logger, old, newObj)
    		},
    	})
    
    	return c
    }
    
    // Run starts one worker.
    func (c *Controller) Run(ctx context.Context) {
    	logger := klog.FromContext(ctx)
    	defer utilruntime.HandleCrash()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10K 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/registry/core/resourcequota/strategy.go

    // ValidateUpdate is the default update validation for an end user.
    func (resourcequotaStrategy) ValidateUpdate(ctx context.Context, obj, old runtime.Object) field.ErrorList {
    	newObj, oldObj := obj.(*api.ResourceQuota), old.(*api.ResourceQuota)
    	return validation.ValidateResourceQuotaUpdate(newObj, oldObj)
    }
    
    // WarningsOnUpdate returns warnings for the given update.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 18 17:07:29 UTC 2022
    - 4.7K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/strategy.go

    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)
    }
    
    func (statusStrategy) AllowCreateOnUpdate() bool {
    	return false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/admission/conversion_test.go

    				Attributes: attrs(
    					u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"newobj"}}`),
    					u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"oldobj"}}`),
    				),
    				VersionedObject:    u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"newobj"}}`),
    				VersionedOldObject: u(`{"apiVersion": "mygroup.k8s.io/v1","kind": "Flunder","metadata":{"name":"oldobj"}}`),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 13.7K bytes
    - Viewed (0)
Back to top