chore: generate libraries at Fri Jan 31 02:24:00 UTC 2025

googleapis · Jan 31, 2025 · 85b66ff · 85b66ff
1 parent 0ab63f9
commit 85b66ff
Show file tree

Hide file tree

Showing 23 changed files with 4,014 additions and 415 deletions.
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);