Support uploading GC safe point to PD (#273)

pingcap · Jul 5, 2018 · 4647096 · 4647096
1 parent 716bb0d
commit 4647096
Show file tree

Hide file tree

Showing 12 changed files with 2,409 additions and 727 deletions.
diff --git a/pkg/pdpb/pdpb.pb.go b/pkg/pdpb/pdpb.pb.go
diff --git a/proto/pdpb.proto b/proto/pdpb.proto
@@ -48,6 +48,10 @@ service PD {
     rpc PutClusterConfig(PutClusterConfigRequest) returns (PutClusterConfigResponse) {}
 
     rpc ScatterRegion(ScatterRegionRequest) returns (ScatterRegionResponse) {}
+
+    rpc GetGCSafePoint(GetGCSafePointRequest) returns (GetGCSafePointResponse) {}
+
+    rpc UpdateGCSafePoint(UpdateGCSafePointRequest) returns (UpdateGCSafePointResponse) {}
 }
 
 message RequestHeader {
@@ -386,3 +390,26 @@ message ScatterRegionRequest {
 message ScatterRegionResponse {
     ResponseHeader header = 1;
 }
+
+message GetGCSafePointRequest {
+    RequestHeader header = 1;
+}
+
+message GetGCSafePointResponse {
+    ResponseHeader header = 1;
+
+    uint64 safe_point = 2;
+}
+
+message UpdateGCSafePointRequest {
+    RequestHeader header = 1;
+
+    uint64 safe_point = 2;
+}
+
+message UpdateGCSafePointResponse {
+    ResponseHeader header = 1;
+
+    uint64 new_safe_point = 2;
+}
+
diff --git a/src/coprocessor.rs b/src/coprocessor.rs
diff --git a/src/debugpb.rs b/src/debugpb.rs
diff --git a/src/errorpb.rs b/src/errorpb.rs
diff --git a/src/import_kvpb.rs b/src/import_kvpb.rs
diff --git a/src/import_sstpb.rs b/src/import_sstpb.rs
diff --git a/src/kvrpcpb.rs b/src/kvrpcpb.rs
diff --git a/src/metapb.rs b/src/metapb.rs