- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Sandboxes (0.17 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_gc_test.go
description string // description of the test case sandboxes []sandboxTemplate // templates of sandboxes containers []containerTemplate // templates of containers remain []int // template indexes of remaining sandboxes evictTerminatingPods bool }{ { description: "notready sandboxes without containers for deleted pods should be garbage collected.",
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_gc.go
// removeOldestNSandboxes removes the oldest inactive toRemove sandboxes and // returns the resulting slice. func (cgc *containerGC) removeOldestNSandboxes(ctx context.Context, sandboxes []sandboxGCInfo, toRemove int) { numToKeep := len(sandboxes) - toRemove if numToKeep > 0 { sort.Sort(sandboxByCreated(sandboxes)) } // Remove from oldest to newest (last to first). for i := len(sandboxes) - 1; i >= numToKeep; i-- { if !sandboxes[i].active {
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/pleg/generic.go
containers = append(containers, c) } } for _, p := range pods { if p == nil { continue } fillCidSet(p.Containers) // Update sandboxes as containers // TODO: keep track of sandboxes explicitly. fillCidSet(p.Sandboxes) } return containers } func computeEvents(oldPod, newPod *kubecontainer.Pod, cid *kubecontainer.ContainerID) []*PodLifecycleEvent { var pid types.UID
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/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_test.go
{Pod: &kubecontainer.Pod{ ID: "1234", Sandboxes: []*kubecontainer.Container{ createTestContainer("c1", kubecontainer.ContainerStateExited), createTestContainer("c2", kubecontainer.ContainerStateRunning), createTestContainer("c3", kubecontainer.ContainerStateUnknown), }, }}, {Pod: &kubecontainer.Pod{ ID: "4567", Sandboxes: []*kubecontainer.Container{
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) -
pkg/kubelet/container/helpers.go
State: containerStatus.State, } 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) -
pkg/kubelet/kuberuntime/helpers.go
State: toKubeContainerState(c.State), }, nil } // sandboxToKubeContainer converts runtimeapi.PodSandbox to kubecontainer.Container. // This is only needed because we need to return sandboxes as if they were // kubecontainer.Containers to avoid substantial changes to PLEG. // TODO: Remove this once it becomes obsolete.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 12K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
if sandboxStatus.State == runtimeapi.PodSandboxState_SANDBOX_READY { return status.IPs } } // For pods with no ready containers or sandboxes (like exited pods) // use the old status' pod IP return oldStatus.IPs } func (e *EventedPLEG) sendPodLifecycleEvent(event *PodLifecycleEvent) { select { case e.eventChannel <- event: default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0)