Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 395 for podutil (0.99 sec)

  1. pkg/kubelet/eviction/eviction_manager.go

    	klog.V(3).InfoS("Evicting pod", "pod", klog.KObj(pod), "podUID", pod.UID, "message", evictMsg)
    	err := m.killPodFunc(pod, true, &gracePeriodOverride, func(status *v1.PodStatus) {
    		status.Phase = v1.PodFailed
    		status.Reason = Reason
    		status.Message = evictMsg
    		if condition != nil {
    			podutil.UpdatePodCondition(status, condition)
    		}
    	})
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  2. pkg/controller/resourceclaim/controller.go

    		// pod itself might not get deleted for a while.
    		podName, podUID := owningPod(claim)
    		if podName != "" {
    			pod, err := ec.podLister.Pods(claim.Namespace).Get(podName)
    			switch {
    			case err == nil:
    				// Pod already replaced or not going to run?
    				if pod.UID != podUID || isPodDone(pod) {
    					// We are certain that the owning pod is not going to need
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/memorymanager/policy_static.go

    }
    
    // RemoveContainer call is idempotent
    func (p *staticPolicy) RemoveContainer(s state.State, podUID string, containerName string) {
    	blocks := s.GetMemoryBlocks(podUID, containerName)
    	if blocks == nil {
    		return
    	}
    
    	klog.InfoS("RemoveContainer", "podUID", podUID, "containerName", containerName)
    	s.Delete(podUID, containerName)
    
    	// Mutate machine memory state to update free and reserved memory
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Nov 12 07:34:55 UTC 2023
    - 34K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cpumanager/policy_static.go

    func (p *staticPolicy) RemoveContainer(s state.State, podUID string, containerName string) error {
    	klog.InfoS("Static policy: RemoveContainer", "podUID", podUID, "containerName", containerName)
    	cpusInUse := getAssignedCPUsOfSiblings(s, podUID, containerName)
    	if toRelease, ok := s.GetCPUSet(podUID, containerName); ok {
    		s.Delete(podUID, containerName)
    		// Mutate the shared pool, adding released cpus.
    		toRelease = toRelease.Difference(cpusInUse)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
  5. pkg/scheduler/internal/queue/scheduling_queue_test.go

    	// Update pod condition to highPod.
    	podutil.UpdatePodCondition(&highPod.Status, &v1.PodCondition{
    		Type:    v1.PodScheduled,
    		Status:  v1.ConditionFalse,
    		Reason:  v1.PodReasonUnschedulable,
    		Message: "fake scheduling failure",
    	})
    
    	// Update pod condition to midPod.
    	podutil.UpdatePodCondition(&midPod.Status, &v1.PodCondition{
    		Type:    v1.PodScheduled,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  6. pkg/controller/statefulset/stateful_set_control_test.go

    	appslisters "k8s.io/client-go/listers/apps/v1"
    	corelisters "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    	featuregatetesting "k8s.io/component-base/featuregate/testing"
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    	"k8s.io/kubernetes/pkg/controller"
    	"k8s.io/kubernetes/pkg/controller/history"
    	"k8s.io/kubernetes/pkg/features"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  7. pkg/controller/statefulset/stateful_set_utils_test.go

    			},
    			setUID:        "set",
    			podUID:        "pod",
    			nonController: true,
    		},
    		{
    			name: "set controller",
    			refs: []metav1.OwnerReference{
    				{
    					APIVersion: "apps/v1",
    					Kind:       "Set",
    					Name:       "set",
    					UID:        "set",
    					Controller: ptr.To(true),
    				},
    			},
    			setUID:        "set",
    			podUID:        "pod",
    			nonController: false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 50.9K bytes
    - Viewed (0)
  8. pkg/scheduler/schedule_one.go

    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/sets"
    	clientset "k8s.io/client-go/kubernetes"
    	"k8s.io/klog/v2"
    	extenderv1 "k8s.io/kube-scheduler/extender/v1"
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    	"k8s.io/kubernetes/pkg/apis/core/validation"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    	"k8s.io/kubernetes/pkg/scheduler/framework/parallelize"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  9. pkg/kubelet/eviction/helpers.go

    	"k8s.io/apimachinery/pkg/api/resource"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	corev1helpers "k8s.io/component-helpers/scheduling/corev1"
    	"k8s.io/klog/v2"
    	statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1"
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    	v1resource "k8s.io/kubernetes/pkg/api/v1/resource"
    	"k8s.io/kubernetes/pkg/features"
    	evictionapi "k8s.io/kubernetes/pkg/kubelet/eviction/api"
    	kubetypes "k8s.io/kubernetes/pkg/kubelet/types"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 53.6K bytes
    - Viewed (0)
  10. pkg/controller/daemon/daemon_controller_test.go

    	for _, obj := range manager.podStore.List() {
    		pod := obj.(*v1.Pod)
    		if pod.CreationTimestamp.IsZero() {
    			pod.CreationTimestamp.Time = now
    		}
    		var readyLast time.Time
    		ready := podutil.IsPodReady(pod)
    		if ready {
    			if c := podutil.GetPodReadyCondition(pod.Status); c != nil {
    				readyLast = c.LastTransitionTime.Time.Add(time.Duration(ds.Spec.MinReadySeconds) * time.Second)
    			}
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
Back to top