@@ -69,7 +69,7 @@ func TestStreamClient(t *testing.T) {
69
69
70
70
streamServers , err := c .GetStreamServers (streamUpstream )
71
71
if err != nil {
72
- t .Errorf ("Error getting stream servers: %w " , err )
72
+ t .Errorf ("Error getting stream servers: %v " , err )
73
73
}
74
74
if len (streamServers ) != 0 {
75
75
t .Errorf ("Expected 0 servers, got %v" , streamServers )
@@ -275,7 +275,7 @@ func TestStreamUpstreamServer(t *testing.T) {
275
275
}
276
276
err = c .AddStreamServer (streamUpstream , streamServer )
277
277
if err != nil {
278
- t .Errorf ("Error adding upstream server: %w " , err )
278
+ t .Errorf ("Error adding upstream server: %v " , err )
279
279
}
280
280
servers , err := c .GetStreamServers (streamUpstream )
281
281
if err != nil {
@@ -294,7 +294,7 @@ func TestStreamUpstreamServer(t *testing.T) {
294
294
// remove stream upstream servers
295
295
_ , _ , _ , err = c .UpdateStreamServers (streamUpstream , []client.StreamUpstreamServer {})
296
296
if err != nil {
297
- t .Errorf ("Couldn't remove servers: %w " , err )
297
+ t .Errorf ("Couldn't remove servers: %v " , err )
298
298
}
299
299
}
300
300
@@ -551,7 +551,7 @@ func TestUpstreamServer(t *testing.T) {
551
551
}
552
552
err = c .AddHTTPServer (upstream , server )
553
553
if err != nil {
554
- t .Errorf ("Error adding upstream server: %w " , err )
554
+ t .Errorf ("Error adding upstream server: %v " , err )
555
555
}
556
556
servers , err := c .GetHTTPServers (upstream )
557
557
if err != nil {
@@ -570,7 +570,7 @@ func TestUpstreamServer(t *testing.T) {
570
570
// remove upstream servers
571
571
_ , _ , _ , err = c .UpdateHTTPServers (upstream , []client.UpstreamServer {})
572
572
if err != nil {
573
- t .Errorf ("Couldn't remove servers: %w " , err )
573
+ t .Errorf ("Couldn't remove servers: %v " , err )
574
574
}
575
575
}
576
576
@@ -586,12 +586,12 @@ func TestStats(t *testing.T) {
586
586
}
587
587
err = c .AddHTTPServer (upstream , server )
588
588
if err != nil {
589
- t .Errorf ("Error adding upstream server: %w " , err )
589
+ t .Errorf ("Error adding upstream server: %v " , err )
590
590
}
591
591
592
592
stats , err := c .GetStats ()
593
593
if err != nil {
594
- t .Errorf ("Error getting stats: %w " , err )
594
+ t .Errorf ("Error getting stats: %v " , err )
595
595
}
596
596
597
597
// NginxInfo
@@ -689,7 +689,7 @@ func TestStats(t *testing.T) {
689
689
// cleanup upstream servers
690
690
_ , _ , _ , err = c .UpdateHTTPServers (upstream , []client.UpstreamServer {})
691
691
if err != nil {
692
- t .Errorf ("Couldn't remove servers: %w " , err )
692
+ t .Errorf ("Couldn't remove servers: %v " , err )
693
693
}
694
694
}
695
695
@@ -720,7 +720,7 @@ func TestUpstreamServerDefaultParameters(t *testing.T) {
720
720
}
721
721
err = c .AddHTTPServer (upstream , server )
722
722
if err != nil {
723
- t .Errorf ("Error adding upstream server: %w " , err )
723
+ t .Errorf ("Error adding upstream server: %v " , err )
724
724
}
725
725
servers , err := c .GetHTTPServers (upstream )
726
726
if err != nil {
@@ -739,7 +739,7 @@ func TestUpstreamServerDefaultParameters(t *testing.T) {
739
739
// remove upstream servers
740
740
_ , _ , _ , err = c .UpdateHTTPServers (upstream , []client.UpstreamServer {})
741
741
if err != nil {
742
- t .Errorf ("Couldn't remove servers: %w " , err )
742
+ t .Errorf ("Couldn't remove servers: %v " , err )
743
743
}
744
744
}
745
745
@@ -755,21 +755,21 @@ func TestStreamStats(t *testing.T) {
755
755
}
756
756
err = c .AddStreamServer (streamUpstream , server )
757
757
if err != nil {
758
- t .Errorf ("Error adding stream upstream server: %w " , err )
758
+ t .Errorf ("Error adding stream upstream server: %v " , err )
759
759
}
760
760
761
761
// make connection so we have stream server zone stats - ignore response
762
762
_ , err = net .Dial ("tcp" , helpers .GetStreamAddress ())
763
763
if err != nil {
764
- t .Errorf ("Error making tcp connection: %w " , err )
764
+ t .Errorf ("Error making tcp connection: %v " , err )
765
765
}
766
766
767
767
// wait for health checks
768
768
time .Sleep (50 * time .Millisecond )
769
769
770
770
stats , err := c .GetStats ()
771
771
if err != nil {
772
- t .Errorf ("Error getting stats: %w " , err )
772
+ t .Errorf ("Error getting stats: %v " , err )
773
773
}
774
774
775
775
if stats .Connections .Active == 0 {
@@ -809,7 +809,7 @@ func TestStreamStats(t *testing.T) {
809
809
// cleanup stream upstream servers
810
810
_ , _ , _ , err = c .UpdateStreamServers (streamUpstream , []client.StreamUpstreamServer {})
811
811
if err != nil {
812
- t .Errorf ("Couldn't remove stream servers: %w " , err )
812
+ t .Errorf ("Couldn't remove stream servers: %v " , err )
813
813
}
814
814
}
815
815
@@ -838,7 +838,7 @@ func TestStreamUpstreamServerDefaultParameters(t *testing.T) {
838
838
}
839
839
err = c .AddStreamServer (streamUpstream , streamServer )
840
840
if err != nil {
841
- t .Errorf ("Error adding upstream server: %w " , err )
841
+ t .Errorf ("Error adding upstream server: %v " , err )
842
842
}
843
843
streamServers , err := c .GetStreamServers (streamUpstream )
844
844
if err != nil {
@@ -857,7 +857,7 @@ func TestStreamUpstreamServerDefaultParameters(t *testing.T) {
857
857
// cleanup stream upstream servers
858
858
_ , _ , _ , err = c .UpdateStreamServers (streamUpstream , []client.StreamUpstreamServer {})
859
859
if err != nil {
860
- t .Errorf ("Couldn't remove stream servers: %w " , err )
860
+ t .Errorf ("Couldn't remove stream servers: %v " , err )
861
861
}
862
862
}
863
863
@@ -871,7 +871,7 @@ func TestKeyValue(t *testing.T) {
871
871
872
872
err = c .AddKeyValPair (zoneName , "key1" , "val1" )
873
873
if err != nil {
874
- t .Errorf ("Couldn't set keyvals: %w " , err )
874
+ t .Errorf ("Couldn't set keyvals: %v " , err )
875
875
}
876
876
877
877
var keyValPairs client.KeyValPairs
@@ -888,7 +888,7 @@ func TestKeyValue(t *testing.T) {
888
888
889
889
keyValuPairsByZone , err := c .GetAllKeyValPairs ()
890
890
if err != nil {
891
- t .Errorf ("Couldn't get keyvals, %w " , err )
891
+ t .Errorf ("Couldn't get keyvals, %v " , err )
892
892
}
893
893
expectedKeyValPairsByZone := client.KeyValPairsByZone {
894
894
zoneName : expectedKeyValPairs ,
@@ -901,12 +901,12 @@ func TestKeyValue(t *testing.T) {
901
901
expectedKeyValPairs ["key1" ] = "valModified1"
902
902
err = c .ModifyKeyValPair (zoneName , "key1" , "valModified1" )
903
903
if err != nil {
904
- t .Errorf ("couldn't set keyval: %w " , err )
904
+ t .Errorf ("couldn't set keyval: %v " , err )
905
905
}
906
906
907
907
keyValPairs , err = c .GetKeyValPairs (zoneName )
908
908
if err != nil {
909
- t .Errorf ("couldn't get keyval: %w " , err )
909
+ t .Errorf ("couldn't get keyval: %v " , err )
910
910
}
911
911
if ! reflect .DeepEqual (expectedKeyValPairs , keyValPairs ) {
912
912
t .Errorf ("maps are not equal. expected: %+v, got: %+v" , expectedKeyValPairs , keyValPairs )
@@ -920,7 +920,7 @@ func TestKeyValue(t *testing.T) {
920
920
921
921
err = c .AddKeyValPair (zoneName , "key2" , "val2" )
922
922
if err != nil {
923
- t .Errorf ("error adding another key/val pair: %w " , err )
923
+ t .Errorf ("error adding another key/val pair: %v " , err )
924
924
}
925
925
926
926
err = c .DeleteKeyValuePair (zoneName , "key1" )
@@ -933,20 +933,20 @@ func TestKeyValue(t *testing.T) {
933
933
}
934
934
keyValPairs , err = c .GetKeyValPairs (zoneName )
935
935
if err != nil {
936
- t .Errorf ("couldn't get keyval: %w " , err )
936
+ t .Errorf ("couldn't get keyval: %v " , err )
937
937
}
938
938
if ! reflect .DeepEqual (keyValPairs , expectedKeyValPairs2 ) {
939
939
t .Errorf ("didn't delete key1 %+v" , keyValPairs )
940
940
}
941
941
942
942
err = c .DeleteKeyValPairs (zoneName )
943
943
if err != nil {
944
- t .Errorf ("couldn't delete all: %w " , err )
944
+ t .Errorf ("couldn't delete all: %v " , err )
945
945
}
946
946
947
947
keyValPairs , err = c .GetKeyValPairs (zoneName )
948
948
if err != nil {
949
- t .Errorf ("couldn't get keyval: %w " , err )
949
+ t .Errorf ("couldn't get keyval: %v " , err )
950
950
}
951
951
if len (keyValPairs ) > 0 {
952
952
t .Errorf ("zone should be empty after bulk delete" )
@@ -969,7 +969,7 @@ func TestKeyValueStream(t *testing.T) {
969
969
970
970
err = c .AddStreamKeyValPair (zoneName , "key1" , "val1" )
971
971
if err != nil {
972
- t .Errorf ("Couldn't set keyvals: %w " , err )
972
+ t .Errorf ("Couldn't set keyvals: %v " , err )
973
973
}
974
974
975
975
keyValPairs , err := c .GetStreamKeyValPairs (zoneName )
@@ -985,7 +985,7 @@ func TestKeyValueStream(t *testing.T) {
985
985
986
986
keyValPairsByZone , err := c .GetAllStreamKeyValPairs ()
987
987
if err != nil {
988
- t .Errorf ("Couldn't get keyvals, %w " , err )
988
+ t .Errorf ("Couldn't get keyvals, %v " , err )
989
989
}
990
990
expectedKeyValuePairsByZone := client.KeyValPairsByZone {
991
991
zoneName : expectedKeyValPairs ,
@@ -999,12 +999,12 @@ func TestKeyValueStream(t *testing.T) {
999
999
expectedKeyValPairs ["key1" ] = "valModified1"
1000
1000
err = c .ModifyStreamKeyValPair (zoneName , "key1" , "valModified1" )
1001
1001
if err != nil {
1002
- t .Errorf ("couldn't set keyval: %w " , err )
1002
+ t .Errorf ("couldn't set keyval: %v " , err )
1003
1003
}
1004
1004
1005
1005
keyValPairs , err = c .GetStreamKeyValPairs (zoneName )
1006
1006
if err != nil {
1007
- t .Errorf ("couldn't get keyval: %w " , err )
1007
+ t .Errorf ("couldn't get keyval: %v " , err )
1008
1008
}
1009
1009
if ! reflect .DeepEqual (expectedKeyValPairs , keyValPairs ) {
1010
1010
t .Errorf ("maps are not equal. expected: %+v, got: %+v" , expectedKeyValPairs , keyValPairs )
@@ -1018,7 +1018,7 @@ func TestKeyValueStream(t *testing.T) {
1018
1018
1019
1019
err = c .AddStreamKeyValPair (zoneName , "key2" , "val2" )
1020
1020
if err != nil {
1021
- t .Errorf ("error adding another key/val pair: %w " , err )
1021
+ t .Errorf ("error adding another key/val pair: %v " , err )
1022
1022
}
1023
1023
1024
1024
err = c .DeleteStreamKeyValuePair (zoneName , "key1" )
@@ -1028,7 +1028,7 @@ func TestKeyValueStream(t *testing.T) {
1028
1028
1029
1029
keyValPairs , err = c .GetStreamKeyValPairs (zoneName )
1030
1030
if err != nil {
1031
- t .Errorf ("couldn't get keyval: %w " , err )
1031
+ t .Errorf ("couldn't get keyval: %v " , err )
1032
1032
}
1033
1033
expectedKeyValPairs2 := client.KeyValPairs {
1034
1034
"key2" : "val2" ,
@@ -1039,12 +1039,12 @@ func TestKeyValueStream(t *testing.T) {
1039
1039
1040
1040
err = c .DeleteStreamKeyValPairs (zoneName )
1041
1041
if err != nil {
1042
- t .Errorf ("couldn't delete all: %w " , err )
1042
+ t .Errorf ("couldn't delete all: %v " , err )
1043
1043
}
1044
1044
1045
1045
keyValPairs , err = c .GetStreamKeyValPairs (zoneName )
1046
1046
if err != nil {
1047
- t .Errorf ("couldn't get keyval: %w " , err )
1047
+ t .Errorf ("couldn't get keyval: %v " , err )
1048
1048
}
1049
1049
if len (keyValPairs ) > 0 {
1050
1050
t .Errorf ("zone should be empty after bulk delete" )
@@ -1070,15 +1070,15 @@ func TestStreamZoneSync(t *testing.T) {
1070
1070
1071
1071
err = c1 .AddStreamKeyValPair (streamZoneSync , "key1" , "val1" )
1072
1072
if err != nil {
1073
- t .Errorf ("Couldn't set keyvals: %w " , err )
1073
+ t .Errorf ("Couldn't set keyvals: %v " , err )
1074
1074
}
1075
1075
1076
1076
// wait for nodes to sync information of synced zones
1077
1077
time .Sleep (5 * time .Second )
1078
1078
1079
1079
statsC1 , err := c1 .GetStats ()
1080
1080
if err != nil {
1081
- t .Errorf ("Error getting stats: %w " , err )
1081
+ t .Errorf ("Error getting stats: %v " , err )
1082
1082
}
1083
1083
1084
1084
if statsC1 .StreamZoneSync == nil {
@@ -1118,7 +1118,7 @@ func TestStreamZoneSync(t *testing.T) {
1118
1118
1119
1119
statsC2 , err := c2 .GetStats ()
1120
1120
if err != nil {
1121
- t .Errorf ("Error getting stats: %w " , err )
1121
+ t .Errorf ("Error getting stats: %v " , err )
1122
1122
}
1123
1123
1124
1124
if statsC2 .StreamZoneSync == nil {
0 commit comments