Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ActivePods (0.64 sec)

  1. pkg/kubelet/cm/qos_container_manager_linux.go

    		Guaranteed: rootContainer,
    		Burstable:  qosClasses[v1.PodQOSBurstable],
    		BestEffort: qosClasses[v1.PodQOSBestEffort],
    	}
    	m.getNodeAllocatable = getNodeAllocatable
    	m.activePods = activePods
    
    	// update qos cgroup tiers on startup and in periodic intervals
    	// to ensure desired state is in sync with actual state.
    	go wait.Until(func() {
    		err := m.UpdateCgroups()
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 20:42:59 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller_test.go

    	}
    	return pods
    }
    
    func setPodsStatuses(podIndexer cache.Indexer, job *batch.Job, pendingPods, activePods, succeededPods, failedPods, terminatingPods, readyPods int) {
    	for _, pod := range newPodList(pendingPods, v1.PodPending, job) {
    		podIndexer.Add(pod)
    	}
    	running := newPodList(activePods, v1.PodRunning, job)
    	for i, p := range running {
    		if i >= readyPods {
    			break
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller.go

    		job:                  &job,
    		pods:                 pods,
    		activePods:           controller.FilterActivePods(logger, pods),
    		terminating:          terminating,
    		uncounted:            newUncountedTerminatedPods(*job.Status.UncountedTerminatedPods),
    		expectedRmFinalizers: jm.finalizerExpectations.getExpectedUIDs(key),
    	}
    	active := int32(len(jobCtx.activePods))
    	newSucceededPods, newFailedPods := getNewFinishedPods(jobCtx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods.go

    // https://github.com/kubernetes/kubernetes/issues/104824
    func (kl *Kubelet) GetActivePods() []*v1.Pod {
    	allPods := kl.podManager.GetPods()
    	activePods := kl.filterOutInactivePods(allPods)
    	return activePods
    }
    
    // makeBlockVolumes maps the raw block devices specified in the path of the container
    // Experimental
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet.go

    		// we simply avoid doing any work.
    		if !kl.podWorkers.IsPodTerminationRequested(pod.UID) {
    			// We failed pods that we rejected, so activePods include all admitted
    			// pods that are alive.
    			activePods := kl.filterOutInactivePods(existingPods)
    
    			if utilfeature.DefaultFeatureGate.Enabled(features.InPlacePodVerticalScaling) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/queue/scheduling_queue_test.go

    `, // the observed value will always be 0, because we don't proceed the fake clock.
    		},
    	}
    
    	resetMetrics := func() {
    		metrics.ActivePods().Set(0)
    		metrics.BackoffPods().Set(0)
    		metrics.UnschedulablePods().Set(0)
    		metrics.GatedPods().Set(0)
    		metrics.PluginExecutionDuration.Reset()
    	}
    
    	for _, test := range tests {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
Back to top