Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newPodContainerDeletor (0.24 sec)

  1. pkg/kubelet/pod_container_deletor.go

    func (a containerStatusbyCreatedList) Swap(i, j int) { a[i], a[j] = a[j], a[i] }
    func (a containerStatusbyCreatedList) Less(i, j int) bool {
    	return a[i].CreatedAt.After(a[j].CreatedAt)
    }
    
    func newPodContainerDeletor(runtime kubecontainer.Runtime, containersToKeep int) *podContainerDeletor {
    	buffer := make(chan kubecontainer.ContainerID, containerDeletorBufferLimit)
    	go wait.Until(func() {
    		for {
    			id := <-buffer
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 4K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    	containerGC, err := kubecontainer.NewContainerGC(klet.containerRuntime, containerGCPolicy, klet.sourcesReady)
    	if err != nil {
    		return nil, err
    	}
    	klet.containerGC = containerGC
    	klet.containerDeletor = newPodContainerDeletor(klet.containerRuntime, max(containerGCPolicy.MaxPerPodContainer, minDeadContainerInPod))
    
    	// setup imageManager
    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