Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for MakeNode (0.12 sec)

  1. pkg/scheduler/eventhandlers_test.go

    	}{
    		{
    			name:       "no specific changed applied",
    			newNode:    st.MakeNode().Unschedulable(false).Obj(),
    			oldNode:    st.MakeNode().Unschedulable(false).Obj(),
    			wantEvents: nil,
    		},
    		{
    			name:       "only node spec unavailable changed",
    			newNode:    st.MakeNode().Unschedulable(false).Obj(),
    			oldNode:    st.MakeNode().Unschedulable(true).Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 10 14:38:54 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  2. pkg/proxy/healthcheck/healthcheck_test.go

    	// Should return 200 "OK" irrespective of node syncs
    	hs.SyncNode(makeNode(tweakTainted("other")))
    	testHTTPHandler(hsTest, http.StatusOK, t)
    
    	// Should return 200 "OK" irrespective of node syncs
    	hs.SyncNode(makeNode(tweakTainted(ToBeDeletedTaint)))
    	testHTTPHandler(hsTest, http.StatusOK, t)
    
    	// Should return 200 "OK" irrespective of node syncs
    	hs.SyncNode(makeNode(tweakTainted("other")))
    	testHTTPHandler(hsTest, http.StatusOK, t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/preemption/preemption_test.go

    		initPods           []*v1.Pod
    		numViolatingVictim int
    		expected           [][]Candidate
    	}{
    		{
    			name: "no pdb violation",
    			nodes: []*v1.Node{
    				st.MakeNode().Name("node1").Capacity(veryLargeRes).Obj(),
    				st.MakeNode().Name("node2").Capacity(veryLargeRes).Obj(),
    			},
    			testPods: []*v1.Pod{
    				st.MakePod().Name("p").UID("p").Priority(highPriority).Obj(),
    			},
    			initPods: []*v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  4. pkg/scheduler/scheduler_test.go

    		testSchedulerProfile2 = "test-scheduler-profile-2"
    		testSchedulerProfile3 = "test-scheduler-profile-3"
    	)
    
    	nodes := []runtime.Object{
    		st.MakeNode().Name("node1").UID("node1").Obj(),
    		st.MakeNode().Name("node2").UID("node2").Obj(),
    		st.MakeNode().Name("node3").UID("node3").Obj(),
    	}
    
    	cases := []struct {
    		name                        string
    		profiles                    []schedulerapi.KubeSchedulerProfile
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  5. pkg/scheduler/testing/wrappers.go

    func (p *PodWrapper) Overhead(rl v1.ResourceList) *PodWrapper {
    	p.Spec.Overhead = rl
    	return p
    }
    
    // NodeWrapper wraps a Node inside.
    type NodeWrapper struct{ v1.Node }
    
    // MakeNode creates a Node wrapper.
    func MakeNode() *NodeWrapper {
    	w := &NodeWrapper{v1.Node{}}
    	return w.Capacity(nil)
    }
    
    // Obj returns the inner Node.
    func (n *NodeWrapper) Obj() *v1.Node {
    	return &n.Node
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 42.1K bytes
    - Viewed (0)
  6. pkg/volume/csi/csi_plugin_test.go

    		host = volumetest.NewFakeVolumeHostWithCSINodeName(t,
    			tmpDir,
    			client,
    			ProbeVolumePlugins(),
    			"fakeNode",
    			csiDriverLister,
    			nil,
    		)
    	case kubeletVolumeHostType:
    		host = volumetest.NewFakeKubeletVolumeHostWithCSINodeName(t,
    			tmpDir,
    			client,
    			ProbeVolumePlugins(),
    			"fakeNode",
    			csiDriverLister,
    			volumeAttachmentLister,
    		)
    	case attachDetachVolumeHostType:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  7. pilot/pkg/autoregistration/controller_test.go

    		// stop1 should be killed early, as part of test
    		if !stopped1 {
    			close(stop1)
    		}
    	}()
    	defer close(stop2)
    	go c1.Run(stop1)
    	go c2.Run(stop2)
    	go store.Run(stop2)
    
    	n := fakeNode("reg1", "zone1", "subzone1")
    
    	var p1conn1, p1conn2 *fakeConn
    	p := fakeProxy("1.2.3.4", wgA, "nw1", "sa-a")
    	p.Locality = n.Locality
    
    	var p2conn1 *fakeConn
    	p2 := fakeProxy("1.2.3.4", wgA, "nw2", "sa-a")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 00:00:36 UTC 2024
    - 31.4K bytes
    - Viewed (0)
Back to top