- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 40 for fakePods (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)