From a9073b05e4ad8d088eeb9838b464ba59833753fd Mon Sep 17 00:00:00 2001 From: Boris Glimcher Date: Wed, 2 Aug 2023 17:59:46 +0300 Subject: [PATCH] refactor(storage): latest API changes ObjectStats -> StatsObject VolumeId -> VolumeNameRef remove pc.ObjectKey Signed-off-by: Boris Glimcher --- go.mod | 10 +++++----- go.sum | 24 ++++++++++-------------- storage/backend.go | 11 +++++------ storage/frontend.go | 15 +++++++-------- storage/middleend.go | 18 +++++++++--------- testing/mock-server/server/server.go | 24 ++++++++++++------------ 6 files changed, 48 insertions(+), 54 deletions(-) diff --git a/go.mod b/go.mod index 1af446f2..c9d30dd8 100644 --- a/go.mod +++ b/go.mod @@ -9,10 +9,10 @@ require ( github.com/lithammer/fuzzysearch v1.1.8 github.com/onsi/ginkgo/v2 v2.11.0 github.com/onsi/gomega v1.27.10 - github.com/opiproject/opi-api v0.0.0-20230728150746-cc0946b7cec4 + github.com/opiproject/opi-api v0.0.0-20230802143709-76c2f23d70d5 github.com/spf13/cobra v1.7.0 github.com/stretchr/testify v1.8.4 - golang.org/x/net v0.12.0 + golang.org/x/net v0.13.0 golang.org/x/text v0.11.0 google.golang.org/grpc v1.57.0 google.golang.org/protobuf v1.31.0 @@ -32,8 +32,8 @@ require ( golang.org/x/sync v0.2.0 // indirect golang.org/x/sys v0.10.0 // indirect golang.org/x/tools v0.9.3 // indirect - google.golang.org/genproto v0.0.0-20230726155614-23370e0ffb3e // indirect - google.golang.org/genproto/googleapis/api v0.0.0-20230726155614-23370e0ffb3e // indirect - google.golang.org/genproto/googleapis/rpc v0.0.0-20230726155614-23370e0ffb3e // indirect + google.golang.org/genproto v0.0.0-20230731193218-e0aa005b6bdf // indirect + google.golang.org/genproto/googleapis/api v0.0.0-20230731193218-e0aa005b6bdf // indirect + google.golang.org/genproto/googleapis/rpc v0.0.0-20230731193218-e0aa005b6bdf // indirect gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/go.sum b/go.sum index 5fd69c44..ee28ad68 100644 --- a/go.sum +++ b/go.sum @@ -31,12 +31,10 @@ github.com/lithammer/fuzzysearch v1.1.8 h1:/HIuJnjHuXS8bKaiTMeeDlW2/AyIWk2brx1V8 github.com/lithammer/fuzzysearch v1.1.8/go.mod h1:IdqeyBClc3FFqSzYq/MXESsS4S0FsZ5ajtkr5xPLts4= github.com/onsi/ginkgo/v2 v2.11.0 h1:WgqUCUt/lT6yXoQ8Wef0fsNn5cAuMK7+KT9UFRz2tcU= github.com/onsi/ginkgo/v2 v2.11.0/go.mod h1:ZhrRA5XmEE3x3rhlzamx/JJvujdZoJ2uvgI7kR0iZvM= -github.com/onsi/gomega v1.27.9 h1:qIyVWbOsvQEye2QCqLsNSeH/5L1RS9vS382erEWfT3o= -github.com/onsi/gomega v1.27.9/go.mod h1:RsS8tutOdbdgzbPtzzATp12yT7kM5I5aElG3evPbQ0M= github.com/onsi/gomega v1.27.10 h1:naR28SdDFlqrG6kScpT8VWpu1xWY5nJRCF3XaYyBjhI= github.com/onsi/gomega v1.27.10/go.mod h1:RsS8tutOdbdgzbPtzzATp12yT7kM5I5aElG3evPbQ0M= -github.com/opiproject/opi-api v0.0.0-20230728150746-cc0946b7cec4 h1:wOsrhHoOo5h1S7BwcPoQsWPPb0ILV6QNX8Fc53GqQ/o= -github.com/opiproject/opi-api v0.0.0-20230728150746-cc0946b7cec4/go.mod h1:92pv4ulvvPMuxCJ9ND3aYbmBfEMLx0VCjpkiR7ZTqPY= +github.com/opiproject/opi-api v0.0.0-20230802143709-76c2f23d70d5 h1:L0TDC4GEqKUpoiZAqEezI/Cha5sstiXg4ZNqLgYUPn0= +github.com/opiproject/opi-api v0.0.0-20230802143709-76c2f23d70d5/go.mod h1:92pv4ulvvPMuxCJ9ND3aYbmBfEMLx0VCjpkiR7ZTqPY= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM= @@ -64,8 +62,8 @@ golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v golang.org/x/net v0.0.0-20210316092652-d523dce5a7f4/go.mod h1:RBQZq4jEuRlivfhVLdyRGr576XBO4/greRjx4P4O3yc= golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= -golang.org/x/net v0.12.0 h1:cfawfvKITfUsFCeJIHJrbSxpeu/E81khclypR0GVT50= -golang.org/x/net v0.12.0/go.mod h1:zEVYFnQC7m/vmpQFELhcD1EWkZlX69l4oqgmer6hfKA= +golang.org/x/net v0.13.0 h1:Nvo8UFsZ8X3BhAC9699Z1j7XQ3rsZnUUm7jfBEk1ueY= +golang.org/x/net v0.13.0/go.mod h1:zEVYFnQC7m/vmpQFELhcD1EWkZlX69l4oqgmer6hfKA= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= @@ -100,14 +98,12 @@ golang.org/x/tools v0.9.3 h1:Gn1I8+64MsuTb/HpH+LmQtNas23LhUVr3rYZ0eKuaMM= golang.org/x/tools v0.9.3/go.mod h1:owI94Op576fPu3cIGQeHs3joujW/2Oc6MtlxbF5dfNc= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -google.golang.org/genproto v0.0.0-20230726155614-23370e0ffb3e h1:xIXmWJ303kJCuogpj0bHq+dcjcZHU+XFyc1I0Yl9cRg= -google.golang.org/genproto v0.0.0-20230726155614-23370e0ffb3e/go.mod h1:0ggbjUrZYpy1q+ANUS30SEoGZ53cdfwtbuG7Ptgy108= -google.golang.org/genproto/googleapis/api v0.0.0-20230726155614-23370e0ffb3e h1:z3vDksarJxsAKM5dmEGv0GHwE2hKJ096wZra71Vs4sw= -google.golang.org/genproto/googleapis/api v0.0.0-20230726155614-23370e0ffb3e/go.mod h1:rsr7RhLuwsDKL7RmgDDCUc6yaGr1iqceVb5Wv6f6YvQ= -google.golang.org/genproto/googleapis/rpc v0.0.0-20230726155614-23370e0ffb3e h1:S83+ibolgyZ0bqz7KEsUOPErxcv4VzlszxY+31OfB/E= -google.golang.org/genproto/googleapis/rpc v0.0.0-20230726155614-23370e0ffb3e/go.mod h1:TUfxEVdsvPg18p6AslUXFoLdpED4oBnGwyqk3dV1XzM= -google.golang.org/grpc v1.56.2 h1:fVRFRnXvU+x6C4IlHZewvJOVHoOv1TUuQyoRsYnB4bI= -google.golang.org/grpc v1.56.2/go.mod h1:I9bI3vqKfayGqPUAwGdOSu7kt6oIJLixfffKrpXqQ9s= +google.golang.org/genproto v0.0.0-20230731193218-e0aa005b6bdf h1:v5Cf4E9+6tawYrs/grq1q1hFpGtzlGFzgWHqwt6NFiU= +google.golang.org/genproto v0.0.0-20230731193218-e0aa005b6bdf/go.mod h1:oH/ZOT02u4kWEp7oYBGYFFkCdKS/uYR9Z7+0/xuuFp8= +google.golang.org/genproto/googleapis/api v0.0.0-20230731193218-e0aa005b6bdf h1:xkVZ5FdZJF4U82Q/JS+DcZA83s/GRVL+QrFMlexk9Yo= +google.golang.org/genproto/googleapis/api v0.0.0-20230731193218-e0aa005b6bdf/go.mod h1:5DZzOUPCLYL3mNkQ0ms0F3EuUNZ7py1Bqeq6sxzI7/Q= +google.golang.org/genproto/googleapis/rpc v0.0.0-20230731193218-e0aa005b6bdf h1:guOdSPaeFgN+jEJwTo1dQ71hdBm+yKSCCKuTRkJzcVo= +google.golang.org/genproto/googleapis/rpc v0.0.0-20230731193218-e0aa005b6bdf/go.mod h1:zBEcrKX2ZOcEkHWxBPAIvYUWOKKMIhYcmNiUIu2ji3I= google.golang.org/grpc v1.57.0 h1:kfzNeI/klCGD2YPMUlaGNT3pxvYfga7smW3Vth8Zsiw= google.golang.org/grpc v1.57.0/go.mod h1:Sd+9RMTACXwmub0zcNY2c4arhtrbBYD1AUHI/dt16Mo= google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= diff --git a/storage/backend.go b/storage/backend.go index 62065485..c2bac1e6 100644 --- a/storage/backend.go +++ b/storage/backend.go @@ -14,7 +14,6 @@ import ( "time" "github.com/google/uuid" - pc "github.com/opiproject/opi-api/common/v1/gen/go" pb "github.com/opiproject/opi-api/storage/v1alpha1/gen/go" "google.golang.org/grpc" @@ -78,7 +77,7 @@ func executeNvmeRemoteController(ctx context.Context, c4 pb.NvmeRemoteController } log.Printf("Created Nvme controller: %v", rr0) // continue - rr2, err := c4.NvmeRemoteControllerReset(ctx, &pb.NvmeRemoteControllerResetRequest{Name: rr0.Name}) + rr2, err := c4.ResetNvmeRemoteController(ctx, &pb.ResetNvmeRemoteControllerRequest{Name: rr0.Name}) if err != nil { return err } @@ -93,7 +92,7 @@ func executeNvmeRemoteController(ctx context.Context, c4 pb.NvmeRemoteController return err } log.Printf("Got Nvme: %v", rr4) - rr5, err := c4.NvmeRemoteControllerStats(ctx, &pb.NvmeRemoteControllerStatsRequest{Name: rr0.Name}) + rr5, err := c4.StatsNvmeRemoteController(ctx, &pb.StatsNvmeRemoteControllerRequest{Name: rr0.Name}) if err != nil { return err } @@ -188,7 +187,7 @@ func executeNvmePath(ctx context.Context, c5 pb.NvmeRemoteControllerServiceClien return err } log.Printf("Got Nvme path: %s", np5.Name) - np6, err := c5.NvmePathStats(ctx, &pb.NvmePathStatsRequest{Name: np0.Name}) + np6, err := c5.StatsNvmePath(ctx, &pb.StatsNvmePathRequest{Name: np0.Name}) if err != nil { return err } @@ -259,7 +258,7 @@ func executeNullVolume(ctx context.Context, c1 pb.NullVolumeServiceClient) error return err } log.Printf("Got Null: %s", rs5.Name) - rs6, err := c1.NullVolumeStats(ctx, &pb.NullVolumeStatsRequest{Handle: &pc.ObjectKey{Value: rs1.Name}}) + rs6, err := c1.StatsNullVolume(ctx, &pb.StatsNullVolumeRequest{Name: rs1.Name}) if err != nil { return err } @@ -318,7 +317,7 @@ func executeAioVolume(ctx context.Context, c2 pb.AioVolumeServiceClient) error { return err } log.Printf("Got Aio: %s", ra5.Name) - ra6, err := c2.AioVolumeStats(ctx, &pb.AioVolumeStatsRequest{Handle: &pc.ObjectKey{Value: ra1.Name}}) + ra6, err := c2.StatsAioVolume(ctx, &pb.StatsAioVolumeRequest{Name: ra1.Name}) if err != nil { return err } diff --git a/storage/frontend.go b/storage/frontend.go index 603d8852..edbdc38b 100644 --- a/storage/frontend.go +++ b/storage/frontend.go @@ -92,7 +92,7 @@ func executeVirtioScsiLun(ctx context.Context, c6 pb.FrontendVirtioScsiServiceCl return err } log.Printf("Got VirtioScsiLun: %v", rl5.VolumeId.Value) - rl6, err := c6.VirtioScsiLunStats(ctx, &pb.VirtioScsiLunStatsRequest{ControllerId: &pbc.ObjectKey{Value: rl1.Name}}) + rl6, err := c6.StatsVirtioScsiLun(ctx, &pb.StatsVirtioScsiLunRequest{Name: rl1.Name}) if err != nil { return err } @@ -152,7 +152,7 @@ func executeVirtioScsiController(ctx context.Context, c5 pb.FrontendVirtioScsiSe return err } log.Printf("Got VirtioScsiController: %s", rss5.Name) - rss6, err := c5.VirtioScsiControllerStats(ctx, &pb.VirtioScsiControllerStatsRequest{ControllerId: &pbc.ObjectKey{Value: rss1.Name}}) + rss6, err := c5.StatsVirtioScsiController(ctx, &pb.StatsVirtioScsiControllerRequest{Name: rss1.Name}) if err != nil { return err } @@ -173,7 +173,7 @@ func executeVirtioBlk(ctx context.Context, c4 pb.FrontendVirtioBlkServiceClient) // testing with and without {resource}_id field for _, resourceID := range []string{"opi-virtio-blk8", ""} { - rv1, err := c4.CreateVirtioBlk(ctx, &pb.CreateVirtioBlkRequest{VirtioBlkId: resourceID, VirtioBlk: &pb.VirtioBlk{Name: "", VolumeId: &pbc.ObjectKey{Value: "Malloc1"}}}) + rv1, err := c4.CreateVirtioBlk(ctx, &pb.CreateVirtioBlkRequest{VirtioBlkId: resourceID, VirtioBlk: &pb.VirtioBlk{Name: "", VolumeNameRef: "Malloc1"}}) if err != nil { return err } @@ -209,7 +209,7 @@ func executeVirtioBlk(ctx context.Context, c4 pb.FrontendVirtioBlkServiceClient) return err } log.Printf("Got VirtioBlk: %v", rv5.Name) - rv6, err := c4.VirtioBlkStats(ctx, &pb.VirtioBlkStatsRequest{ControllerId: &pbc.ObjectKey{Value: rv1.Name}}) + rv6, err := c4.StatsVirtioBlk(ctx, &pb.StatsVirtioBlkRequest{Name: rv1.Name}) if err != nil { // VirtioBlkStats is not implemented, so no error here log.Printf("could not stats VirtioBlk: %v", err) @@ -327,7 +327,7 @@ func executeNvmeNamespace(ctx context.Context, c2 pb.FrontendNvmeServiceClient) return err } log.Printf("Got NvmeNamespace: %v", rn5.Name) - rn6, err := c2.NvmeNamespaceStats(ctx, &pb.NvmeNamespaceStatsRequest{Name: rn1.Name}) + rn6, err := c2.StatsNvmeNamespace(ctx, &pb.StatsNvmeNamespaceRequest{Name: rn1.Name}) if err != nil { return err } @@ -438,7 +438,7 @@ func executeNvmeController(ctx context.Context, c2 pb.FrontendNvmeServiceClient) } log.Printf("Got NvmeController: %s", rc5.Name) - rc6, err := c2.NvmeControllerStats(ctx, &pb.NvmeControllerStatsRequest{Name: rc1.Name}) + rc6, err := c2.StatsNvmeController(ctx, &pb.StatsNvmeControllerRequest{Name: rc1.Name}) if err != nil { return err } @@ -513,8 +513,7 @@ func executeNvmeSubsystem(ctx context.Context, c1 pb.FrontendNvmeServiceClient) return err } log.Printf("Got UpdateNvmeSubsystem: %s", rs5.Spec.Nqn) - rs6, err := c1.NvmeSubsystemStats(ctx, &pb.NvmeSubsystemStatsRequest{ - SubsystemNameRef: rs1.Name}) + rs6, err := c1.StatsNvmeSubsystem(ctx, &pb.StatsNvmeSubsystemRequest{Name: rs1.Name}) if err != nil { return err } diff --git a/storage/middleend.go b/storage/middleend.go index 1de7d014..22db25f5 100644 --- a/storage/middleend.go +++ b/storage/middleend.go @@ -43,9 +43,9 @@ func executeEncryptedVolume(ctx context.Context, c1 pb.MiddleendEncryptionServic rs1, err := c1.CreateEncryptedVolume(ctx, &pb.CreateEncryptedVolumeRequest{ EncryptedVolumeId: resourceID, EncryptedVolume: &pb.EncryptedVolume{ - VolumeId: &pc.ObjectKey{Value: "Malloc1"}, - Key: []byte("0123456789abcdef0123456789abcdee"), - Cipher: pb.EncryptionType_ENCRYPTION_TYPE_AES_XTS_128, + VolumeNameRef: "Malloc1", + Key: []byte("0123456789abcdef0123456789abcdee"), + Cipher: pb.EncryptionType_ENCRYPTION_TYPE_AES_XTS_128, }, }) if err != nil { @@ -68,10 +68,10 @@ func executeEncryptedVolume(ctx context.Context, c1 pb.MiddleendEncryptionServic rs3, err := c1.UpdateEncryptedVolume(ctx, &pb.UpdateEncryptedVolumeRequest{ UpdateMask: &fieldmaskpb.FieldMask{Paths: []string{"*"}}, EncryptedVolume: &pb.EncryptedVolume{ - Name: rs1.Name, - VolumeId: &pc.ObjectKey{Value: "Malloc1"}, - Key: []byte("0123456789abcdef0123456789abcdff"), - Cipher: pb.EncryptionType_ENCRYPTION_TYPE_AES_XTS_128, + Name: rs1.Name, + VolumeNameRef: "Malloc1", + Key: []byte("0123456789abcdef0123456789abcdff"), + Cipher: pb.EncryptionType_ENCRYPTION_TYPE_AES_XTS_128, }, }) if err != nil { @@ -88,7 +88,7 @@ func executeEncryptedVolume(ctx context.Context, c1 pb.MiddleendEncryptionServic return err } log.Printf("Got EncryptedVolume: %s", rs5.Name) - rs6, err := c1.EncryptedVolumeStats(ctx, &pb.EncryptedVolumeStatsRequest{EncryptedVolumeId: &pc.ObjectKey{Value: rs1.Name}}) + rs6, err := c1.StatsEncryptedVolume(ctx, &pb.StatsEncryptedVolumeRequest{Name: rs1.Name}) if err != nil { return err } @@ -159,7 +159,7 @@ func executeQosVolume(ctx context.Context, c2 pb.MiddleendQosVolumeServiceClient return err } log.Printf("Got QosVolume: %v", rs5.Name) - rs6, err := c2.QosVolumeStats(ctx, &pb.QosVolumeStatsRequest{VolumeId: &pc.ObjectKey{Value: rs1.Name}}) + rs6, err := c2.StatsQosVolume(ctx, &pb.StatsQosVolumeRequest{Name: rs1.Name}) if err != nil { return err } diff --git a/testing/mock-server/server/server.go b/testing/mock-server/server/server.go index 71ab3462..a9759db0 100644 --- a/testing/mock-server/server/server.go +++ b/testing/mock-server/server/server.go @@ -54,8 +54,8 @@ func (s *GoopCSI) GetNullVolume(_ context2.Context, _ *pb.GetNullVolumeRequest) panic("implement me") } -// NullVolumeStats gets mock NullVolumeStats -func (s *GoopCSI) NullVolumeStats(_ context2.Context, _ *pb.NullVolumeStatsRequest) (*pb.NullVolumeStatsResponse, error) { +// StatsNullVolume gets mock StatsNullVolume +func (s *GoopCSI) StatsNullVolume(_ context2.Context, _ *pb.StatsNullVolumeRequest) (*pb.StatsNullVolumeResponse, error) { // TODO implement me panic("implement me") } @@ -100,8 +100,8 @@ func (s *GoopCSI) NvmeRemoteControllerReset(_ context2.Context, _ *pb.NvmeRemote panic("implement me") } -// NvmeRemoteControllerStats gets mock stats -func (s *GoopCSI) NvmeRemoteControllerStats(_ context2.Context, _ *pb.NvmeRemoteControllerStatsRequest) (*pb.NvmeRemoteControllerStatsResponse, error) { +// StatsNvmeRemoteController gets mock stats +func (s *GoopCSI) StatsNvmeRemoteController(_ context2.Context, _ *pb.StatsNvmeRemoteControllerRequest) (*pb.StatsNvmeRemoteControllerResponse, error) { // TODO implement me panic("implement me") } @@ -144,8 +144,8 @@ func (s *GoopCSI) GetNvmePath(_ context2.Context, _ *pb.GetNvmePathRequest) (*pb panic("implement me") } -// NvmePathStats gets mock stats -func (s *GoopCSI) NvmePathStats(_ context2.Context, _ *pb.NvmePathStatsRequest) (*pb.NvmePathStatsResponse, error) { +// StatsNvmePath gets mock stats +func (s *GoopCSI) StatsNvmePath(_ context2.Context, _ *pb.StatsNvmePathRequest) (*pb.StatsNvmePathResponse, error) { // TODO implement me panic("implement me") } @@ -182,8 +182,8 @@ func (s *GoopCSI) GetNvmeSubsystem(_ context.Context, request *pb.GetNvmeSubsyst return out, err } -// NvmeSubsystemStats gets mock subsystem stats -func (s *GoopCSI) NvmeSubsystemStats(_ context.Context, _ *pb.NvmeSubsystemStatsRequest) (*pb.NvmeSubsystemStatsResponse, error) { +// StatsNvmeSubsystem gets mock subsystem stats +func (s *GoopCSI) StatsNvmeSubsystem(_ context.Context, _ *pb.StatsNvmeSubsystemRequest) (*pb.StatsNvmeSubsystemResponse, error) { // TODO implement me panic("implement me") } @@ -219,8 +219,8 @@ func (s *GoopCSI) GetNvmeController(_ context.Context, request *pb.GetNvmeContro return out, err } -// NvmeControllerStats gets mock stats -func (s *GoopCSI) NvmeControllerStats(_ context.Context, _ *pb.NvmeControllerStatsRequest) (*pb.NvmeControllerStatsResponse, error) { +// StatsNvmeController gets mock stats +func (s *GoopCSI) StatsNvmeController(_ context.Context, _ *pb.StatsNvmeControllerRequest) (*pb.StatsNvmeControllerResponse, error) { // TODO implement me panic("implement me") } @@ -257,8 +257,8 @@ func (s *GoopCSI) GetNvmeNamespace(_ context.Context, _ *pb.GetNvmeNamespaceRequ panic("implement me") } -// NvmeNamespaceStats gets mock namespace stats -func (s *GoopCSI) NvmeNamespaceStats(_ context.Context, _ *pb.NvmeNamespaceStatsRequest) (*pb.NvmeNamespaceStatsResponse, error) { +// StatsNvmeNamespace gets mock namespace stats +func (s *GoopCSI) StatsNvmeNamespace(_ context.Context, _ *pb.StatsNvmeNamespaceRequest) (*pb.StatsNvmeNamespaceResponse, error) { // TODO implement me panic("implement me") }