Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,261 for Pods (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. common-protos/k8s.io/api/apps/v1beta1/generated.proto

      // can be scaled down further, followed by scaling up the new ReplicaSet, ensuring
      // that the total number of pods available at all times during the update is at
      // least 70% of desired pods.
      // +optional
      optional k8s.io.apimachinery.pkg.util.intstr.IntOrString maxUnavailable = 1;
    
      // The maximum number of pods that can be scheduled above the desired number of
      // pods.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 24K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/apps/v1beta1/types_swagger_doc_generated.go

    	"unavailableReplicas": "unavailableReplicas is the total number of unavailable pods targeted by this deployment. This is the total number of pods that are still required for the deployment to have 100% available capacity. They may either be pods that are running but not yet available or pods that still have not been created.",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 10 05:34:30 UTC 2023
    - 23.1K bytes
    - Viewed (0)
  10. pkg/controller/statefulset/stateful_set_test.go

    		om.setsIndexer.Add(set)
    
    		pods := []*v1.Pod{}
    		pods = append(pods, newStatefulSetPod(set, 0))
    		// pod1 is orphaned
    		pods = append(pods, newStatefulSetPod(set, 1))
    		pods[1].OwnerReferences = nil
    		// pod2 is owned but has wrong name.
    		pods = append(pods, newStatefulSetPod(set, 2))
    		pods[2].Name = "x" + pods[2].Name
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
Back to top