Add ttl for raw client (#324)

* Add ttl for raw client Signed-off-by: Andy Lok <[email protected]> * fmt Signed-off-by: Andy Lok <[email protected]> --------- Signed-off-by: Andy Lok <[email protected]>
tikv · Dec 28, 2023 · 6f9c133 · 6f9c133
1 parent 1178d79
commit 6f9c133
Show file tree

Hide file tree

Showing 75 changed files with 11,071 additions and 367 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -38,7 +38,6 @@ prometheus = { version = "0.13", default-features = false }
 prost = "0.12"
 rand = "0.8"
 regex = "1"
-reqwest = { version = "0.11", features = ["json", "native-tls-vendored"] }
 semver = "1.0"
 serde = "1.0"
 serde_derive = "1.0"
@@ -54,6 +53,7 @@ env_logger = "0.10"
 fail = { version = "0.4", features = ["failpoints"] }
 proptest = "1"
 proptest-derive = "0.3"
+reqwest = { version = "0.11", features = ["json", "native-tls-vendored"] }
 rstest = "0.18.2"
 serde_json = "1"
 serial_test = "0.5.0"

diff --git a/proto-build/Cargo.toml b/proto-build/Cargo.toml
@@ -12,4 +12,4 @@ edition = "2021"
 
 [dependencies]
 glob = "0.3"
-tonic-build = { version = "0.10", features = ["cleanup-markdown"] }
+tonic-build = { version = "0.10", features = ["cleanup-markdown"] }
diff --git a/proto/autoid.proto b/proto/autoid.proto
@@ -0,0 +1,47 @@
+syntax = "proto3";
+package autoid;
+
+import "gogoproto/gogo.proto";
+import "rustproto.proto";
+
+option (gogoproto.sizer_all) = true;
+option (gogoproto.marshaler_all) = true;
+option (gogoproto.unmarshaler_all) = true;
+option (rustproto.lite_runtime_all) = true;
+
+option java_package = "org.tikv.kvproto";
+
+message AutoIDRequest {
+	int64 dbID = 1;
+	int64 tblID = 2;
+	bool isUnsigned = 3;
+	uint64 n = 4;
+	int64 increment = 5;
+	int64 offset = 6;
+	uint32 keyspaceID = 7;
+}
+
+message AutoIDResponse {
+	int64 min = 1;
+	int64 max = 2;
+
+	bytes errmsg = 3;
+}
+
+message RebaseRequest {
+	int64 dbID = 1;
+	int64 tblID = 2;
+	bool isUnsigned = 3;
+	int64 base = 4;
+	bool force = 5;
+}
+
+message RebaseResponse {
+	bytes errmsg = 1;
+}
+
+service AutoIDAlloc {
+    rpc AllocAutoID(AutoIDRequest) returns (AutoIDResponse) {}
+    rpc Rebase(RebaseRequest) returns (RebaseResponse) {}
+}
+