Skip to content

Commit

Permalink
refactor(storage): latest API changes
Browse files Browse the repository at this point in the history 
ObjectStats -> StatsObject
VolumeId -> VolumeNameRef
remove pc.ObjectKey

Signed-off-by: Boris Glimcher <[email protected]>
  • Loading branch information
@glimchb
glimchb committed Aug 2, 2023
1 parent 8ac6510 commit a9073b0
Show file tree
Hide file tree
Showing 6 changed files with 48 additions and 54 deletions.
10 changes: 5 additions & 5 deletions go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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
)
24 changes: 10 additions & 14 deletions go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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=
Expand Down Expand Up @@ -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=
Expand Down Expand Up @@ -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=
Expand Down
11 changes: 5 additions & 6 deletions storage/backend.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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
}
Expand All @@ -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
}
Expand Down Expand Up @@ -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
}
Expand Down Expand Up @@ -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
}
Expand Down Expand Up @@ -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
}
Expand Down
15 changes: 7 additions & 8 deletions storage/frontend.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
Expand Down Expand Up @@ -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
}
Expand All @@ -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
}
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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
}
Expand Down Expand Up @@ -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
}
Expand Down Expand Up @@ -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
}
Expand Down
18 changes: 9 additions & 9 deletions storage/middleend.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand All @@ -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 {
Expand All @@ -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
}
Expand Down Expand Up @@ -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
}
Expand Down
24 changes: 12 additions & 12 deletions testing/mock-server/server/server.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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")
}
Expand Down Expand Up @@ -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")
}
Expand Down Expand Up @@ -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")
}
Expand Down Expand Up @@ -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")
}
Expand Down Expand Up @@ -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")
}
Expand Down Expand Up @@ -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")
}
Expand Down

0 comments on commit a9073b0

Please sign in to comment.