Use PublishContext instead
This commit is contained in:
parent
4274180f3d
commit
9e3c2ce6e2
@ -26,7 +26,7 @@ func newSeaweedFsMounter(bucketName string, driver *SeaweedFsDriver, volParamete
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (seaweedFs *seaweedFsMounter) Mount(target string) error {
|
func (seaweedFs *seaweedFsMounter) Mount(target string) error {
|
||||||
glog.V(0).Infof("mounting %s%s to %s", seaweedFs.driver.filer, seaweedFs.bucketName, target)
|
glog.V(0).Infof("mounting %s %s to %s", seaweedFs.driver.filer, seaweedFs.bucketName, target)
|
||||||
|
|
||||||
args := []string{
|
args := []string{
|
||||||
"mount",
|
"mount",
|
||||||
|
|||||||
@ -55,7 +55,7 @@ func (ns *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublis
|
|||||||
mo = append(mo, "ro")
|
mo = append(mo, "ro")
|
||||||
}
|
}
|
||||||
|
|
||||||
volParameters := req.GetVolumeContext()
|
volParameters := req.GetPublishContext()
|
||||||
|
|
||||||
mounter, err := newMounter(volumeID, ns.Driver, volParameters)
|
mounter, err := newMounter(volumeID, ns.Driver, volParameters)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user