Commit f986db1 1 parent 30d75cb commit f986db1 Copy full SHA for f986db1
File tree 1 file changed +48
-0
lines changed
1 file changed +48
-0
lines changed Original file line number Diff line number Diff line change @@ -852,4 +852,52 @@ mod test {
852
852
<SyncResponse as PbCodec >:: decode ( & sync_resp. encode ( ) ) . expect ( "decode should success" ) ;
853
853
assert_eq ! ( sync_resp, decoded_sync_resp) ;
854
854
}
855
+
856
+ #[ test]
857
+ fn txn_command_keys_is_ok ( ) {
858
+ let txn_req = TxnRequest {
859
+ compare : vec ! [ Compare {
860
+ key: b"a" . to_vec( ) ,
861
+ ..Default :: default ( )
862
+ } ] ,
863
+ success : vec ! [
864
+ RequestOp {
865
+ request: Some ( Request :: RequestRange ( RangeRequest {
866
+ key: b"1" . to_vec( ) ,
867
+ ..Default :: default ( )
868
+ } ) ) ,
869
+ } ,
870
+ RequestOp {
871
+ request: Some ( Request :: RequestTxn ( TxnRequest {
872
+ compare: vec![ Compare {
873
+ key: b"b" . to_vec( ) ,
874
+ range_end: b"e" . to_vec( ) ,
875
+ ..Default :: default ( )
876
+ } ] ,
877
+ success: vec![ RequestOp {
878
+ request: Some ( Request :: RequestRange ( RangeRequest {
879
+ key: b"3" . to_vec( ) ,
880
+ range_end: b"4" . to_vec( ) ,
881
+ ..Default :: default ( )
882
+ } ) ) ,
883
+ } ] ,
884
+ failure: vec![ ] ,
885
+ } ) ) ,
886
+ } ,
887
+ ] ,
888
+ failure : vec ! [ RequestOp {
889
+ request: Some ( Request :: RequestPut ( PutRequest {
890
+ key: b"2" . to_vec( ) ,
891
+ ..Default :: default ( )
892
+ } ) ) ,
893
+ } ] ,
894
+ } ;
895
+
896
+ let keys = txn_req. keys ( ) ;
897
+ assert ! ( keys. contains( & KeyRange :: new_one_key( "a" ) ) ) ;
898
+ assert ! ( keys. contains( & KeyRange :: new( "b" , "e" ) ) ) ;
899
+ assert ! ( keys. contains( & KeyRange :: new_one_key( "1" ) ) ) ;
900
+ assert ! ( keys. contains( & KeyRange :: new_one_key( "2" ) ) ) ;
901
+ assert ! ( keys. contains( & KeyRange :: new( "3" , "4" ) ) ) ;
902
+ }
855
903
}
You can’t perform that action at this time.
0 commit comments