- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 283 for containerId (0.19 sec)
-
pkg/kubelet/stats/cadvisor_stats_provider.go
// adding it to podStats.Containers. containerName := kubetypes.GetContainerName(cinfo.Spec.Labels) if containerName == kubetypes.PodInfraContainerName { // Special case for infrastructure container which is hidden from // the user and has network stats. podStats.StartTime = metav1.NewTime(cinfo.Spec.CreationTime) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 16 13:34:22 UTC 2023 - 18.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
InitContainers: []v1.Container{ {Name: "containerX"}, }, Containers: []v1.Container{ {Name: "containerA"}, {Name: "containerB"}, }, RestartPolicy: v1.RestartPolicyAlways, } tests := []struct { pod *v1.Pod status v1.PodPhase test string }{ {&v1.Pod{Spec: desiredState, Status: v1.PodStatus{}}, v1.PodPending, "empty, waiting"}, { &v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/kubelet/prober/worker_test.go
expectResult(t, w, results.Failure, msg) if !w.onHold { t.Errorf("Prober should be on hold due to %s check failure", probeType) } // Set a new container ID to lift the hold. The next probe will succeed. status.ContainerStatuses[0].ContainerID = "test://newCont_ID" m.statusManager.SetPodStatus(w.pod, status) msg = "hold lifted" expectContinue(t, w, w.doProbe(ctx), msg)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 23:48:10 UTC 2023 - 16.1K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
utilsnet "k8s.io/utils/net" ) // HandlerRunner runs a lifecycle handler for a container. type HandlerRunner interface { Run(ctx context.Context, containerID ContainerID, pod *v1.Pod, container *v1.Container, handler *v1.LifecycleHandler) (string, error) } // RuntimeHelper wraps kubelet to make container runtime // able to get necessary informations like the RunContainerOptions, DNS settings, Host IP.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
} } // Number of running containers to keep. keepCount := 0 // check the status of containers. for idx, container := range pod.Spec.Containers { containerStatus := podStatus.FindContainerStatusByName(container.Name) // Call internal container post-stop lifecycle hook for any non-running container so that any // allocated cpus are released immediately. If the container is restarted, cpus will be re-allocated
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
newPod := func(initContainers, containers int, fns ...func(*v1.Pod)) *v1.Pod { pod := getTestPod() for i := 0; i < initContainers; i++ { pod.Spec.InitContainers = append(pod.Spec.InitContainers, v1.Container{ Name: fmt.Sprintf("init-%d", i), }) } for i := 0; i < containers; i++ { pod.Spec.Containers = append(pod.Spec.Containers, v1.Container{ Name: fmt.Sprintf("%d", i), }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/kubelet/images/image_gc_manager_test.go
ID: imageID(id), Size: size, Spec: container.ImageSpec{ RuntimeHandler: runtimeHandler, }, } } } // Make a container with the specified ID. It will use the image with the same ID. func makeContainer(id int) *container.Container { return &container.Container{ ID: container.ContainerID{Type: "test", ID: fmt.Sprintf("container-%d", id)}, Image: imageName(id),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 15:38:20 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/kubelet/prober/scale_test.go
pod.Spec.Containers = append(pod.Spec.Containers, v1.Container{ Name: fmt.Sprintf("container%d", j), LivenessProbe: newProbe(handler), }) pod.Status.ContainerStatuses = append(pod.Status.ContainerStatuses, v1.ContainerStatus{ Name: fmt.Sprintf("container%d", j), ContainerID: fmt.Sprintf("pod%d://container%d", i, j), State: v1.ContainerState{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 8.2K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/helpers_test.go
} } func TestStableKey(t *testing.T) { container := &v1.Container{ Name: "test_container", Image: "foo/image:v1", } pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test_pod", Namespace: "test_pod_namespace", UID: "test_pod_uid", }, Spec: v1.PodSpec{ Containers: []v1.Container{*container}, }, } oldKey := getStableKey(pod, container)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/api/testing/deep_copy_test.go
{ Name: "varetcd", VolumeSource: api.VolumeSource{ HostPath: &api.HostPathVolumeSource{ Path: "/mnt/master-pd/var/etcd", }, }, }, }, Containers: []api.Container{ { Name: "etcd-container", Image: "registry.k8s.io/etcd:2.0.9", Command: []string{ "/usr/local/bin/etcd", "--addr", "127.0.0.1:2379", "--bind-addr", "127.0.0.1:2379",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 4.7K bytes - Viewed (0)