Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for initialPods (0.14 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go

    	initialPods := []*example.Pod{}
    	ns := "ns-foo"
    	for _, initialPod := range []*example.Pod{makePod("1"), makePod("2"), makePod("3"), makePod("4"), makePod("5")} {
    		initialPod.Namespace = ns
    		out := &example.Pod{}
    		err := store.Create(ctx, computePodKey(initialPod), initialPod, out, 0)
    		require.NoError(t, err, "failed to add a pod: %v")
    		initialPods = append(initialPods, out)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 63.8K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue_test.go

    		callback     func(t *testing.T, q *PriorityQueue)
    	}
    
    	tests := []struct {
    		name            string
    		queueingHintMap QueueingHintMapPerProfile
    		// initialPods is the initial Pods in the activeQ.
    		initialPods                  []*v1.Pod
    		actions                      []action
    		wantInFlightPods             []*v1.Pod
    		wantInFlightEvents           []interface{}
    		wantActiveQPodNames          []string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  3. pkg/scheduler/schedule_one_test.go

    		assignedNodeName := fmt.Sprintf("node%d", random.Intn(initialNodeNumber))
    		initialPods = append(initialPods, st.MakePod().Name(podName).UID(podName).Node(assignedNodeName).Obj())
    	}
    
    	objs := []runtime.Object{&v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: fakeNamespace}}}
    	objs = append(objs, initialNodes...)
    	objs = append(objs, initialPods...)
    	client := clientsetfake.NewSimpleClientset(objs...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_node_status.go

    func (kl *Kubelet) reconcileHugePageResource(initialNode, existingNode *v1.Node) bool {
    	requiresUpdate := updateDefaultResources(initialNode, existingNode)
    	supportedHugePageResources := sets.Set[string]{}
    
    	for resourceName := range initialNode.Status.Capacity {
    		if !v1helper.IsHugePageResourceName(resourceName) {
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_node_status_test.go

    	cases := []struct {
    		name         string
    		initialNode  *v1.Node
    		existingNode *v1.Node
    		needsUpdate  bool
    		finalLabels  map[string]string
    	}{
    		{
    			name: "make sure default labels exist",
    			initialNode: &v1.Node{
    				ObjectMeta: metav1.ObjectMeta{
    					Labels: map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  6. pkg/registry/core/pod/storage/eviction_test.go

    		name              string
    		initialPod        bool
    		makeDeleteOptions func(*api.Pod) *metav1.DeleteOptions
    		expectErr         string
    	}{
    		{
    			name:              "simple",
    			initialPod:        true,
    			makeDeleteOptions: func(pod *api.Pod) *metav1.DeleteOptions { return &metav1.DeleteOptions{} },
    		},
    		{
    			name:              "missing",
    			initialPod:        false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 09:26:37 UTC 2024
    - 40K bytes
    - Viewed (0)
Back to top