googleapis
diff --git a/‎generation_config.yaml‎
Lines changed: 2 additions & 2 deletions b/‎generation_config.yaml‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎java-accessapproval/README.md‎
Lines changed: 1 addition & 1 deletion b/‎java-accessapproval/README.md‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎java-accesscontextmanager/README.md‎
Lines changed: 1 addition & 1 deletion b/‎java-accesscontextmanager/README.md‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎java-advisorynotifications/README.md‎
Lines changed: 1 addition & 1 deletion b/‎java-advisorynotifications/README.md‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎java-aiplatform/README.md‎
Lines changed: 1 addition & 1 deletion b/‎java-aiplatform/README.md‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ReasoningEngineExecutionServiceClient.java‎
Lines changed: 142 additions & 0 deletions b/‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ReasoningEngineExecutionServiceClient.java‎
Lines changed: 142 additions & 0 deletions
diff --git a/‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ReasoningEngineExecutionServiceSettings.java‎
Lines changed: 60 additions & 0 deletions b/‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/ReasoningEngineExecutionServiceSettings.java‎
Lines changed: 60 additions & 0 deletions
diff --git a/‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/gapic_metadata.json‎
Lines changed: 3 additions & 0 deletions b/‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/gapic_metadata.json‎
Lines changed: 3 additions & 0 deletions
@@ -1,5 +1,5 @@
-googleapis_commitish: 62e4ecb2f4390728990514fea14aad0431881a52
-libraries_bom_version: 26.79.0
+googleapis_commitish: 260e3f5d5dcf9692c77d14b01b47c16ef01837e9
+libraries_bom_version: 26.80.0
 is_monorepo: true
 libraries:
 - api_shortname: accessapproval
 
@@ -20,7 +20,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file:
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>libraries-bom</artifactId>
-      <version>26.79.0</version>
+      <version>26.80.0</version>
       <type>pom</type>
       <scope>import</scope>
     </dependency>
 
@@ -20,7 +20,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file:
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>libraries-bom</artifactId>
-      <version>26.79.0</version>
+      <version>26.80.0</version>
       <type>pom</type>
       <scope>import</scope>
     </dependency>
 
@@ -20,7 +20,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file:
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>libraries-bom</artifactId>
-      <version>26.79.0</version>
+      <version>26.80.0</version>
       <type>pom</type>
       <scope>import</scope>
     </dependency>
 
@@ -20,7 +20,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file:
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>libraries-bom</artifactId>
-      <version>26.79.0</version>
+      <version>26.80.0</version>
       <type>pom</type>
       <scope>import</scope>
     </dependency>
 
@@ -20,9 +20,11 @@
 import com.google.api.core.ApiFuture;
 import com.google.api.core.ApiFutures;
 import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.longrunning.OperationFuture;
 import com.google.api.gax.paging.AbstractFixedSizeCollection;
 import com.google.api.gax.paging.AbstractPage;
 import com.google.api.gax.paging.AbstractPagedListResponse;
+import com.google.api.gax.rpc.OperationCallable;
 import com.google.api.gax.rpc.PageContext;
 import com.google.api.gax.rpc.ServerStreamingCallable;
 import com.google.api.gax.rpc.UnaryCallable;
@@ -38,6 +40,8 @@
 import com.google.iam.v1.SetIamPolicyRequest;
 import com.google.iam.v1.TestIamPermissionsRequest;
 import com.google.iam.v1.TestIamPermissionsResponse;
+import com.google.longrunning.Operation;
+import com.google.longrunning.OperationsClient;
 import java.io.IOException;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
@@ -107,6 +111,21 @@
  *       </td>
  *    </tr>
  *    <tr>
+ *      <td><p> AsyncQueryReasoningEngine</td>
+ *      <td><p> Async query using a reasoning engine.</td>
+ *      <td>
+ *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
+ *      <ul>
+ *           <li><p> asyncQueryReasoningEngineAsync(AsyncQueryReasoningEngineRequest request)
+ *      </ul>
+ *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
+ *      <ul>
+ *           <li><p> asyncQueryReasoningEngineOperationCallable()
+ *           <li><p> asyncQueryReasoningEngineCallable()
+ *      </ul>
+ *       </td>
+ *    </tr>
+ *    <tr>
  *      <td><p> ListLocations</td>
  *      <td><p> Lists information about the supported locations for this service.</td>
  *      <td>
