Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for runVolumeManager (0.12 sec)

  1. pkg/kubelet/kubelet_test.go

    	for {
    		select {
    		case <-ticker.C:
    			volumeManager.MarkVolumesAsReportedInUse(
    				[]v1.UniqueVolumeName{volumeName})
    		case <-stopCh:
    			return
    		}
    	}
    }
    
    func runVolumeManager(kubelet *Kubelet) chan struct{} {
    	stopCh := make(chan struct{})
    	go kubelet.volumeManager.Run(kubelet.sourcesReady, stopCh)
    	return stopCh
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top