Merge pull request #29 from liftbridge-io/async_publish_api

Add AsyncPublish endpoint
liftbridge-io · Jul 16, 2020 · 20d10c0 · 20d10c0
2 parents edbf0f9 + 52124ef
commit 20d10c0
Show file tree

Hide file tree

Showing 4 changed files with 3,088 additions and 1,509 deletions.
diff --git a/api.proto b/api.proto
@@ -264,6 +264,11 @@ service API {
     // code is returned.
     rpc Publish(PublishRequest) returns (PublishResponse) {}
 
+    // PublishAsync is used to asynchronously publish messages to a stream in a
+    // pipelined fashion. This returns a stream which will yield
+    // PublishResponses for messages whose AckPolicy is not NONE.
+    rpc PublishAsync(stream PublishRequest) returns (stream PublishResponse) {}
+
     // Publish a Liftbridge message to a NATS subject. If the AckPolicy is not NONE and a
     // deadline is provided, this will synchronously block until the first ack
     // is received. If an ack is not received in time, a DeadlineExceeded