googleapis
diff --git a/‎README.md‎
Lines changed: 2 additions & 2 deletions b/‎README.md‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎protos/google/pubsub/v1/pubsub.proto‎
Lines changed: 48 additions & 0 deletions b/‎protos/google/pubsub/v1/pubsub.proto‎
Lines changed: 48 additions & 0 deletions
diff --git a/‎protos/protos.d.ts‎
Lines changed: 222 additions & 0 deletions b/‎protos/protos.d.ts‎
Lines changed: 222 additions & 0 deletions
@@ -70,14 +70,14 @@ const {PubSub} = require('@google-cloud/pubsub');
 
 async function quickstart(
   projectId = 'your-project-id', // Your Google Cloud Platform project ID
-  topicName = 'my-topic', // Name for the new topic to create
+  topicNameOrId = 'my-topic', // Name for the new topic to create
   subscriptionName = 'my-sub' // Name for the new subscription to create
 ) {
   // Instantiates a client
   const pubsub = new PubSub({projectId});
 
   // Creates a new topic
-  const [topic] = await pubsub.createTopic(topicName);
+  const [topic] = await pubsub.createTopic(topicNameOrId);
   console.log(`Topic ${topic.name} created.`);
 
   // Creates a subscription on that new topic
 
@@ -752,6 +752,19 @@ message Subscription {
   // the endpoint will not be made.
   bool detached = 15;
 
+  // If true, Pub/Sub provides the following guarantees for the delivery of
+  // a message with a given value of `message_id` on this subscription:
+  //
+  // * The message sent to a subscriber is guaranteed not to be resent
+  // before the message's acknowledgement deadline expires.
+  // * An acknowledged message will not be resent to a subscriber.
+  //
+  // Note that subscribers may still receive multiple copies of a message
+  // when `enable_exactly_once_delivery` is true if the message was published
+  // multiple times by a publisher client. These copies are  considered distinct
+  // by Pub/Sub and have distinct `message_id` values.
+  bool enable_exactly_once_delivery = 16;
+
   // Output only. Indicates the minimum duration for which a message is retained
   // after it is published to the subscription's topic. If this field is set,
   // messages published to the subscription's topic in the last
@@ -1163,15 +1176,50 @@ message StreamingPullRequest {
 // Response for the `StreamingPull` method. This response is used to stream
 // messages from the server to the client.
 message StreamingPullResponse {
+  // Acknowledgement IDs sent in one or more previous requests to acknowledge a
+  // previously received message.
+  message AcknowledgeConfirmation {
+    // Successfully processed acknowledgement IDs.
+    repeated string ack_ids = 1 [ctype = CORD];
+
+    // List of acknowledgement IDs that were malformed or whose acknowledgement
+    // deadline has expired.
+    repeated string invalid_ack_ids = 2 [ctype = CORD];
+
+    // List of acknowledgement IDs that were out of order.
+    repeated string unordered_ack_ids = 3 [ctype = CORD];
+  }
+
+  // Acknowledgement IDs sent in one or more previous requests to modify the
+  // deadline for a specific message.
+  message ModifyAckDeadlineConfirmation {
+    // Successfully processed acknowledgement IDs.
+    repeated string ack_ids = 1 [ctype = CORD];
+
+    // List of acknowledgement IDs that were malformed or whose acknowledgement
+    // deadline has expired.
+    repeated string invalid_ack_ids = 2 [ctype = CORD];
+  }
+
   // Subscription properties sent as part of the response.
   message SubscriptionProperties {
+    // True iff exactly once delivery is enabled for this subscription.
+    bool exactly_once_delivery_enabled = 1;
     // True iff message ordering is enabled for this subscription.
     bool message_ordering_enabled = 2;
   }
 
   // Received Pub/Sub messages. This will not be empty.
   repeated ReceivedMessage received_messages = 1;
 
+  // This field will only be set if `enable_exactly_once_delivery` is set to
+  // `true`.
+  AcknowledgeConfirmation acknowlege_confirmation = 2;
+
+  // This field will only be set if `enable_exactly_once_delivery` is set to
+  // `true`.
+  ModifyAckDeadlineConfirmation modify_ack_deadline_confirmation = 3;
+
   // Properties associated with this subscription.
   SubscriptionProperties subscription_properties = 4;
 }