Skip to content
Snippets Groups Projects
Commit db85e824 authored by Sameer Mene's avatar Sameer Mene Committed by Derek Su
Browse files

use storage class for path

parent 7f717388
Branches
Tags
No related merge requests found
...@@ -230,6 +230,7 @@ func (p *LocalPathProvisioner) isSharedFilesystem() (bool, error) { ...@@ -230,6 +230,7 @@ func (p *LocalPathProvisioner) isSharedFilesystem() (bool, error) {
func (p *LocalPathProvisioner) Provision(ctx context.Context, opts pvController.ProvisionOptions) (*v1.PersistentVolume, pvController.ProvisioningState, error) { func (p *LocalPathProvisioner) Provision(ctx context.Context, opts pvController.ProvisionOptions) (*v1.PersistentVolume, pvController.ProvisioningState, error) {
pvc := opts.PVC pvc := opts.PVC
node := opts.SelectedNode node := opts.SelectedNode
storageClass := opts.StorageClass
sharedFS, err := p.isSharedFilesystem() sharedFS, err := p.isSharedFilesystem()
if err != nil { if err != nil {
return nil, pvController.ProvisioningFinished, err return nil, pvController.ProvisioningFinished, err
...@@ -253,7 +254,13 @@ func (p *LocalPathProvisioner) Provision(ctx context.Context, opts pvController. ...@@ -253,7 +254,13 @@ func (p *LocalPathProvisioner) Provision(ctx context.Context, opts pvController.
// This clause works only with sharedFS // This clause works only with sharedFS
nodeName = node.Name nodeName = node.Name
} }
basePath, err := p.getRandomPathOnNode(nodeName) var basePath string
basePath, err = p.getRandomPathOnNode(nodeName)
if storageClass.Parameters != nil {
if _, ok := storageClass.Parameters["path"]; ok {
basePath = storageClass.Parameters["path"]
}
}
if err != nil { if err != nil {
return nil, pvController.ProvisioningFinished, err return nil, pvController.ProvisioningFinished, err
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment