- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for sandboxIDs (0.26 sec)
-
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/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/kuberuntime/kuberuntime_manager_test.go
// 3. should create all app containers because init container finished. // Stop init container instance 0. sandboxIDs, err := m.getSandboxIDByPodUID(ctx, pod.UID, nil) require.NoError(t, err) sandboxID := sandboxIDs[0] initID0, err := fakeRuntime.GetContainerID(sandboxID, initContainers[0].Name, 0) require.NoError(t, err) fakeRuntime.StopContainer(ctx, initID0, 0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K 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) -
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 }
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/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/kuberuntime_manager.go
func (m *kubeGenericRuntimeManager) GetPods(ctx context.Context, all bool) ([]*kubecontainer.Pod, error) { pods := make(map[kubetypes.UID]*kubecontainer.Pod) sandboxes, err := m.getKubeletSandboxes(ctx, all) if err != nil { return nil, err } for i := range sandboxes { s := sandboxes[i] if s.Metadata == nil { klog.V(4).InfoS("Sandbox does not have metadata", "sandbox", s) continue }
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/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)