- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for cpod3 (0.22 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go
t.Errorf("expected %v, got %v", expected, item) } } pod3 := makeTestPod("pod", 3) if err := store.Delete(pod3); err != nil { t.Errorf("unexpected error: %v", err) } if _, ok, _ := store.Get(pod3); ok { t.Errorf("found pod") } // Test List. store.Add(makeTestPod("pod1", 4)) store.Add(makeTestPod("pod2", 5)) store.Add(makeTestPod("pod3", 6)) { expected := map[string]storeElement{
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/pod_workers_test.go
} pod2 = podWorkers.podSyncStatuses[types.UID("2-static")] if pod2.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod2) } pod3 := podWorkers.podSyncStatuses[types.UID("3-static")] if pod3.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod3) } pod4 := podWorkers.podSyncStatuses[types.UID("4-static")] if pod4.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod4) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go
name: "buffer has elements", events: []*watchCacheEvent{ {Type: watch.Added, Object: makeTestPod("pod1", 1)}, {Type: watch.Added, Object: makeTestPod("pod2", 2)}, {Type: watch.Modified, Object: makeTestPod("pod3", 3)}, }, }, { name: "buffer is empty", events: []*watchCacheEvent{}, }, } for _, c := range cases { t.Run(c.name, func(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 11.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
Namespace: "ns", ResourceVersion: rv, }, } } pod1 := makePod("pod", "1001") pod2 := makePod("pod", "1002") pod3 := makePod("pod", "1003") cacher.watchCache.Add(pod1) cacher.watchCache.Update(pod2) cacher.watchCache.Delete(pod3) // At this point, we already have dispatchedEvents fully propagated. verifyEvents := func(w watch.Interface) { var event watch.Event
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
}, }, { name: "Having both memory and cpu, resource allocation exists (with different value)", pod: podWithUIDNameNsSpec("3", "pod3", "foo", *cpu500mMem500MPodSpec), existingPodAllocation: podWithUIDNameNsSpec("3", "pod3", "foo", *cpu800mMem800MPodSpec), expectedPodResourceAllocation: state.PodResourceAllocation{ "3": map[string]v1.ResourceList{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
newContainerAllocateResponse( withDevices(map[string]string{"/dev/r1dev4": "/dev/r1dev4"}), withMounts(map[string]string{"/home/r1lib1": "/usr/r1lib1"}), ), ) testManager.podDevices.insert("pod3", "con3", resourceName3, checkpoint.DevicesPerNUMA{nodeWithoutTopology: []string{"dev5"}}, newContainerAllocateResponse( withDevices(map[string]string{"/dev/r3dev5": "/dev/r3dev5"}),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
func Test_InFlightPods(t *testing.T) { logger, _ := ktesting.NewTestContext(t) pod := st.MakePod().Name("targetpod").UID("pod1").Obj() pod2 := st.MakePod().Name("targetpod2").UID("pod2").Obj() pod3 := st.MakePod().Name("targetpod3").UID("pod3").Obj() var poppedPod, poppedPod2 *framework.QueuedPodInfo type action struct { // ONLY ONE of the following should be set. eventHappens *framework.ClusterEvent podPopped *v1.Pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager_test.go
fakeClient := &fake.Clientset{} store := newSecretStore(fakeClient, clock.RealClock{}, noObjectTTL, 0) store.AddReference("ns1", "name1", "pod1") store.AddReference("ns2", "name2", "pod2") store.AddReference("ns1", "name1", "pod3") store.AddReference("ns1", "name1", "pod4") store.DeleteReference("ns1", "name1", "pod1") store.DeleteReference("ns2", "name2", "pod2") store.AddReference("ns3", "name3", "pod5") // Adds don't issue Get requests.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
st.MakePod().Name("pod2").UID("pod2").SchedulerName("match-node2").Obj(), st.MakePod().Name("pod3").UID("pod3").SchedulerName("match-node2").Obj(), st.MakePod().Name("pod4").UID("pod4").SchedulerName("match-node3").Obj(), } wantBindings := map[string]string{ "pod1": "node3", "pod2": "node2", "pod3": "node2", "pod4": "node3", } wantControllers := map[string]string{ "pod1": "match-node3",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
{ podWithOtherFinalizers("pod2"), orphanOptions, defaultDeleteStrategy, false, []string{"foo.com/x", "bar.com/y", metav1.FinalizerOrphanDependents}, }, { podWithNoFinalizer("pod3"), orphanOptions, defaultDeleteStrategy, false, []string{metav1.FinalizerOrphanDependents}, }, { podWithOnlyOrphanFinalizer("pod4"), orphanOptions,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0)