Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 113 for fakePod (0.12 sec)

  1. pkg/kubelet/prober/scale_test.go

    			).(*manager)
    			defer cleanup(t, m)
    
    			now := time.Now()
    			fakePods := make([]*fakePod, numTestPods)
    			for i := 0; i < numTestPods; i++ {
    				fake, err := newFakePod(tt.http)
    				if err != nil {
    					t.Fatalf("unexpected error creating fake pod: %v", err)
    				}
    				defer fake.stop()
    				handler := fake.probeHandler()
    				fakePods[i] = fake
    
    				pod := v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 16 16:33:01 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  2. 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)
  3. pkg/kubelet/container/runtime_cache_test.go

    	ctx := context.Background()
    	runtime := &ctest.FakeRuntime{}
    	cache := NewTestRuntimeCache(runtime)
    
    	// Cache old pods.
    	oldpods := []*ctest.FakePod{{Pod: &Pod{ID: "1111"}}}
    	runtime.PodList = oldpods
    	cache.UpdateCacheWithLock()
    
    	// Update the runtime to new pods.
    	newpods := []*ctest.FakePod{{Pod: &Pod{ID: "1111"}}, {Pod: &Pod{ID: "2222"}}, {Pod: &Pod{ID: "3333"}}}
    	runtime.PodList = newpods
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  4. 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)
  5. pkg/kubelet/cm/cpumanager/policy_none_test.go

    func TestNonePolicyAllocate(t *testing.T) {
    	policy := &nonePolicy{}
    
    	st := &mockState{
    		assignments:   state.ContainerCPUAssignments{},
    		defaultCPUSet: cpuset.New(1, 2, 3, 4, 5, 6, 7),
    	}
    
    	testPod := makePod("fakePod", "fakeContainer", "1000m", "1000m")
    
    	container := &testPod.Spec.Containers[0]
    	err := policy.Allocate(st, testPod, container)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. pkg/kubelet/cm/devicemanager/topology_hints_test.go

    }
    
    func getCommonTestCases() []topologyHintTestCase {
    	return []topologyHintTestCase{
    		{
    			description: "Single Request, no alignment",
    			pod: &v1.Pod{
    				ObjectMeta: metav1.ObjectMeta{
    					UID: "fakePod",
    				},
    				Spec: v1.PodSpec{
    					Containers: []v1.Container{
    						{
    							Name: "fakeContainer",
    							Resources: v1.ResourceRequirements{
    								Limits: v1.ResourceList{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 47.5K bytes
    - Viewed (0)
  9. 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)
  10. pkg/kubelet/pleg/generic_test.go

    	testPleg := newTestGenericPLEG()
    	pleg, runtime := testPleg.pleg, testPleg.runtime
    	ch := pleg.Watch()
    	// The first relist should send a PodSync event to each pod.
    	runtime.AllPodList = []*containertest.FakePod{
    		{Pod: &kubecontainer.Pod{
    			ID: "1234",
    			Containers: []*kubecontainer.Container{
    				createTestContainer("c1", kubecontainer.ContainerStateExited),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 24.8K bytes
    - Viewed (0)
Back to top