Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 140 for oldpod (1.33 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top