{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]"); * Dataset response = datasetServiceClient.getDataset(name); @@ -83,6 +93,8 @@ *To customize credentials: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * DatasetServiceSettings datasetServiceSettings = * DatasetServiceSettings.newBuilder() * .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials)) @@ -93,6 +105,8 @@ *To customize the endpoint: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * DatasetServiceSettings datasetServiceSettings = * DatasetServiceSettings.newBuilder().setEndpoint(myEndpoint).build(); * DatasetServiceClient datasetServiceClient = DatasetServiceClient.create(datasetServiceSettings); @@ -124,7 +138,6 @@ public static final DatasetServiceClient create(DatasetServiceSettings settings) * Constructs an instance of DatasetServiceClient, using the given stub for making calls. This is * for advanced usage - prefer using create(DatasetServiceSettings). */ - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") public static final DatasetServiceClient create(DatasetServiceStub stub) { return new DatasetServiceClient(stub); } @@ -140,7 +153,6 @@ protected DatasetServiceClient(DatasetServiceSettings settings) throws IOExcepti this.operationsClient = OperationsClient.create(this.stub.getOperationsStub()); } - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") protected DatasetServiceClient(DatasetServiceStub stub) { this.settings = null; this.stub = stub; @@ -151,7 +163,6 @@ public final DatasetServiceSettings getSettings() { return settings; } - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") public DatasetServiceStub getStub() { return stub; } @@ -171,6 +182,8 @@ public final OperationsClient getOperationsClient() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); * Dataset dataset = Dataset.newBuilder().build(); @@ -200,6 +213,8 @@ public final OperationFuturecreateData * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); * Dataset dataset = Dataset.newBuilder().build(); @@ -226,6 +241,8 @@ public final OperationFuturecreateData * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * CreateDatasetRequest request = * CreateDatasetRequest.newBuilder() @@ -251,6 +268,8 @@ public final OperationFuturecreateData * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * CreateDatasetRequest request = * CreateDatasetRequest.newBuilder() @@ -276,6 +295,8 @@ public final OperationFuturecreateData * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * CreateDatasetRequest request = * CreateDatasetRequest.newBuilder() @@ -300,6 +321,8 @@ public final UnaryCallablecreateDatasetCallabl * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]"); * Dataset response = datasetServiceClient.getDataset(name); @@ -322,6 +345,8 @@ public final Dataset getDataset(DatasetName name) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * String name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString(); * Dataset response = datasetServiceClient.getDataset(name); @@ -343,6 +368,8 @@ public final Dataset getDataset(String name) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * GetDatasetRequest request = * GetDatasetRequest.newBuilder() @@ -367,6 +394,8 @@ public final Dataset getDataset(GetDatasetRequest request) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * GetDatasetRequest request = * GetDatasetRequest.newBuilder() @@ -390,6 +419,8 @@ public final UnaryCallablegetDatasetCallable() { * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * Dataset dataset = Dataset.newBuilder().build(); * FieldMask updateMask = FieldMask.newBuilder().build(); @@ -416,6 +447,8 @@ public final Dataset updateDataset(Dataset dataset, FieldMask updateMask) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * UpdateDatasetRequest request = * UpdateDatasetRequest.newBuilder() @@ -440,6 +473,8 @@ public final Dataset updateDataset(UpdateDatasetRequest request) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * UpdateDatasetRequest request = * UpdateDatasetRequest.newBuilder() @@ -463,6 +498,8 @@ public final UnaryCallableupdateDatasetCallable( * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); * for (Dataset element : datasetServiceClient.listDatasets(parent).iterateAll()) { @@ -490,6 +527,8 @@ public final ListDatasetsPagedResponse listDatasets(LocationName parent) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); * for (Dataset element : datasetServiceClient.listDatasets(parent).iterateAll()) { @@ -514,6 +553,8 @@ public final ListDatasetsPagedResponse listDatasets(String parent) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ListDatasetsRequest request = * ListDatasetsRequest.newBuilder() @@ -544,6 +585,8 @@ public final ListDatasetsPagedResponse listDatasets(ListDatasetsRequest request) *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ListDatasetsRequest request = * ListDatasetsRequest.newBuilder() @@ -575,6 +618,8 @@ public final ListDatasetsPagedResponse listDatasets(ListDatasetsRequest request) *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ListDatasetsRequest request = * ListDatasetsRequest.newBuilder() @@ -587,7 +632,7 @@ public final ListDatasetsPagedResponse listDatasets(ListDatasetsRequest request) * .build(); * while (true) { * ListDatasetsResponse response = datasetServiceClient.listDatasetsCallable().call(request); - * for (Dataset element : response.getResponsesList()) { + * for (Dataset element : response.getDatasetsList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -611,6 +656,8 @@ public final UnaryCallablelistDatase * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]"); * datasetServiceClient.deleteDatasetAsync(name).get(); @@ -635,6 +682,8 @@ public final OperationFuturedeleteDatasetAsync( * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * String name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString(); * datasetServiceClient.deleteDatasetAsync(name).get(); @@ -657,6 +706,8 @@ public final OperationFuturedeleteDatasetAsync( * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DeleteDatasetRequest request = * DeleteDatasetRequest.newBuilder() @@ -681,6 +732,8 @@ public final OperationFuturedeleteDatasetAsync( * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DeleteDatasetRequest request = * DeleteDatasetRequest.newBuilder() @@ -705,6 +758,8 @@ public final OperationFuturedeleteDatasetAsync( * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DeleteDatasetRequest request = * DeleteDatasetRequest.newBuilder() @@ -728,6 +783,8 @@ public final UnaryCallabledeleteDatasetCallabl * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]"); * ListimportConfigs = new ArrayList<>(); @@ -758,6 +815,8 @@ public final OperationFuture im * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * String name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString(); * ListimportConfigs = new ArrayList<>(); @@ -785,6 +844,8 @@ public final OperationFuture im * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ImportDataRequest request = * ImportDataRequest.newBuilder() @@ -810,6 +871,8 @@ public final OperationFutureim * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ImportDataRequest request = * ImportDataRequest.newBuilder() @@ -835,6 +898,8 @@ public final OperationFutureim * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ImportDataRequest request = * ImportDataRequest.newBuilder() @@ -858,6 +923,8 @@ public final UnaryCallableimportDataCallable() { * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DatasetName name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]"); * ExportDataConfig exportConfig = ExportDataConfig.newBuilder().build(); @@ -887,6 +954,8 @@ public final OperationFutureex * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * String name = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString(); * ExportDataConfig exportConfig = ExportDataConfig.newBuilder().build(); @@ -913,6 +982,8 @@ public final OperationFutureex * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ExportDataRequest request = * ExportDataRequest.newBuilder() @@ -938,6 +1009,8 @@ public final OperationFutureex * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ExportDataRequest request = * ExportDataRequest.newBuilder() @@ -963,6 +1036,8 @@ public final OperationFutureex * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ExportDataRequest request = * ExportDataRequest.newBuilder() @@ -986,6 +1061,8 @@ public final UnaryCallableexportDataCallable() { * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DatasetName parent = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]"); * for (DataItem element : datasetServiceClient.listDataItems(parent).iterateAll()) { @@ -1013,6 +1090,8 @@ public final ListDataItemsPagedResponse listDataItems(DatasetName parent) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * String parent = DatasetName.of("[PROJECT]", "[LOCATION]", "[DATASET]").toString(); * for (DataItem element : datasetServiceClient.listDataItems(parent).iterateAll()) { @@ -1037,6 +1116,8 @@ public final ListDataItemsPagedResponse listDataItems(String parent) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ListDataItemsRequest request = * ListDataItemsRequest.newBuilder() @@ -1067,6 +1148,8 @@ public final ListDataItemsPagedResponse listDataItems(ListDataItemsRequest reque *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ListDataItemsRequest request = * ListDataItemsRequest.newBuilder() @@ -1098,6 +1181,8 @@ public final ListDataItemsPagedResponse listDataItems(ListDataItemsRequest reque *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ListDataItemsRequest request = * ListDataItemsRequest.newBuilder() @@ -1110,7 +1195,7 @@ public final ListDataItemsPagedResponse listDataItems(ListDataItemsRequest reque * .build(); * while (true) { * ListDataItemsResponse response = datasetServiceClient.listDataItemsCallable().call(request); - * for (DataItem element : response.getResponsesList()) { + * for (DataItem element : response.getDataItemsList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -1134,6 +1219,8 @@ public final UnaryCallablelistData * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * AnnotationSpecName name = * AnnotationSpecName.of("[PROJECT]", "[LOCATION]", "[DATASET]", "[ANNOTATION_SPEC]"); @@ -1160,6 +1247,8 @@ public final AnnotationSpec getAnnotationSpec(AnnotationSpecName name) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * String name = * AnnotationSpecName.of("[PROJECT]", "[LOCATION]", "[DATASET]", "[ANNOTATION_SPEC]") @@ -1184,6 +1273,8 @@ public final AnnotationSpec getAnnotationSpec(String name) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * GetAnnotationSpecRequest request = * GetAnnotationSpecRequest.newBuilder() @@ -1210,6 +1301,8 @@ public final AnnotationSpec getAnnotationSpec(GetAnnotationSpecRequest request) *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * GetAnnotationSpecRequest request = * GetAnnotationSpecRequest.newBuilder() @@ -1236,6 +1329,8 @@ public final UnaryCallablegetAnnotati * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * DataItemName parent = DataItemName.of("[PROJECT]", "[LOCATION]", "[DATASET]", "[DATA_ITEM]"); * for (Annotation element : datasetServiceClient.listAnnotations(parent).iterateAll()) { @@ -1263,6 +1358,8 @@ public final ListAnnotationsPagedResponse listAnnotations(DataItemName parent) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * String parent = * DataItemName.of("[PROJECT]", "[LOCATION]", "[DATASET]", "[DATA_ITEM]").toString(); @@ -1288,6 +1385,8 @@ public final ListAnnotationsPagedResponse listAnnotations(String parent) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ListAnnotationsRequest request = * ListAnnotationsRequest.newBuilder() @@ -1319,6 +1418,8 @@ public final ListAnnotationsPagedResponse listAnnotations(ListAnnotationsRequest *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ListAnnotationsRequest request = * ListAnnotationsRequest.newBuilder() @@ -1351,6 +1452,8 @@ public final ListAnnotationsPagedResponse listAnnotations(ListAnnotationsRequest *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { * ListAnnotationsRequest request = * ListAnnotationsRequest.newBuilder() @@ -1365,7 +1468,7 @@ public final ListAnnotationsPagedResponse listAnnotations(ListAnnotationsRequest * while (true) { * ListAnnotationsResponse response = * datasetServiceClient.listAnnotationsCallable().call(request); - * for (Annotation element : response.getResponsesList()) { + * for (Annotation element : response.getAnnotationsList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -1383,6 +1486,331 @@ public final ListAnnotationsPagedResponse listAnnotations(ListAnnotationsRequest return stub.listAnnotationsCallable(); } + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Lists information about the supported locations for this service. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * ListLocationsRequest request = + * ListLocationsRequest.newBuilder() + * .setName("name3373707") + * .setFilter("filter-1274492040") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .build(); + * for (Location element : datasetServiceClient.listLocations(request).iterateAll()) { + * // doThingsWith(element); + * } + * } + * }+ * + * @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 ListLocationsPagedResponse listLocations(ListLocationsRequest request) { + return listLocationsPagedCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Lists information about the supported locations for this service. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * ListLocationsRequest request = + * ListLocationsRequest.newBuilder() + * .setName("name3373707") + * .setFilter("filter-1274492040") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .build(); + * ApiFuture+ */ + public final UnaryCallablefuture = + * datasetServiceClient.listLocationsPagedCallable().futureCall(request); + * // Do something. + * for (Location element : future.get().iterateAll()) { + * // doThingsWith(element); + * } + * } + * } + listLocationsPagedCallable() { + return stub.listLocationsPagedCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Lists information about the supported locations for this service. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * ListLocationsRequest request = + * ListLocationsRequest.newBuilder() + * .setName("name3373707") + * .setFilter("filter-1274492040") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .build(); + * while (true) { + * ListLocationsResponse response = datasetServiceClient.listLocationsCallable().call(request); + * for (Location element : response.getLocationsList()) { + * // doThingsWith(element); + * } + * String nextPageToken = response.getNextPageToken(); + * if (!Strings.isNullOrEmpty(nextPageToken)) { + * request = request.toBuilder().setPageToken(nextPageToken).build(); + * } else { + * break; + * } + * } + * } + * }+ */ + public final UnaryCallablelistLocationsCallable() { + return stub.listLocationsCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets information about a location. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build(); + * Location response = datasetServiceClient.getLocation(request); + * } + * }+ * + * @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 Location getLocation(GetLocationRequest request) { + return getLocationCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets information about a location. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build(); + * ApiFuture+ */ + public final UnaryCallablefuture = datasetServiceClient.getLocationCallable().futureCall(request); + * // Do something. + * Location response = future.get(); + * } + * } getLocationCallable() { + return stub.getLocationCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Sets the access control policy on the specified resource. Replacesany existing policy. + * + * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * SetIamPolicyRequest request = + * SetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setPolicy(Policy.newBuilder().build()) + * .setUpdateMask(FieldMask.newBuilder().build()) + * .build(); + * Policy response = datasetServiceClient.setIamPolicy(request); + * } + * }+ * + * @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 Policy setIamPolicy(SetIamPolicyRequest request) { + return setIamPolicyCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Sets the access control policy on the specified resource. Replacesany existing policy. + * + *Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * SetIamPolicyRequest request = + * SetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setPolicy(Policy.newBuilder().build()) + * .setUpdateMask(FieldMask.newBuilder().build()) + * .build(); + * ApiFuture+ */ + public final UnaryCallablefuture = datasetServiceClient.setIamPolicyCallable().futureCall(request); + * // Do something. + * Policy response = future.get(); + * } + * } setIamPolicyCallable() { + return stub.setIamPolicyCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets the access control policy for a resource. Returns an empty policyif the resource exists + * and does not have a policy set. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * GetIamPolicyRequest request = + * GetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setOptions(GetPolicyOptions.newBuilder().build()) + * .build(); + * Policy response = datasetServiceClient.getIamPolicy(request); + * } + * }+ * + * @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 Policy getIamPolicy(GetIamPolicyRequest request) { + return getIamPolicyCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets the access control policy for a resource. Returns an empty policyif the resource exists + * and does not have a policy set. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * GetIamPolicyRequest request = + * GetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setOptions(GetPolicyOptions.newBuilder().build()) + * .build(); + * ApiFuture+ */ + public final UnaryCallablefuture = datasetServiceClient.getIamPolicyCallable().futureCall(request); + * // Do something. + * Policy response = future.get(); + * } + * } getIamPolicyCallable() { + return stub.getIamPolicyCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Returns permissions that a caller has on the specified resource. If theresource does not exist, + * this will return an empty set ofpermissions, not a `NOT_FOUND` error. + * + * Note: This operation is designed to be used for buildingpermission-aware UIs and + * command-line tools, not for authorizationchecking. This operation may "fail open" without + * warning. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * TestIamPermissionsRequest request = + * TestIamPermissionsRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .addAllPermissions(new ArrayList+ * + * @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 TestIamPermissionsResponse testIamPermissions(TestIamPermissionsRequest request) { + return testIamPermissionsCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Returns permissions that a caller has on the specified resource. If theresource does not exist, + * this will return an empty set ofpermissions, not a `NOT_FOUND` error. + * + *()) + * .build(); + * TestIamPermissionsResponse response = datasetServiceClient.testIamPermissions(request); + * } + * } Note: This operation is designed to be used for buildingpermission-aware UIs and + * command-line tools, not for authorizationchecking. This operation may "fail open" without + * warning. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create()) { + * TestIamPermissionsRequest request = + * TestIamPermissionsRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .addAllPermissions(new ArrayList+ */ + public final UnaryCallable()) + * .build(); + * ApiFuture future = + * datasetServiceClient.testIamPermissionsCallable().futureCall(request); + * // Do something. + * TestIamPermissionsResponse response = future.get(); + * } + * } + testIamPermissionsCallable() { + return stub.testIamPermissionsCallable(); + } + @Override public final void close() { stub.close(); @@ -1640,4 +2068,80 @@ protected ListAnnotationsFixedSizeCollection createCollection( return new ListAnnotationsFixedSizeCollection(pages, collectionSize); } } + + public static class ListLocationsPagedResponse + extends AbstractPagedListResponse< + ListLocationsRequest, + ListLocationsResponse, + Location, + ListLocationsPage, + ListLocationsFixedSizeCollection> { + + public static ApiFuture createAsync( + PageContext context, + ApiFuture futureResponse) { + ApiFuture futurePage = + ListLocationsPage.createEmptyPage().createPageAsync(context, futureResponse); + return ApiFutures.transform( + futurePage, + input -> new ListLocationsPagedResponse(input), + MoreExecutors.directExecutor()); + } + + private ListLocationsPagedResponse(ListLocationsPage page) { + super(page, ListLocationsFixedSizeCollection.createEmptyCollection()); + } + } + + public static class ListLocationsPage + extends AbstractPage< + ListLocationsRequest, ListLocationsResponse, Location, ListLocationsPage> { + + private ListLocationsPage( + PageContext context, + ListLocationsResponse response) { + super(context, response); + } + + private static ListLocationsPage createEmptyPage() { + return new ListLocationsPage(null, null); + } + + @Override + protected ListLocationsPage createPage( + PageContext context, + ListLocationsResponse response) { + return new ListLocationsPage(context, response); + } + + @Override + public ApiFuture createPageAsync( + PageContext context, + ApiFuture futureResponse) { + return super.createPageAsync(context, futureResponse); + } + } + + public static class ListLocationsFixedSizeCollection + extends AbstractFixedSizeCollection< + ListLocationsRequest, + ListLocationsResponse, + Location, + ListLocationsPage, + ListLocationsFixedSizeCollection> { + + private ListLocationsFixedSizeCollection(List pages, int collectionSize) { + super(pages, collectionSize); + } + + private static ListLocationsFixedSizeCollection createEmptyCollection() { + return new ListLocationsFixedSizeCollection(null, 0); + } + + @Override + protected ListLocationsFixedSizeCollection createCollection( + List pages, int collectionSize) { + return new ListLocationsFixedSizeCollection(pages, collectionSize); + } + } } diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java index 3956f654b..6c5eb24b8 100644 --- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java +++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/DatasetServiceSettings.java @@ -1,5 +1,5 @@ /* - * Copyright 2021 Google LLC + * Copyright 2022 Google LLC * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -19,6 +19,7 @@ import static com.google.cloud.aiplatform.v1.DatasetServiceClient.ListAnnotationsPagedResponse; import static com.google.cloud.aiplatform.v1.DatasetServiceClient.ListDataItemsPagedResponse; import static com.google.cloud.aiplatform.v1.DatasetServiceClient.ListDatasetsPagedResponse; +import static com.google.cloud.aiplatform.v1.DatasetServiceClient.ListLocationsPagedResponse; import com.google.api.core.ApiFunction; import com.google.api.core.BetaApi; @@ -33,6 +34,15 @@ import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.aiplatform.v1.stub.DatasetServiceStubSettings; +import com.google.cloud.location.GetLocationRequest; +import com.google.cloud.location.ListLocationsRequest; +import com.google.cloud.location.ListLocationsResponse; +import com.google.cloud.location.Location; +import com.google.iam.v1.GetIamPolicyRequest; +import com.google.iam.v1.Policy; +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.protobuf.Empty; import java.io.IOException; @@ -57,6 +67,8 @@ * For example, to set the total timeout of getDataset to 30 seconds: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * DatasetServiceSettings.Builder datasetServiceSettingsBuilder = * DatasetServiceSettings.newBuilder(); * datasetServiceSettingsBuilder @@ -152,6 +164,33 @@ public UnaryCallSettingsgetAnnotation return ((DatasetServiceStubSettings) getStubSettings()).listAnnotationsSettings(); } + /** Returns the object with the settings used for calls to listLocations. */ + public PagedCallSettings + listLocationsSettings() { + return ((DatasetServiceStubSettings) getStubSettings()).listLocationsSettings(); + } + + /** Returns the object with the settings used for calls to getLocation. */ + public UnaryCallSettings getLocationSettings() { + return ((DatasetServiceStubSettings) getStubSettings()).getLocationSettings(); + } + + /** Returns the object with the settings used for calls to setIamPolicy. */ + public UnaryCallSettings setIamPolicySettings() { + return ((DatasetServiceStubSettings) getStubSettings()).setIamPolicySettings(); + } + + /** Returns the object with the settings used for calls to getIamPolicy. */ + public UnaryCallSettings getIamPolicySettings() { + return ((DatasetServiceStubSettings) getStubSettings()).getIamPolicySettings(); + } + + /** Returns the object with the settings used for calls to testIamPermissions. */ + public UnaryCallSettings + testIamPermissionsSettings() { + return ((DatasetServiceStubSettings) getStubSettings()).testIamPermissionsSettings(); + } + public static final DatasetServiceSettings create(DatasetServiceStubSettings stub) throws IOException { return new DatasetServiceSettings.Builder(stub.toBuilder()).build(); @@ -333,6 +372,34 @@ public UnaryCallSettings.Builder exportDataSetting return getStubSettingsBuilder().listAnnotationsSettings(); } + /** Returns the builder for the settings used for calls to listLocations. */ + public PagedCallSettings.Builder< + ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse> + listLocationsSettings() { + return getStubSettingsBuilder().listLocationsSettings(); + } + + /** Returns the builder for the settings used for calls to getLocation. */ + public UnaryCallSettings.Builder getLocationSettings() { + return getStubSettingsBuilder().getLocationSettings(); + } + + /** Returns the builder for the settings used for calls to setIamPolicy. */ + public UnaryCallSettings.Builder setIamPolicySettings() { + return getStubSettingsBuilder().setIamPolicySettings(); + } + + /** Returns the builder for the settings used for calls to getIamPolicy. */ + public UnaryCallSettings.Builder getIamPolicySettings() { + return getStubSettingsBuilder().getIamPolicySettings(); + } + + /** Returns the builder for the settings used for calls to testIamPermissions. */ + public UnaryCallSettings.Builder + testIamPermissionsSettings() { + return getStubSettingsBuilder().testIamPermissionsSettings(); + } + @Override public DatasetServiceSettings build() throws IOException { return new DatasetServiceSettings(this); diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java index e04b99c99..28ba86eed 100644 --- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java +++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceClient.java @@ -1,5 +1,5 @@ /* - * Copyright 2021 Google LLC + * Copyright 2022 Google LLC * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -18,7 +18,6 @@ import com.google.api.core.ApiFuture; 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; @@ -29,7 +28,16 @@ import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.aiplatform.v1.stub.EndpointServiceStub; import com.google.cloud.aiplatform.v1.stub.EndpointServiceStubSettings; +import com.google.cloud.location.GetLocationRequest; +import com.google.cloud.location.ListLocationsRequest; +import com.google.cloud.location.ListLocationsResponse; +import com.google.cloud.location.Location; import com.google.common.util.concurrent.MoreExecutors; +import com.google.iam.v1.GetIamPolicyRequest; +import com.google.iam.v1.Policy; +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 com.google.protobuf.Empty; @@ -48,6 +56,8 @@ * calls that map to API methods. Sample code to get started: * * {@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * EndpointName name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]"); * Endpoint response = endpointServiceClient.getEndpoint(name); @@ -84,6 +94,8 @@ *To customize credentials: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * EndpointServiceSettings endpointServiceSettings = * EndpointServiceSettings.newBuilder() * .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials)) @@ -95,6 +107,8 @@ *To customize the endpoint: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * EndpointServiceSettings endpointServiceSettings = * EndpointServiceSettings.newBuilder().setEndpoint(myEndpoint).build(); * EndpointServiceClient endpointServiceClient = @@ -127,7 +141,6 @@ public static final EndpointServiceClient create(EndpointServiceSettings setting * Constructs an instance of EndpointServiceClient, using the given stub for making calls. This is * for advanced usage - prefer using create(EndpointServiceSettings). */ - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") public static final EndpointServiceClient create(EndpointServiceStub stub) { return new EndpointServiceClient(stub); } @@ -143,7 +156,6 @@ protected EndpointServiceClient(EndpointServiceSettings settings) throws IOExcep this.operationsClient = OperationsClient.create(this.stub.getOperationsStub()); } - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") protected EndpointServiceClient(EndpointServiceStub stub) { this.settings = null; this.stub = stub; @@ -154,7 +166,6 @@ public final EndpointServiceSettings getSettings() { return settings; } - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") public EndpointServiceStub getStub() { return stub; } @@ -174,6 +185,8 @@ public final OperationsClient getOperationsClient() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); * Endpoint endpoint = Endpoint.newBuilder().build(); @@ -203,6 +216,8 @@ public final OperationFuturecreateEn * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); * Endpoint endpoint = Endpoint.newBuilder().build(); @@ -229,6 +244,8 @@ public final OperationFuturecreateEn * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); * Endpoint endpoint = Endpoint.newBuilder().build(); @@ -268,6 +285,8 @@ public final OperationFuturecreateEn * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); * Endpoint endpoint = Endpoint.newBuilder().build(); @@ -307,6 +326,8 @@ public final OperationFuturecreateEn * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * CreateEndpointRequest request = * CreateEndpointRequest.newBuilder() @@ -333,6 +354,8 @@ public final OperationFuturecreateEn * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * CreateEndpointRequest request = * CreateEndpointRequest.newBuilder() @@ -359,6 +382,8 @@ public final OperationFuturecreateEn * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * CreateEndpointRequest request = * CreateEndpointRequest.newBuilder() @@ -384,6 +409,8 @@ public final UnaryCallablecreateEndpointCalla * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * EndpointName name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]"); * Endpoint response = endpointServiceClient.getEndpoint(name); @@ -407,6 +434,8 @@ public final Endpoint getEndpoint(EndpointName name) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * String name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]").toString(); * Endpoint response = endpointServiceClient.getEndpoint(name); @@ -429,6 +458,8 @@ public final Endpoint getEndpoint(String name) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * GetEndpointRequest request = * GetEndpointRequest.newBuilder() @@ -452,6 +483,8 @@ public final Endpoint getEndpoint(GetEndpointRequest request) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * GetEndpointRequest request = * GetEndpointRequest.newBuilder() @@ -474,6 +507,8 @@ public final UnaryCallablegetEndpointCallable() { * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); * for (Endpoint element : endpointServiceClient.listEndpoints(parent).iterateAll()) { @@ -501,6 +536,8 @@ public final ListEndpointsPagedResponse listEndpoints(LocationName parent) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); * for (Endpoint element : endpointServiceClient.listEndpoints(parent).iterateAll()) { @@ -525,6 +562,8 @@ public final ListEndpointsPagedResponse listEndpoints(String parent) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * ListEndpointsRequest request = * ListEndpointsRequest.newBuilder() @@ -555,6 +594,8 @@ public final ListEndpointsPagedResponse listEndpoints(ListEndpointsRequest reque *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * ListEndpointsRequest request = * ListEndpointsRequest.newBuilder() @@ -586,6 +627,8 @@ public final ListEndpointsPagedResponse listEndpoints(ListEndpointsRequest reque *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * ListEndpointsRequest request = * ListEndpointsRequest.newBuilder() @@ -599,7 +642,7 @@ public final ListEndpointsPagedResponse listEndpoints(ListEndpointsRequest reque * while (true) { * ListEndpointsResponse response = * endpointServiceClient.listEndpointsCallable().call(request); - * for (Endpoint element : response.getResponsesList()) { + * for (Endpoint element : response.getEndpointsList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -623,6 +666,8 @@ public final UnaryCallablelistEndp * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * Endpoint endpoint = Endpoint.newBuilder().build(); * FieldMask updateMask = FieldMask.newBuilder().build(); @@ -648,6 +693,8 @@ public final Endpoint updateEndpoint(Endpoint endpoint, FieldMask updateMask) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * UpdateEndpointRequest request = * UpdateEndpointRequest.newBuilder() @@ -672,6 +719,8 @@ public final Endpoint updateEndpoint(UpdateEndpointRequest request) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * UpdateEndpointRequest request = * UpdateEndpointRequest.newBuilder() @@ -696,6 +745,8 @@ public final UnaryCallableupdateEndpointCallab * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * EndpointName name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]"); * endpointServiceClient.deleteEndpointAsync(name).get(); @@ -720,6 +771,8 @@ public final OperationFuturedeleteEndpointAsync * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * String name = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]").toString(); * endpointServiceClient.deleteEndpointAsync(name).get(); @@ -742,6 +795,8 @@ public final OperationFuturedeleteEndpointAsync * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * DeleteEndpointRequest request = * DeleteEndpointRequest.newBuilder() @@ -766,6 +821,8 @@ public final OperationFuturedeleteEndpointAsync * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * DeleteEndpointRequest request = * DeleteEndpointRequest.newBuilder() @@ -790,6 +847,8 @@ public final OperationFuturedeleteEndpointAsync * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * DeleteEndpointRequest request = * DeleteEndpointRequest.newBuilder() @@ -813,6 +872,8 @@ public final UnaryCallabledeleteEndpointCalla * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * EndpointName endpoint = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]"); * DeployedModel deployedModel = DeployedModel.newBuilder().build(); @@ -857,6 +918,8 @@ public final OperationFuture* Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * String endpoint = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]").toString(); * DeployedModel deployedModel = DeployedModel.newBuilder().build(); @@ -901,6 +964,8 @@ public final OperationFuture* Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * DeployModelRequest request = * DeployModelRequest.newBuilder() @@ -927,6 +992,8 @@ public final OperationFuture* Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * DeployModelRequest request = * DeployModelRequest.newBuilder() @@ -954,6 +1021,8 @@ public final OperationFuture* Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * DeployModelRequest request = * DeployModelRequest.newBuilder() @@ -979,6 +1048,8 @@ public final UnaryCallabledeployModelCallable() * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * EndpointName endpoint = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]"); * String deployedModelId = "deployedModelId-1817547906"; @@ -1020,6 +1091,8 @@ public final UnaryCallabledeployModelCallable() * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * String endpoint = EndpointName.of("[PROJECT]", "[LOCATION]", "[ENDPOINT]").toString(); * String deployedModelId = "deployedModelId-1817547906"; @@ -1061,6 +1134,8 @@ public final UnaryCallabledeployModelCallable() * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * UndeployModelRequest request = * UndeployModelRequest.newBuilder() @@ -1088,6 +1163,8 @@ public final UnaryCallabledeployModelCallable() * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * UndeployModelRequest request = * UndeployModelRequest.newBuilder() @@ -1116,6 +1193,8 @@ public final UnaryCallabledeployModelCallable() * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { * UndeployModelRequest request = * UndeployModelRequest.newBuilder() @@ -1134,6 +1213,332 @@ public final UnaryCallableundeployModelCallabl return stub.undeployModelCallable(); } + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Lists information about the supported locations for this service. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * ListLocationsRequest request = + * ListLocationsRequest.newBuilder() + * .setName("name3373707") + * .setFilter("filter-1274492040") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .build(); + * for (Location element : endpointServiceClient.listLocations(request).iterateAll()) { + * // doThingsWith(element); + * } + * } + * }+ * + * @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 ListLocationsPagedResponse listLocations(ListLocationsRequest request) { + return listLocationsPagedCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Lists information about the supported locations for this service. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * ListLocationsRequest request = + * ListLocationsRequest.newBuilder() + * .setName("name3373707") + * .setFilter("filter-1274492040") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .build(); + * ApiFuture+ */ + public final UnaryCallablefuture = + * endpointServiceClient.listLocationsPagedCallable().futureCall(request); + * // Do something. + * for (Location element : future.get().iterateAll()) { + * // doThingsWith(element); + * } + * } + * } + listLocationsPagedCallable() { + return stub.listLocationsPagedCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Lists information about the supported locations for this service. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * ListLocationsRequest request = + * ListLocationsRequest.newBuilder() + * .setName("name3373707") + * .setFilter("filter-1274492040") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .build(); + * while (true) { + * ListLocationsResponse response = + * endpointServiceClient.listLocationsCallable().call(request); + * for (Location element : response.getLocationsList()) { + * // doThingsWith(element); + * } + * String nextPageToken = response.getNextPageToken(); + * if (!Strings.isNullOrEmpty(nextPageToken)) { + * request = request.toBuilder().setPageToken(nextPageToken).build(); + * } else { + * break; + * } + * } + * } + * }+ */ + public final UnaryCallablelistLocationsCallable() { + return stub.listLocationsCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets information about a location. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build(); + * Location response = endpointServiceClient.getLocation(request); + * } + * }+ * + * @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 Location getLocation(GetLocationRequest request) { + return getLocationCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets information about a location. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build(); + * ApiFuture+ */ + public final UnaryCallablefuture = endpointServiceClient.getLocationCallable().futureCall(request); + * // Do something. + * Location response = future.get(); + * } + * } getLocationCallable() { + return stub.getLocationCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Sets the access control policy on the specified resource. Replacesany existing policy. + * + * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * SetIamPolicyRequest request = + * SetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setPolicy(Policy.newBuilder().build()) + * .setUpdateMask(FieldMask.newBuilder().build()) + * .build(); + * Policy response = endpointServiceClient.setIamPolicy(request); + * } + * }+ * + * @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 Policy setIamPolicy(SetIamPolicyRequest request) { + return setIamPolicyCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Sets the access control policy on the specified resource. Replacesany existing policy. + * + *Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * SetIamPolicyRequest request = + * SetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setPolicy(Policy.newBuilder().build()) + * .setUpdateMask(FieldMask.newBuilder().build()) + * .build(); + * ApiFuture+ */ + public final UnaryCallablefuture = endpointServiceClient.setIamPolicyCallable().futureCall(request); + * // Do something. + * Policy response = future.get(); + * } + * } setIamPolicyCallable() { + return stub.setIamPolicyCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets the access control policy for a resource. Returns an empty policyif the resource exists + * and does not have a policy set. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * GetIamPolicyRequest request = + * GetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setOptions(GetPolicyOptions.newBuilder().build()) + * .build(); + * Policy response = endpointServiceClient.getIamPolicy(request); + * } + * }+ * + * @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 Policy getIamPolicy(GetIamPolicyRequest request) { + return getIamPolicyCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets the access control policy for a resource. Returns an empty policyif the resource exists + * and does not have a policy set. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * GetIamPolicyRequest request = + * GetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setOptions(GetPolicyOptions.newBuilder().build()) + * .build(); + * ApiFuture+ */ + public final UnaryCallablefuture = endpointServiceClient.getIamPolicyCallable().futureCall(request); + * // Do something. + * Policy response = future.get(); + * } + * } getIamPolicyCallable() { + return stub.getIamPolicyCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Returns permissions that a caller has on the specified resource. If theresource does not exist, + * this will return an empty set ofpermissions, not a `NOT_FOUND` error. + * + * Note: This operation is designed to be used for buildingpermission-aware UIs and + * command-line tools, not for authorizationchecking. This operation may "fail open" without + * warning. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * TestIamPermissionsRequest request = + * TestIamPermissionsRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .addAllPermissions(new ArrayList+ * + * @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 TestIamPermissionsResponse testIamPermissions(TestIamPermissionsRequest request) { + return testIamPermissionsCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Returns permissions that a caller has on the specified resource. If theresource does not exist, + * this will return an empty set ofpermissions, not a `NOT_FOUND` error. + * + *()) + * .build(); + * TestIamPermissionsResponse response = endpointServiceClient.testIamPermissions(request); + * } + * } Note: This operation is designed to be used for buildingpermission-aware UIs and + * command-line tools, not for authorizationchecking. This operation may "fail open" without + * warning. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (EndpointServiceClient endpointServiceClient = EndpointServiceClient.create()) { + * TestIamPermissionsRequest request = + * TestIamPermissionsRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .addAllPermissions(new ArrayList+ */ + public final UnaryCallable()) + * .build(); + * ApiFuture future = + * endpointServiceClient.testIamPermissionsCallable().futureCall(request); + * // Do something. + * TestIamPermissionsResponse response = future.get(); + * } + * } + testIamPermissionsCallable() { + return stub.testIamPermissionsCallable(); + } + @Override public final void close() { stub.close(); @@ -1239,4 +1644,80 @@ protected ListEndpointsFixedSizeCollection createCollection( return new ListEndpointsFixedSizeCollection(pages, collectionSize); } } + + public static class ListLocationsPagedResponse + extends AbstractPagedListResponse< + ListLocationsRequest, + ListLocationsResponse, + Location, + ListLocationsPage, + ListLocationsFixedSizeCollection> { + + public static ApiFuture createAsync( + PageContext context, + ApiFuture futureResponse) { + ApiFuture futurePage = + ListLocationsPage.createEmptyPage().createPageAsync(context, futureResponse); + return ApiFutures.transform( + futurePage, + input -> new ListLocationsPagedResponse(input), + MoreExecutors.directExecutor()); + } + + private ListLocationsPagedResponse(ListLocationsPage page) { + super(page, ListLocationsFixedSizeCollection.createEmptyCollection()); + } + } + + public static class ListLocationsPage + extends AbstractPage< + ListLocationsRequest, ListLocationsResponse, Location, ListLocationsPage> { + + private ListLocationsPage( + PageContext context, + ListLocationsResponse response) { + super(context, response); + } + + private static ListLocationsPage createEmptyPage() { + return new ListLocationsPage(null, null); + } + + @Override + protected ListLocationsPage createPage( + PageContext context, + ListLocationsResponse response) { + return new ListLocationsPage(context, response); + } + + @Override + public ApiFuture createPageAsync( + PageContext context, + ApiFuture futureResponse) { + return super.createPageAsync(context, futureResponse); + } + } + + public static class ListLocationsFixedSizeCollection + extends AbstractFixedSizeCollection< + ListLocationsRequest, + ListLocationsResponse, + Location, + ListLocationsPage, + ListLocationsFixedSizeCollection> { + + private ListLocationsFixedSizeCollection(List pages, int collectionSize) { + super(pages, collectionSize); + } + + private static ListLocationsFixedSizeCollection createEmptyCollection() { + return new ListLocationsFixedSizeCollection(null, 0); + } + + @Override + protected ListLocationsFixedSizeCollection createCollection( + List pages, int collectionSize) { + return new ListLocationsFixedSizeCollection(pages, collectionSize); + } + } } diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java index eca80dba7..3862dc143 100644 --- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java +++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/EndpointServiceSettings.java @@ -1,5 +1,5 @@ /* - * Copyright 2021 Google LLC + * Copyright 2022 Google LLC * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -17,6 +17,7 @@ package com.google.cloud.aiplatform.v1; import static com.google.cloud.aiplatform.v1.EndpointServiceClient.ListEndpointsPagedResponse; +import static com.google.cloud.aiplatform.v1.EndpointServiceClient.ListLocationsPagedResponse; import com.google.api.core.ApiFunction; import com.google.api.core.BetaApi; @@ -31,6 +32,15 @@ import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.aiplatform.v1.stub.EndpointServiceStubSettings; +import com.google.cloud.location.GetLocationRequest; +import com.google.cloud.location.ListLocationsRequest; +import com.google.cloud.location.ListLocationsResponse; +import com.google.cloud.location.Location; +import com.google.iam.v1.GetIamPolicyRequest; +import com.google.iam.v1.Policy; +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.protobuf.Empty; import java.io.IOException; @@ -55,6 +65,8 @@ * For example, to set the total timeout of getEndpoint to 30 seconds: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * EndpointServiceSettings.Builder endpointServiceSettingsBuilder = * EndpointServiceSettings.newBuilder(); * endpointServiceSettingsBuilder @@ -134,6 +146,33 @@ public UnaryCallSettingsundeployModelSettings( return ((EndpointServiceStubSettings) getStubSettings()).undeployModelOperationSettings(); } + /** Returns the object with the settings used for calls to listLocations. */ + public PagedCallSettings + listLocationsSettings() { + return ((EndpointServiceStubSettings) getStubSettings()).listLocationsSettings(); + } + + /** Returns the object with the settings used for calls to getLocation. */ + public UnaryCallSettings getLocationSettings() { + return ((EndpointServiceStubSettings) getStubSettings()).getLocationSettings(); + } + + /** Returns the object with the settings used for calls to setIamPolicy. */ + public UnaryCallSettings setIamPolicySettings() { + return ((EndpointServiceStubSettings) getStubSettings()).setIamPolicySettings(); + } + + /** Returns the object with the settings used for calls to getIamPolicy. */ + public UnaryCallSettings getIamPolicySettings() { + return ((EndpointServiceStubSettings) getStubSettings()).getIamPolicySettings(); + } + + /** Returns the object with the settings used for calls to testIamPermissions. */ + public UnaryCallSettings + testIamPermissionsSettings() { + return ((EndpointServiceStubSettings) getStubSettings()).testIamPermissionsSettings(); + } + public static final EndpointServiceSettings create(EndpointServiceStubSettings stub) throws IOException { return new EndpointServiceSettings.Builder(stub.toBuilder()).build(); @@ -295,6 +334,34 @@ public UnaryCallSettings.Builder undeployModelS return getStubSettingsBuilder().undeployModelOperationSettings(); } + /** Returns the builder for the settings used for calls to listLocations. */ + public PagedCallSettings.Builder< + ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse> + listLocationsSettings() { + return getStubSettingsBuilder().listLocationsSettings(); + } + + /** Returns the builder for the settings used for calls to getLocation. */ + public UnaryCallSettings.Builder getLocationSettings() { + return getStubSettingsBuilder().getLocationSettings(); + } + + /** Returns the builder for the settings used for calls to setIamPolicy. */ + public UnaryCallSettings.Builder setIamPolicySettings() { + return getStubSettingsBuilder().setIamPolicySettings(); + } + + /** Returns the builder for the settings used for calls to getIamPolicy. */ + public UnaryCallSettings.Builder getIamPolicySettings() { + return getStubSettingsBuilder().getIamPolicySettings(); + } + + /** Returns the builder for the settings used for calls to testIamPermissions. */ + public UnaryCallSettings.Builder + testIamPermissionsSettings() { + return getStubSettingsBuilder().testIamPermissionsSettings(); + } + @Override public EndpointServiceSettings build() throws IOException { return new EndpointServiceSettings(this); diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceClient.java index 010101145..2084dcd03 100644 --- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceClient.java +++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceClient.java @@ -1,5 +1,5 @@ /* - * Copyright 2021 Google LLC + * Copyright 2022 Google LLC * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -16,13 +16,29 @@ package com.google.cloud.aiplatform.v1; -import com.google.api.core.BetaApi; +import com.google.api.core.ApiFuture; +import com.google.api.core.ApiFutures; import com.google.api.gax.core.BackgroundResource; +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.PageContext; import com.google.api.gax.rpc.ServerStreamingCallable; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.aiplatform.v1.stub.FeaturestoreOnlineServingServiceStub; import com.google.cloud.aiplatform.v1.stub.FeaturestoreOnlineServingServiceStubSettings; +import com.google.cloud.location.GetLocationRequest; +import com.google.cloud.location.ListLocationsRequest; +import com.google.cloud.location.ListLocationsResponse; +import com.google.cloud.location.Location; +import com.google.common.util.concurrent.MoreExecutors; +import com.google.iam.v1.GetIamPolicyRequest; +import com.google.iam.v1.Policy; +import com.google.iam.v1.SetIamPolicyRequest; +import com.google.iam.v1.TestIamPermissionsRequest; +import com.google.iam.v1.TestIamPermissionsResponse; import java.io.IOException; +import java.util.List; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -34,6 +50,8 @@ * calls that map to API methods. Sample code to get started: * * {@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = * FeaturestoreOnlineServingServiceClient.create()) { * EntityTypeName entityType = @@ -73,6 +91,8 @@ *To customize credentials: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * FeaturestoreOnlineServingServiceSettings featurestoreOnlineServingServiceSettings = * FeaturestoreOnlineServingServiceSettings.newBuilder() * .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials)) @@ -84,6 +104,8 @@ *To customize the endpoint: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * FeaturestoreOnlineServingServiceSettings featurestoreOnlineServingServiceSettings = * FeaturestoreOnlineServingServiceSettings.newBuilder().setEndpoint(myEndpoint).build(); * FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = @@ -117,7 +139,6 @@ public static final FeaturestoreOnlineServingServiceClient create( * making calls. This is for advanced usage - prefer using * create(FeaturestoreOnlineServingServiceSettings). */ - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") public static final FeaturestoreOnlineServingServiceClient create( FeaturestoreOnlineServingServiceStub stub) { return new FeaturestoreOnlineServingServiceClient(stub); @@ -135,7 +156,6 @@ protected FeaturestoreOnlineServingServiceClient( ((FeaturestoreOnlineServingServiceStubSettings) settings.getStubSettings()).createStub(); } - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") protected FeaturestoreOnlineServingServiceClient(FeaturestoreOnlineServingServiceStub stub) { this.settings = null; this.stub = stub; @@ -145,7 +165,6 @@ public final FeaturestoreOnlineServingServiceSettings getSettings() { return settings; } - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") public FeaturestoreOnlineServingServiceStub getStub() { return stub; } @@ -158,6 +177,8 @@ public FeaturestoreOnlineServingServiceStub getStub() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = * FeaturestoreOnlineServingServiceClient.create()) { * EntityTypeName entityType = @@ -190,6 +211,8 @@ public final ReadFeatureValuesResponse readFeatureValues(EntityTypeName entityTy *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = * FeaturestoreOnlineServingServiceClient.create()) { * String entityType = @@ -221,6 +244,8 @@ public final ReadFeatureValuesResponse readFeatureValues(String entityType) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = * FeaturestoreOnlineServingServiceClient.create()) { * ReadFeatureValuesRequest request = @@ -251,6 +276,8 @@ public final ReadFeatureValuesResponse readFeatureValues(ReadFeatureValuesReques *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = * FeaturestoreOnlineServingServiceClient.create()) { * ReadFeatureValuesRequest request = @@ -281,6 +308,8 @@ public final ReadFeatureValuesResponse readFeatureValues(ReadFeatureValuesReques *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = * FeaturestoreOnlineServingServiceClient.create()) { * StreamingReadFeatureValuesRequest request = @@ -304,6 +333,348 @@ public final ReadFeatureValuesResponse readFeatureValues(ReadFeatureValuesReques return stub.streamingReadFeatureValuesCallable(); } + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Lists information about the supported locations for this service. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * ListLocationsRequest request = + * ListLocationsRequest.newBuilder() + * .setName("name3373707") + * .setFilter("filter-1274492040") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .build(); + * for (Location element : + * featurestoreOnlineServingServiceClient.listLocations(request).iterateAll()) { + * // doThingsWith(element); + * } + * } + * }+ * + * @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 ListLocationsPagedResponse listLocations(ListLocationsRequest request) { + return listLocationsPagedCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Lists information about the supported locations for this service. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * ListLocationsRequest request = + * ListLocationsRequest.newBuilder() + * .setName("name3373707") + * .setFilter("filter-1274492040") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .build(); + * ApiFuture+ */ + public final UnaryCallablefuture = + * featurestoreOnlineServingServiceClient.listLocationsPagedCallable().futureCall(request); + * // Do something. + * for (Location element : future.get().iterateAll()) { + * // doThingsWith(element); + * } + * } + * } + listLocationsPagedCallable() { + return stub.listLocationsPagedCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Lists information about the supported locations for this service. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * ListLocationsRequest request = + * ListLocationsRequest.newBuilder() + * .setName("name3373707") + * .setFilter("filter-1274492040") + * .setPageSize(883849137) + * .setPageToken("pageToken873572522") + * .build(); + * while (true) { + * ListLocationsResponse response = + * featurestoreOnlineServingServiceClient.listLocationsCallable().call(request); + * for (Location element : response.getLocationsList()) { + * // doThingsWith(element); + * } + * String nextPageToken = response.getNextPageToken(); + * if (!Strings.isNullOrEmpty(nextPageToken)) { + * request = request.toBuilder().setPageToken(nextPageToken).build(); + * } else { + * break; + * } + * } + * } + * }+ */ + public final UnaryCallablelistLocationsCallable() { + return stub.listLocationsCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets information about a location. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build(); + * Location response = featurestoreOnlineServingServiceClient.getLocation(request); + * } + * }+ * + * @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 Location getLocation(GetLocationRequest request) { + return getLocationCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets information about a location. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build(); + * ApiFuture+ */ + public final UnaryCallablefuture = + * featurestoreOnlineServingServiceClient.getLocationCallable().futureCall(request); + * // Do something. + * Location response = future.get(); + * } + * } getLocationCallable() { + return stub.getLocationCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Sets the access control policy on the specified resource. Replacesany existing policy. + * + * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * SetIamPolicyRequest request = + * SetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setPolicy(Policy.newBuilder().build()) + * .setUpdateMask(FieldMask.newBuilder().build()) + * .build(); + * Policy response = featurestoreOnlineServingServiceClient.setIamPolicy(request); + * } + * }+ * + * @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 Policy setIamPolicy(SetIamPolicyRequest request) { + return setIamPolicyCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Sets the access control policy on the specified resource. Replacesany existing policy. + * + *Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED`errors. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * SetIamPolicyRequest request = + * SetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setPolicy(Policy.newBuilder().build()) + * .setUpdateMask(FieldMask.newBuilder().build()) + * .build(); + * ApiFuture+ */ + public final UnaryCallablefuture = + * featurestoreOnlineServingServiceClient.setIamPolicyCallable().futureCall(request); + * // Do something. + * Policy response = future.get(); + * } + * } setIamPolicyCallable() { + return stub.setIamPolicyCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets the access control policy for a resource. Returns an empty policyif the resource exists + * and does not have a policy set. + * + * Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * GetIamPolicyRequest request = + * GetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setOptions(GetPolicyOptions.newBuilder().build()) + * .build(); + * Policy response = featurestoreOnlineServingServiceClient.getIamPolicy(request); + * } + * }+ * + * @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 Policy getIamPolicy(GetIamPolicyRequest request) { + return getIamPolicyCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Gets the access control policy for a resource. Returns an empty policyif the resource exists + * and does not have a policy set. + * + *Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * GetIamPolicyRequest request = + * GetIamPolicyRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .setOptions(GetPolicyOptions.newBuilder().build()) + * .build(); + * ApiFuture+ */ + public final UnaryCallablefuture = + * featurestoreOnlineServingServiceClient.getIamPolicyCallable().futureCall(request); + * // Do something. + * Policy response = future.get(); + * } + * } getIamPolicyCallable() { + return stub.getIamPolicyCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Returns permissions that a caller has on the specified resource. If theresource does not exist, + * this will return an empty set ofpermissions, not a `NOT_FOUND` error. + * + * Note: This operation is designed to be used for buildingpermission-aware UIs and + * command-line tools, not for authorizationchecking. This operation may "fail open" without + * warning. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * TestIamPermissionsRequest request = + * TestIamPermissionsRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .addAllPermissions(new ArrayList+ * + * @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 TestIamPermissionsResponse testIamPermissions(TestIamPermissionsRequest request) { + return testIamPermissionsCallable().call(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Returns permissions that a caller has on the specified resource. If theresource does not exist, + * this will return an empty set ofpermissions, not a `NOT_FOUND` error. + * + *()) + * .build(); + * TestIamPermissionsResponse response = + * featurestoreOnlineServingServiceClient.testIamPermissions(request); + * } + * } Note: This operation is designed to be used for buildingpermission-aware UIs and + * command-line tools, not for authorizationchecking. This operation may "fail open" without + * warning. + * + *
Sample code: + * + *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. + * try (FeaturestoreOnlineServingServiceClient featurestoreOnlineServingServiceClient = + * FeaturestoreOnlineServingServiceClient.create()) { + * TestIamPermissionsRequest request = + * TestIamPermissionsRequest.newBuilder() + * .setResource( + * EntityTypeName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]", "[ENTITY_TYPE]") + * .toString()) + * .addAllPermissions(new ArrayList+ */ + public final UnaryCallable()) + * .build(); + * ApiFuture future = + * featurestoreOnlineServingServiceClient.testIamPermissionsCallable().futureCall(request); + * // Do something. + * TestIamPermissionsResponse response = future.get(); + * } + * } + testIamPermissionsCallable() { + return stub.testIamPermissionsCallable(); + } + @Override public final void close() { stub.close(); @@ -333,4 +704,80 @@ public void shutdownNow() { public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException { return stub.awaitTermination(duration, unit); } + + public static class ListLocationsPagedResponse + extends AbstractPagedListResponse< + ListLocationsRequest, + ListLocationsResponse, + Location, + ListLocationsPage, + ListLocationsFixedSizeCollection> { + + public static ApiFuture createAsync( + PageContext context, + ApiFuture futureResponse) { + ApiFuture futurePage = + ListLocationsPage.createEmptyPage().createPageAsync(context, futureResponse); + return ApiFutures.transform( + futurePage, + input -> new ListLocationsPagedResponse(input), + MoreExecutors.directExecutor()); + } + + private ListLocationsPagedResponse(ListLocationsPage page) { + super(page, ListLocationsFixedSizeCollection.createEmptyCollection()); + } + } + + public static class ListLocationsPage + extends AbstractPage< + ListLocationsRequest, ListLocationsResponse, Location, ListLocationsPage> { + + private ListLocationsPage( + PageContext context, + ListLocationsResponse response) { + super(context, response); + } + + private static ListLocationsPage createEmptyPage() { + return new ListLocationsPage(null, null); + } + + @Override + protected ListLocationsPage createPage( + PageContext context, + ListLocationsResponse response) { + return new ListLocationsPage(context, response); + } + + @Override + public ApiFuture createPageAsync( + PageContext context, + ApiFuture futureResponse) { + return super.createPageAsync(context, futureResponse); + } + } + + public static class ListLocationsFixedSizeCollection + extends AbstractFixedSizeCollection< + ListLocationsRequest, + ListLocationsResponse, + Location, + ListLocationsPage, + ListLocationsFixedSizeCollection> { + + private ListLocationsFixedSizeCollection(List pages, int collectionSize) { + super(pages, collectionSize); + } + + private static ListLocationsFixedSizeCollection createEmptyCollection() { + return new ListLocationsFixedSizeCollection(null, 0); + } + + @Override + protected ListLocationsFixedSizeCollection createCollection( + List pages, int collectionSize) { + return new ListLocationsFixedSizeCollection(pages, collectionSize); + } + } } diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceSettings.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceSettings.java index ea99fa565..5b481fb4d 100644 --- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceSettings.java +++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreOnlineServingServiceSettings.java @@ -1,5 +1,5 @@ /* - * Copyright 2021 Google LLC + * Copyright 2022 Google LLC * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -16,6 +16,8 @@ package com.google.cloud.aiplatform.v1; +import static com.google.cloud.aiplatform.v1.FeaturestoreOnlineServingServiceClient.ListLocationsPagedResponse; + import com.google.api.core.ApiFunction; import com.google.api.core.BetaApi; import com.google.api.gax.core.GoogleCredentialsProvider; @@ -24,10 +26,20 @@ 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.PagedCallSettings; import com.google.api.gax.rpc.ServerStreamingCallSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.aiplatform.v1.stub.FeaturestoreOnlineServingServiceStubSettings; +import com.google.cloud.location.GetLocationRequest; +import com.google.cloud.location.ListLocationsRequest; +import com.google.cloud.location.ListLocationsResponse; +import com.google.cloud.location.Location; +import com.google.iam.v1.GetIamPolicyRequest; +import com.google.iam.v1.Policy; +import com.google.iam.v1.SetIamPolicyRequest; +import com.google.iam.v1.TestIamPermissionsRequest; +import com.google.iam.v1.TestIamPermissionsResponse; import java.io.IOException; import java.util.List; import javax.annotation.Generated; @@ -50,6 +62,8 @@ * For example, to set the total timeout of readFeatureValues to 30 seconds: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * FeaturestoreOnlineServingServiceSettings.Builder * featurestoreOnlineServingServiceSettingsBuilder = * FeaturestoreOnlineServingServiceSettings.newBuilder(); @@ -84,6 +98,37 @@ public class FeaturestoreOnlineServingServiceSettings .streamingReadFeatureValuesSettings(); } + /** Returns the object with the settings used for calls to listLocations. */ + public PagedCallSettings+ listLocationsSettings() { + return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings()) + .listLocationsSettings(); + } + + /** Returns the object with the settings used for calls to getLocation. */ + public UnaryCallSettings getLocationSettings() { + return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings()).getLocationSettings(); + } + + /** Returns the object with the settings used for calls to setIamPolicy. */ + public UnaryCallSettings setIamPolicySettings() { + return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings()) + .setIamPolicySettings(); + } + + /** Returns the object with the settings used for calls to getIamPolicy. */ + public UnaryCallSettings getIamPolicySettings() { + return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings()) + .getIamPolicySettings(); + } + + /** Returns the object with the settings used for calls to testIamPermissions. */ + public UnaryCallSettings + testIamPermissionsSettings() { + return ((FeaturestoreOnlineServingServiceStubSettings) getStubSettings()) + .testIamPermissionsSettings(); + } + public static final FeaturestoreOnlineServingServiceSettings create( FeaturestoreOnlineServingServiceStubSettings stub) throws IOException { return new FeaturestoreOnlineServingServiceSettings.Builder(stub.toBuilder()).build(); @@ -195,6 +240,34 @@ public Builder applyToAllUnaryMethods( return getStubSettingsBuilder().streamingReadFeatureValuesSettings(); } + /** Returns the builder for the settings used for calls to listLocations. */ + public PagedCallSettings.Builder< + ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse> + listLocationsSettings() { + return getStubSettingsBuilder().listLocationsSettings(); + } + + /** Returns the builder for the settings used for calls to getLocation. */ + public UnaryCallSettings.Builder getLocationSettings() { + return getStubSettingsBuilder().getLocationSettings(); + } + + /** Returns the builder for the settings used for calls to setIamPolicy. */ + public UnaryCallSettings.Builder setIamPolicySettings() { + return getStubSettingsBuilder().setIamPolicySettings(); + } + + /** Returns the builder for the settings used for calls to getIamPolicy. */ + public UnaryCallSettings.Builder getIamPolicySettings() { + return getStubSettingsBuilder().getIamPolicySettings(); + } + + /** Returns the builder for the settings used for calls to testIamPermissions. */ + public UnaryCallSettings.Builder + testIamPermissionsSettings() { + return getStubSettingsBuilder().testIamPermissionsSettings(); + } + @Override public FeaturestoreOnlineServingServiceSettings build() throws IOException { return new FeaturestoreOnlineServingServiceSettings(this); diff --git a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClient.java b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClient.java index dbbc953db..d542ddc6c 100644 --- a/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClient.java +++ b/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeaturestoreServiceClient.java @@ -1,5 +1,5 @@ /* - * Copyright 2021 Google LLC + * Copyright 2022 Google LLC * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -18,7 +18,6 @@ import com.google.api.core.ApiFuture; 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; @@ -29,7 +28,16 @@ import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.aiplatform.v1.stub.FeaturestoreServiceStub; import com.google.cloud.aiplatform.v1.stub.FeaturestoreServiceStubSettings; +import com.google.cloud.location.GetLocationRequest; +import com.google.cloud.location.ListLocationsRequest; +import com.google.cloud.location.ListLocationsResponse; +import com.google.cloud.location.Location; import com.google.common.util.concurrent.MoreExecutors; +import com.google.iam.v1.GetIamPolicyRequest; +import com.google.iam.v1.Policy; +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 com.google.protobuf.Empty; @@ -47,6 +55,8 @@ * calls that map to API methods. Sample code to get started: * * {@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * FeaturestoreName name = FeaturestoreName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]"); * Featurestore response = featurestoreServiceClient.getFeaturestore(name); @@ -83,6 +93,8 @@ *To customize credentials: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * FeaturestoreServiceSettings featurestoreServiceSettings = * FeaturestoreServiceSettings.newBuilder() * .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials)) @@ -94,6 +106,8 @@ *To customize the endpoint: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * FeaturestoreServiceSettings featurestoreServiceSettings = * FeaturestoreServiceSettings.newBuilder().setEndpoint(myEndpoint).build(); * FeaturestoreServiceClient featurestoreServiceClient = @@ -126,7 +140,6 @@ public static final FeaturestoreServiceClient create(FeaturestoreServiceSettings * Constructs an instance of FeaturestoreServiceClient, using the given stub for making calls. * This is for advanced usage - prefer using create(FeaturestoreServiceSettings). */ - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") public static final FeaturestoreServiceClient create(FeaturestoreServiceStub stub) { return new FeaturestoreServiceClient(stub); } @@ -142,7 +155,6 @@ protected FeaturestoreServiceClient(FeaturestoreServiceSettings settings) throws this.operationsClient = OperationsClient.create(this.stub.getOperationsStub()); } - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") protected FeaturestoreServiceClient(FeaturestoreServiceStub stub) { this.settings = null; this.stub = stub; @@ -153,7 +165,6 @@ public final FeaturestoreServiceSettings getSettings() { return settings; } - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") public FeaturestoreServiceStub getStub() { return stub; } @@ -173,6 +184,8 @@ public final OperationsClient getOperationsClient() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); * Featurestore featurestore = Featurestore.newBuilder().build(); @@ -203,6 +216,8 @@ public final OperationsClient getOperationsClient() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); * Featurestore featurestore = Featurestore.newBuilder().build(); @@ -233,6 +248,8 @@ public final OperationsClient getOperationsClient() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); * Featurestore featurestore = Featurestore.newBuilder().build(); @@ -273,6 +290,8 @@ public final OperationsClient getOperationsClient() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); * Featurestore featurestore = Featurestore.newBuilder().build(); @@ -312,6 +331,8 @@ public final OperationsClient getOperationsClient() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * CreateFeaturestoreRequest request = * CreateFeaturestoreRequest.newBuilder() @@ -338,6 +359,8 @@ public final OperationsClient getOperationsClient() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * CreateFeaturestoreRequest request = * CreateFeaturestoreRequest.newBuilder() @@ -365,6 +388,8 @@ public final OperationsClient getOperationsClient() { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * CreateFeaturestoreRequest request = * CreateFeaturestoreRequest.newBuilder() @@ -390,6 +415,8 @@ public final UnaryCallablecreateFeaturest * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * FeaturestoreName name = FeaturestoreName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]"); * Featurestore response = featurestoreServiceClient.getFeaturestore(name); @@ -412,6 +439,8 @@ public final Featurestore getFeaturestore(FeaturestoreName name) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * String name = FeaturestoreName.of("[PROJECT]", "[LOCATION]", "[FEATURESTORE]").toString(); * Featurestore response = featurestoreServiceClient.getFeaturestore(name); @@ -433,6 +462,8 @@ public final Featurestore getFeaturestore(String name) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * GetFeaturestoreRequest request = * GetFeaturestoreRequest.newBuilder() @@ -456,6 +487,8 @@ public final Featurestore getFeaturestore(GetFeaturestoreRequest request) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * GetFeaturestoreRequest request = * GetFeaturestoreRequest.newBuilder() @@ -479,6 +512,8 @@ public final UnaryCallablegetFeaturestore * Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); * for (Featurestore element : @@ -507,6 +542,8 @@ public final ListFeaturestoresPagedResponse listFeaturestores(LocationName paren *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString(); * for (Featurestore element : @@ -533,6 +570,8 @@ public final ListFeaturestoresPagedResponse listFeaturestores(String parent) { *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * ListFeaturestoresRequest request = * ListFeaturestoresRequest.newBuilder() @@ -564,6 +603,8 @@ public final ListFeaturestoresPagedResponse listFeaturestores(ListFeaturestoresR *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * ListFeaturestoresRequest request = * ListFeaturestoresRequest.newBuilder() @@ -595,6 +636,8 @@ public final ListFeaturestoresPagedResponse listFeaturestores(ListFeaturestoresR *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * ListFeaturestoresRequest request = * ListFeaturestoresRequest.newBuilder() @@ -608,7 +651,7 @@ public final ListFeaturestoresPagedResponse listFeaturestores(ListFeaturestoresR * while (true) { * ListFeaturestoresResponse response = * featurestoreServiceClient.listFeaturestoresCallable().call(request); - * for (Featurestore element : response.getResponsesList()) { + * for (Featurestore element : response.getFeaturestoresList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -633,6 +676,8 @@ public final ListFeaturestoresPagedResponse listFeaturestores(ListFeaturestoresR *Sample code: * *
{@code + * // This snippet has been automatically generated for illustrative purposes only. + * // It may require modifications to work in your environment. * try (FeaturestoreServiceClient featurestoreServiceClient = FeaturestoreServiceClient.create()) { * Featurestore featurestore = Featurestore.newBuilder().build(); * FieldMask updateMask = FieldMask.newBuilder().build(); @@ -650,7 +695,8 @@ public final ListFeaturestoresPagedResponse listFeaturestores(ListFeaturestoresR * the user does not provide a mask then only the non-empty fields present in the request will * be overwritten. Set the update_mask to `*` to override all fields. *