chore: Update generation configuration at Sat Feb 8 02:22:18 UTC 2025 (…

…#2330) * chore: Update generation configuration at Wed Jan 29 02:22:57 UTC 2025 * chore: Update generation configuration at Thu Jan 30 02:22:19 UTC 2025 * chore: Update generation configuration at Fri Jan 31 02:23:28 UTC 2025 * chore: generate libraries at Fri Jan 31 02:24:00 UTC 2025 * chore: Update generation configuration at Mon Feb 3 02:24:21 UTC 2025 * chore: Update generation configuration at Tue Feb 4 02:23:44 UTC 2025 * chore: Update generation configuration at Wed Feb 5 02:24:49 UTC 2025 * chore: generate libraries at Wed Feb 5 02:25:31 UTC 2025 * chore: Update generation configuration at Thu Feb 6 02:25:06 UTC 2025 * chore: Update generation configuration at Fri Feb 7 02:25:37 UTC 2025 * chore: Update generation configuration at Sat Feb 8 02:22:18 UTC 2025
googleapis · Feb 10, 2025 · 3889a05 · 3889a05
1 parent c8a6c52
commit 3889a05
Show file tree

Hide file tree

Showing 25 changed files with 4,044 additions and 417 deletions.
diff --git a/README.md b/README.md
@@ -51,7 +51,7 @@ If you are using Maven without the BOM, add this to your dependencies:
 If you are using Gradle 5.x or later, add this to your dependencies:
 
 ```Groovy
-implementation platform('com.google.cloud:libraries-bom:26.53.0')
+implementation platform('com.google.cloud:libraries-bom:26.54.0')
 
 implementation 'com.google.cloud:google-cloud-pubsub'
 ```

diff --git a/generation_config.yaml b/generation_config.yaml
@@ -1,6 +1,6 @@
 gapic_generator_version: 2.52.0
-googleapis_commitish: 0ce8062889f30daa64eed6810e3c124ccd89608f
-libraries_bom_version: 26.53.0
+googleapis_commitish: 0a459af4362c0e41b9723dd4d7edc022c552db40
+libraries_bom_version: 26.54.0
 libraries:
   - api_shortname: pubsub
     name_pretty: Cloud Pub/Sub

diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java
@@ -880,6 +880,7 @@ public final Subscription createSubscription(
    *           .setTopicMessageRetentionDuration(Duration.newBuilder().build())
    *           .setAnalyticsHubSubscriptionInfo(
    *               Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+   *           .addAllMessageTransforms(new ArrayList<MessageTransform>())
    *           .build();
    *   Subscription response = subscriptionAdminClient.createSubscription(request);
    * }
@@ -1145,6 +1146,7 @@ public final Subscription createSubscription(
    *           .setTopicMessageRetentionDuration(Duration.newBuilder().build())
    *           .setAnalyticsHubSubscriptionInfo(
    *               Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+   *           .addAllMessageTransforms(new ArrayList<MessageTransform>())
    *           .build();
    *   ApiFuture<Subscription> future =
    *       subscriptionAdminClient.createSubscriptionCallable().futureCall(request);

diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java
@@ -516,6 +516,7 @@ public final Topic createTopic(ProjectTopicName name) {
    *           .setSatisfiesPzs(true)
    *           .setMessageRetentionDuration(Duration.newBuilder().build())
    *           .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+   *           .addAllMessageTransforms(new ArrayList<MessageTransform>())
    *           .build();
    *   Topic response = topicAdminClient.createTopic(request);
    * }
@@ -552,6 +553,7 @@ public final Topic createTopic(Topic request) {
    *           .setSatisfiesPzs(true)
    *           .setMessageRetentionDuration(Duration.newBuilder().build())
    *           .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+   *           .addAllMessageTransforms(new ArrayList<MessageTransform>())
    *           .build();
    *   ApiFuture<Topic> future = topicAdminClient.createTopicCallable().futureCall(request);
    *   // Do something.

diff --git a/...b/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json b/...b/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json
@@ -2195,6 +2195,24 @@
     "allDeclaredClasses": true,
     "allPublicClasses": true
   },
+  {
+    "name": "com.google.pubsub.v1.JavaScriptUDF",
+    "queryAllDeclaredConstructors": true,
+    "queryAllPublicConstructors": true,
+    "queryAllDeclaredMethods": true,
+    "allPublicMethods": true,
+    "allDeclaredClasses": true,
+    "allPublicClasses": true
+  },
+  {
+    "name": "com.google.pubsub.v1.JavaScriptUDF$Builder",
+    "queryAllDeclaredConstructors": true,
+    "queryAllPublicConstructors": true,
+    "queryAllDeclaredMethods": true,
+    "allPublicMethods": true,
+    "allDeclaredClasses": true,
+    "allPublicClasses": true
+  },
   {
     "name": "com.google.pubsub.v1.ListSchemaRevisionsRequest",
     "queryAllDeclaredConstructors": true,
@@ -2465,6 +2483,24 @@
     "allDeclaredClasses": true,
     "allPublicClasses": true
   },
+  {
+    "name": "com.google.pubsub.v1.MessageTransform",
+    "queryAllDeclaredConstructors": true,
+    "queryAllPublicConstructors": true,
+    "queryAllDeclaredMethods": true,
+    "allPublicMethods": true,
+    "allDeclaredClasses": true,
+    "allPublicClasses": true
+  },
+  {
+    "name": "com.google.pubsub.v1.MessageTransform$Builder",
+    "queryAllDeclaredConstructors": true,
+    "queryAllPublicConstructors": true,
+    "queryAllDeclaredMethods": true,
+    "allPublicMethods": true,
+    "allDeclaredClasses": true,
+    "allPublicClasses": true
+  },
   {
     "name": "com.google.pubsub.v1.ModifyAckDeadlineRequest",
     "queryAllDeclaredConstructors": true,

diff --git a/...-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientHttpJsonTest.java b/...-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientHttpJsonTest.java
@@ -49,6 +49,7 @@
 import com.google.pubsub.v1.ExpirationPolicy;
 import com.google.pubsub.v1.ListSnapshotsResponse;
 import com.google.pubsub.v1.ListSubscriptionsResponse;
+import com.google.pubsub.v1.MessageTransform;
 import com.google.pubsub.v1.ProjectName;
 import com.google.pubsub.v1.PullResponse;
 import com.google.pubsub.v1.PushConfig;
@@ -133,6 +134,7 @@ public void createSubscriptionTest() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -202,6 +204,7 @@ public void createSubscriptionTest2() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -271,6 +274,7 @@ public void createSubscriptionTest3() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -340,6 +344,7 @@ public void createSubscriptionTest4() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -409,6 +414,7 @@ public void getSubscriptionTest() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -471,6 +477,7 @@ public void getSubscriptionTest2() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -533,6 +540,7 @@ public void updateSubscriptionTest() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -557,6 +565,7 @@ public void updateSubscriptionTest() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     FieldMask updateMask = FieldMask.newBuilder().build();
 
@@ -607,6 +616,7 @@ public void updateSubscriptionExceptionTest() throws Exception {
               .setTopicMessageRetentionDuration(Duration.newBuilder().build())
               .setAnalyticsHubSubscriptionInfo(
                   Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+              .addAllMessageTransforms(new ArrayList<MessageTransform>())
               .build();
       FieldMask updateMask = FieldMask.newBuilder().build();
       client.updateSubscription(subscription, updateMask);

diff --git a/...le-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java b/...le-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java
@@ -59,6 +59,7 @@
 import com.google.pubsub.v1.ListSnapshotsResponse;
 import com.google.pubsub.v1.ListSubscriptionsRequest;
 import com.google.pubsub.v1.ListSubscriptionsResponse;
+import com.google.pubsub.v1.MessageTransform;
 import com.google.pubsub.v1.ModifyAckDeadlineRequest;
 import com.google.pubsub.v1.ModifyPushConfigRequest;
 import com.google.pubsub.v1.ProjectName;
@@ -159,6 +160,7 @@ public void createSubscriptionTest() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockSubscriber.addResponse(expectedResponse);
 
@@ -225,6 +227,7 @@ public void createSubscriptionTest2() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockSubscriber.addResponse(expectedResponse);
 
@@ -291,6 +294,7 @@ public void createSubscriptionTest3() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockSubscriber.addResponse(expectedResponse);
 
@@ -357,6 +361,7 @@ public void createSubscriptionTest4() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockSubscriber.addResponse(expectedResponse);
 
@@ -423,6 +428,7 @@ public void getSubscriptionTest() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockSubscriber.addResponse(expectedResponse);
 
@@ -479,6 +485,7 @@ public void getSubscriptionTest2() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockSubscriber.addResponse(expectedResponse);
 
@@ -535,6 +542,7 @@ public void updateSubscriptionTest() throws Exception {
             .setTopicMessageRetentionDuration(Duration.newBuilder().build())
             .setAnalyticsHubSubscriptionInfo(
                 Subscription.AnalyticsHubSubscriptionInfo.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockSubscriber.addResponse(expectedResponse);
 

diff --git a/...e-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java b/...e-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java
@@ -50,6 +50,7 @@
 import com.google.pubsub.v1.ListTopicSubscriptionsResponse;
 import com.google.pubsub.v1.ListTopicsResponse;
 import com.google.pubsub.v1.MessageStoragePolicy;
+import com.google.pubsub.v1.MessageTransform;
 import com.google.pubsub.v1.ProjectName;
 import com.google.pubsub.v1.PublishResponse;
 import com.google.pubsub.v1.PubsubMessage;
@@ -117,6 +118,7 @@ public void createTopicTest() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -168,6 +170,7 @@ public void createTopicTest2() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -219,6 +222,7 @@ public void updateTopicTest() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -232,6 +236,7 @@ public void updateTopicTest() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     FieldMask updateMask = FieldMask.newBuilder().build();
 
@@ -271,6 +276,7 @@ public void updateTopicExceptionTest() throws Exception {
               .setSatisfiesPzs(true)
               .setMessageRetentionDuration(Duration.newBuilder().build())
               .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+              .addAllMessageTransforms(new ArrayList<MessageTransform>())
               .build();
       FieldMask updateMask = FieldMask.newBuilder().build();
       client.updateTopic(topic, updateMask);
@@ -380,6 +386,7 @@ public void getTopicTest() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 
@@ -431,6 +438,7 @@ public void getTopicTest2() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockService.addResponse(expectedResponse);
 

diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java
@@ -53,6 +53,7 @@
 import com.google.pubsub.v1.ListTopicsRequest;
 import com.google.pubsub.v1.ListTopicsResponse;
 import com.google.pubsub.v1.MessageStoragePolicy;
+import com.google.pubsub.v1.MessageTransform;
 import com.google.pubsub.v1.ProjectName;
 import com.google.pubsub.v1.PublishRequest;
 import com.google.pubsub.v1.PublishResponse;
@@ -131,6 +132,7 @@ public void createTopicTest() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockPublisher.addResponse(expectedResponse);
 
@@ -176,6 +178,7 @@ public void createTopicTest2() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockPublisher.addResponse(expectedResponse);
 
@@ -221,6 +224,7 @@ public void updateTopicTest() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockPublisher.addResponse(expectedResponse);
 
@@ -347,6 +351,7 @@ public void getTopicTest() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockPublisher.addResponse(expectedResponse);
 
@@ -392,6 +397,7 @@ public void getTopicTest2() throws Exception {
             .setSatisfiesPzs(true)
             .setMessageRetentionDuration(Duration.newBuilder().build())
             .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
+            .addAllMessageTransforms(new ArrayList<MessageTransform>())
             .build();
     mockPublisher.addResponse(expectedResponse);