- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for reconstructVolume (0.3 sec)
-
pkg/kubelet/volumemanager/reconciler/reconstruct_common.go
return nil, fmt.Errorf( "reconstructVolume.NewMounter failed for volume %q (spec.Name: %q) pod %q (UID: %q) with: %v", uniqueVolumeName, volumeSpec.Name(), volume.podName, pod.UID, err) } if deviceMountablePlugin != nil { deviceMounter, err = deviceMountablePlugin.NewDeviceMounter() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct.go
return false } return true } // reconstructVolumes tries to reconstruct the actual state of world by scanning all pods' volume // directories from the disk. For the volumes that cannot support or fail reconstruction, it will // put the volumes to volumesFailedReconstruction to be cleaned up later when DesiredStateOfWorld // is populated. func (rc *reconciler) reconstructVolumes() { // Get volumes information by reading the pod's directory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor.go
// Filesystem Volume case if volumeMode == v1.PersistentVolumeFilesystem { // Create volumeSpec from mount path klog.V(5).Infof("Starting operationExecutor.ReconstructVolume for file volume on pod %q", podName) reconstructed, err := plugin.ConstructVolumeSpec(volumeSpecName, volumePath) if err != nil { return volume.ReconstructedVolume{}, err } return reconstructed, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler.go
limitations under the License. */ package reconciler import ( "k8s.io/apimachinery/pkg/util/wait" "k8s.io/klog/v2" ) func (rc *reconciler) Run(stopCh <-chan struct{}) { rc.reconstructVolumes() klog.InfoS("Reconciler: start to sync state") wait.Until(rc.reconcile, rc.loopSleepDuration, stopCh) } func (rc *reconciler) reconcile() { readyToUnmount := rc.readyToUnmount() if readyToUnmount {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
os.MkdirAll(vp, 0755) } rc, fakePlugin := getReconciler(tmpKubeletDir, t, mountPaths, nil /*custom kubeclient*/) rcInstance, _ := rc.(*reconciler) // Act rcInstance.reconstructVolumes() // Assert // Convert to []UniqueVolumeName expectedVolumes := make([]v1.UniqueVolumeName, len(tc.expectedVolumesNeedDevicePath)) for i := range tc.expectedVolumesNeedDevicePath {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0)