chore: generate libraries at Tue Apr 21 03:03:54 UTC 2026

Author: cloud-java-bot

java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1beta1/ReasoningEngineExecutionServiceClient.java

@@ -21,9 +21,11 @@
 import com.google.api.core.ApiFutures;
 import com.google.api.core.BetaApi;
 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;
@@ -39,6 +41,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;
@@ -108,6 +112,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>
@@ -228,6 +247,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 {
@@ -264,11 +284,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() {
@@ -279,6 +301,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.
@@ -383,6 +413,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.

java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1beta1/ReasoningEngineExecutionServiceSettings.java

@@ -27,6 +27,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;
@@ -41,6 +42,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;
@@ -95,6 +97,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>
  */
 @BetaApi
 @Generated("by gapic-generator-java")
@@ -115,6 +143,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() {
@@ -253,6 +298,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>

java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1beta1/gapic_metadata.json

@@ -1636,6 +1636,9 @@
         "grpc": {
           "libraryClient": "ReasoningEngineExecutionServiceClient",
           "rpcs": {
+            "AsyncQueryReasoningEngine": {
+              "methods": ["asyncQueryReasoningEngineAsync", "asyncQueryReasoningEngineOperationCallable", "asyncQueryReasoningEngineCallable"]
+            },
             "GetIamPolicy": {
               "methods": ["getIamPolicy", "getIamPolicyCallable"]
             },