feat: Unify Map Stream and Unary Map Operations Using a Shared gRPC P…

…rotocol (#162) Signed-off-by: Yashash H L <[email protected]>
numaproj · Oct 14, 2024 · 53eedf8 · 53eedf8
1 parent ed18862
commit 53eedf8
Show file tree

Hide file tree

Showing 19 changed files with 640 additions and 1,273 deletions.
diff --git a/pkg/apis/proto/map/v1/map.pb.go b/pkg/apis/proto/map/v1/map.pb.go
diff --git a/pkg/apis/proto/map/v1/map.proto b/pkg/apis/proto/map/v1/map.proto
@@ -30,7 +30,7 @@ message MapRequest {
   // This ID is used to uniquely identify a map request
   string id = 2;
   optional Handshake handshake = 3;
-  optional Status status = 4;
+  optional TransmissionStatus status = 4;
 }
 
 /*
@@ -44,7 +44,7 @@ message Handshake {
 /*
  * Status message to indicate the status of the message.
  */
-message Status {
+message TransmissionStatus {
   bool eot = 1;
 }
 
@@ -61,7 +61,7 @@ message MapResponse {
   // This ID is used to refer the responses to the request it corresponds to.
   string id = 2;
   optional Handshake handshake = 3;
-  optional Status status = 4;
+  optional TransmissionStatus status = 4;
 }
 
 /**