chore: generate libraries at Thu Mar 14 03:06:02 UTC 2024 (#10541)

* chore: generate libraries at Thu Mar 14 03:06:02 UTC 2024 * add missing dependencies in network management * ignore failing tests for network management * ignore failing tests in service management --------- Co-authored-by: Joe Wang <joewa@google.com>

Author: cloud-java-bot

generation_config.yaml

@@ -1,6 +1,6 @@
 gapic_generator_version: 2.37.0
 protobuf_version: '25.2'
-googleapis_commitish: e960a82d36e3ddaeb62f549dbd4c300e11e240dc
+googleapis_commitish: 65277ddce9caa1cfd1a0eb7ab67980fc73d20b50
 owlbot_cli_image: sha256:623647ee79ac605858d09e60c1382a716c125fb776f69301b72de1cd35d49409
 synthtool_commitish: 6612ab8f3afcd5e292aecd647f0fa68812c9f5b5
 template_excludes:

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

@@ -23,6 +23,7 @@
 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.BidiStreamingCallable;
 import com.google.api.gax.rpc.PageContext;
 import com.google.api.gax.rpc.UnaryCallable;
 import com.google.cloud.aiplatform.v1beta1.stub.FeatureOnlineStoreServiceStub;
@@ -96,6 +97,16 @@
  * </td>
  * </tr>
  * <tr>
+ * <td><p> StreamingFetchFeatureValues</td>
+ * <td><p> Bidirectional streaming RPC to fetch feature values under a FeatureView. Requests may not have a one-to-one mapping to responses and responses may be returned out-of-order to reduce latency.</td>
+ * <td>
+ * <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> streamingFetchFeatureValuesCallable()
+ * </ul>
+ * </td>
+ * </tr>
+ * <tr>
  * <td><p> SearchNearestEntities</td>
  * <td><p> Search the nearest entities under a FeatureView. Search only works for indexable feature view; if a feature view isn't indexable, returns Invalid argument response.</td>
  * <td>
@@ -423,6 +434,45 @@ public final FetchFeatureValuesResponse fetchFeatureValues(FetchFeatureValuesReq
  return stub.fetchFeatureValuesCallable();
  }
 
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Bidirectional streaming RPC to fetch feature values under a FeatureView. Requests may not have
+ * a one-to-one mapping to responses and responses may be returned out-of-order to reduce latency.
+ *
+ * <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 (FeatureOnlineStoreServiceClient featureOnlineStoreServiceClient =
+ * FeatureOnlineStoreServiceClient.create()) {
+ * BidiStream<StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ * bidiStream = featureOnlineStoreServiceClient.streamingFetchFeatureValuesCallable().call();
+ * StreamingFetchFeatureValuesRequest request =
+ * StreamingFetchFeatureValuesRequest.newBuilder()
+ * .setFeatureView(
+ * FeatureViewName.of(
+ * "[PROJECT]", "[LOCATION]", "[FEATURE_ONLINE_STORE]", "[FEATURE_VIEW]")
+ * .toString())
+ * .addAllDataKeys(new ArrayList<FeatureViewDataKey>())
+ * .setDataFormat(FeatureViewDataFormat.forNumber(0))
+ * .build();
+ * bidiStream.send(request);
+ * for (StreamingFetchFeatureValuesResponse response : bidiStream) {
+ * // Do something when a response is received.
+ * }
+ * }
+ * }</pre>
+ */
+ public final BidiStreamingCallable<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesCallable() {
+ return stub.streamingFetchFeatureValuesCallable();
+ }
+
  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
  * Search the nearest entities under a FeatureView. Search only works for indexable feature view;

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

@@ -27,6 +27,7 @@
 import com.google.api.gax.rpc.ClientContext;
 import com.google.api.gax.rpc.ClientSettings;
 import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.StreamingCallSettings;
 import com.google.api.gax.rpc.TransportChannelProvider;
 import com.google.api.gax.rpc.UnaryCallSettings;
 import com.google.cloud.aiplatform.v1beta1.stub.FeatureOnlineStoreServiceStubSettings;
