Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for PodAffinityExists (0.25 sec)

  1. pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go

    			expectedHint: framework.QueueSkip,
    		},
    		{
    			name: "update a pod from match to non-match pod's affinity - multiple terms case",
    			pod: st.MakePod().Name("p").PodAffinityExists("aaa", "hostname", st.PodAffinityWithRequiredReq).
    				PodAffinityExists("bbb", "hostname", st.PodAffinityWithRequiredReq).Obj(),
    			newPod:       st.MakePod().Node("fake-node").Label("service", "securityscan").Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go

    		},
    		{
    			pod: st.MakePod().Namespace(defaultNamespace).PodAffinityExists("foo", "region", st.PodAffinityWithRequiredReq).
    				PodAffinityExists("bar", "zone", st.PodAffinityWithRequiredReq).Obj(),
    			pods: []*v1.Pod{
    				st.MakePod().Name("pod1").Labels(map[string]string{"foo": "", "bar": ""}).Node("nodeA").Obj(),
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 58.2K bytes
    - Viewed (0)
  3. pkg/scheduler/testing/wrappers.go

    			v1.WeightedPodAffinityTerm{Weight: 1, PodAffinityTerm: term},
    		)
    	}
    	return p
    }
    
    // PodAffinityExists creates a PodAffinity with the operator "Exists"
    // and injects into the inner pod.
    func (p *PodWrapper) PodAffinityExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper {
    	labelSelector := MakeLabelSelector().Exists(labelKey).Obj()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 42.1K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/cache/cache_test.go

    	var podsWithAffinity []*v1.Pod
    	for i := 0; i < 2; i++ {
    		pod := st.MakePod().Name(fmt.Sprintf("p-affinity-%v", i)).Namespace("test-ns").UID(fmt.Sprintf("puid-affinity-%v", i)).
    			PodAffinityExists("foo", "", st.PodAffinityWithRequiredReq).Node(fmt.Sprintf("test-node%v", i)).Obj()
    		podsWithAffinity = append(podsWithAffinity, pod)
    	}
    
    	// Add a few of pods with PVC
    	var podsWithPVC []*v1.Pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 63.8K bytes
    - Viewed (0)
  5. pkg/scheduler/internal/queue/scheduling_queue_test.go

    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	affinityPod := st.MakePod().Name("afp").Namespace("ns1").UID("afp").Annotation("annot2", "val2").Priority(mediumPriority).NominatedNodeName("node1").PodAffinityExists("service", "region", st.PodAffinityWithRequiredReq).Obj()
    	labelPod := st.MakePod().Name("lbp").Namespace(affinityPod.Namespace).Label("service", "securityscan").Node("node1").Obj()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
Back to top