Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,369 for Pods (0.08 sec)

  1. pkg/kubelet/kubelet_test.go

    	pods[2].Spec.ActiveDeadlineSeconds = &exceededActiveDeadlineSeconds
    
    	kubelet.podManager.SetPods(pods)
    	kubelet.workQueue.Enqueue(pods[2].UID, 0)
    	kubelet.workQueue.Enqueue(pods[3].UID, 30*time.Second)
    	kubelet.workQueue.Enqueue(pods[4].UID, 2*time.Minute)
    
    	clock.Step(1 * time.Minute)
    
    	expected := []*v1.Pod{pods[2], pods[3], pods[0]}
    	podsToSync := kubelet.getPodsToSync()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  2. pkg/kubelet/pod/pod_manager.go

    	pods := make([]*v1.Pod, 0, len(UIDMap))
    	for _, pod := range UIDMap {
    		pods = append(pods, pod)
    	}
    	return pods
    }
    
    func mirrorPodsMapToMirrorPods(UIDMap map[kubetypes.MirrorPodUID]*v1.Pod) []*v1.Pod {
    	pods := make([]*v1.Pod, 0, len(UIDMap))
    	for _, pod := range UIDMap {
    		pods = append(pods, pod)
    	}
    	return pods
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:00 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  3. pkg/kubelet/util/sliceutils/sliceutils_test.go

    	fooTests := []struct {
    		pods PodsByCreationTime
    		i    int
    		j    int
    	}{
    		{buildPodsByCreationTime(), 0, 1},
    		{buildPodsByCreationTime(), 2, 1},
    	}
    
    	for _, fooTest := range fooTests {
    		fooi := fooTest.pods[fooTest.i]
    		fooj := fooTest.pods[fooTest.j]
    		fooTest.pods.Swap(fooTest.i, fooTest.j)
    		if fooi.GetName() != fooTest.pods[fooTest.j].GetName() || fooj.GetName() != fooTest.pods[fooTest.i].GetName() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 13 08:27:42 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  4. pkg/client/tests/fake_client_test.go

    	}
    
    	wrongPod, err := tc.CoreV1().Pods("nsB").Get(context.TODO(), "pod-1", metav1.GetOptions{})
    	if err == nil {
    		t.Fatalf("Pods.Get: expected nsB/pod-1 not to match, but it matched %s/%s", wrongPod.Namespace, wrongPod.Name)
    	}
    
    	allPods, err := tc.CoreV1().Pods(metav1.NamespaceAll).List(context.TODO(), metav1.ListOptions{})
    	if err != nil {
    		t.Fatalf("Pods.List: %s", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 17:30:21 UTC 2020
    - 5.6K bytes
    - Viewed (0)
  5. pkg/controller/resourceclaim/controller_test.go

    			key:  podKey(testPodWithResource),
    		},
    		{
    			name: "pod-deleted",
    			pods: func() []*v1.Pod {
    				deleted := metav1.Now()
    				pods := []*v1.Pod{testPodWithResource.DeepCopy()}
    				pods[0].DeletionTimestamp = &deleted
    				return pods
    			}(),
    			key: podKey(testPodWithResource),
    		},
    		{
    			name: "no-volumes",
    			pods: []*v1.Pod{testPod},
    			key:  podKey(testPod),
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 08:56:16 UTC 2024
    - 28.2K bytes
    - Viewed (0)
  6. plugin/pkg/admission/gc/gc_admission_test.go

    		}
    		return authorizer.DecisionAllow, "", nil
    	}
    
    	if username == "non-pod-deleter" {
    		if a.GetVerb() == "delete" && a.GetResource() == "pods" {
    			return authorizer.DecisionNoOpinion, "", nil
    		}
    		if a.GetVerb() == "update" && a.GetResource() == "pods" && a.GetSubresource() == "finalizers" {
    			return authorizer.DecisionNoOpinion, "", nil
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  7. pkg/controller/podgc/gc_controller.go

    		return
    	}
    	if gcc.terminatedPodThreshold > 0 {
    		gcc.gcTerminated(ctx, pods)
    	}
    	gcc.gcTerminating(ctx, pods)
    	gcc.gcOrphaned(ctx, pods, nodes)
    	gcc.gcUnscheduledTerminating(ctx, pods)
    }
    
    func isPodTerminated(pod *v1.Pod) bool {
    	if phase := pod.Status.Phase; phase != v1.PodPending && phase != v1.PodRunning && phase != v1.PodUnknown {
    		return true
    	}
    	return false
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. pkg/controller/job/job_controller.go

    	// When adopting Pods, this operation adds an ownerRef and finalizers.
    	pods, err = cm.ClaimPods(ctx, pods)
    	if err != nil {
    		return pods, err
    	}
    	// Set finalizer on adopted pods for the remaining calculations.
    	for i, p := range pods {
    		adopted := true
    		for _, r := range p.OwnerReferences {
    			if r.UID == j.UID {
    				adopted = false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  9. pkg/controller/replicaset/replica_set_test.go

    	pods := newPodList(nil, 2, v1.PodPending, labelMap, rsSpec, "pod")
    	informers.Core().V1().Pods().Informer().GetIndexer().Add(&pods.Items[0])
    	postExpectationsPod := pods.Items[1]
    
    	manager.expectations = controller.NewUIDTrackingControllerExpectations(FakeRSExpectations{
    		controller.NewControllerExpectations(), true, func() {
    			// If we check active pods before checking expectataions, the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
  10. pkg/kubelet/server/stats/summary_test.go

    		Name:               "pods",
    		StartTime:          cgroupStatsMap["/pods"].cs.StartTime,
    		CPU:                cgroupStatsMap["/pods"].cs.CPU,
    		Memory:             cgroupStatsMap["/pods"].cs.Memory,
    		Accelerators:       cgroupStatsMap["/pods"].cs.Accelerators,
    		UserDefinedMetrics: cgroupStatsMap["/pods"].cs.UserDefinedMetrics,
    		Swap:               cgroupStatsMap["/pods"].cs.Swap,
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 15.1K bytes
    - Viewed (0)
Back to top