- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for pod17 (0.09 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
{ podWithOtherFinalizers("pod12"), nilOrphanOptions, orphanDeleteStrategy, false, []string{"foo.com/x", "bar.com/y", metav1.FinalizerOrphanDependents}, }, { podWithNoFinalizer("pod13"), nilOrphanOptions, defaultDeleteStrategy, true, []string{}, }, { podWithNoFinalizer("pod14"), nilOrphanOptions, orphanDeleteStrategy, false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go
pod: podWithTolerations("pod1", []v1.Toleration{{Key: "dedicated", Value: "user1", Effect: "NoSchedule"}}), node: nodeWithTaints("nodeA", []v1.Taint{{Key: "dedicated", Value: "user1", Effect: "NoSchedule"}}), }, { name: "A pod which can't be scheduled on a dedicated node assigned to user2 with effect NoSchedule",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
Pod: newNamedPod("1", "test1", "pod1", false), UpdateType: kubetypes.SyncPodUpdate, }) drainAllWorkers(podWorkers) // should observe pod terminating pod1 = podWorkers.podSyncStatuses[types.UID("1")] if !pod1.IsTerminationRequested() || !pod1.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod1) } } func TestStaticPodExclusion(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
} volumes := rcInstance.actualStateOfWorld.GetPossiblyMountedVolumesForPod("pod1") if len(volumes) != 1 { return fmt.Errorf("expected 1 uncertain volume in asw got %d", len(volumes)) } // The volume should be marked as reconstructed in ASW if reconstructed := rcInstance.actualStateOfWorld.IsVolumeReconstructed("fake-plugin/pvc-abcdef", "pod1"); !reconstructed {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
func TestSyncServicePodSelection(t *testing.T) { client, esController := newController(t, []string{"node-1"}, time.Duration(0)) ns := metav1.NamespaceDefault pod1 := newPod(1, ns, true, 0, false) esController.podStore.Add(pod1) // ensure this pod will not match the selector pod2 := newPod(2, ns, true, 0, false) pod2.Labels["foo"] = "boo" esController.podStore.Add(pod2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
Operator: metav1.LabelSelectorOpExists, }, }, }, nil, nil, nil, nil).Obj(), pods: []*v1.Pod{ st.MakePod().Name("pod1a").UID("pod1a").Label("foo", "").Node("node1").Phase(v1.PodRunning).Obj(), st.MakePod().Name("pod1b").UID("pod1b").Label("foo", "").Node("node1").Phase(v1.PodRunning).Obj(), st.MakePod().Name("pod2").UID("pod2").Label("foo", "").Node("node2").Phase(v1.PodRunning).Obj(), },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
}, }, { name: "No CPU and memory, resource allocation exists", pod: podWithUIDNameNsSpec("11", "pod11", "foo", *emptyPodSpec), existingPodAllocation: podWithUIDNameNsSpec("11", "pod11", "foo", *emptyPodSpec), expectedPodResourceAllocation: state.PodResourceAllocation{ "11": map[string]v1.ResourceList{ emptyPodSpec.Containers[0].Name: emptyPodSpec.Containers[0].Resources.Requests,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go
func TestWatchCacheBasic(t *testing.T) { store := newTestWatchCache(2, &cache.Indexers{}) defer store.Stop() // Test Add/Update/Delete. pod1 := makeTestPod("pod", 1) if err := store.Add(pod1); err != nil { t.Errorf("unexpected error: %v", err) } if item, ok, _ := store.Get(pod1); !ok { t.Errorf("didn't find pod") } else { expected := makeTestStoreElement(makeTestPod("pod", 1))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
as.Nil(err) err = testManager.Allocate(pod2, &pod2.Spec.Containers[0]) as.Nil(err) // when pod is in activePods, GetDeviceRunContainerOptions should return runContainerOpts, err := testManager.GetDeviceRunContainerOptions(pod1, &pod1.Spec.Containers[0]) as.Nil(err) as.Equal(len(runContainerOpts.Devices), 3) as.Equal(len(runContainerOpts.Mounts), 2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
Labels: labels, ResourceVersion: rv, }, } } pod1 := makePod(map[string]string{"foo": "true", "bar": "true"}, "1001") pod2 := makePod(map[string]string{"foo": "true"}, "1002") pod3 := makePod(map[string]string{}, "1003") pod4 := makePod(map[string]string{}, "1004") pod1DeletedAt2 := pod1.DeepCopyObject().(*examplev1.Pod) pod1DeletedAt2.ResourceVersion = "1002"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0)