Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 103 for pod_1 (0.07 sec)

  1. pkg/scheduler/schedule_one_test.go

    	}
    	pods := []*v1.Pod{
    		st.MakePod().Name("pod1").UID("pod1").SchedulerName("match-node3").Obj(),
    		st.MakePod().Name("pod2").UID("pod2").SchedulerName("match-node2").Obj(),
    		st.MakePod().Name("pod3").UID("pod3").SchedulerName("match-node2").Obj(),
    		st.MakePod().Name("pod4").UID("pod4").SchedulerName("match-node3").Obj(),
    	}
    	wantBindings := map[string]string{
    		"pod1": "node3",
    		"pod2": "node2",
    		"pod3": "node2",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_volumes_linux_test.go

    				return validateDirNotExists(filepath.Join(podDir, "not"))
    			},
    		},
    		"pod-exists-with-volume": {
    			pods: []*v1.Pod{
    				{
    					ObjectMeta: metav1.ObjectMeta{
    						Name: "pod1",
    						UID:  "pod1uid",
    					},
    				},
    			},
    			prepareFunc: func(kubelet *Kubelet) error {
    				podDir := kubelet.getPodDir("pod1uid")
    				return os.MkdirAll(filepath.Join(podDir, "volumes/plugin/name"), 0750)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 30 03:35:26 UTC 2022
    - 8.9K bytes
    - Viewed (0)
  3. pkg/kubelet/util/manager/cache_based_manager_test.go

    	fakeClient := &fake.Clientset{}
    	store := newSecretStore(fakeClient, clock.RealClock{}, noObjectTTL, 0)
    	store.AddReference("ns1", "name1", "pod1")
    	store.AddReference("ns2", "name2", "pod2")
    	store.AddReference("ns1", "name1", "pod3")
    	store.AddReference("ns1", "name1", "pod4")
    	store.DeleteReference("ns1", "name1", "pod1")
    	store.DeleteReference("ns2", "name2", "pod2")
    	store.AddReference("ns3", "name3", "pod5")
    
    	// Adds don't issue Get requests.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/devicemanager/pod_devices_test.go

    	kubecontainer "k8s.io/kubernetes/pkg/kubelet/container"
    )
    
    func TestGetContainerDevices(t *testing.T) {
    	podDevices := newPodDevices()
    	resourceName1 := "domain1.com/resource1"
    	podID := "pod1"
    	contID := "con1"
    	devices := checkpoint.DevicesPerNUMA{0: []string{"dev1"}, 1: []string{"dev1"}}
    
    	podDevices.insert(podID, contID, resourceName1,
    		devices,
    		newContainerAllocateResponse(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  5. pkg/registry/core/pod/storage/storage_test.go

    				},
    			},
    		},
    		{
    			in: pod1,
    			out: &metav1.Table{
    				ColumnDefinitions: columns,
    				Rows: []metav1.TableRow{
    					{Cells: []interface{}{"foo", "1/2", "Pending", "10", "370d", "10.1.2.3", "test-node", "nominated-node", "1/2"}, Object: runtime.RawExtension{Object: pod1}},
    				},
    			},
    		},
    		{
    			in:  &api.PodList{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 07:18:44 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go

    	cases := []struct {
    		name   string
    		events []*watchCacheEvent
    	}{
    		{
    			name: "buffer has elements",
    			events: []*watchCacheEvent{
    				{Type: watch.Added, Object: makeTestPod("pod1", 1)},
    				{Type: watch.Added, Object: makeTestPod("pod2", 2)},
    				{Type: watch.Modified, Object: makeTestPod("pod3", 3)},
    			},
    		},
    		{
    			name:   "buffer is empty",
    			events: []*watchCacheEvent{},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. pkg/controller/disruption/disruption_test.go

    		"notthere": {Time: currentTime},                       // Should be removed, pod deleted.
    	}
    	add(t, dc.pdbStore, pdb)
    
    	pod1, _ := newPod(t, "p1")
    	pod1.DeletionTimestamp = &metav1.Time{Time: dc.clock.Now()}
    	pod2, _ := newPod(t, "p2")
    	pod3, _ := newPod(t, "p3")
    
    	add(t, dc.podStore, pod1)
    	add(t, dc.podStore, pod2)
    	add(t, dc.podStore, pod3)
    
    	dc.sync(ctx, pdbName)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 50K bytes
    - Viewed (0)
  8. pkg/scheduler/internal/cache/cache_test.go

    				&st.MakeNode().Name("test-node-4").Capacity(resourceList2).Taints(taints).Images(imageStatus2).Node,
    			},
    			pods: []*v1.Pod{
    				{
    					ObjectMeta: metav1.ObjectMeta{
    						Name: "pod1",
    						UID:  types.UID("pod1"),
    					},
    					Spec: v1.PodSpec{
    						NodeName: "test-node-1",
    						Containers: []v1.Container{
    							{
    								Resources: v1.ResourceRequirements{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 63.8K bytes
    - Viewed (0)
  9. pkg/controller/volume/pvcprotection/pvc_protection_controller_test.go

    )
    
    type reaction struct {
    	verb      string
    	resource  string
    	reactorfn clienttesting.ReactionFunc
    }
    
    const (
    	defaultNS       = "default"
    	defaultPVCName  = "pvc1"
    	defaultPodName  = "pod1"
    	defaultNodeName = "node1"
    	defaultUID      = "uid1"
    )
    
    func pod() *v1.Pod {
    	return &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      defaultPodName,
    			Namespace: defaultNS,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 12:57:29 UTC 2023
    - 15.5K bytes
    - Viewed (0)
  10. pkg/api/pod/warnings_test.go

    				t.Errorf("missing: %s", missing)
    			}
    			for _, extra := range sets.List[string](actual.Difference(expected)) {
    				t.Errorf("extra: %s", extra)
    			}
    		})
    
    		t.Run("pod_"+tc.name, func(t *testing.T) {
    			var pod *api.Pod
    			if tc.template != nil {
    				pod = &api.Pod{
    					ObjectMeta: tc.template.ObjectMeta,
    					Spec:       tc.template.Spec,
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 42.1K bytes
    - Viewed (0)
Back to top