@@ -387,8 +387,7 @@ func TestPingRequestDefaultValues(t *testing.T) {
387
387
refEnc := msgpack .NewEncoder (& refBuf )
388
388
err := RefImplPingBody (refEnc )
389
389
if err != nil {
390
- t .Errorf ("An unexpected RefImplPingBody() error: %q" , err .Error ())
391
- return
390
+ t .Fatalf ("An unexpected RefImplPingBody() error: %q" , err .Error ())
392
391
}
393
392
394
393
req := NewPingRequest ()
@@ -402,8 +401,7 @@ func TestSelectRequestDefaultValues(t *testing.T) {
402
401
err := RefImplSelectBody (refEnc , & resolver , validSpace , defaultIndex , 0 , 0xFFFFFFFF ,
403
402
IterAll , []interface {}{}, nil , false )
404
403
if err != nil {
405
- t .Errorf ("An unexpected RefImplSelectBody() error %q" , err .Error ())
406
- return
404
+ t .Fatalf ("An unexpected RefImplSelectBody() error %q" , err .Error ())
407
405
}
408
406
409
407
req := NewSelectRequest (validSpace )
@@ -451,8 +449,7 @@ func TestSelectRequestDefaultIteratorEqIfKey(t *testing.T) {
451
449
err := RefImplSelectBody (refEnc , & resolver , validSpace , defaultIndex , 0 , 0xFFFFFFFF ,
452
450
IterEq , key , nil , false )
453
451
if err != nil {
454
- t .Errorf ("An unexpected RefImplSelectBody() error %q" , err .Error ())
455
- return
452
+ t .Fatalf ("An unexpected RefImplSelectBody() error %q" , err .Error ())
456
453
}
457
454
458
455
req := NewSelectRequest (validSpace ).
@@ -469,8 +466,7 @@ func TestSelectRequestIteratorNotChangedIfKey(t *testing.T) {
469
466
err := RefImplSelectBody (refEnc , & resolver , validSpace , defaultIndex , 0 , 0xFFFFFFFF ,
470
467
iter , key , nil , false )
471
468
if err != nil {
472
- t .Errorf ("An unexpected RefImplSelectBody() error %q" , err .Error ())
473
- return
469
+ t .Fatalf ("An unexpected RefImplSelectBody() error %q" , err .Error ())
474
470
}
475
471
476
472
req := NewSelectRequest (validSpace ).
@@ -492,16 +488,14 @@ func TestSelectRequestSetters(t *testing.T) {
492
488
err := RefImplSelectBody (refEncAfterBytes , & resolver , validSpace , validIndex , offset ,
493
489
limit , iter , key , afterBytes , true )
494
490
if err != nil {
495
- t .Errorf ("An unexpected RefImplSelectBody() error %s" , err )
496
- return
491
+ t .Fatalf ("An unexpected RefImplSelectBody() error %s" , err )
497
492
}
498
493
499
494
refEncAfterKey := msgpack .NewEncoder (& refBufAfterKey )
500
495
err = RefImplSelectBody (refEncAfterKey , & resolver , validSpace , validIndex , offset ,
501
496
limit , iter , key , afterKey , true )
502
497
if err != nil {
503
- t .Errorf ("An unexpected RefImplSelectBody() error %s" , err )
504
- return
498
+ t .Fatalf ("An unexpected RefImplSelectBody() error %s" , err )
505
499
}
506
500
507
501
reqAfterBytes := NewSelectRequest (validSpace ).
@@ -531,8 +525,7 @@ func TestInsertRequestDefaultValues(t *testing.T) {
531
525
refEnc := msgpack .NewEncoder (& refBuf )
532
526
err := RefImplInsertBody (refEnc , & resolver , validSpace , []interface {}{})
533
527
if err != nil {
534
- t .Errorf ("An unexpected RefImplInsertBody() error: %q" , err .Error ())
535
- return
528
+ t .Fatalf ("An unexpected RefImplInsertBody() error: %q" , err .Error ())
536
529
}
537
530
538
531
req := NewInsertRequest (validSpace )
@@ -561,8 +554,7 @@ func TestInsertRequestSetters(t *testing.T) {
561
554
refEnc := msgpack .NewEncoder (& refBuf )
562
555
err := RefImplInsertBody (refEnc , & resolver , validSpace , tuple )
563
556
if err != nil {
564
- t .Errorf ("An unexpected RefImplInsertBody() error: %q" , err .Error ())
565
- return
557
+ t .Fatalf ("An unexpected RefImplInsertBody() error: %q" , err .Error ())
566
558
}
567
559
568
560
req := NewInsertRequest (validSpace ).
@@ -576,8 +568,7 @@ func TestReplaceRequestDefaultValues(t *testing.T) {
576
568
refEnc := msgpack .NewEncoder (& refBuf )
577
569
err := RefImplReplaceBody (refEnc , & resolver , validSpace , []interface {}{})
578
570
if err != nil {
579
- t .Errorf ("An unexpected RefImplReplaceBody() error: %q" , err .Error ())
580
- return
571
+ t .Fatalf ("An unexpected RefImplReplaceBody() error: %q" , err .Error ())
581
572
}
582
573
583
574
req := NewReplaceRequest (validSpace )
@@ -592,8 +583,7 @@ func TestReplaceRequestSpaceByName(t *testing.T) {
592
583
refEnc := msgpack .NewEncoder (& refBuf )
593
584
err := RefImplReplaceBody (refEnc , & resolver , "valid" , []interface {}{})
594
585
if err != nil {
595
- t .Errorf ("An unexpected RefImplReplaceBody() error: %q" , err .Error ())
596
- return
586
+ t .Fatalf ("An unexpected RefImplReplaceBody() error: %q" , err .Error ())
597
587
}
598
588
599
589
req := NewReplaceRequest ("valid" )
@@ -607,8 +597,7 @@ func TestReplaceRequestSetters(t *testing.T) {
607
597
refEnc := msgpack .NewEncoder (& refBuf )
608
598
err := RefImplReplaceBody (refEnc , & resolver , validSpace , tuple )
609
599
if err != nil {
610
- t .Errorf ("An unexpected RefImplReplaceBody() error: %q" , err .Error ())
611
- return
600
+ t .Fatalf ("An unexpected RefImplReplaceBody() error: %q" , err .Error ())
612
601
}
613
602
614
603
req := NewReplaceRequest (validSpace ).
@@ -622,8 +611,7 @@ func TestDeleteRequestDefaultValues(t *testing.T) {
622
611
refEnc := msgpack .NewEncoder (& refBuf )
623
612
err := RefImplDeleteBody (refEnc , & resolver , validSpace , defaultIndex , []interface {}{})
624
613
if err != nil {
625
- t .Errorf ("An unexpected RefImplDeleteBody() error: %q" , err .Error ())
626
- return
614
+ t .Fatalf ("An unexpected RefImplDeleteBody() error: %q" , err .Error ())
627
615
}
628
616
629
617
req := NewDeleteRequest (validSpace )
@@ -668,8 +656,7 @@ func TestDeleteRequestSetters(t *testing.T) {
668
656
refEnc := msgpack .NewEncoder (& refBuf )
669
657
err := RefImplDeleteBody (refEnc , & resolver , validSpace , validIndex , key )
670
658
if err != nil {
671
- t .Errorf ("An unexpected RefImplDeleteBody() error: %q" , err .Error ())
672
- return
659
+ t .Fatalf ("An unexpected RefImplDeleteBody() error: %q" , err .Error ())
673
660
}
674
661
675
662
req := NewDeleteRequest (validSpace ).
@@ -685,8 +672,7 @@ func TestUpdateRequestDefaultValues(t *testing.T) {
685
672
err := RefImplUpdateBody (refEnc , & resolver , validSpace , defaultIndex ,
686
673
[]interface {}{}, []Op {})
687
674
if err != nil {
688
- t .Errorf ("An unexpected RefImplUpdateBody() error: %q" , err .Error ())
689
- return
675
+ t .Fatalf ("An unexpected RefImplUpdateBody() error: %q" , err .Error ())
690
676
}
691
677
692
678
req := NewUpdateRequest (validSpace )
@@ -734,8 +720,7 @@ func TestUpdateRequestSetters(t *testing.T) {
734
720
refEnc := msgpack .NewEncoder (& refBuf )
735
721
err := RefImplUpdateBody (refEnc , & resolver , validSpace , validIndex , key , refOps )
736
722
if err != nil {
737
- t .Errorf ("An unexpected RefImplUpdateBody() error: %q" , err .Error ())
738
- return
723
+ t .Fatalf ("An unexpected RefImplUpdateBody() error: %q" , err .Error ())
739
724
}
740
725
741
726
req := NewUpdateRequest (validSpace ).
@@ -751,8 +736,7 @@ func TestUpsertRequestDefaultValues(t *testing.T) {
751
736
refEnc := msgpack .NewEncoder (& refBuf )
752
737
err := RefImplUpsertBody (refEnc , & resolver , validSpace , []interface {}{}, []Op {})
753
738
if err != nil {
754
- t .Errorf ("An unexpected RefImplUpsertBody() error: %q" , err .Error ())
755
- return
739
+ t .Fatalf ("An unexpected RefImplUpsertBody() error: %q" , err .Error ())
756
740
}
757
741
758
742
req := NewUpsertRequest (validSpace )
@@ -782,8 +766,7 @@ func TestUpsertRequestSetters(t *testing.T) {
782
766
refEnc := msgpack .NewEncoder (& refBuf )
783
767
err := RefImplUpsertBody (refEnc , & resolver , validSpace , tuple , refOps )
784
768
if err != nil {
785
- t .Errorf ("An unexpected RefImplUpsertBody() error: %q" , err .Error ())
786
- return
769
+ t .Fatalf ("An unexpected RefImplUpsertBody() error: %q" , err .Error ())
787
770
}
788
771
789
772
req := NewUpsertRequest (validSpace ).
@@ -798,8 +781,7 @@ func TestCallRequestsDefaultValues(t *testing.T) {
798
781
refEnc := msgpack .NewEncoder (& refBuf )
799
782
err := RefImplCallBody (refEnc , validExpr , []interface {}{})
800
783
if err != nil {
801
- t .Errorf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
802
- return
784
+ t .Fatalf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
803
785
}
804
786
805
787
req := NewCallRequest (validExpr )
@@ -817,8 +799,7 @@ func TestCallRequestsSetters(t *testing.T) {
817
799
refEnc := msgpack .NewEncoder (& refBuf )
818
800
err := RefImplCallBody (refEnc , validExpr , args )
819
801
if err != nil {
820
- t .Errorf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
821
- return
802
+ t .Fatalf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
822
803
}
823
804
824
805
req := NewCallRequest (validExpr ).
@@ -838,8 +819,7 @@ func TestEvalRequestDefaultValues(t *testing.T) {
838
819
refEnc := msgpack .NewEncoder (& refBuf )
839
820
err := RefImplEvalBody (refEnc , validExpr , []interface {}{})
840
821
if err != nil {
841
- t .Errorf ("An unexpected RefImplEvalBody() error: %q" , err .Error ())
842
- return
822
+ t .Fatalf ("An unexpected RefImplEvalBody() error: %q" , err .Error ())
843
823
}
844
824
845
825
req := NewEvalRequest (validExpr )
@@ -853,8 +833,7 @@ func TestEvalRequestSetters(t *testing.T) {
853
833
refEnc := msgpack .NewEncoder (& refBuf )
854
834
err := RefImplEvalBody (refEnc , validExpr , args )
855
835
if err != nil {
856
- t .Errorf ("An unexpected RefImplEvalBody() error: %q" , err .Error ())
857
- return
836
+ t .Fatalf ("An unexpected RefImplEvalBody() error: %q" , err .Error ())
858
837
}
859
838
860
839
req := NewEvalRequest (validExpr ).
@@ -868,8 +847,7 @@ func TestExecuteRequestDefaultValues(t *testing.T) {
868
847
refEnc := msgpack .NewEncoder (& refBuf )
869
848
err := RefImplExecuteBody (refEnc , validExpr , []interface {}{})
870
849
if err != nil {
871
- t .Errorf ("An unexpected RefImplExecuteBody() error: %q" , err .Error ())
872
- return
850
+ t .Fatalf ("An unexpected RefImplExecuteBody() error: %q" , err .Error ())
873
851
}
874
852
875
853
req := NewExecuteRequest (validExpr )
@@ -883,8 +861,7 @@ func TestExecuteRequestSetters(t *testing.T) {
883
861
refEnc := msgpack .NewEncoder (& refBuf )
884
862
err := RefImplExecuteBody (refEnc , validExpr , args )
885
863
if err != nil {
886
- t .Errorf ("An unexpected RefImplExecuteBody() error: %q" , err .Error ())
887
- return
864
+ t .Fatalf ("An unexpected RefImplExecuteBody() error: %q" , err .Error ())
888
865
}
889
866
890
867
req := NewExecuteRequest (validExpr ).
@@ -898,8 +875,7 @@ func TestPrepareRequestDefaultValues(t *testing.T) {
898
875
refEnc := msgpack .NewEncoder (& refBuf )
899
876
err := RefImplPrepareBody (refEnc , validExpr )
900
877
if err != nil {
901
- t .Errorf ("An unexpected RefImplPrepareBody() error: %q" , err .Error ())
902
- return
878
+ t .Fatalf ("An unexpected RefImplPrepareBody() error: %q" , err .Error ())
903
879
}
904
880
905
881
req := NewPrepareRequest (validExpr )
@@ -912,8 +888,7 @@ func TestUnprepareRequestDefaultValues(t *testing.T) {
912
888
refEnc := msgpack .NewEncoder (& refBuf )
913
889
err := RefImplUnprepareBody (refEnc , * validStmt )
914
890
if err != nil {
915
- t .Errorf ("An unexpected RefImplUnprepareBody() error: %q" , err .Error ())
916
- return
891
+ t .Fatalf ("An unexpected RefImplUnprepareBody() error: %q" , err .Error ())
917
892
}
918
893
919
894
req := NewUnprepareRequest (validStmt )
@@ -928,8 +903,7 @@ func TestExecutePreparedRequestSetters(t *testing.T) {
928
903
refEnc := msgpack .NewEncoder (& refBuf )
929
904
err := RefImplExecutePreparedBody (refEnc , * validStmt , args )
930
905
if err != nil {
931
- t .Errorf ("An unexpected RefImplExecutePreparedBody() error: %q" , err .Error ())
932
- return
906
+ t .Fatalf ("An unexpected RefImplExecutePreparedBody() error: %q" , err .Error ())
933
907
}
934
908
935
909
req := NewExecutePreparedRequest (validStmt ).
@@ -944,8 +918,7 @@ func TestExecutePreparedRequestDefaultValues(t *testing.T) {
944
918
refEnc := msgpack .NewEncoder (& refBuf )
945
919
err := RefImplExecutePreparedBody (refEnc , * validStmt , []interface {}{})
946
920
if err != nil {
947
- t .Errorf ("An unexpected RefImplExecutePreparedBody() error: %q" , err .Error ())
948
- return
921
+ t .Fatalf ("An unexpected RefImplExecutePreparedBody() error: %q" , err .Error ())
949
922
}
950
923
951
924
req := NewExecutePreparedRequest (validStmt )
@@ -959,8 +932,7 @@ func TestBeginRequestDefaultValues(t *testing.T) {
959
932
refEnc := msgpack .NewEncoder (& refBuf )
960
933
err := RefImplBeginBody (refEnc , defaultIsolationLevel , defaultTimeout )
961
934
if err != nil {
962
- t .Errorf ("An unexpected RefImplBeginBody() error: %q" , err .Error ())
963
- return
935
+ t .Fatalf ("An unexpected RefImplBeginBody() error: %q" , err .Error ())
964
936
}
965
937
966
938
req := NewBeginRequest ()
@@ -973,8 +945,7 @@ func TestBeginRequestSetters(t *testing.T) {
973
945
refEnc := msgpack .NewEncoder (& refBuf )
974
946
err := RefImplBeginBody (refEnc , ReadConfirmedLevel , validTimeout )
975
947
if err != nil {
976
- t .Errorf ("An unexpected RefImplBeginBody() error: %q" , err .Error ())
977
- return
948
+ t .Fatalf ("An unexpected RefImplBeginBody() error: %q" , err .Error ())
978
949
}
979
950
980
951
req := NewBeginRequest ().TxnIsolation (ReadConfirmedLevel ).Timeout (validTimeout )
@@ -987,8 +958,7 @@ func TestCommitRequestDefaultValues(t *testing.T) {
987
958
refEnc := msgpack .NewEncoder (& refBuf )
988
959
err := RefImplCommitBody (refEnc )
989
960
if err != nil {
990
- t .Errorf ("An unexpected RefImplCommitBody() error: %q" , err .Error ())
991
- return
961
+ t .Fatalf ("An unexpected RefImplCommitBody() error: %q" , err .Error ())
992
962
}
993
963
994
964
req := NewCommitRequest ()
@@ -1001,8 +971,7 @@ func TestRollbackRequestDefaultValues(t *testing.T) {
1001
971
refEnc := msgpack .NewEncoder (& refBuf )
1002
972
err := RefImplRollbackBody (refEnc )
1003
973
if err != nil {
1004
- t .Errorf ("An unexpected RefImplRollbackBody() error: %q" , err .Error ())
1005
- return
974
+ t .Fatalf ("An unexpected RefImplRollbackBody() error: %q" , err .Error ())
1006
975
}
1007
976
1008
977
req := NewRollbackRequest ()
@@ -1016,8 +985,7 @@ func TestBroadcastRequestDefaultValues(t *testing.T) {
1016
985
expectedArgs := []interface {}{validKey }
1017
986
err := RefImplCallBody (refEnc , "box.broadcast" , expectedArgs )
1018
987
if err != nil {
1019
- t .Errorf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
1020
- return
988
+ t .Fatalf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
1021
989
}
1022
990
1023
991
req := NewBroadcastRequest (validKey )
@@ -1032,8 +1000,7 @@ func TestBroadcastRequestSetters(t *testing.T) {
1032
1000
expectedArgs := []interface {}{validKey , value }
1033
1001
err := RefImplCallBody (refEnc , "box.broadcast" , expectedArgs )
1034
1002
if err != nil {
1035
- t .Errorf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
1036
- return
1003
+ t .Fatalf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
1037
1004
}
1038
1005
1039
1006
req := NewBroadcastRequest (validKey ).Value (value )
@@ -1046,8 +1013,7 @@ func TestWatchOnceRequestDefaultValues(t *testing.T) {
1046
1013
refEnc := msgpack .NewEncoder (& refBuf )
1047
1014
err := RefImplWatchOnceBody (refEnc , validKey )
1048
1015
if err != nil {
1049
- t .Errorf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
1050
- return
1016
+ t .Fatalf ("An unexpected RefImplCallBody() error: %q" , err .Error ())
1051
1017
}
1052
1018
1053
1019
req := NewWatchOnceRequest (validKey )
0 commit comments