Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 45 for oldObj (0.5 sec)

  1. 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)
  2. pkg/registry/rbac/role/policybased/storage.go

    	}
    
    	nonEscalatingInfo := rest.WrapUpdatedObjectInfo(obj, func(ctx context.Context, obj runtime.Object, oldObj runtime.Object) (runtime.Object, error) {
    		role := obj.(*rbac.Role)
    
    		// if we're only mutating fields needed for the GC to eventually delete this obj, return
    		if rbacregistry.IsOnlyMutatingGCFields(obj, oldObj, kapihelper.Semantic) {
    			return obj, nil
    		}
    
    		rules := role.Rules
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 10:11:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  3. 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)
  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. pkg/registry/rbac/clusterrole/strategy.go

    func (strategy) ValidateUpdate(ctx context.Context, obj, old runtime.Object) field.ErrorList {
    	newObj := obj.(*rbac.ClusterRole)
    	oldObj := old.(*rbac.ClusterRole)
    	opts := validation.ClusterRoleValidationOptions{
    		AllowInvalidLabelValueInSelector: hasInvalidLabelValueInLabelSelector(oldObj),
    	}
    	errorList := validation.ValidateClusterRole(newObj, opts)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 08 01:52:02 UTC 2022
    - 4.2K bytes
    - Viewed (0)
  6. 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)
  7. pkg/registry/core/resourcequota/strategy.go

    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.
    func (resourcequotaStrategy) WarningsOnUpdate(ctx context.Context, obj, old runtime.Object) []string {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 18 17:07:29 UTC 2022
    - 4.7K bytes
    - Viewed (0)
  8. pkg/registry/rbac/clusterrolebinding/policybased/storage.go

    	}
    
    	nonEscalatingInfo := rest.WrapUpdatedObjectInfo(obj, func(ctx context.Context, obj runtime.Object, oldObj runtime.Object) (runtime.Object, error) {
    		clusterRoleBinding := obj.(*rbac.ClusterRoleBinding)
    
    		// if we're only mutating fields needed for the GC to eventually delete this obj, return
    		if rbacregistry.IsOnlyMutatingGCFields(obj, oldObj, kapihelper.Semantic) {
    			return obj, nil
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 10:11:16 UTC 2022
    - 4.9K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable.go

    // pod schedulable.
    func (pl *NodeUnschedulable) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	_, modifiedNode, err := util.As[*v1.Node](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    	if !modifiedNode.Spec.Unschedulable {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 16 12:50:11 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  10. pkg/registry/rbac/rolebinding/policybased/storage.go

    		return s.StandardStorage.Update(ctx, name, obj, createValidation, updateValidation, forceAllowCreate, options)
    	}
    
    	nonEscalatingInfo := rest.WrapUpdatedObjectInfo(obj, func(ctx context.Context, obj runtime.Object, oldObj runtime.Object) (runtime.Object, error) {
    		// Get the namespace from the context (populated from the URL).
    		// The namespace in the object can be empty until StandardStorage.Update()->BeforeUpdate() populates it from the context.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 10:11:16 UTC 2022
    - 5.5K bytes
    - Viewed (0)
Back to top