Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 236 for podutil (0.18 sec)

  1. pkg/kubelet/status/status_manager_test.go

    	syncer.SetPodStatus(pod, anotherStatus)
    	verifyUpdates(t, syncer, 1)
    	newStatus := expectPodStatus(t, syncer, pod)
    
    	oldReadyCondition := podutil.GetPodReadyCondition(oldStatus)
    	newReadyCondition := podutil.GetPodReadyCondition(newStatus)
    	if newReadyCondition.LastTransitionTime.IsZero() {
    		t.Errorf("Unexpected: last transition time not set")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_pods.go

    	var cID string
    
    	cStatus, found := podutil.GetContainerStatus(podStatus.ContainerStatuses, containerName)
    	if !found {
    		cStatus, found = podutil.GetContainerStatus(podStatus.InitContainerStatuses, containerName)
    	}
    	if !found {
    		cStatus, found = podutil.GetContainerStatus(podStatus.EphemeralContainerStatuses, containerName)
    	}
    	if !found {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_set_utils.go

    func isRunningAndReady(pod *v1.Pod) bool {
    	return pod.Status.Phase == v1.PodRunning && podutil.IsPodReady(pod)
    }
    
    func isRunningAndAvailable(pod *v1.Pod, minReadySeconds int32) bool {
    	return podutil.IsPodAvailable(pod, minReadySeconds, metav1.Now())
    }
    
    // isCreated returns true if pod has been created and is maintained by the API server
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  4. pkg/controller/endpoint/endpoints_controller.go

    	"k8s.io/client-go/tools/record"
    	"k8s.io/client-go/util/workqueue"
    	endpointsliceutil "k8s.io/endpointslice/util"
    	"k8s.io/klog/v2"
    	"k8s.io/kubernetes/pkg/api/v1/endpoints"
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	helper "k8s.io/kubernetes/pkg/apis/core/v1/helper"
    	"k8s.io/kubernetes/pkg/controller"
    	utillabels "k8s.io/kubernetes/pkg/util/labels"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  5. pkg/kubelet/util/manager/cache_based_manager_test.go

    	return podWithSecretsAndUID(ns, podName, fmt.Sprintf("%s/%s", ns, podName), toAttach)
    }
    
    func podWithSecretsAndUID(ns, podName, podUID string, toAttach secretsToAttach) *v1.Pod {
    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Namespace: ns,
    			Name:      podName,
    			UID:       types.UID(podUID),
    		},
    		Spec: v1.PodSpec{},
    	}
    	for _, name := range toAttach.imagePullSecretNames {
    		pod.Spec.ImagePullSecrets = append(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top