- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 664 for volName (0.36 sec)
-
pkg/volume/testing/testing.go
} // Block volume support func (plugin *FakeVolumePlugin) NewBlockVolumeUnmapper(volName string, podUID types.UID) (volume.BlockVolumeUnmapper, error) { plugin.Lock() defer plugin.Unlock() volume := plugin.getFakeVolume(&plugin.BlockVolumeUnmappers) volume.Lock() defer volume.Unlock() volume.PodUID = podUID volume.VolName = volName volume.Plugin = plugin return volume, nil }
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/configmap/configmap.go
type configMapPlugin struct { host volume.VolumeHost getConfigMap func(namespace, name string) (*v1.ConfigMap, error) } var _ volume.VolumePlugin = &configMapPlugin{} func getPath(uid types.UID, volName string, host volume.VolumeHost) string { return host.GetPodVolumeDir(uid, utilstrings.EscapeQualifiedName(configMapPluginName), volName) } func (plugin *configMapPlugin) Init(host volume.VolumeHost) error { plugin.host = host
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10K bytes - Viewed (0) -
pkg/volume/downwardapi/downwardapi.go
type downwardAPIPlugin struct { host volume.VolumeHost } var _ volume.VolumePlugin = &downwardAPIPlugin{} func getPath(uid types.UID, volName string, host volume.VolumeHost) string { return host.GetPodVolumeDir(uid, utilstrings.EscapeQualifiedName(downwardAPIPluginName), volName) } func wrappedVolumeSpec() volume.Spec { return volume.Spec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/volume/secret/secret.go
type secretPlugin struct { host volume.VolumeHost getSecret func(namespace, name string) (*v1.Secret, error) } var _ volume.VolumePlugin = &secretPlugin{} func wrappedVolumeSpec() volume.Spec { return volume.Spec{ Volume: &v1.Volume{VolumeSource: v1.VolumeSource{EmptyDir: &v1.EmptyDirVolumeSource{Medium: v1.StorageMediumMemory}}}, } } func getPath(uid types.UID, volName string, host volume.VolumeHost) string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/volume/projected/projected.go
MetricsProvider: volume.NewCachedMetrics(volume.NewMetricsDu(getPath(pod.UID, spec.Name(), plugin.host))), }, source: *spec.Volume.Projected, pod: pod, opts: &opts, }, nil } func (plugin *projectedPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &projectedVolumeUnmounter{ &projectedVolume{ volName: volName, podUID: podUID,
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/portworx/portworx.go
// ProbeVolumePlugins is the primary entrypoint for volume plugins. func ProbeVolumePlugins() []volume.VolumePlugin { return []volume.VolumePlugin{&portworxVolumePlugin{nil, nil}} } type portworxVolumePlugin struct { host volume.VolumeHost util *portworxVolumeUtil } var _ volume.VolumePlugin = &portworxVolumePlugin{} var _ volume.PersistentVolumePlugin = &portworxVolumePlugin{} var _ volume.DeletableVolumePlugin = &portworxVolumePlugin{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/volume/git_repo/git_repo.go
"k8s.io/apimachinery/pkg/types" "k8s.io/kubernetes/pkg/volume" volumeutil "k8s.io/kubernetes/pkg/volume/util" "k8s.io/utils/exec" utilstrings "k8s.io/utils/strings" ) // This is the primary entrypoint for volume plugins. func ProbeVolumePlugins() []volume.VolumePlugin { return []volume.VolumePlugin{&gitRepoPlugin{nil}} } type gitRepoPlugin struct { host volume.VolumeHost }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/volume/util/nested_volumes_test.go
name string err bool expected sets.Set[string] volname string pod v1.Pod } func TestGetNestedMountpoints(t *testing.T) { var ( testNamespace = "test_namespace" testPodUID = types.UID("test_pod_uid") ) tc := []testCases{ { name: "Simple Pod", err: false, expected: sets.New[string](), volname: "vol1", pod: v1.Pod{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/volume/nfs/nfs.go
} func (plugin *nfsPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return plugin.newUnmounterInternal(volName, podUID, plugin.host.GetMounter(plugin.GetPluginName())) } func (plugin *nfsPlugin) newUnmounterInternal(volName string, podUID types.UID, mounter mount.Interface) (volume.Unmounter, error) { return &nfsUnmounter{&nfs{ volName: volName, mounter: mounter,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/volume/local/local.go
return []volume.VolumePlugin{&localVolumePlugin{}} } type localVolumePlugin struct { host volume.VolumeHost volumeLocks keymutex.KeyMutex recorder record.EventRecorder } var _ volume.VolumePlugin = &localVolumePlugin{} var _ volume.PersistentVolumePlugin = &localVolumePlugin{} var _ volume.BlockVolumePlugin = &localVolumePlugin{} var _ volume.NodeExpandableVolumePlugin = &localVolumePlugin{} const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0)