- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for runVolumeManager (0.48 sec)
-
pkg/kubelet/volumemanager/volume_manager_test.go
node, pod, pv, claim := createObjects(test.pvMode, test.podMode) kubeClient := fake.NewSimpleClientset(node, pod, pv, claim) manager := newTestVolumeManager(t, tmpDir, podManager, kubeClient, node) stopCh := runVolumeManager(manager) defer close(stopCh) podManager.SetPods([]*v1.Pod{pod}) // Fake node status update go simulateVolumeInUseUpdate( v1.UniqueVolumeName(node.Status.VolumesAttached[0].Name),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes_test.go
{ Name: "vol2", VolumeSource: v1.VolumeSource{ GCEPersistentDisk: &v1.GCEPersistentDiskVolumeSource{ PDName: "fake-device2", }, }, }, }, }) stopCh := runVolumeManager(kubelet) defer close(stopCh) kubelet.podManager.SetPods([]*v1.Pod{pod}) err := kubelet.volumeManager.WaitForAttachAndMount(context.Background(), pod) assert.NoError(t, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 20.4K bytes - Viewed (0) -
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)