Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for sandboxIDs (1.97 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. pkg/kubelet/kubelet_pods.go

    }
    
    // killPod instructs the container runtime to kill the pod. This method requires that
    // the pod status contains the result of the last syncPod, otherwise it may fail to
    // terminate newly created containers and sandboxes.
    func (kl *Kubelet) killPod(ctx context.Context, pod *v1.Pod, p kubecontainer.Pod, gracePeriodOverride *int64) error {
    	// Call the container runtime KillPod method which stops all known running containers of the pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet.go

    func (kl *Kubelet) ListMetricDescriptors(ctx context.Context) ([]*runtimeapi.MetricDescriptor, error) {
    	return kl.containerRuntime.ListMetricDescriptors(ctx)
    }
    
    // ListPodSandboxMetrics retrieves the metrics for all pod sandboxes.
    func (kl *Kubelet) ListPodSandboxMetrics(ctx context.Context) ([]*runtimeapi.PodSandboxMetrics, error) {
    	return kl.containerRuntime.ListPodSandboxMetrics(ctx)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top