@@ -226,6 +245,7 @@
 public class ReasoningEngineExecutionServiceClient implements BackgroundResource {
   private final ReasoningEngineExecutionServiceSettings settings;
   private final ReasoningEngineExecutionServiceStub stub;
+  private final OperationsClient operationsClient;
 
   /** Constructs an instance of ReasoningEngineExecutionServiceClient with default settings. */
   public static final ReasoningEngineExecutionServiceClient create() throws IOException {
@@ -262,11 +282,13 @@ protected ReasoningEngineExecutionServiceClient(ReasoningEngineExecutionServiceS
     this.settings = settings;
     this.stub =
         ((ReasoningEngineExecutionServiceStubSettings) settings.getStubSettings()).createStub();
+    this.operationsClient = OperationsClient.create(this.stub.getOperationsStub());
   }
 
   protected ReasoningEngineExecutionServiceClient(ReasoningEngineExecutionServiceStub stub) {
     this.settings = null;
     this.stub = stub;
+    this.operationsClient = OperationsClient.create(this.stub.getOperationsStub());
   }
 
   public final ReasoningEngineExecutionServiceSettings getSettings() {
@@ -277,6 +299,14 @@ public ReasoningEngineExecutionServiceStub getStub() {
     return stub;
   }
 
+  /**
+   * Returns the OperationsClient that can be used to query the status of a long-running operation
+   * returned by another API method call.
+   */
+  public final OperationsClient getOperationsClient() {
+    return operationsClient;
+  }
+
   // AUTO-GENERATED DOCUMENTATION AND METHOD.
   /**
    * Queries using a reasoning engine.
@@ -381,6 +411,118 @@ public final QueryReasoningEngineResponse queryReasoningEngine(
     return stub.streamQueryReasoningEngineCallable();
   }
 
+  // AUTO-GENERATED DOCUMENTATION AND METHOD.
+  /**
+   * Async query using a reasoning engine.
+   *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * // This snippet has been automatically generated and should be regarded as a code template only.
+   * // It will require modifications to work:
+   * // - It may require correct/in-range values for request initialization.
+   * // - It may require specifying regional endpoints when creating the service client as shown in
+   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+   * try (ReasoningEngineExecutionServiceClient reasoningEngineExecutionServiceClient =
+   *     ReasoningEngineExecutionServiceClient.create()) {
+   *   AsyncQueryReasoningEngineRequest request =
+   *       AsyncQueryReasoningEngineRequest.newBuilder()
+   *           .setName(
+   *               ReasoningEngineName.of("[PROJECT]", "[LOCATION]", "[REASONING_ENGINE]")
+   *                   .toString())
+   *           .setInputGcsUri("inputGcsUri-665217217")
+   *           .setOutputGcsUri("outputGcsUri-489598154")
+   *           .build();
+   *   AsyncQueryReasoningEngineResponse response =
+   *       reasoningEngineExecutionServiceClient.asyncQueryReasoningEngineAsync(request).get();
+   * }
+   * }</pre>
+   *
+   * @param request The request object containing all of the parameters for the API call.
+   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+   */
+  public final OperationFuture<
+          AsyncQueryReasoningEngineResponse, AsyncQueryReasoningEngineOperationMetadata>
+      asyncQueryReasoningEngineAsync(AsyncQueryReasoningEngineRequest request) {
+    return asyncQueryReasoningEngineOperationCallable().futureCall(request);
+  }
+
+  // AUTO-GENERATED DOCUMENTATION AND METHOD.
+  /**
+   * Async query using a reasoning engine.
+   *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * // This snippet has been automatically generated and should be regarded as a code template only.
+   * // It will require modifications to work:
+   * // - It may require correct/in-range values for request initialization.
+   * // - It may require specifying regional endpoints when creating the service client as shown in
+   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+   * try (ReasoningEngineExecutionServiceClient reasoningEngineExecutionServiceClient =
+   *     ReasoningEngineExecutionServiceClient.create()) {
+   *   AsyncQueryReasoningEngineRequest request =
+   *       AsyncQueryReasoningEngineRequest.newBuilder()
+   *           .setName(
+   *               ReasoningEngineName.of("[PROJECT]", "[LOCATION]", "[REASONING_ENGINE]")
+   *                   .toString())
+   *           .setInputGcsUri("inputGcsUri-665217217")
+   *           .setOutputGcsUri("outputGcsUri-489598154")
+   *           .build();
+   *   OperationFuture<AsyncQueryReasoningEngineResponse, AsyncQueryReasoningEngineOperationMetadata>
+   *       future =
+   *           reasoningEngineExecutionServiceClient
+   *               .asyncQueryReasoningEngineOperationCallable()
+   *               .futureCall(request);
+   *   // Do something.
+   *   AsyncQueryReasoningEngineResponse response = future.get();
+   * }
+   * }</pre>
+   */
+  public final OperationCallable<
+          AsyncQueryReasoningEngineRequest,
+          AsyncQueryReasoningEngineResponse,
+          AsyncQueryReasoningEngineOperationMetadata>
+      asyncQueryReasoningEngineOperationCallable() {
+    return stub.asyncQueryReasoningEngineOperationCallable();
+  }
+
+  // AUTO-GENERATED DOCUMENTATION AND METHOD.
+  /**
+   * Async query using a reasoning engine.
+   *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * // This snippet has been automatically generated and should be regarded as a code template only.
+   * // It will require modifications to work:
+   * // - It may require correct/in-range values for request initialization.
+   * // - It may require specifying regional endpoints when creating the service client as shown in
+   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+   * try (ReasoningEngineExecutionServiceClient reasoningEngineExecutionServiceClient =
+   *     ReasoningEngineExecutionServiceClient.create()) {
+   *   AsyncQueryReasoningEngineRequest request =
+   *       AsyncQueryReasoningEngineRequest.newBuilder()
+   *           .setName(
+   *               ReasoningEngineName.of("[PROJECT]", "[LOCATION]", "[REASONING_ENGINE]")
+   *                   .toString())
+   *           .setInputGcsUri("inputGcsUri-665217217")
+   *           .setOutputGcsUri("outputGcsUri-489598154")
+   *           .build();
+   *   ApiFuture<Operation> future =
+   *       reasoningEngineExecutionServiceClient
+   *           .asyncQueryReasoningEngineCallable()
+   *           .futureCall(request);
+   *   // Do something.
+   *   Operation response = future.get();
+   * }
+   * }</pre>
+   */
+  public final UnaryCallable<AsyncQueryReasoningEngineRequest, Operation>
+      asyncQueryReasoningEngineCallable() {
+    return stub.asyncQueryReasoningEngineCallable();
+  }
+
   // AUTO-GENERATED DOCUMENTATION AND METHOD.
   /**
    * Lists information about the supported locations for this service.
 
@@ -26,6 +26,7 @@
 import com.google.api.gax.rpc.ApiClientHeaderProvider;
 import com.google.api.gax.rpc.ClientContext;
 import com.google.api.gax.rpc.ClientSettings;
+import com.google.api.gax.rpc.OperationCallSettings;
 import com.google.api.gax.rpc.PagedCallSettings;
 import com.google.api.gax.rpc.ServerStreamingCallSettings;
 import com.google.api.gax.rpc.TransportChannelProvider;
@@ -40,6 +41,7 @@
 import com.google.iam.v1.SetIamPolicyRequest;
 import com.google.iam.v1.TestIamPermissionsRequest;
 import com.google.iam.v1.TestIamPermissionsResponse;
+import com.google.longrunning.Operation;
 import java.io.IOException;
 import java.util.List;
 import javax.annotation.Generated;
@@ -94,6 +96,32 @@
  * Please refer to the [Client Side Retry
  * Guide](https://docs.cloud.google.com/java/docs/client-retries) for additional support in setting
  * retries.
+ *
+ * <p>To configure the RetrySettings of a Long Running Operation method, create an
+ * OperationTimedPollAlgorithm object and update the RPC's polling algorithm. For example, to
+ * configure the RetrySettings for asyncQueryReasoningEngine:
+ *
+ * <pre>{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * ReasoningEngineExecutionServiceSettings.Builder reasoningEngineExecutionServiceSettingsBuilder =
+ *     ReasoningEngineExecutionServiceSettings.newBuilder();
+ * TimedRetryAlgorithm timedRetryAlgorithm =
+ *     OperationalTimedPollAlgorithm.create(
+ *         RetrySettings.newBuilder()
+ *             .setInitialRetryDelayDuration(Duration.ofMillis(500))
+ *             .setRetryDelayMultiplier(1.5)
+ *             .setMaxRetryDelayDuration(Duration.ofMillis(5000))
+ *             .setTotalTimeoutDuration(Duration.ofHours(24))
+ *             .build());
+ * reasoningEngineExecutionServiceSettingsBuilder
+ *     .createClusterOperationSettings()
+ *     .setPollingAlgorithm(timedRetryAlgorithm)
+ *     .build();
+ * }</pre>
  */
 @Generated("by gapic-generator-java")
 public class ReasoningEngineExecutionServiceSettings
@@ -113,6 +141,23 @@ public class ReasoningEngineExecutionServiceSettings
         .streamQueryReasoningEngineSettings();
   }
 
+  /** Returns the object with the settings used for calls to asyncQueryReasoningEngine. */
+  public UnaryCallSettings<AsyncQueryReasoningEngineRequest, Operation>
+      asyncQueryReasoningEngineSettings() {
+    return ((ReasoningEngineExecutionServiceStubSettings) getStubSettings())
+        .asyncQueryReasoningEngineSettings();
+  }
+
+  /** Returns the object with the settings used for calls to asyncQueryReasoningEngine. */
+  public OperationCallSettings<
+          AsyncQueryReasoningEngineRequest,
+          AsyncQueryReasoningEngineResponse,
+          AsyncQueryReasoningEngineOperationMetadata>
+      asyncQueryReasoningEngineOperationSettings() {
+    return ((ReasoningEngineExecutionServiceStubSettings) getStubSettings())
+        .asyncQueryReasoningEngineOperationSettings();
+  }
+
   /** Returns the object with the settings used for calls to listLocations. */
   public PagedCallSettings<ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
       listLocationsSettings() {
@@ -251,6 +296,21 @@ public Builder applyToAllUnaryMethods(
       return getStubSettingsBuilder().streamQueryReasoningEngineSettings();
     }
 
+    /** Returns the builder for the settings used for calls to asyncQueryReasoningEngine. */
+    public UnaryCallSettings.Builder<AsyncQueryReasoningEngineRequest, Operation>
+        asyncQueryReasoningEngineSettings() {
+      return getStubSettingsBuilder().asyncQueryReasoningEngineSettings();
+    }
+
+    /** Returns the builder for the settings used for calls to asyncQueryReasoningEngine. */
+    public OperationCallSettings.Builder<
+            AsyncQueryReasoningEngineRequest,
+            AsyncQueryReasoningEngineResponse,
+            AsyncQueryReasoningEngineOperationMetadata>
+        asyncQueryReasoningEngineOperationSettings() {
+      return getStubSettingsBuilder().asyncQueryReasoningEngineOperationSettings();
+    }
+
     /** Returns the builder for the settings used for calls to listLocations. */
     public PagedCallSettings.Builder<
             ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
 
@@ -1375,6 +1375,9 @@
         "grpc": {
           "libraryClient": "ReasoningEngineExecutionServiceClient",
           "rpcs": {
+            "AsyncQueryReasoningEngine": {
+              "methods": ["asyncQueryReasoningEngineAsync", "asyncQueryReasoningEngineOperationCallable", "asyncQueryReasoningEngineCallable"]
+            },
             "GetIamPolicy": {
               "methods": ["getIamPolicy", "getIamPolicyCallable"]
             },