Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 117 for oldObj (0.17 sec)

  1. 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)
  2. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    	testcases := map[string]struct {
    		pod                             *v1.Pod
    		oldObj, newObj                  interface{}
    		enableInPlacePodVerticalScaling bool
    		expectedHint                    framework.QueueingHint
    		expectedErr                     bool
    	}{
    		"backoff-wrong-old-object": {
    			pod:                             &v1.Pod{},
    			oldObj:                          "not-a-pod",
    			enableInPlacePodVerticalScaling: true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. pkg/scheduler/framework/plugins/interpodaffinity/plugin.go

    	return
    }
    
    func (pl *InterPodAffinity) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/queue/scheduling_queue.go

    	PluginName     string
    	QueueingHintFn framework.QueueingHintFn
    }
    
    // clusterEvent has the event and involved objects.
    type clusterEvent struct {
    	event framework.ClusterEvent
    	// oldObj is the object that involved this event.
    	oldObj interface{}
    	// newObj is the object that involved this event.
    	newObj interface{}
    }
    
    type priorityQueueOptions struct {
    	clock                             clock.Clock
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/validation/validation.go

    		requireOpenAPISchema:                     requireOpenAPISchema(&oldObj.Spec),
    		requireValidPropertyType:                 requireValidPropertyType(&oldObj.Spec),
    		requireStructuralSchema:                  requireStructuralSchema(&oldObj.Spec),
    		requirePrunedDefaults:                    requirePrunedDefaults(&oldObj.Spec),
    		requireAtomicSetType:                     requireAtomicSetType(&oldObj.Spec),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 82.6K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    }
    
    func (pl *PodTopologySpread) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. 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)
  10. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go

    			pod:          podWithNodeAffinity.Obj(),
    			oldObj:       st.MakeNode().Obj(),
    			newObj:       st.MakeNode().Capacity(nil).Obj(),
    			expectedHint: framework.QueueSkip,
    		},
    		"skip-unrelated-changes-on-labels": {
    			args:         &config.NodeAffinityArgs{},
    			pod:          podWithNodeAffinity.DeepCopy(),
    			oldObj:       st.MakeNode().Obj(),
    			newObj:       st.MakeNode().Label("k", "v").Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 38.7K bytes
    - Viewed (0)
Back to top