Batch request replication

dsg-uwaterloo · Dec 4, 2023 · 54d142a · 54d142a
1 parent 13822d7
commit 54d142a
Show file tree

Hide file tree

Showing 18 changed files with 920 additions and 587 deletions.
diff --git a/api/oramnode/oramnode.pb.go b/api/oramnode/oramnode.pb.go
diff --git a/api/oramnode/oramnode_grpc.pb.go b/api/oramnode/oramnode_grpc.pb.go
diff --git a/api/router/router.pb.go b/api/router/router.pb.go
diff --git a/api/router/router_grpc.pb.go b/api/router/router_grpc.pb.go
diff --git a/api/shardnode.proto b/api/shardnode.proto
@@ -5,28 +5,41 @@ option go_package = "github.com/dsg-uwaterloo/oblishard/api/shardnode";
 package shardnode;
 
 service ShardNode {
-    rpc Read (ReadRequest) returns (ReadReply) {}
-    rpc Write (WriteRequest) returns (WriteReply) {}
+    rpc BatchQuery (RequestBatch) returns (ReplyBatch) {}
     rpc SendBlocks(SendBlocksRequest) returns (SendBlocksReply) {}
     rpc AckSentBlocks(AckSentBlocksRequest) returns (AckSentBlocksReply) {}
     rpc JoinRaftVoter (JoinRaftVoterRequest) returns (JoinRaftVoterReply) {}
 }
 
+message RequestBatch {
+    repeated ReadRequest read_requests = 1;
+    repeated WriteRequest write_requests = 2;
+}
+
+message ReplyBatch {
+    repeated ReadReply read_replies = 1;
+    repeated WriteReply write_replies = 2;
+}
+
 message ReadRequest {
-    string block = 1;
+    string request_id = 1;
+    string block = 2;
 }
 
 message ReadReply {
-    string value = 1;
+    string request_id = 1;
+    string value = 2;
 }
 
 message WriteRequest {
-    string block = 1;
-    string value = 2;
+    string request_id = 1;
+    string block = 2;
+    string value = 3;
 }
 
 message WriteReply {
-    bool success = 1;
+    string request_id = 1;
+    bool success = 2;
 }
 
 message JoinRaftVoterRequest {