diff --git a/internal/nfs/controller/controllerserver.go b/internal/nfs/controller/controllerserver.go index 36a55a9bd..15c610131 100644 --- a/internal/nfs/controller/controllerserver.go +++ b/internal/nfs/controller/controllerserver.go @@ -84,9 +84,9 @@ func (cs *Server) CreateVolume( 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() cr, err := util.NewAdminCredentials(secret) @@ -97,7 +97,7 @@ func (cs *Server) CreateVolume( } defer cr.DeleteCredentials() - nfsVolume, err := NewNFSVolume(ctx, backend.VolumeId) + nfsVolume, err := NewNFSVolume(ctx, backend.GetVolumeId()) if err != nil { return nil, status.Error(codes.InvalidArgument, err.Error()) } diff --git a/internal/nfs/controller/volume.go b/internal/nfs/controller/volume.go index 271393d97..f8ca47d2b 100644 --- a/internal/nfs/controller/volume.go +++ b/internal/nfs/controller/volume.go @@ -127,12 +127,12 @@ func (nv *NFSVolume) CreateExport(backend *csi.Volume) error { if !nv.connected { return fmt.Errorf("can not created export for %q: %w", nv, ErrNotConnected) } - - fs := backend.VolumeContext["fsName"] - nfsCluster := backend.VolumeContext["nfsCluster"] - path := backend.VolumeContext["subvolumePath"] - secTypes := backend.VolumeContext["secTypes"] - clients := backend.VolumeContext["clients"] + vctx := backend.GetVolumeContext() + fs := vctx["fsName"] + nfsCluster := vctx["nfsCluster"] + path := vctx["subvolumePath"] + secTypes := vctx["secTypes"] + clients := vctx["clients"] err := nv.setNFSCluster(nfsCluster) if err != nil {