googleapis · yoshi-code-bot · Feb 19, 2026
@@ -22,7 +22,7 @@ Add the following lines to your `pom.xml` file:
     <dependency>
       <groupId>com.google.apis</groupId>
       <artifactId>google-api-services-pubsub</artifactId>
-      <version>v1-rev20251212-2.0.0</version>
+      <version>v1-rev20260116-2.0.0</version>
     </dependency>
   </dependencies>
 </project>
@@ -35,7 +35,7 @@ repositories {
   mavenCentral()
 }
 dependencies {
-  implementation 'com.google.apis:google-api-services-pubsub:v1-rev20251212-2.0.0'
+  implementation 'com.google.apis:google-api-services-pubsub:v1-rev20260116-2.0.0'
 }
 ```
 

@@ -0,0 +1,135 @@
+/*
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/*
+ * This code was generated by https://github.com/googleapis/google-api-java-client-services/
+ * Modify at your own risk.
+ */
+
+package com.google.api.services.pubsub.model;
+
+/**
+ * Configuration for making inference requests against Vertex AI models.
+ *
+ * <p> This is the Java data model class that specifies how to parse/serialize into the JSON that is
+ * transmitted over HTTP when working with the Cloud Pub/Sub API. For a detailed explanation see:
+ * <a href="https://developers.google.com/api-client-library/java/google-http-java-client/json">https://developers.google.com/api-client-library/java/google-http-java-client/json</a>
+ * </p>
+ *
+ * @author Google, Inc.
+ */
+@SuppressWarnings("javadoc")
+public final class AIInference extends com.google.api.client.json.GenericJson {
+
+  /**
+   * Required. An endpoint to a Vertex AI model of the form
+   * `projects/{project}/locations/{location}/endpoints/{endpoint}` or
+   * `projects/{project}/locations/{location}/publishers/{publisher}/models/{model}`. Vertex AI API
+   * requests will be sent to this endpoint.
+   * The value may be {@code null}.
+   */
+  @com.google.api.client.util.Key
+  private java.lang.String endpoint;
+
+  /**
+   * Optional. The service account to use to make prediction requests against endpoints. The
+   * resource creator or updater that specifies this field must have `iam.serviceAccounts.actAs`
+   * permission on the service account. If not specified, the Pub/Sub [service
+   * agent]({$universe.dns_names.final_documentation_domain}/iam/docs/service-agents),
+   * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+   * The value may be {@code null}.
+   */
+  @com.google.api.client.util.Key
+  private java.lang.String serviceAccountEmail;
+
+  /**
+   * Optional. Requests and responses can be any arbitrary JSON object.
+   * The value may be {@code null}.
+   */
+  @com.google.api.client.util.Key
+  private UnstructuredInference unstructuredInference;
+
+  /**
+   * Required. An endpoint to a Vertex AI model of the form
+   * `projects/{project}/locations/{location}/endpoints/{endpoint}` or
+   * `projects/{project}/locations/{location}/publishers/{publisher}/models/{model}`. Vertex AI API
+   * requests will be sent to this endpoint.
+   * @return value or {@code null} for none
+   */
+  public java.lang.String getEndpoint() {
+    return endpoint;
+  }
+
+  /**
+   * Required. An endpoint to a Vertex AI model of the form
+   * `projects/{project}/locations/{location}/endpoints/{endpoint}` or
+   * `projects/{project}/locations/{location}/publishers/{publisher}/models/{model}`. Vertex AI API
+   * requests will be sent to this endpoint.
+   * @param endpoint endpoint or {@code null} for none
+   */
+  public AIInference setEndpoint(java.lang.String endpoint) {
+    this.endpoint = endpoint;
+    return this;
+  }
+
+  /**
+   * Optional. The service account to use to make prediction requests against endpoints. The
+   * resource creator or updater that specifies this field must have `iam.serviceAccounts.actAs`
+   * permission on the service account. If not specified, the Pub/Sub [service
+   * agent]({$universe.dns_names.final_documentation_domain}/iam/docs/service-agents),
+   * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+   * @return value or {@code null} for none
+   */
+  public java.lang.String getServiceAccountEmail() {
+    return serviceAccountEmail;
+  }
+
+  /**
+   * Optional. The service account to use to make prediction requests against endpoints. The
+   * resource creator or updater that specifies this field must have `iam.serviceAccounts.actAs`
+   * permission on the service account. If not specified, the Pub/Sub [service
+   * agent]({$universe.dns_names.final_documentation_domain}/iam/docs/service-agents),
+   * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+   * @param serviceAccountEmail serviceAccountEmail or {@code null} for none
+   */
+  public AIInference setServiceAccountEmail(java.lang.String serviceAccountEmail) {
+    this.serviceAccountEmail = serviceAccountEmail;
+    return this;
+  }
+
+  /**
+   * Optional. Requests and responses can be any arbitrary JSON object.
+   * @return value or {@code null} for none
+   */
+  public UnstructuredInference getUnstructuredInference() {
+    return unstructuredInference;
+  }
+
+  /**
+   * Optional. Requests and responses can be any arbitrary JSON object.
+   * @param unstructuredInference unstructuredInference or {@code null} for none
+   */
+  public AIInference setUnstructuredInference(UnstructuredInference unstructuredInference) {
+    this.unstructuredInference = unstructuredInference;
+    return this;
+  }
+
+  @Override
+  public AIInference set(String fieldName, Object value) {
+    return (AIInference) super.set(fieldName, value);
+  }
+
+  @Override
+  public AIInference clone() {
+    return (AIInference) super.clone();
+  }
+
+}
@@ -37,12 +37,12 @@ public final class CreateSnapshotRequest extends com.google.api.client.json.Gene
   private java.util.Map<String, java.lang.String> labels;
 
   /**
-   * Required. Identifier. The subscription whose backlog the snapshot retains. Specifically, the
-   * created snapshot is guaranteed to retain: (a) The existing backlog on the subscription. More
-   * precisely, this is defined as the messages in the subscription's backlog that are
-   * unacknowledged upon the successful completion of the `CreateSnapshot` request; as well as: (b)
-   * Any messages published to the subscription's topic following the successful completion of the
-   * CreateSnapshot request. Format is `projects/{project}/subscriptions/{sub}`.
+   * Required. The subscription whose backlog the snapshot retains. Specifically, the created
+   * snapshot is guaranteed to retain: (a) The existing backlog on the subscription. More precisely,
+   * this is defined as the messages in the subscription's backlog that are unacknowledged upon the
+   * successful completion of the `CreateSnapshot` request; as well as: (b) Any messages published
+   * to the subscription's topic following the successful completion of the CreateSnapshot request.
+   * Format is `projects/{project}/subscriptions/{sub}`.
    * The value may be {@code null}.
    */
   @com.google.api.client.util.Key
@@ -74,25 +74,25 @@ public CreateSnapshotRequest setLabels(java.util.Map<String, java.lang.String> l
   }
 
   /**
-   * Required. Identifier. The subscription whose backlog the snapshot retains. Specifically, the
-   * created snapshot is guaranteed to retain: (a) The existing backlog on the subscription. More
-   * precisely, this is defined as the messages in the subscription's backlog that are
-   * unacknowledged upon the successful completion of the `CreateSnapshot` request; as well as: (b)
-   * Any messages published to the subscription's topic following the successful completion of the
-   * CreateSnapshot request. Format is `projects/{project}/subscriptions/{sub}`.
+   * Required. The subscription whose backlog the snapshot retains. Specifically, the created
+   * snapshot is guaranteed to retain: (a) The existing backlog on the subscription. More precisely,
+   * this is defined as the messages in the subscription's backlog that are unacknowledged upon the
+   * successful completion of the `CreateSnapshot` request; as well as: (b) Any messages published
+   * to the subscription's topic following the successful completion of the CreateSnapshot request.
+   * Format is `projects/{project}/subscriptions/{sub}`.
    * @return value or {@code null} for none
    */
   public java.lang.String getSubscription() {
     return subscription;
   }
 
   /**
-   * Required. Identifier. The subscription whose backlog the snapshot retains. Specifically, the
-   * created snapshot is guaranteed to retain: (a) The existing backlog on the subscription. More
-   * precisely, this is defined as the messages in the subscription's backlog that are
-   * unacknowledged upon the successful completion of the `CreateSnapshot` request; as well as: (b)
-   * Any messages published to the subscription's topic following the successful completion of the
-   * CreateSnapshot request. Format is `projects/{project}/subscriptions/{sub}`.
+   * Required. The subscription whose backlog the snapshot retains. Specifically, the created
+   * snapshot is guaranteed to retain: (a) The existing backlog on the subscription. More precisely,
+   * this is defined as the messages in the subscription's backlog that are unacknowledged upon the
+   * successful completion of the `CreateSnapshot` request; as well as: (b) Any messages published
+   * to the subscription's topic following the successful completion of the CreateSnapshot request.
+   * Format is `projects/{project}/subscriptions/{sub}`.
    * @param subscription subscription or {@code null} for none
    */
   public CreateSnapshotRequest setSubscription(java.lang.String subscription) {

@@ -29,6 +29,14 @@
 @SuppressWarnings("javadoc")
 public final class MessageTransform extends com.google.api.client.json.GenericJson {
 
+  /**
+   * Optional. AI Inference. Specifies the Vertex AI endpoint that inference requests built from the
+   * Pub/Sub message data and provided parameters will be sent to.
+   * The value may be {@code null}.
+   */
+  @com.google.api.client.util.Key
+  private AIInference aiInference;
+
   /**
    * Optional. If true, the transform is disabled and will not be applied to messages. Defaults to
    * `false`.
@@ -52,6 +60,25 @@ public final class MessageTransform extends com.google.api.client.json.GenericJs
   @com.google.api.client.util.Key
   private JavaScriptUDF javascriptUdf;
 
+  /**
+   * Optional. AI Inference. Specifies the Vertex AI endpoint that inference requests built from the
+   * Pub/Sub message data and provided parameters will be sent to.
+   * @return value or {@code null} for none
+   */
+  public AIInference getAiInference() {
+    return aiInference;
+  }
+
+  /**
+   * Optional. AI Inference. Specifies the Vertex AI endpoint that inference requests built from the
+   * Pub/Sub message data and provided parameters will be sent to.
+   * @param aiInference aiInference or {@code null} for none
+   */
+  public MessageTransform setAiInference(AIInference aiInference) {
+    this.aiInference = aiInference;
+    return this;
+  }
+
   /**
    * Optional. If true, the transform is disabled and will not be applied to messages. Defaults to
    * `false`.

@@ -51,7 +51,7 @@ public final class Subscription extends com.google.api.client.json.GenericJson {
 
   /**
    * Output only. Information about the associated Analytics Hub subscription. Only set if the
-   * subscritpion is created by Analytics Hub.
+   * subscription is created by Analytics Hub.
    * The value may be {@code null}.
    */
   @com.google.api.client.util.Key
@@ -225,9 +225,9 @@ public final class Subscription extends com.google.api.client.json.GenericJson {
   private java.util.Map<String, java.lang.String> tags;
 
   /**
-   * Required. Identifier. The name of the topic from which this subscription is receiving messages.
-   * Format is `projects/{project}/topics/{topic}`. The value of this field will be `_deleted-
-   * topic_` if the topic has been deleted.
+   * Required. The name of the topic from which this subscription is receiving messages. Format is
+   * `projects/{project}/topics/{topic}`. The value of this field will be `_deleted-topic_` if the
+   * topic has been deleted.
    * The value may be {@code null}.
    */
   @com.google.api.client.util.Key
@@ -285,7 +285,7 @@ public Subscription setAckDeadlineSeconds(java.lang.Integer ackDeadlineSeconds)
 
   /**
    * Output only. Information about the associated Analytics Hub subscription. Only set if the
-   * subscritpion is created by Analytics Hub.
+   * subscription is created by Analytics Hub.
    * @return value or {@code null} for none
    */
   public AnalyticsHubSubscriptionInfo getAnalyticsHubSubscriptionInfo() {
@@ -294,7 +294,7 @@ public AnalyticsHubSubscriptionInfo getAnalyticsHubSubscriptionInfo() {
 
   /**
    * Output only. Information about the associated Analytics Hub subscription. Only set if the
-   * subscritpion is created by Analytics Hub.
+   * subscription is created by Analytics Hub.
    * @param analyticsHubSubscriptionInfo analyticsHubSubscriptionInfo or {@code null} for none
    */
   public Subscription setAnalyticsHubSubscriptionInfo(AnalyticsHubSubscriptionInfo analyticsHubSubscriptionInfo) {
@@ -676,19 +676,19 @@ public Subscription setTags(java.util.Map<String, java.lang.String> tags) {
   }
 
   /**
-   * Required. Identifier. The name of the topic from which this subscription is receiving messages.
-   * Format is `projects/{project}/topics/{topic}`. The value of this field will be `_deleted-
-   * topic_` if the topic has been deleted.
+   * Required. The name of the topic from which this subscription is receiving messages. Format is
+   * `projects/{project}/topics/{topic}`. The value of this field will be `_deleted-topic_` if the
+   * topic has been deleted.
    * @return value or {@code null} for none
    */
   public java.lang.String getTopic() {
     return topic;
   }
 
   /**
-   * Required. Identifier. The name of the topic from which this subscription is receiving messages.
-   * Format is `projects/{project}/topics/{topic}`. The value of this field will be `_deleted-
-   * topic_` if the topic has been deleted.
+   * Required. The name of the topic from which this subscription is receiving messages. Format is
+   * `projects/{project}/topics/{topic}`. The value of this field will be `_deleted-topic_` if the
+   * topic has been deleted.
    * @param topic topic or {@code null} for none
    */
   public Subscription setTopic(java.lang.String topic) {

@@ -0,0 +1,69 @@
+/*
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/*
+ * This code was generated by https://github.com/googleapis/google-api-java-client-services/
+ * Modify at your own risk.
+ */
+
+package com.google.api.services.pubsub.model;
+
+/**
+ * Configuration for making inferences using arbitrary JSON payloads.
+ *
+ * <p> This is the Java data model class that specifies how to parse/serialize into the JSON that is
+ * transmitted over HTTP when working with the Cloud Pub/Sub API. For a detailed explanation see:
+ * <a href="https://developers.google.com/api-client-library/java/google-http-java-client/json">https://developers.google.com/api-client-library/java/google-http-java-client/json</a>
+ * </p>
+ *
+ * @author Google, Inc.
+ */
+@SuppressWarnings("javadoc")
+public final class UnstructuredInference extends com.google.api.client.json.GenericJson {
+
+  /**
+   * Optional. A parameters object to be included in each inference request. The parameters object
+   * is combined with the data field of the Pub/Sub message to form the inference request.
+   * The value may be {@code null}.
+   */
+  @com.google.api.client.util.Key
+  private java.util.Map<String, java.lang.Object> parameters;
+
+  /**
+   * Optional. A parameters object to be included in each inference request. The parameters object
+   * is combined with the data field of the Pub/Sub message to form the inference request.
+   * @return value or {@code null} for none
+   */
+  public java.util.Map<String, java.lang.Object> getParameters() {
+    return parameters;
+  }
+
+  /**
+   * Optional. A parameters object to be included in each inference request. The parameters object
+   * is combined with the data field of the Pub/Sub message to form the inference request.
+   * @param parameters parameters or {@code null} for none
+   */
+  public UnstructuredInference setParameters(java.util.Map<String, java.lang.Object> parameters) {
+    this.parameters = parameters;
+    return this;
+  }
+
+  @Override
+  public UnstructuredInference set(String fieldName, Object value) {
+    return (UnstructuredInference) super.set(fieldName, value);
+  }
+
+  @Override
+  public UnstructuredInference clone() {
+    return (UnstructuredInference) super.clone();
+  }
+
+}
@@ -8,8 +8,8 @@
 
   <groupId>com.google.apis</groupId>
   <artifactId>google-api-services-pubsub</artifactId>
-  <version>v1-rev20251212-2.0.0</version>
-  <name>Cloud Pub/Sub API v1-rev20251212-2.0.0</name>
+  <version>v1-rev20260116-2.0.0</version>
+  <name>Cloud Pub/Sub API v1-rev20260116-2.0.0</name>
   <packaging>jar</packaging>
 
   <inceptionYear>2011</inceptionYear>