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

use storage class for path

parent 2bf33164
No related branches found
No related tags found
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