- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 39 for getvolumename (0.23 sec)
-
pkg/volume/projected/projected.go
plugin.deleteServiceAccountToken = host.DeleteServiceAccountTokenFunc() return nil } func (plugin *projectedPlugin) GetPluginName() string { return projectedPluginName } func (plugin *projectedPlugin) GetVolumeName(spec *volume.Spec) (string, error) { _, _, err := getVolumeSource(spec) if err != nil { return "", err } return spec.Name(), nil } func (plugin *projectedPlugin) CanSupport(spec *volume.Spec) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/volume/util/util.go
return "", fmt.Errorf( "volumePlugin should not be nil. volumeSpec.Name=%q", volumeSpec.Name()) } volumeName, err := volumePlugin.GetVolumeName(volumeSpec) if err != nil || volumeName == "" { return "", fmt.Errorf( "failed to GetVolumeName from volumePlugin for volumeSpec %q err=%v", volumeSpec.Name(), err) } return GetUniqueVolumeName( volumePlugin.GetPluginName(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
shouldFail: true, }, } for _, tc := range testCases { t.Logf("testing: %s", tc.name) registerFakePlugin(tc.driverName, "endpoint", []string{"1.3.0"}, t) name, err := plug.GetVolumeName(tc.spec) if tc.shouldFail != (err != nil) { t.Fatal("shouldFail does match expected error") } if tc.shouldFail && err != nil { t.Log(err) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/volume/plugins.go
// such as "example.com/volume" and contain exactly one '/' character. // The "kubernetes.io" namespace is reserved for plugins which are // bundled with kubernetes. GetPluginName() string // GetVolumeName returns the name/ID to uniquely identifying the actual // backing device, directory, path, etc. referenced by the specified volume // spec. // For Attachable volumes, this value must be able to be passed back to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/volume/fc/fc.go
) func (plugin *fcPlugin) Init(host volume.VolumeHost) error { plugin.host = host return nil } func (plugin *fcPlugin) GetPluginName() string { return fcPluginName } func (plugin *fcPlugin) GetVolumeName(spec *volume.Spec) (string, error) { volumeSource, _, err := getVolumeSource(spec) if err != nil { return "", err } // API server validates these parameters beforehand but attach/detach
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
plugin.host = host return nil } func (plugin *emptyDirPlugin) GetPluginName() string { return emptyDirPluginName } func (plugin *emptyDirPlugin) GetVolumeName(spec *volume.Spec) (string, error) { volumeSource, _ := getVolumeSource(spec) if volumeSource == nil { return "", fmt.Errorf("Spec does not reference an EmptyDir volume type") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
pkg/volume/local/local_test.go
} } func TestGetVolumeName(t *testing.T) { tmpDir, plug := getPersistentPlugin(t) defer os.RemoveAll(tmpDir) volName, err := plug.GetVolumeName(getTestVolume(false, tmpDir, false, nil)) if err != nil { t.Errorf("Failed to get volume name: %v", err) } if volName != testPVName { t.Errorf("Expected volume name %q, got %q", testPVName, volName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 10:53:39 UTC 2023 - 22.5K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
plugin.host = host plugin.targetLocks = keymutex.NewHashed(0) return nil } func (plugin *iscsiPlugin) GetPluginName() string { return iscsiPluginName } func (plugin *iscsiPlugin) GetVolumeName(spec *volume.Spec) (string, error) { tp, _, iqn, lun, err := getISCSITargetInfo(spec) if err != nil { return "", err } return fmt.Sprintf("%v:%v:%v", tp, iqn, lun), nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/volume/local/local.go
plugin.recorder = host.GetEventRecorder() return nil } func (plugin *localVolumePlugin) GetPluginName() string { return localVolumePluginName } func (plugin *localVolumePlugin) GetVolumeName(spec *volume.Spec) (string, error) { // This volume is only supported as a PersistentVolumeSource, so the PV name is unique return spec.Name(), nil } func (plugin *localVolumePlugin) CanSupport(spec *volume.Spec) 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_attacher.go
klog.Error(log("detacher.Detach missing value for parameter volumeName")) return errors.New("missing expected parameter volumeName") } // volumeName in format driverName<SEP>volumeHandle generated by plugin.GetVolumeName() parts := strings.Split(volumeName, volNameSep) if len(parts) != 2 { klog.Error(log("detacher.Detach insufficient info encoded in volumeName")) return errors.New("volumeName missing expected data") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K bytes - Viewed (0)