feat: Add topic retention options

PiperOrigin-RevId: 389879008 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Aug 10 07:28:42 2021 -0700 Source-Repo: googleapis/googleapis Source-Sha: 7b6a2ceed6cacf676b3918b1703b3ddd6322444c Source-Link: googleapis/googleapis@7b6a2ce
googleapis · Aug 10, 2021 · 4cc3e58 · 4cc3e58
1 parent 9c8f71f
commit 4cc3e58
Show file tree

Hide file tree

Showing 8 changed files with 388 additions and 238 deletions.
diff --git a/...le.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Snippets/PublisherServiceApiClientSnippets.g.cs b/...le.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Snippets/PublisherServiceApiClientSnippets.g.cs
@@ -42,6 +42,7 @@ public void CreateTopicRequestObject()
                 KmsKeyName = "",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new Duration(),
             };
             // Make the request
             Topic response = publisherServiceApiClient.CreateTopic(request);
@@ -64,6 +65,7 @@ public async Task CreateTopicRequestObjectAsync()
                 KmsKeyName = "",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new Duration(),
             };
             // Make the request
             Topic response = await publisherServiceApiClient.CreateTopicAsync(request);

diff --git a/...e.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Snippets/SubscriberServiceApiClientSnippets.g.cs b/...e.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Snippets/SubscriberServiceApiClientSnippets.g.cs
@@ -50,6 +50,7 @@ public void CreateSubscriptionRequestObject()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new Duration(),
             };
             // Make the request
             Subscription response = subscriberServiceApiClient.CreateSubscription(request);
@@ -79,6 +80,7 @@ public async Task CreateSubscriptionRequestObjectAsync()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new Duration(),
             };
             // Make the request
             Subscription response = await subscriberServiceApiClient.CreateSubscriptionAsync(request);

diff --git a/apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Tests/PublisherServiceApiClientTest.g.cs b/apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Tests/PublisherServiceApiClientTest.g.cs
@@ -45,6 +45,7 @@ public void CreateTopicRequestObject()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             Topic expectedResponse = new Topic
             {
@@ -60,6 +61,7 @@ public void CreateTopicRequestObject()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -86,6 +88,7 @@ public void CreateTopicRequestObject()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             Topic expectedResponse = new Topic
             {
@@ -101,6 +104,7 @@ public void CreateTopicRequestObject()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -133,6 +137,7 @@ public void CreateTopic()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -163,6 +168,7 @@ public void CreateTopic()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -195,6 +201,7 @@ public void CreateTopicResourceNames()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -225,6 +232,7 @@ public void CreateTopicResourceNames()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -258,6 +266,7 @@ public void UpdateTopicRequestObject()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.UpdateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -289,6 +298,7 @@ public void UpdateTopicRequestObject()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.UpdateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -483,6 +493,7 @@ public void GetTopicRequestObject()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -513,6 +524,7 @@ public void GetTopicRequestObject()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -545,6 +557,7 @@ public void GetTopic()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -575,6 +588,7 @@ public void GetTopic()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -607,6 +621,7 @@ public void GetTopicResourceNames()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -637,6 +652,7 @@ public void GetTopicResourceNames()
                 KmsKeyName = "kms_key_name06bd122b",
                 SchemaSettings = new SchemaSettings(),
                 SatisfiesPzs = false,
+                MessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);

diff --git a/apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Tests/SubscriberServiceApiClientTest.g.cs b/apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Tests/SubscriberServiceApiClientTest.g.cs
@@ -52,6 +52,7 @@ public void CreateSubscriptionRequestObject()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             Subscription expectedResponse = new Subscription
             {
@@ -74,6 +75,7 @@ public void CreateSubscriptionRequestObject()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateSubscription(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -107,6 +109,7 @@ public void CreateSubscriptionRequestObject()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             Subscription expectedResponse = new Subscription
             {
@@ -129,6 +132,7 @@ public void CreateSubscriptionRequestObject()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateSubscriptionAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Subscription>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -171,6 +175,7 @@ public void CreateSubscription()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateSubscription(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -211,6 +216,7 @@ public void CreateSubscription()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateSubscriptionAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Subscription>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -253,6 +259,7 @@ public void CreateSubscriptionResourceNames()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateSubscription(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -293,6 +300,7 @@ public void CreateSubscriptionResourceNames()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.CreateSubscriptionAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Subscription>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -332,6 +340,7 @@ public void GetSubscriptionRequestObject()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetSubscription(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -369,6 +378,7 @@ public void GetSubscriptionRequestObject()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetSubscriptionAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Subscription>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -408,6 +418,7 @@ public void GetSubscription()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetSubscription(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -445,6 +456,7 @@ public void GetSubscription()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetSubscriptionAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Subscription>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -484,6 +496,7 @@ public void GetSubscriptionResourceNames()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetSubscription(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -521,6 +534,7 @@ public void GetSubscriptionResourceNames()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.GetSubscriptionAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Subscription>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -561,6 +575,7 @@ public void UpdateSubscriptionRequestObject()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.UpdateSubscription(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -599,6 +614,7 @@ public void UpdateSubscriptionRequestObject()
                 DeadLetterPolicy = new DeadLetterPolicy(),
                 RetryPolicy = new RetryPolicy(),
                 Detached = false,
+                TopicMessageRetentionDuration = new wkt::Duration(),
             };
             mockGrpcClient.Setup(x => x.UpdateSubscriptionAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Subscription>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);