Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for runningPod (0.18 sec)

  1. pkg/kubelet/kubelet_pods_test.go

    	runtimePod := func(pod *v1.Pod) *kubecontainer.Pod {
    		runningPod := &kubecontainer.Pod{
    			ID:        types.UID(pod.UID),
    			Name:      pod.Name,
    			Namespace: pod.Namespace,
    			Containers: []*kubecontainer.Container{
    				{Name: "container-1", ID: kubecontainer.ContainerID{Type: "test", ID: "c1"}},
    			},
    		}
    		for i, container := range pod.Spec.Containers {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_pods.go

    				RunningPod:     runningPod,
    				KillPodOptions: killPodOptions,
    			})
    
    			// the running pod is now known as well
    			workingPods[runningPod.ID] = PodWorkerSync{State: TerminatingPod, Orphan: true}
    			orphanCount++
    		}
    	}
    	metrics.OrphanedRuntimePodTotal.Add(float64(orphanCount))
    
    	// Now that we have recorded any terminating pods, and added new pods that should be running,
    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/kubelet/kubelet_test.go

    	testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
    	defer testKubelet.Cleanup()
    	runningPod := &kubecontainer.Pod{
    		ID:        "12345678",
    		Name:      "pod1",
    		Namespace: "ns",
    	}
    	apiPod := podWithUIDNameNs(runningPod.ID, runningPod.Name, runningPod.Namespace)
    
    	// Sync once to create pod directory; confirm that the pod directory has
    	// already been created.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet.go

    		// While resize is in progress, periodically call PLEG to update pod cache
    		runningPod := kubecontainer.ConvertPodStatusToRunningPod(kl.getRuntime().Type(), podStatus)
    		if err, _ := kl.pleg.UpdateCache(&runningPod, pod.UID); err != nil {
    			klog.ErrorS(err, "Failed to update pod cache", "pod", klog.KObj(pod))
    			return false, err
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  5. pkg/printers/internalversion/printers_test.go

    		}
    		if !reflect.DeepEqual(test.expect, rows) {
    			t.Errorf("%d mismatch: %s", i, cmp.Diff(test.expect, rows))
    		}
    	}
    }
    
    func TestPrintPodConditions(t *testing.T) {
    	runningPod := &api.Pod{
    		ObjectMeta: metav1.ObjectMeta{Name: "test1", Labels: map[string]string{"a": "1", "b": "2"}},
    		Spec:       api.PodSpec{Containers: make([]api.Container, 2)},
    		Status: api.PodStatus{
    			Phase: "Running",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
Back to top