Skip to content

Commit 96ca781

Browse files
feat: Add export config protos to API (#1196)
- [ ] Regenerate this pull request now. PiperOrigin-RevId: 468442481 Source-Link: googleapis/googleapis@154b410 Source-Link: https://github.com/googleapis/googleapis-gen/commit/d49c3ee9406fef608206d54e4259afa3c9e8c0c9 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZDQ5YzNlZTk0MDZmZWY2MDgyMDZkNTRlNDI1OWFmYTNjOWU4YzBjOSJ9
1 parent 4d4cb6a commit 96ca781

File tree

126 files changed

+9601
-73
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

126 files changed

+9601
-73
lines changed

google-cloud-pubsublite/src/test/java/com/google/cloud/pubsublite/v1/AdminServiceClientTest.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@
3636
import com.google.cloud.pubsublite.proto.DeleteReservationRequest;
3737
import com.google.cloud.pubsublite.proto.DeleteSubscriptionRequest;
3838
import com.google.cloud.pubsublite.proto.DeleteTopicRequest;
39+
import com.google.cloud.pubsublite.proto.ExportConfig;
3940
import com.google.cloud.pubsublite.proto.GetReservationRequest;
4041
import com.google.cloud.pubsublite.proto.GetSubscriptionRequest;
4142
import com.google.cloud.pubsublite.proto.GetTopicPartitionsRequest;
@@ -666,6 +667,7 @@ public void createSubscriptionTest() throws Exception {
666667
.setName(SubscriptionName.of("[PROJECT]", "[LOCATION]", "[SUBSCRIPTION]").toString())
667668
.setTopic(TopicName.of("[PROJECT]", "[LOCATION]", "[TOPIC]").toString())
668669
.setDeliveryConfig(Subscription.DeliveryConfig.newBuilder().build())
670+
.setExportConfig(ExportConfig.newBuilder().build())
669671
.build();
670672
mockAdminService.addResponse(expectedResponse);
671673

@@ -712,6 +714,7 @@ public void createSubscriptionTest2() throws Exception {
712714
.setName(SubscriptionName.of("[PROJECT]", "[LOCATION]", "[SUBSCRIPTION]").toString())
713715
.setTopic(TopicName.of("[PROJECT]", "[LOCATION]", "[TOPIC]").toString())
714716
.setDeliveryConfig(Subscription.DeliveryConfig.newBuilder().build())
717+
.setExportConfig(ExportConfig.newBuilder().build())
715718
.build();
716719
mockAdminService.addResponse(expectedResponse);
717720

@@ -758,6 +761,7 @@ public void getSubscriptionTest() throws Exception {
758761
.setName(SubscriptionName.of("[PROJECT]", "[LOCATION]", "[SUBSCRIPTION]").toString())
759762
.setTopic(TopicName.of("[PROJECT]", "[LOCATION]", "[TOPIC]").toString())
760763
.setDeliveryConfig(Subscription.DeliveryConfig.newBuilder().build())
764+
.setExportConfig(ExportConfig.newBuilder().build())
761765
.build();
762766
mockAdminService.addResponse(expectedResponse);
763767

@@ -798,6 +802,7 @@ public void getSubscriptionTest2() throws Exception {
798802
.setName(SubscriptionName.of("[PROJECT]", "[LOCATION]", "[SUBSCRIPTION]").toString())
799803
.setTopic(TopicName.of("[PROJECT]", "[LOCATION]", "[TOPIC]").toString())
800804
.setDeliveryConfig(Subscription.DeliveryConfig.newBuilder().build())
805+
.setExportConfig(ExportConfig.newBuilder().build())
801806
.build();
802807
mockAdminService.addResponse(expectedResponse);
803808

@@ -926,6 +931,7 @@ public void updateSubscriptionTest() throws Exception {
926931
.setName(SubscriptionName.of("[PROJECT]", "[LOCATION]", "[SUBSCRIPTION]").toString())
927932
.setTopic(TopicName.of("[PROJECT]", "[LOCATION]", "[TOPIC]").toString())
928933
.setDeliveryConfig(Subscription.DeliveryConfig.newBuilder().build())
934+
.setExportConfig(ExportConfig.newBuilder().build())
929935
.build();
930936
mockAdminService.addResponse(expectedResponse);
931937

proto-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/CommonProto.java

Lines changed: 120 additions & 64 deletions
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)