- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 69 for sandboxes (0.2 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_gc.go
cgc.removeSandbox(ctx, sandboxes[i].id) } } } // removeSandbox removes the sandbox by sandboxID. func (cgc *containerGC) removeSandbox(ctx context.Context, sandboxID string) { klog.V(4).InfoS("Removing sandbox", "sandboxID", sandboxID) // In normal cases, kubelet should've already called StopPodSandbox before // GC kicks in. To guard against the rare cases where this is not true, try // stopping the sandbox before removing it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc_test.go
}, { description: "multiple sandboxes should be handled properly.", sandboxes: []sandboxTemplate{ // running sandbox. makeGCSandbox(pods[0], 1, runtimeapi.PodSandboxState_SANDBOX_READY, true, false, 1), // exited sandbox without containers. makeGCSandbox(pods[0], 0, runtimeapi.PodSandboxState_SANDBOX_NOTREADY, true, false, 0), // exited sandbox with containers.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 20.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_sandbox.go
State: *state, } } sandboxes, err := m.runtimeService.ListPodSandbox(ctx, filter) if err != nil { klog.ErrorS(err, "Failed to list sandboxes for pod", "podUID", podUID) return nil, err } if len(sandboxes) == 0 { return nil, nil } // Sort with newest first. sandboxIDs := make([]string, len(sandboxes)) sort.Sort(podSandboxByCreated(sandboxes)) for i, s := range sandboxes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
containerStateCount[string(container.State)]++ } sandboxes := pod.Sandboxes for _, sandbox := range sandboxes { if sandbox.State == kubecontainer.ContainerStateRunning { runningSandboxNum++ // every pod should only have one running sandbox break } } } for key, value := range containerStateCount {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
pkg/kubelet/pleg/generic_test.go
runtime.AllPodList = []*containertest.FakePod{ {Pod: &kubecontainer.Pod{ ID: "1234", Sandboxes: []*kubecontainer.Container{ createTestContainer("c2", kubecontainer.ContainerStateExited), createTestContainer("c3", kubecontainer.ContainerStateRunning), }, }}, {Pod: &kubecontainer.Pod{ ID: "4567", Sandboxes: []*kubecontainer.Container{ createTestContainer("c4", kubecontainer.ContainerStateRunning),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 24.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_sandbox_test.go
assert.NoError(t, err) assert.Contains(t, fakeRuntime.Called, "RunPodSandbox") sandboxes, err := fakeRuntime.ListPodSandbox(ctx, &runtimeapi.PodSandboxFilter{Id: id}) assert.NoError(t, err) assert.Equal(t, len(sandboxes), 1) assert.Equal(t, sandboxes[0].Id, fmt.Sprintf("%s_%s_%s_1", pod.Name, pod.Namespace, pod.UID)) assert.Equal(t, sandboxes[0].State, runtimeapi.PodSandboxState_SANDBOX_READY) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime.go
ctx, cancel := defaultContext() defer cancel() sandboxes, err := runtime.impl.ListPodSandbox(ctx, runtime.runtimeService, nil) if err != nil { return nil, errors.Wrap(err, "failed to list pod sandboxes") } pods := []string{} for _, sandbox := range sandboxes { pods = append(pods, sandbox.GetId()) } return pods, nil } // RemoveContainers removes running k8s pods
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/util/util.go
if s.State == runtimeapi.PodSandboxState_SANDBOX_READY { readySandboxCount++ } } // Needs to create a new sandbox when readySandboxCount > 1 or the ready sandbox is not the latest one. sandboxStatus := podStatus.SandboxStatuses[0] if readySandboxCount > 1 { klog.V(2).InfoS("Multiple sandboxes are ready for Pod. Need to reconcile them", "pod", klog.KObj(pod)) return true, sandboxStatus.Metadata.Attempt + 1, sandboxStatus.Id }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 23:14:48 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
} runningPod.Containers = append(runningPod.Containers, container) } // Populate sandboxes in kubecontainer.Pod for _, sandbox := range podStatus.SandboxStatuses { runningPod.Sandboxes = append(runningPod.Sandboxes, &Container{ ID: ContainerID{Type: runtimeName, ID: sandbox.Id}, State: SandboxToContainerState(sandbox.State), }) } return runningPod }
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/container/runtime.go
Containers []*Container // List of sandboxes associated with this pod. The sandboxes are converted // to Container temporarily to avoid substantial changes to other // components. This is only populated by kuberuntime. // TODO: use the runtimeApi.PodSandbox type directly. Sandboxes []*Container } // PodPair contains both runtime#Pod and api#Pod type PodPair struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0)