mirrors/ceph-csi
1
0
Fork 0
mirror of https://github.com/ceph/ceph-csi.git synced 2024-09-19 15:09:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

nfs: address golangci-lint issues

Browse Source 
addressing golangci-lint issues for
the nfs code.

Signed-off-by: Madhu Rajanna <madhupr007@gmail.com>
This commit is contained in:
Madhu Rajanna 2024-04-04 10:54:24 +02:00 committed by mergify[bot]
parent 4b7cafe821
commit 48d2e2ce2d
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/nfs/controller/controllerserver.go
View File

@ -84,9 +84,9 @@ func (cs *Server) CreateVolume(
return nil, err return nil, err
} }
backend := res.Volume backend := res.GetVolume()
log.DebugLog(ctx, "CephFS volume created: %s", backend.VolumeId) log.DebugLog(ctx, "CephFS volume created: %s", backend.GetVolumeId())
secret := req.GetSecrets() secret := req.GetSecrets()
cr, err := util.NewAdminCredentials(secret) cr, err := util.NewAdminCredentials(secret)
@ -97,7 +97,7 @@ func (cs *Server) CreateVolume(
} }
defer cr.DeleteCredentials() defer cr.DeleteCredentials()
nfsVolume, err := NewNFSVolume(ctx, backend.VolumeId) nfsVolume, err := NewNFSVolume(ctx, backend.GetVolumeId())
if err != nil { if err != nil {
return nil, status.Error(codes.InvalidArgument, err.Error()) return nil, status.Error(codes.InvalidArgument, err.Error())
} }

12
internal/nfs/controller/volume.go
View File

@ -127,12 +127,12 @@ func (nv *NFSVolume) CreateExport(backend *csi.Volume) error {
if !nv.connected { if !nv.connected {
return fmt.Errorf("can not created export for %q: %w", nv, ErrNotConnected) return fmt.Errorf("can not created export for %q: %w", nv, ErrNotConnected)
} }
vctx := backend.GetVolumeContext()
fs := backend.VolumeContext["fsName"] fs := vctx["fsName"]
nfsCluster := backend.VolumeContext["nfsCluster"] nfsCluster := vctx["nfsCluster"]
path := backend.VolumeContext["subvolumePath"] path := vctx["subvolumePath"]
secTypes := backend.VolumeContext["secTypes"] secTypes := vctx["secTypes"]
clients := backend.VolumeContext["clients"] clients := vctx["clients"]
err := nv.setNFSCluster(nfsCluster) err := nv.setNFSCluster(nfsCluster)
if err != nil { if err != nil {