- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 140 for oldpod (1.33 sec)
-
pkg/api/pod/warnings_test.go
}, Overhead: resources, Volumes: []api.Volume{ {Name: "a"}, {Name: "b"}, }, }, } oldPod := &api.Pod{} b.ResetTimer() for i := 0; i < b.N; i++ { w := GetWarningsForPod(ctx, pod, oldPod) if len(w) > 0 { b.Fatalf("expected 0 warnings, got %q", w) } } } func BenchmarkWarnings(b *testing.B) { ctx := context.TODO()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 17:51:48 UTC 2024 - 42.1K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
// prepareFunc is the function called to prepare pods in the queue before the test case calls Update(). // This function returns three values; // - oldPod/newPod: each test will call Update() with these oldPod and newPod. prepareFunc func(t *testing.T, logger klog.Logger, q *PriorityQueue) (oldPod, newPod *v1.Pod) // schedulingHintsEnablement shows which value of QHint feature gate we test a test case with. schedulingHintsEnablement []bool
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/controller/replicaset/replica_set_test.go
} // An update from no deletion timestamp to having one should be treated // as a deletion. oldPod := newPodList(nil, 1, v1.PodPending, labelMap, rs, "pod").Items[0] oldPod.ResourceVersion = "2" manager.expectations.ExpectDeletions(logger, rsKey, []string{controller.PodKey(&pod)}) manager.updatePod(logger, &oldPod, &pod) queueRS, _ = manager.queue.Get() if queueRS != rsKey {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
for i := 1; i < 5; i++ { oldPod := newPod(fmt.Sprintf("node-%d-preserve-", i), fmt.Sprintf("node-%d", i), simpleDaemonSetLabel, ds) delete(oldPod.Labels, apps.ControllerRevisionHashLabelKey) oldPod.CreationTimestamp.Time = time.Unix(1, 0) oldPod.Status.Conditions = []v1.PodCondition{{Type: v1.PodReady, Status: v1.ConditionTrue}} manager.podStore.Add(oldPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
nc.zoneStates[k] = newState } } } func (nc *Controller) podUpdated(oldPod, newPod *v1.Pod) { if newPod == nil { return } if len(newPod.Spec.NodeName) != 0 && (oldPod == nil || newPod.Spec.NodeName != oldPod.Spec.NodeName) { podItem := podUpdateItem{newPod.Namespace, newPod.Name} nc.podUpdateQueue.Add(podItem) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// DeleteNominatedPodIfExists deletes nominatedPod from internal cache. It's a no-op if it doesn't exist. DeleteNominatedPodIfExists(pod *v1.Pod) // UpdateNominatedPod updates the <oldPod> with <newPod>. UpdateNominatedPod(logger klog.Logger, oldPod *v1.Pod, newPodInfo *PodInfo) // NominatedPodsForNode returns nominatedPods on the given node. NominatedPodsForNode(nodeName string) []*PodInfo }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
if !exists { t.Fatalf("Pod %q doesn't exist", update.podName) } oldPod := old.(*v1.Pod) newPod := oldPod.DeepCopy() newPod.Status.PodIPs[0].IP = update.podIP newPod.ResourceVersion = strconv.Itoa(resourceVersion) resourceVersion++ esController.podStore.Update(newPod) esController.updatePod(oldPod, newPod) } time.Sleep(tc.finalDelay)
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/controller/endpoint/endpoints_controller_test.go
t.Fatalf("Pod %q doesn't exist", update.podName) } oldPod := old.(*v1.Pod) newPod := oldPod.DeepCopy() newPod.Status.PodIP = update.podIP newPod.Status.PodIPs[0].IP = update.podIP newPod.ResourceVersion = strconv.Itoa(resourceVersion) resourceVersion++ endpoints.podStore.Update(newPod) endpoints.updatePod(oldPod, newPod) } time.Sleep(tc.finalDelay)
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/controller/job/job_controller_test.go
func TestJobBackoff(t *testing.T) { _, ctx := ktesting.NewTestContext(t) logger := klog.FromContext(ctx) job := newJob(1, 1, 1, batch.NonIndexedCompletion) oldPod := newPod(fmt.Sprintf("pod-%v", rand.String(10)), job) oldPod.ResourceVersion = "1" newPod := oldPod.DeepCopy() newPod.ResourceVersion = "2" testCases := map[string]struct { requeues int oldPodPhase v1.PodPhase phase v1.PodPhase
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
kubelet.kubeClient = testKubelet.fakeKubeClient defer testKubelet.fakeKubeClient.ClearActions() kubelet.podManager.AddPod(testPod1) kubelet.podManager.AddPod(testPod2) kubelet.podManager.AddPod(testPod3) kubelet.podWorkers.(*fakePodWorkers).running = map[types.UID]bool{ testPod1.UID: true, testPod2.UID: true, testPod3.UID: true, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0)