@@ -949,42 +949,42 @@ func TestMiddleEnd_GetQosVolume(t *testing.T) {
949
949
950
950
func TestMiddleEnd_StatsQosVolume (t * testing.T ) {
951
951
tests := map [string ]struct {
952
- in * _go. ObjectKey
952
+ in string
953
953
out * pb.StatsQosVolumeResponse
954
954
spdk []string
955
955
errCode codes.Code
956
956
errMsg string
957
957
}{
958
- "empty QoS volume id is not allowed " : {
959
- in : & _go. ObjectKey { Value : "" } ,
958
+ "empty QoS volume name is not allowed " : {
959
+ in : "" ,
960
960
out : nil ,
961
961
spdk : []string {},
962
962
errCode : codes .Unknown ,
963
963
errMsg : "missing required field: name" ,
964
964
},
965
965
"unknown QoS volume Id" : {
966
- in : & _go. ObjectKey { Value : "unknown-qos-volume-id" } ,
966
+ in : "unknown-qos-volume-id" ,
967
967
out : nil ,
968
968
spdk : []string {},
969
969
errCode : codes .NotFound ,
970
970
errMsg : fmt .Sprintf ("unable to find key %s" , "unknown-qos-volume-id" ),
971
971
},
972
972
"SPDK call failed" : {
973
- in : & _go. ObjectKey { Value : testQosVolumeName } ,
973
+ in : testQosVolumeName ,
974
974
out : nil ,
975
975
spdk : []string {`{"id":%d,"error":{"code":1,"message":"some internal error"}}` },
976
976
errCode : status .Convert (spdk .ErrFailedSpdkCall ).Code (),
977
977
errMsg : status .Convert (spdk .ErrFailedSpdkCall ).Message (),
978
978
},
979
979
"SPDK call result false" : {
980
- in : & _go. ObjectKey { Value : testQosVolumeName } ,
980
+ in : testQosVolumeName ,
981
981
out : nil ,
982
982
spdk : []string {`{"id":%d,"error":{"code":0,"message":""},"result":{"tick_rate": 3300000000,"ticks": 5,"bdevs":[]}}` },
983
983
errCode : status .Convert (spdk .ErrUnexpectedSpdkCallResult ).Code (),
984
984
errMsg : status .Convert (spdk .ErrUnexpectedSpdkCallResult ).Message (),
985
985
},
986
986
"successful QoS volume stats" : {
987
- in : & _go. ObjectKey { Value : testQosVolumeName } ,
987
+ in : testQosVolumeName ,
988
988
out : & pb.StatsQosVolumeResponse {
989
989
Stats : & pb.VolumeStats {
990
990
ReadBytesCount : 36864 ,
@@ -998,7 +998,7 @@ func TestMiddleEnd_StatsQosVolume(t *testing.T) {
998
998
errMsg : "" ,
999
999
},
1000
1000
"malformed name" : {
1001
- in : & _go. ObjectKey { Value : "-ABC-DEF" } ,
1001
+ in : "-ABC-DEF" ,
1002
1002
out : nil ,
1003
1003
spdk : []string {},
1004
1004
errCode : codes .Unknown ,
@@ -1012,7 +1012,7 @@ func TestMiddleEnd_StatsQosVolume(t *testing.T) {
1012
1012
1013
1013
testEnv .opiSpdkServer .volumes .qosVolumes [testQosVolumeName ] = testQosVolume
1014
1014
1015
- request := & pb.StatsQosVolumeRequest {Name : tt .in . Value }
1015
+ request := & pb.StatsQosVolumeRequest {Name : tt .in }
1016
1016
response , err := testEnv .client .StatsQosVolume (testEnv .ctx , request )
1017
1017
1018
1018
if ! proto .Equal (tt .out , response ) {
0 commit comments