@@ -777,6 +777,7 @@ func TestAutoDetectProtocolVersionOldServer1(t *testing.T) {
777777 defer srv .Close ()
778778 sender , err := qdb .NewLineSender (ctx , qdb .WithHttp (), qdb .WithAddress (srv .Addr ()))
779779 assert .Equal (t , qdb .ProtocolVersion (sender ), qdb .ProtocolVersion1 )
780+ assert .NoError (t , err )
780781}
781782
782783func TestAutoDetectProtocolVersionOldServer2 (t * testing.T ) {
@@ -787,6 +788,7 @@ func TestAutoDetectProtocolVersionOldServer2(t *testing.T) {
787788 defer srv .Close ()
788789 sender , err := qdb .NewLineSender (ctx , qdb .WithHttp (), qdb .WithAddress (srv .Addr ()))
789790 assert .Equal (t , qdb .ProtocolVersion (sender ), qdb .ProtocolVersion1 )
791+ assert .NoError (t , err )
790792}
791793
792794func TestAutoDetectProtocolVersionOldServer3 (t * testing.T ) {
@@ -797,6 +799,7 @@ func TestAutoDetectProtocolVersionOldServer3(t *testing.T) {
797799 defer srv .Close ()
798800 sender , err := qdb .NewLineSender (ctx , qdb .WithHttp (), qdb .WithAddress (srv .Addr ()))
799801 assert .Equal (t , qdb .ProtocolVersion (sender ), qdb .ProtocolVersion1 )
802+ assert .NoError (t , err )
800803}
801804
802805func TestAutoDetectProtocolVersionNewServer1 (t * testing.T ) {
@@ -807,6 +810,7 @@ func TestAutoDetectProtocolVersionNewServer1(t *testing.T) {
807810 defer srv .Close ()
808811 sender , err := qdb .NewLineSender (ctx , qdb .WithHttp (), qdb .WithAddress (srv .Addr ()))
809812 assert .Equal (t , qdb .ProtocolVersion (sender ), qdb .ProtocolVersion2 )
813+ assert .NoError (t , err )
810814}
811815
812816func TestAutoDetectProtocolVersionNewServer2 (t * testing.T ) {
@@ -817,6 +821,7 @@ func TestAutoDetectProtocolVersionNewServer2(t *testing.T) {
817821 defer srv .Close ()
818822 sender , err := qdb .NewLineSender (ctx , qdb .WithHttp (), qdb .WithAddress (srv .Addr ()))
819823 assert .Equal (t , qdb .ProtocolVersion (sender ), qdb .ProtocolVersion2 )
824+ assert .NoError (t , err )
820825}
821826
822827func TestAutoDetectProtocolVersionNewServer3 (t * testing.T ) {
@@ -827,6 +832,7 @@ func TestAutoDetectProtocolVersionNewServer3(t *testing.T) {
827832 defer srv .Close ()
828833 sender , err := qdb .NewLineSender (ctx , qdb .WithHttp (), qdb .WithAddress (srv .Addr ()))
829834 assert .Equal (t , qdb .ProtocolVersion (sender ), qdb .ProtocolVersion2 )
835+ assert .NoError (t , err )
830836}
831837
832838func TestAutoDetectProtocolVersionNewServer4 (t * testing.T ) {
@@ -857,6 +863,7 @@ func TestSpecifyProtocolVersion(t *testing.T) {
857863 defer srv .Close ()
858864 sender , err := qdb .NewLineSender (ctx , qdb .WithHttp (), qdb .WithAddress (srv .Addr ()), qdb .WithProtocolVersion (qdb .ProtocolVersion1 ))
859865 assert .Equal (t , qdb .ProtocolVersion (sender ), qdb .ProtocolVersion1 )
866+ assert .NoError (t , err )
860867}
861868
862869func TestArrayColumnUnsupportedInHttpProtocolV1 (t * testing.T ) {
0 commit comments