Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for fakePod (2.42 sec)

  1. pkg/kubelet/cm/cpumanager/policy_static_test.go

    			topo:            topoSingleSocketHT,
    			numReservedCPUs: 1,
    			stAssignments: state.ContainerCPUAssignments{
    				"fakePod": map[string]cpuset.CPUSet{
    					"fakeContainer100": cpuset.New(2, 3, 6, 7),
    				},
    			},
    			stDefaultCPUSet: cpuset.New(0, 1, 4, 5),
    			pod:             makePod("fakePod", "fakeContainer3", "2000m", "2000m"),
    			expErr:          nil,
    			expCPUAlloc:     true,
    			expCSet:         cpuset.New(1, 5),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 40.8K bytes
    - Viewed (0)
  2. pkg/kubelet/server/stats/volume_stat_calculator_test.go

    	volumes := map[string]volume.Volume{vol0: &fakeVolume{}, vol1: &fakeVolume{}, vol3: &fakeVolume{}}
    	mockStats.EXPECT().ListVolumesForPod(fakePod.UID).Return(volumes, true)
    	blockVolumes := map[string]volume.BlockVolume{vol2: &fakeBlockVolume{}}
    	mockStats.EXPECT().ListBlockVolumesForPod(fakePod.UID).Return(blockVolumes, true)
    
    	eventStore := make(chan string, 1)
    	fakeEventRecorder := record.FakeRecorder{
    		Events: eventStore,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  3. pkg/scheduler/scheduler_test.go

    	if !ok {
    		return []string{}, nil
    	}
    	return []string{nodeName}, nil
    }
    
    const (
    	filterWithoutEnqueueExtensions = "filterWithoutEnqueueExtensions"
    	fakeNode                       = "fakeNode"
    	fakePod                        = "fakePod"
    	emptyEventsToRegister          = "emptyEventsToRegister"
    	queueSort                      = "no-op-queue-sort-plugin"
    	fakeBind                       = "bind-plugin"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  4. pkg/kubelet/images/image_gc_manager_test.go

    	}
    	fakeRuntime.AllPodList = []*containertest.FakePod{
    		{Pod: &container.Pod{
    			Containers: []*container.Container{
    				makeContainer(0),
    				makeContainer(1),
    			},
    		}},
    	}
    
    	// Make 1 be more recently used than 0.
    	_, err := manager.detectImages(ctx, zero)
    	require.NoError(t, err)
    	fakeRuntime.AllPodList = []*containertest.FakePod{
    		{Pod: &container.Pod{
    			Containers: []*container.Container{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 15:38:20 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/cpumanager/topology_hints_test.go

    }
    
    func returnTestCases() []testCase {
    	testPod1 := makePod("fakePod", "fakeContainer", "2", "2")
    	testContainer1 := &testPod1.Spec.Containers[0]
    	testPod2 := makePod("fakePod", "fakeContainer", "5", "5")
    	testContainer2 := &testPod2.Spec.Containers[0]
    	testPod3 := makePod("fakePod", "fakeContainer", "7", "7")
    	testContainer3 := &testPod3.Spec.Containers[0]
    	testPod4 := makePod("fakePod", "fakeContainer", "11", "11")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 19K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_test.go

    		ID:   "abc1234",
    	}
    
    	fakePod := &containertest.FakePod{
    		Pod: &kubecontainer.Pod{
    			ID:        "12345678",
    			Name:      "podFoo",
    			Namespace: "nsFoo",
    			Containers: []*kubecontainer.Container{
    				{
    					Name: "containerFoo",
    					ID:   containerID,
    				},
    			},
    		},
    	}
    
    	fakeRuntime.PodList = []*containertest.FakePod{fakePod}
    	wrongContainerName := "wrongContainerName"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  7. cni/pkg/plugin/plugin_test.go

    		ambientEnabled,
    		"mock",
    	)
    }
    
    func buildFakePodAndNSForClient() (*corev1.Pod, *corev1.Namespace) {
    	proxy := corev1.Container{Name: "mockContainer"}
    	app := corev1.Container{Name: "foo-init"}
    	fakePod := &corev1.Pod{
    		TypeMeta: metav1.TypeMeta{
    			APIVersion: "core/v1",
    			Kind:       "Pod",
    		},
    		ObjectMeta: metav1.ObjectMeta{
    			Name:        testPodName,
    			Namespace:   testNSName,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 21 18:32:01 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods_test.go

    	testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
    	defer testKubelet.Cleanup()
    	kubelet := testKubelet.kubelet
    	fakeRuntime := testKubelet.fakeRuntime
    	fakeRuntime.PodList = []*containertest.FakePod{}
    
    	podName := "podFoo"
    	podNamespace := "nsFoo"
    	containerName := "containerFoo"
    	output, err := kubelet.RunInContainer(
    		ctx,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    			func(b *testing.B) {
    				// create sample pods
    				fakePods := make([]example.Pod, tc.totalObjectNum, tc.totalObjectNum)
    				for i := range fakePods {
    					fakePods[i].Namespace = "default"
    					fakePods[i].Name = fmt.Sprintf("pod-%d", i)
    					fakePods[i].ResourceVersion = strconv.Itoa(i)
    					if i%(tc.totalObjectNum/tc.expectObjectNum) == 0 {
    						fakePods[i].Spec.NodeName = "node-0"
    					}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  10. pkg/probe/exec/exec_test.go

    func (f *FakeCmd) SetStdout(out io.Writer) {
    	f.writer = out
    }
    
    func (f *FakeCmd) SetStderr(out io.Writer) {
    	f.writer = out
    }
    
    func (f *FakeCmd) SetEnv(env []string) {}
    
    func (f *FakeCmd) Stop() {}
    
    func (f *FakeCmd) Start() error {
    	if f.writer != nil {
    		f.writer.Write(f.out)
    		return f.err
    	}
    	return f.err
    }
    
    func (f *FakeCmd) Wait() error { return nil }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 08:58:18 UTC 2024
    - 3.8K bytes
    - Viewed (0)
Back to top