@@ -66,7 +66,7 @@ impl Display for TableIdent {
66
66
}
67
67
}
68
68
69
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Eq , PartialEq , Default ) ]
69
+ #[ derive( Clone , Debug , Eq , PartialEq , Default ) ]
70
70
pub struct TableNameIdent {
71
71
pub tenant : String ,
72
72
pub db_name : String ,
@@ -112,7 +112,7 @@ impl Display for TableNameIdent {
112
112
}
113
113
}
114
114
115
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Eq , PartialEq , Default ) ]
115
+ #[ derive( Clone , Debug , Eq , PartialEq , Default ) ]
116
116
pub struct DBIdTableName {
117
117
pub db_id : u64 ,
118
118
pub table_name : String ,
@@ -124,7 +124,7 @@ impl Display for DBIdTableName {
124
124
}
125
125
}
126
126
127
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Eq , PartialEq , Default ) ]
127
+ #[ derive( Clone , Debug , Eq , PartialEq , Default ) ]
128
128
pub struct TableId {
129
129
pub table_id : u64 ,
130
130
}
@@ -141,7 +141,7 @@ impl Display for TableId {
141
141
}
142
142
}
143
143
144
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Eq , PartialEq , Default ) ]
144
+ #[ derive( Clone , Debug , Eq , PartialEq , Default ) ]
145
145
pub struct TableIdListKey {
146
146
pub db_id : u64 ,
147
147
pub table_name : String ,
@@ -458,7 +458,7 @@ impl Display for TableIdList {
458
458
}
459
459
}
460
460
461
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
461
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
462
462
pub struct CreateTableReq {
463
463
pub create_option : CreateOption ,
464
464
pub name_ident : TableNameIdent ,
@@ -554,7 +554,7 @@ pub struct DropTableReply {
554
554
pub spec_vec : Option < ( Vec < ShareSpec > , Vec < ShareTableInfoMap > ) > ,
555
555
}
556
556
557
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
557
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
558
558
pub struct UndropTableReq {
559
559
pub name_ident : TableNameIdent ,
560
560
}
@@ -583,10 +583,10 @@ impl Display for UndropTableReq {
583
583
}
584
584
}
585
585
586
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
586
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
587
587
pub struct UndropTableReply { }
588
588
589
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
589
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
590
590
pub struct RenameTableReq {
591
591
pub if_exists : bool ,
592
592
pub name_ident : TableNameIdent ,
@@ -620,12 +620,12 @@ impl Display for RenameTableReq {
620
620
}
621
621
}
622
622
623
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
623
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
624
624
pub struct RenameTableReply {
625
625
pub table_id : u64 ,
626
626
}
627
627
628
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
628
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
629
629
pub struct UpsertTableOptionReq {
630
630
pub table_id : u64 ,
631
631
pub seq : MatchSeq ,
@@ -644,7 +644,7 @@ pub struct UpdateStreamMetaReq {
644
644
pub options : BTreeMap < String , String > ,
645
645
}
646
646
647
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
647
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
648
648
pub struct UpdateTableMetaReq {
649
649
pub table_id : u64 ,
650
650
pub seq : MatchSeq ,
@@ -685,15 +685,15 @@ impl Display for UpsertTableOptionReq {
685
685
}
686
686
}
687
687
688
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
688
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
689
689
pub enum SetTableColumnMaskPolicyAction {
690
690
// new mask name, old mask name(if any)
691
691
Set ( String , Option < String > ) ,
692
692
// prev mask name
693
693
Unset ( String ) ,
694
694
}
695
695
696
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
696
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
697
697
pub struct SetTableColumnMaskPolicyReq {
698
698
pub tenant : String ,
699
699
pub table_id : u64 ,
@@ -702,17 +702,17 @@ pub struct SetTableColumnMaskPolicyReq {
702
702
pub action : SetTableColumnMaskPolicyAction ,
703
703
}
704
704
705
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
705
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
706
706
pub struct SetTableColumnMaskPolicyReply {
707
707
pub share_table_info : Option < Vec < ShareTableInfoMap > > ,
708
708
}
709
709
710
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
710
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
711
711
pub struct UpsertTableOptionReply {
712
712
pub share_table_info : Option < Vec < ShareTableInfoMap > > ,
713
713
}
714
714
715
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
715
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
716
716
pub struct UpdateTableMetaReply {
717
717
pub share_table_info : Option < Vec < ShareTableInfoMap > > ,
718
718
}
@@ -745,7 +745,7 @@ impl Display for CreateTableIndexReq {
745
745
}
746
746
}
747
747
748
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Eq , PartialEq ) ]
748
+ #[ derive( Clone , Debug , Eq , PartialEq ) ]
749
749
pub struct CreateTableIndexReply { }
750
750
751
751
#[ derive( Clone , Debug , PartialEq , Eq ) ]
@@ -765,10 +765,10 @@ impl Display for DropTableIndexReq {
765
765
}
766
766
}
767
767
768
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
768
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
769
769
pub struct DropTableIndexReply { }
770
770
771
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
771
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
772
772
pub struct GetTableReq {
773
773
pub inner : TableNameIdent ,
774
774
}
@@ -799,7 +799,7 @@ impl GetTableReq {
799
799
}
800
800
}
801
801
802
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
802
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
803
803
pub struct ListTableReq {
804
804
pub inner : DatabaseNameIdent ,
805
805
}
@@ -823,7 +823,7 @@ impl ListTableReq {
823
823
}
824
824
}
825
825
826
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
826
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
827
827
pub enum TableInfoFilter {
828
828
// if datatime is some, filter only dropped tables which drop time before that,
829
829
// else filter all dropped tables
@@ -838,37 +838,37 @@ pub enum TableInfoFilter {
838
838
All ,
839
839
}
840
840
841
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
841
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
842
842
pub struct ListDroppedTableReq {
843
843
pub inner : DatabaseNameIdent ,
844
844
pub filter : TableInfoFilter ,
845
845
pub limit : Option < usize > ,
846
846
}
847
847
848
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
848
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
849
849
pub enum DroppedId {
850
850
// db id, db name
851
851
Db ( u64 , String ) ,
852
852
// db id, table id, table name
853
853
Table ( u64 , u64 , String ) ,
854
854
}
855
855
856
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
856
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
857
857
pub struct ListDroppedTableResp {
858
858
pub drop_table_infos : Vec < Arc < TableInfo > > ,
859
859
pub drop_ids : Vec < DroppedId > ,
860
860
}
861
861
862
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
862
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
863
863
pub struct GcDroppedTableReq {
864
864
pub tenant : String ,
865
865
pub drop_ids : Vec < DroppedId > ,
866
866
}
867
867
868
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
868
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
869
869
pub struct GcDroppedTableResp { }
870
870
871
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Eq , PartialEq , Default ) ]
871
+ #[ derive( Clone , Debug , Eq , PartialEq , Default ) ]
872
872
pub struct CountTablesKey {
873
873
pub tenant : String ,
874
874
}
@@ -888,7 +888,7 @@ impl CountTablesKey {
888
888
}
889
889
890
890
/// count tables for a tenant
891
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
891
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
892
892
pub struct CountTablesReq {
893
893
pub tenant : String ,
894
894
}
@@ -898,7 +898,7 @@ pub struct CountTablesReply {
898
898
pub count : u64 ,
899
899
}
900
900
901
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Default , Eq , PartialEq ) ]
901
+ #[ derive( Clone , Debug , Default , Eq , PartialEq ) ]
902
902
pub struct TableIdToName {
903
903
pub table_id : u64 ,
904
904
}
@@ -909,41 +909,41 @@ impl Display for TableIdToName {
909
909
}
910
910
}
911
911
912
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Eq , PartialEq , Default ) ]
912
+ #[ derive( Clone , Debug , Eq , PartialEq , Default ) ]
913
913
pub struct TableCopiedFileNameIdent {
914
914
pub table_id : u64 ,
915
915
pub file : String ,
916
916
}
917
917
918
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Eq , PartialEq , Default ) ]
918
+ #[ derive( Clone , Debug , Eq , PartialEq , Default ) ]
919
919
pub struct TableCopiedFileInfo {
920
920
pub etag : Option < String > ,
921
921
pub content_length : u64 ,
922
922
pub last_modified : Option < DateTime < Utc > > ,
923
923
}
924
924
925
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
925
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
926
926
pub struct GetTableCopiedFileReq {
927
927
pub table_id : u64 ,
928
928
pub files : Vec < String > ,
929
929
}
930
930
931
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
931
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
932
932
pub struct GetTableCopiedFileReply {
933
933
pub file_info : BTreeMap < String , TableCopiedFileInfo > ,
934
934
}
935
935
936
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
936
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
937
937
pub struct UpsertTableCopiedFileReq {
938
938
pub file_info : BTreeMap < String , TableCopiedFileInfo > ,
939
939
pub expire_at : Option < u64 > ,
940
940
pub fail_if_duplicated : bool ,
941
941
}
942
942
943
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
943
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
944
944
pub struct UpsertTableCopiedFileReply { }
945
945
946
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
946
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
947
947
pub struct TruncateTableReq {
948
948
pub table_id : u64 ,
949
949
/// Specify the max number copied file to delete in every sub-transaction.
@@ -952,10 +952,10 @@ pub struct TruncateTableReq {
952
952
pub batch_size : Option < u64 > ,
953
953
}
954
954
955
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
955
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
956
956
pub struct TruncateTableReply { }
957
957
958
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
958
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
959
959
pub struct EmptyProto { }
960
960
961
961
mod kvapi_key_impl {
0 commit comments