Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for nodeutil (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/kubelet/kubelet.go

    	runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1"
    	remote "k8s.io/cri-client/pkg"
    	"k8s.io/klog/v2"
    	pluginwatcherapi "k8s.io/kubelet/pkg/apis/pluginregistration/v1"
    	statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1"
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    	"k8s.io/kubernetes/pkg/api/v1/resource"
    	"k8s.io/kubernetes/pkg/features"
    	kubeletconfiginternal "k8s.io/kubernetes/pkg/kubelet/apis/config"
    	"k8s.io/kubernetes/pkg/kubelet/apis/podresources"
    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/controller/nodelifecycle/node_lifecycle_controller_test.go

    				nodeUID, _ := value.UID.(string)
    				pods, err := nodeController.getPodsAssignedToNode(value.Value)
    				if err != nil {
    					t.Errorf("unexpected error: %v", err)
    				}
    				controllerutil.DeletePods(ctx, item.fakeNodeHandler, pods, nodeController.recorder, value.Value, nodeUID, nodeController.daemonSetStore)
    				return true, 0
    			})
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
  7. pkg/printers/internalversion/printers.go

    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apimachinery/pkg/runtime/schema"
    	"k8s.io/apimachinery/pkg/util/duration"
    	"k8s.io/apimachinery/pkg/util/sets"
    	"k8s.io/client-go/util/certificate/csr"
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    	"k8s.io/kubernetes/pkg/apis/admissionregistration"
    	"k8s.io/kubernetes/pkg/apis/apiserverinternal"
    	"k8s.io/kubernetes/pkg/apis/apps"
    	"k8s.io/kubernetes/pkg/apis/autoscaling"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods_test.go

    				Name: container.Name,
    				ID:   kubecontainer.ContainerID{Type: "test", ID: fmt.Sprintf("c%d", i)},
    			})
    		}
    		return runningPod
    	}
    	mirrorPod := func(pod *v1.Pod, nodeName string, nodeUID types.UID) *v1.Pod {
    		copied := pod.DeepCopy()
    		if copied.Annotations == nil {
    			copied.Annotations = make(map[string]string)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top