chore: Batch ack requests and sink responses for better performance (#…

…163) Signed-off-by: Yashash H L <[email protected]>
numaproj · Oct 30, 2024 · 7ec3f2c · 7ec3f2c
1 parent 53eedf8
commit 7ec3f2c
Show file tree

Hide file tree

Showing 10 changed files with 188 additions and 190 deletions.
diff --git a/pkg/apis/proto/sink/v1/sink.pb.go b/pkg/apis/proto/sink/v1/sink.pb.go
diff --git a/pkg/apis/proto/sink/v1/sink.proto b/pkg/apis/proto/sink/v1/sink.proto
@@ -80,7 +80,7 @@ message SinkResponse {
     // err_msg is the error message, set it if success is set to false.
     string err_msg = 3;
   }
-  Result result = 1;
+  repeated Result results = 1;
   optional Handshake handshake = 2;
   optional TransmissionStatus status = 3;
 }