- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for GetStagingPath (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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)