dominik/seaweedfs-csi-driver
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Match variable names to Context instead of Parameters

Browse Source
This commit is contained in:
Daniel Santos 2021-01-27 21:12:13 -07:00
parent 7844509790
commit ca767fdce1
3 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/driver/mounter.go
View File

@ -20,8 +20,8 @@ type Mounter interface {
Mount(target string) error
}
func newMounter(bucketName string, driver *SeaweedFsDriver, volParameters map[string]string) (Mounter, error) {
return newSeaweedFsMounter(bucketName, driver, volParameters)
func newMounter(bucketName string, driver *SeaweedFsDriver, volContext map[string]string) (Mounter, error) {
return newSeaweedFsMounter(bucketName, driver, volContext)
}
func fuseMount(path string, command string, args []string) error {

16
pkg/driver/mounter_seaweedfs.go
View File

@ -8,20 +8,20 @@ import (
// Implements Mounter
type seaweedFsMounter struct {
bucketName string
driver *SeaweedFsDriver
volParameters map[string]string
bucketName string
driver *SeaweedFsDriver
volContext map[string]string
}
const (
seaweedFsCmd = "weed"
)
func newSeaweedFsMounter(bucketName string, driver *SeaweedFsDriver, volParameters map[string]string) (Mounter, error) {
func newSeaweedFsMounter(bucketName string, driver *SeaweedFsDriver, volContext map[string]string) (Mounter, error) {
return &seaweedFsMounter{
bucketName: bucketName,
driver: driver,
volParameters: volParameters,
bucketName: bucketName,
driver: driver,
volContext: volContext,
}, nil
}
@ -38,7 +38,7 @@ func (seaweedFs *seaweedFsMounter) Mount(target string) error {
fmt.Sprintf("-filer.path=/buckets/%s", seaweedFs.bucketName),
}
for arg, value := range seaweedFs.volParameters {
for arg, value := range seaweedFs.volContext {
switch arg {
case "map.uid":
args = append(args, fmt.Sprintf("-map.uid=%s", value))

4
pkg/driver/nodeserver.go
View File

@ -55,9 +55,9 @@ func (ns *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublis
mo = append(mo, "ro")
}
volParameters := req.GetVolumeContext()
volContext := req.GetVolumeContext()
mounter, err := newMounter(volumeID, ns.Driver, volParameters)
mounter, err := newMounter(volumeID, ns.Driver, volContext)
if err != nil {
return nil, err
}