Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetStagingPath (0.2 sec)

  1. pkg/volume/csi/csi_block.go

    	klog.V(4).Infof(log("blockMapper.GetGlobalMapPath = %s", dir))
    	return dir, nil
    }
    
    // GetStagingPath returns a staging path for a directory (on the node) that should be used on NodeStageVolume/NodeUnstageVolume
    // Example: plugins/kubernetes.io/csi/volumeDevices/staging/{specName}
    func (m *csiBlockMapper) GetStagingPath() string {
    	return filepath.Join(m.plugin.host.GetVolumeDevicePluginDir(CSIPluginName), "staging", m.specName)
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 06:07:40 UTC 2023
    - 20.1K bytes
    - Viewed (0)
  2. pkg/volume/volume.go

    	// attacher.WaitForAttach() will be used.
    	MapPodDevice() (publishPath string, err error)
    
    	// GetStagingPath returns path that was used for staging the volume
    	// it is mainly used by CSI plugins
    	GetStagingPath() string
    }
    
    // BlockVolumeUnmapper interface is an unmapper interface for block volume.
    type BlockVolumeUnmapper interface {
    	BlockVolume
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. pkg/volume/local/local.go

    	globalPath := util.MakeAbsolutePath(runtime.GOOS, m.globalPath)
    	klog.V(4).Infof("MapPodDevice returning path %s", globalPath)
    	return globalPath, nil
    }
    
    // GetStagingPath returns
    func (m *localVolumeMapper) GetStagingPath() string {
    	return ""
    }
    
    // SupportsMetrics returns true for SupportsMetrics as it initializes the
    // MetricsProvider.
    func (m *localVolumeMapper) SupportsMetrics() bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  4. pkg/volume/csi/csi_block_test.go

    		t.Logf("test case: %s", tc.name)
    		csiMapper, _, _, err := prepareBlockMapperTest(plug, tc.specVolumeName, t)
    		if err != nil {
    			t.Fatalf("Failed to make a new Mapper: %v", err)
    		}
    
    		path := csiMapper.GetStagingPath()
    
    		if tc.path != path {
    			t.Errorf("expecting path %s, got %s", tc.path, path)
    		}
    	}
    }
    
    func TestBlockMapperGetPublishPath(t *testing.T) {
    	plug, tmpDir := newTestPlugin(t, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 06:07:40 UTC 2023
    - 26.5K bytes
    - Viewed (0)
  5. pkg/volume/testing/testing.go

    			return "", fmt.Errorf("error mapping disk: %s", fv.VolName)
    		}
    	}
    
    	fv.DeviceMountState[fv.VolName] = deviceMounted
    	fv.SetUpDeviceCallCount++
    
    	return "", nil
    }
    
    func (fv *FakeVolume) GetStagingPath() string {
    	return filepath.Join(fv.Plugin.Host.GetVolumeDevicePluginDir(utilstrings.EscapeQualifiedName(fv.Plugin.PluginName)), "staging", fv.VolName)
    }
    
    // Block volume support
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  6. pkg/volume/util/operationexecutor/operation_generator.go

    			// if plugin supports custom mappers lets add DeviceStagePath
    			if customBlockVolumeMapper, ok := blockVolumeMapper.(volume.CustomBlockVolumeMapper); ok {
    				resizeOptions.DeviceStagePath = customBlockVolumeMapper.GetStagingPath()
    			}
    		}
    
    		// if we are doing online expansion then volume is already published
    		resizeDone, eventErr, detailedErr = og.doOnlineExpansion(volumeToMount, actualStateOfWorld, resizeOptions)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
Back to top