Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for MakeNode (0.12 sec)

  1. pkg/controller/garbagecollector/dump_test.go

    				{F: types.UID("foxtrot"), T: types.UID("golf")},
    			},
    		},
    		{
    			file: "escaping.dot",
    			nodes: []*dotVertex{
    				NewDOTVertex(makeNode(ref1, withOwners(ref2))),
    				NewDOTVertex(makeNode(ref2)),
    			},
    			edges: []dotEdge{
    				{F: types.UID(ref1.UID), T: types.UID(ref2.UID)},
    			},
    		},
    	}
    
    	for _, tc := range testcases {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 11.2K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/volume/csi/csi_test.go

    						Name: test.driver,
    					},
    					Spec: *test.driverSpec,
    				}
    				objs = append(objs, driverInfo)
    			}
    			objs = append(objs, &api.Node{
    				ObjectMeta: meta.ObjectMeta{
    					Name: "fakeNode",
    				},
    				Spec: api.NodeSpec{},
    			})
    
    			client := fakeclient.NewSimpleClientset(objs...)
    
    			factory := informers.NewSharedInformerFactory(client, time.Hour /* disable resync */)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 15:55:13 UTC 2022
    - 21.1K bytes
    - Viewed (0)
  6. 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