@@ -92,6 +93,14 @@ public class FeatureOnlineStoreServiceSettings
  return ((FeatureOnlineStoreServiceStubSettings) getStubSettings()).fetchFeatureValuesSettings();
  }
 
+ /** Returns the object with the settings used for calls to streamingFetchFeatureValues. */
+ public StreamingCallSettings<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesSettings() {
+ return ((FeatureOnlineStoreServiceStubSettings) getStubSettings())
+ .streamingFetchFeatureValuesSettings();
+ }
+
  /** Returns the object with the settings used for calls to searchNearestEntities. */
  public UnaryCallSettings<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesSettings() {
@@ -229,6 +238,13 @@ public Builder applyToAllUnaryMethods(
  return getStubSettingsBuilder().fetchFeatureValuesSettings();
  }
 
+ /** Returns the builder for the settings used for calls to streamingFetchFeatureValues. */
+ public StreamingCallSettings.Builder<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesSettings() {
+ return getStubSettingsBuilder().streamingFetchFeatureValuesSettings();
+ }
+
  /** Returns the builder for the settings used for calls to searchNearestEntities. */
  public UnaryCallSettings.Builder<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesSettings() {

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

@@ -256,6 +256,9 @@
  "SetIamPolicy": {
  "methods": ["setIamPolicy", "setIamPolicyCallable"]
  },
+ "StreamingFetchFeatureValues": {
+ "methods": ["streamingFetchFeatureValuesCallable"]
+ },
  "TestIamPermissions": {
  "methods": ["testIamPermissions", "testIamPermissionsCallable"]
  }

java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1beta1/stub/FeatureOnlineStoreServiceStub.java

@@ -20,11 +20,14 @@
 
 import com.google.api.core.BetaApi;
 import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.rpc.BidiStreamingCallable;
 import com.google.api.gax.rpc.UnaryCallable;
 import com.google.cloud.aiplatform.v1beta1.FetchFeatureValuesRequest;
 import com.google.cloud.aiplatform.v1beta1.FetchFeatureValuesResponse;
 import com.google.cloud.aiplatform.v1beta1.SearchNearestEntitiesRequest;
 import com.google.cloud.aiplatform.v1beta1.SearchNearestEntitiesResponse;
+import com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesRequest;
+import com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesResponse;
 import com.google.cloud.location.GetLocationRequest;
 import com.google.cloud.location.ListLocationsRequest;
 import com.google.cloud.location.ListLocationsResponse;
@@ -51,6 +54,13 @@ public abstract class FeatureOnlineStoreServiceStub implements BackgroundResourc
  throw new UnsupportedOperationException("Not implemented: fetchFeatureValuesCallable()");
  }
 
+ public BidiStreamingCallable<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: streamingFetchFeatureValuesCallable()");
+ }
+
  public UnaryCallable<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesCallable() {
  throw new UnsupportedOperationException("Not implemented: searchNearestEntitiesCallable()");

java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1beta1/stub/FeatureOnlineStoreServiceStubSettings.java

@@ -36,6 +36,7 @@
 import com.google.api.gax.rpc.PagedListDescriptor;
 import com.google.api.gax.rpc.PagedListResponseFactory;
 import com.google.api.gax.rpc.StatusCode;
+import com.google.api.gax.rpc.StreamingCallSettings;
 import com.google.api.gax.rpc.StubSettings;
 import com.google.api.gax.rpc.TransportChannelProvider;
 import com.google.api.gax.rpc.UnaryCallSettings;
@@ -44,6 +45,8 @@
 import com.google.cloud.aiplatform.v1beta1.FetchFeatureValuesResponse;
 import com.google.cloud.aiplatform.v1beta1.SearchNearestEntitiesRequest;
 import com.google.cloud.aiplatform.v1beta1.SearchNearestEntitiesResponse;
+import com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesRequest;
+import com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesResponse;
 import com.google.cloud.location.GetLocationRequest;
 import com.google.cloud.location.ListLocationsRequest;
 import com.google.cloud.location.ListLocationsResponse;
@@ -109,6 +112,9 @@ public class FeatureOnlineStoreServiceStubSettings
 
  private final UnaryCallSettings<FetchFeatureValuesRequest, FetchFeatureValuesResponse>
  fetchFeatureValuesSettings;
+ private final StreamingCallSettings<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesSettings;
  private final UnaryCallSettings<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesSettings;
  private final PagedCallSettings<
@@ -179,6 +185,13 @@ public ApiFuture<ListLocationsPagedResponse> getFuturePagedResponse(
  return fetchFeatureValuesSettings;
  }
 
+ /** Returns the object with the settings used for calls to streamingFetchFeatureValues. */
+ public StreamingCallSettings<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesSettings() {
+ return streamingFetchFeatureValuesSettings;
+ }
+
  /** Returns the object with the settings used for calls to searchNearestEntities. */
  public UnaryCallSettings<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesSettings() {
@@ -302,6 +315,8 @@ protected FeatureOnlineStoreServiceStubSettings(Builder settingsBuilder) throws
  super(settingsBuilder);
 
  fetchFeatureValuesSettings = settingsBuilder.fetchFeatureValuesSettings().build();
+ streamingFetchFeatureValuesSettings =
+ settingsBuilder.streamingFetchFeatureValuesSettings().build();
  searchNearestEntitiesSettings = settingsBuilder.searchNearestEntitiesSettings().build();
  listLocationsSettings = settingsBuilder.listLocationsSettings().build();
  getLocationSettings = settingsBuilder.getLocationSettings().build();
@@ -316,6 +331,9 @@ public static class Builder
  private final ImmutableList<UnaryCallSettings.Builder<?, ?>> unaryMethodSettingsBuilders;
  private final UnaryCallSettings.Builder<FetchFeatureValuesRequest, FetchFeatureValuesResponse>
  fetchFeatureValuesSettings;
+ private final StreamingCallSettings.Builder<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesSettings;
  private final UnaryCallSettings.Builder<
  SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesSettings;
@@ -355,6 +373,7 @@ protected Builder(ClientContext clientContext) {
  super(clientContext);
 
  fetchFeatureValuesSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ streamingFetchFeatureValuesSettings = StreamingCallSettings.newBuilder();
  searchNearestEntitiesSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
  listLocationsSettings = PagedCallSettings.newBuilder(LIST_LOCATIONS_PAGE_STR_FACT);
  getLocationSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
@@ -378,6 +397,8 @@ protected Builder(FeatureOnlineStoreServiceStubSettings settings) {
  super(settings);
 
  fetchFeatureValuesSettings = settings.fetchFeatureValuesSettings.toBuilder();
+ streamingFetchFeatureValuesSettings =
+ settings.streamingFetchFeatureValuesSettings.toBuilder();
  searchNearestEntitiesSettings = settings.searchNearestEntitiesSettings.toBuilder();
  listLocationsSettings = settings.listLocationsSettings.toBuilder();
  getLocationSettings = settings.getLocationSettings.toBuilder();
@@ -468,6 +489,13 @@ public Builder applyToAllUnaryMethods(
  return fetchFeatureValuesSettings;
  }
 
+ /** Returns the builder for the settings used for calls to streamingFetchFeatureValues. */
+ public StreamingCallSettings.Builder<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesSettings() {
+ return streamingFetchFeatureValuesSettings;
+ }
+
  /** Returns the builder for the settings used for calls to searchNearestEntities. */
  public UnaryCallSettings.Builder<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesSettings() {

java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1beta1/stub/GrpcFeatureOnlineStoreServiceStub.java

@@ -23,13 +23,16 @@
 import com.google.api.gax.core.BackgroundResourceAggregation;
 import com.google.api.gax.grpc.GrpcCallSettings;
 import com.google.api.gax.grpc.GrpcStubCallableFactory;
+import com.google.api.gax.rpc.BidiStreamingCallable;
 import com.google.api.gax.rpc.ClientContext;
 import com.google.api.gax.rpc.RequestParamsBuilder;
 import com.google.api.gax.rpc.UnaryCallable;
 import com.google.cloud.aiplatform.v1beta1.FetchFeatureValuesRequest;
 import com.google.cloud.aiplatform.v1beta1.FetchFeatureValuesResponse;
 import com.google.cloud.aiplatform.v1beta1.SearchNearestEntitiesRequest;
 import com.google.cloud.aiplatform.v1beta1.SearchNearestEntitiesResponse;
+import com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesRequest;
+import com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesResponse;
 import com.google.cloud.location.GetLocationRequest;
 import com.google.cloud.location.ListLocationsRequest;
 import com.google.cloud.location.ListLocationsResponse;
@@ -67,6 +70,20 @@ public class GrpcFeatureOnlineStoreServiceStub extends FeatureOnlineStoreService
  ProtoUtils.marshaller(FetchFeatureValuesResponse.getDefaultInstance()))
  .build();
 
+ private static final MethodDescriptor<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesMethodDescriptor =
+ MethodDescriptor
+ .<StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>newBuilder()
+ .setType(MethodDescriptor.MethodType.BIDI_STREAMING)
+ .setFullMethodName(
+ "google.cloud.aiplatform.v1beta1.FeatureOnlineStoreService/StreamingFetchFeatureValues")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(StreamingFetchFeatureValuesRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(StreamingFetchFeatureValuesResponse.getDefaultInstance()))
+ .build();
+
  private static final MethodDescriptor<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesMethodDescriptor =
  MethodDescriptor.<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>newBuilder()
@@ -127,6 +144,9 @@ public class GrpcFeatureOnlineStoreServiceStub extends FeatureOnlineStoreService
 
  private final UnaryCallable<FetchFeatureValuesRequest, FetchFeatureValuesResponse>
  fetchFeatureValuesCallable;
+ private final BidiStreamingCallable<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesCallable;
  private final UnaryCallable<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesCallable;
  private final UnaryCallable<ListLocationsRequest, ListLocationsResponse> listLocationsCallable;
@@ -194,6 +214,19 @@ protected GrpcFeatureOnlineStoreServiceStub(
  return builder.build();
  })
  .build();
+ GrpcCallSettings<StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesTransportSettings =
+ GrpcCallSettings
+ .<StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ newBuilder()
+ .setMethodDescriptor(streamingFetchFeatureValuesMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("feature_view", String.valueOf(request.getFeatureView()));
+ return builder.build();
+ })
+ .build();
  GrpcCallSettings<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesTransportSettings =
  GrpcCallSettings
@@ -263,6 +296,11 @@ protected GrpcFeatureOnlineStoreServiceStub(
  fetchFeatureValuesTransportSettings,
  settings.fetchFeatureValuesSettings(),
  clientContext);
+ this.streamingFetchFeatureValuesCallable =
+ callableFactory.createBidiStreamingCallable(
+ streamingFetchFeatureValuesTransportSettings,
+ settings.streamingFetchFeatureValuesSettings(),
+ clientContext);
  this.searchNearestEntitiesCallable =
  callableFactory.createUnaryCallable(
  searchNearestEntitiesTransportSettings,
@@ -303,6 +341,13 @@ public GrpcOperationsStub getOperationsStub() {
  return fetchFeatureValuesCallable;
  }
 
+ @Override
+ public BidiStreamingCallable<
+ StreamingFetchFeatureValuesRequest, StreamingFetchFeatureValuesResponse>
+ streamingFetchFeatureValuesCallable() {
+ return streamingFetchFeatureValuesCallable;
+ }
+
  @Override
  public UnaryCallable<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
  searchNearestEntitiesCallable() {

java-aiplatform/google-cloud-aiplatform/src/main/resources/META-INF/native-image/com.google.cloud.aiplatform.v1beta1/reflect-config.json

@@ -13076,6 +13076,42 @@
  "allDeclaredClasses": true,
  "allPublicClasses": true
  },
+ {
+ "name": "com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesResponse",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.aiplatform.v1beta1.StreamingFetchFeatureValuesResponse$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
  {
  "name": "com.google.cloud.aiplatform.v1beta1.StreamingPredictRequest",
  "queryAllDeclaredConstructors": true,