Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 40 for fakePods (0.19 sec)

  1. pkg/kubelet/runonce_test.go

    		mirrorPodClient:  podtest.NewFakeMirrorClient(),
    		podManager:       podManager,
    		podWorkers:       &fakePodWorkers{},
    		os:               &containertest.FakeOS{},
    		containerRuntime: fakeRuntime,
    		reasonCache:      NewReasonCache(),
    		clock:            clock.RealClock{},
    		kubeClient:       &fake.Clientset{},
    		hostname:         testKubeletHostname,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. pkg/kubelet/stats/cadvisor_stats_provider_test.go

    	}
    	fakeStatsSlice := []*volume.Metrics{containerLogStats0, containerLogStats1}
    	fakeOS := &containertest.FakeOS{}
    
    	freeRootfsInodes := rootfsInodesFree
    	totalRootfsInodes := rootfsInodes
    	rootfs := cadvisorapiv2.FsInfo{
    		Capacity:   rootfsCapacity,
    		Available:  rootfsAvailable,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. pkg/kubemark/hollow_kubelet.go

    		RemoteRuntimeService:      runtimeService,
    		RemoteImageService:        imageService,
    		CAdvisorInterface:         cadvisorInterface,
    		Cloud:                     nil,
    		OSInterface:               &containertest.FakeOS{},
    		ContainerManager:          containerManager,
    		VolumePlugins:             volumePlugins(),
    		TLSOptions:                nil,
    		OOMAdjuster:               oom.NewFakeOOMAdjuster(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:10:54 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cpumanager/cpu_manager_test.go

    				err: testCase.updateErr,
    			},
    			containerMap:      containermap.NewContainerMap(),
    			podStatusProvider: mockPodStatusProvider{},
    			sourcesReady:      &sourcesReadyStub{},
    		}
    
    		pod := makePod("fakePod", "fakeContainer", "2", "2")
    		container := &pod.Spec.Containers[0]
    		mgr.activePods = func() []*v1.Pod { return nil }
    
    		err := mgr.Allocate(pod, container)
    		if !reflect.DeepEqual(err, testCase.expAllocateErr) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 42.9K bytes
    - Viewed (0)
  5. 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)
  6. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    						v1.ResourceName(v1.ResourceCPU):    resource.MustParse("10"),
    						v1.ResourceName(v1.ResourceMemory): resource.MustParse("10G"),
    					},
    				},
    			}
    		}
    		return nodes
    	}
    	makePods := func() []v1.Pod {
    		pods := make([]v1.Pod, numNodes*podsPerNode)
    		for i := 0; i < numNodes*podsPerNode; i++ {
    			pods[i] = *testutil.NewPod(fmt.Sprintf("pod%d", i), fmt.Sprintf("node%d", i%numNodes))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    			prefix: "/pods",
    			pred: storage.SelectionPredicate{
    				Field: fields.OneTermEqualSelector("spec.nodeName", "fakeNode"),
    				Label: labels.Everything(),
    				Limit: 5,
    			},
    			rv:          list.ResourceVersion,
    			rvMatch:     metav1.ResourceVersionMatchNotOlderThan,
    			expectedOut: []example.Pod{*preset[0]},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  8. pkg/controller/endpoint/endpoints_controller_test.go

    		deletionTimestamp := &now
    		if !terminating {
    			deletionTimestamp = nil
    		}
    		return &v1.Pod{
    			ObjectMeta: metav1.ObjectMeta{
    				Namespace:         "ns",
    				Name:              "fakepod",
    				DeletionTimestamp: deletionTimestamp,
    				Labels:            map[string]string{"foo": "bar"},
    			},
    			Spec: v1.PodSpec{
    				Containers: []v1.Container{{Ports: []v1.ContainerPort{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  9. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    	memoryCapacityQuantity := resource.MustParse(fakeNodeAllocatableMemory)
    	machineInfo := &cadvisorapi.MachineInfo{
    		MemoryCapacity: uint64(memoryCapacityQuantity.Value()),
    	}
    	osInterface := &containertest.FakeOS{}
    	manager, err := newFakeKubeRuntimeManager(fakeRuntimeService, fakeImageService, machineInfo, osInterface, &containertest.FakeRuntimeHelper{}, keyring, noopoteltrace.NewTracerProvider().Tracer(""))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  10. pkg/apis/core/validation/validation_test.go

    			volume: testVolume("foo", "", core.PersistentVolumeSpec{
    				Capacity: core.ResourceList{
    					core.ResourceName(core.ResourceStorage): resource.MustParse("10G"),
    				},
    				AccessModes: []core.PersistentVolumeAccessMode{"fakemode"},
    				PersistentVolumeSource: core.PersistentVolumeSource{
    					HostPath: &core.HostPathVolumeSource{
    						Path: "/foo",
    						Type: newHostPathType(string(core.HostPathDirectory)),
    					},
    				},
    			}),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 857.7K bytes
    - Viewed (0)
Back to top