Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 664 for volName (0.36 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top