Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for sandboxIDs (1.22 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. pkg/kubelet/kuberuntime/util/util.go

    		}
    	}
    
    	// 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
    	}
    	if sandboxStatus.State != runtimeapi.PodSandboxState_SANDBOX_READY {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:14:48 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top