diff --git a/java-tpu/README.md b/java-tpu/README.md index 350c15f40615..7145a0d5c7f3 100644 --- a/java-tpu/README.md +++ b/java-tpu/README.md @@ -20,7 +20,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file: com.google.cloud libraries-bom - 26.11.0 + 26.13.0 pom import @@ -195,7 +195,7 @@ Java is a registered trademark of Oracle and/or its affiliates. [kokoro-badge-link-5]: http://storage.googleapis.com/cloud-devrel-public/java/badges/google-cloud-java/java11.html [stability-image]: https://img.shields.io/badge/stability-stable-green [maven-version-image]: https://img.shields.io/maven-central/v/com.google.cloud/google-cloud-tpu.svg -[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-tpu/2.15.0 +[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-tpu/2.16.0 [authentication]: https://github.com/googleapis/google-cloud-java#authentication [auth-scopes]: https://developers.google.com/identity/protocols/oauth2/scopes [predefined-iam-roles]: https://cloud.google.com/iam/docs/understanding-roles#predefined_roles diff --git a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/TpuClient.java b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/TpuClient.java index e9f3f21dda6b..35d74add7bff 100644 --- a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/TpuClient.java +++ b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/TpuClient.java @@ -1336,7 +1336,7 @@ public final UnaryCallable getQueuedRe * * @param parent Required. The parent resource name. * @param queuedResource Required. The queued resource. - * @param queuedResourceId The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$ + * @param queuedResourceId The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$` * regex format. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ @@ -1374,7 +1374,7 @@ public final OperationFuture createQueuedReso * * @param parent Required. The parent resource name. * @param queuedResource Required. The queued resource. - * @param queuedResourceId The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$ + * @param queuedResourceId The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$` * regex format. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ @@ -1636,6 +1636,154 @@ public final OperationFuture deleteQueuedReso return stub.deleteQueuedResourceCallable(); } + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Resets a QueuedResource TPU instance + * + *

Sample code: + * + * 

{@code
+   * // This snippet has been automatically generated and should be regarded as a code template only.
+   * // It will require modifications to work:
+   * // - It may require correct/in-range values for request initialization.
+   * // - It may require specifying regional endpoints when creating the service client as shown in
+   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+   * try (TpuClient tpuClient = TpuClient.create()) {
+   *   QueuedResourceName name =
+   *       QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]");
+   *   QueuedResource response = tpuClient.resetQueuedResourceAsync(name).get();
+   * }
+   * }
+ * + * @param name Required. The name of the queued resource. + * @throws com.google.api.gax.rpc.ApiException if the remote call fails + */ + public final OperationFuture resetQueuedResourceAsync( + QueuedResourceName name) { + ResetQueuedResourceRequest request = + ResetQueuedResourceRequest.newBuilder() + .setName(name == null ? null : name.toString()) + .build(); + return resetQueuedResourceAsync(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Resets a QueuedResource TPU instance + * + *

Sample code: + * + * 

{@code
+   * // This snippet has been automatically generated and should be regarded as a code template only.
+   * // It will require modifications to work:
+   * // - It may require correct/in-range values for request initialization.
+   * // - It may require specifying regional endpoints when creating the service client as shown in
+   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+   * try (TpuClient tpuClient = TpuClient.create()) {
+   *   String name =
+   *       QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString();
+   *   QueuedResource response = tpuClient.resetQueuedResourceAsync(name).get();
+   * }
+   * }
+ * + * @param name Required. The name of the queued resource. + * @throws com.google.api.gax.rpc.ApiException if the remote call fails + */ + public final OperationFuture resetQueuedResourceAsync( + String name) { + ResetQueuedResourceRequest request = + ResetQueuedResourceRequest.newBuilder().setName(name).build(); + return resetQueuedResourceAsync(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Resets a QueuedResource TPU instance + * + *

Sample code: + * + * 

{@code
+   * // This snippet has been automatically generated and should be regarded as a code template only.
+   * // It will require modifications to work:
+   * // - It may require correct/in-range values for request initialization.
+   * // - It may require specifying regional endpoints when creating the service client as shown in
+   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+   * try (TpuClient tpuClient = TpuClient.create()) {
+   *   ResetQueuedResourceRequest request =
+   *       ResetQueuedResourceRequest.newBuilder()
+   *           .setName(
+   *               QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString())
+   *           .build();
+   *   QueuedResource response = tpuClient.resetQueuedResourceAsync(request).get();
+   * }
+   * }
+ * + * @param request The request object containing all of the parameters for the API call. + * @throws com.google.api.gax.rpc.ApiException if the remote call fails + */ + public final OperationFuture resetQueuedResourceAsync( + ResetQueuedResourceRequest request) { + return resetQueuedResourceOperationCallable().futureCall(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Resets a QueuedResource TPU instance + * + *

Sample code: + * + * 

{@code
+   * // This snippet has been automatically generated and should be regarded as a code template only.
+   * // It will require modifications to work:
+   * // - It may require correct/in-range values for request initialization.
+   * // - It may require specifying regional endpoints when creating the service client as shown in
+   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+   * try (TpuClient tpuClient = TpuClient.create()) {
+   *   ResetQueuedResourceRequest request =
+   *       ResetQueuedResourceRequest.newBuilder()
+   *           .setName(
+   *               QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString())
+   *           .build();
+   *   OperationFuture future =
+   *       tpuClient.resetQueuedResourceOperationCallable().futureCall(request);
+   *   // Do something.
+   *   QueuedResource response = future.get();
+   * }
+   * }
+ */ + public final OperationCallable + resetQueuedResourceOperationCallable() { + return stub.resetQueuedResourceOperationCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Resets a QueuedResource TPU instance + * + *

Sample code: + * + * 

{@code
+   * // This snippet has been automatically generated and should be regarded as a code template only.
+   * // It will require modifications to work:
+   * // - It may require correct/in-range values for request initialization.
+   * // - It may require specifying regional endpoints when creating the service client as shown in
+   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+   * try (TpuClient tpuClient = TpuClient.create()) {
+   *   ResetQueuedResourceRequest request =
+   *       ResetQueuedResourceRequest.newBuilder()
+   *           .setName(
+   *               QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString())
+   *           .build();
+   *   ApiFuture future = tpuClient.resetQueuedResourceCallable().futureCall(request);
+   *   // Do something.
+   *   Operation response = future.get();
+   * }
+   * }
+ */ + public final UnaryCallable resetQueuedResourceCallable() { + return stub.resetQueuedResourceCallable(); + } + // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Generates the Cloud TPU service identity for the project. diff --git a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/TpuSettings.java b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/TpuSettings.java index a0ba9a34deeb..9054ead9cc87 100644 --- a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/TpuSettings.java +++ b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/TpuSettings.java @@ -185,6 +185,17 @@ public UnaryCallSettings deleteQueuedRes return ((TpuStubSettings) getStubSettings()).deleteQueuedResourceOperationSettings(); } + /** Returns the object with the settings used for calls to resetQueuedResource. */ + public UnaryCallSettings resetQueuedResourceSettings() { + return ((TpuStubSettings) getStubSettings()).resetQueuedResourceSettings(); + } + + /** Returns the object with the settings used for calls to resetQueuedResource. */ + public OperationCallSettings + resetQueuedResourceOperationSettings() { + return ((TpuStubSettings) getStubSettings()).resetQueuedResourceOperationSettings(); + } + /** Returns the object with the settings used for calls to generateServiceIdentity. */ public UnaryCallSettings generateServiceIdentitySettings() { @@ -450,6 +461,19 @@ public UnaryCallSettings.Builder updateNodeSetting return getStubSettingsBuilder().deleteQueuedResourceOperationSettings(); } + /** Returns the builder for the settings used for calls to resetQueuedResource. */ + public UnaryCallSettings.Builder + resetQueuedResourceSettings() { + return getStubSettingsBuilder().resetQueuedResourceSettings(); + } + + /** Returns the builder for the settings used for calls to resetQueuedResource. */ + public OperationCallSettings.Builder< + ResetQueuedResourceRequest, QueuedResource, OperationMetadata> + resetQueuedResourceOperationSettings() { + return getStubSettingsBuilder().resetQueuedResourceOperationSettings(); + } + /** Returns the builder for the settings used for calls to generateServiceIdentity. */ public UnaryCallSettings.Builder< GenerateServiceIdentityRequest, GenerateServiceIdentityResponse> diff --git a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/gapic_metadata.json b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/gapic_metadata.json index c0c8ee5f3d5d..f0df61cdf037 100644 --- a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/gapic_metadata.json +++ b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/gapic_metadata.json @@ -58,6 +58,9 @@ "ListRuntimeVersions": { "methods": ["listRuntimeVersions", "listRuntimeVersions", "listRuntimeVersions", "listRuntimeVersionsPagedCallable", "listRuntimeVersionsCallable"] }, + "ResetQueuedResource": { + "methods": ["resetQueuedResourceAsync", "resetQueuedResourceAsync", "resetQueuedResourceAsync", "resetQueuedResourceOperationCallable", "resetQueuedResourceCallable"] + }, "SimulateMaintenanceEvent": { "methods": ["simulateMaintenanceEventAsync", "simulateMaintenanceEventOperationCallable", "simulateMaintenanceEventCallable"] }, diff --git a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/GrpcTpuStub.java b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/GrpcTpuStub.java index 5760526c4511..c2ce5a5de60e 100644 --- a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/GrpcTpuStub.java +++ b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/GrpcTpuStub.java @@ -58,6 +58,7 @@ import com.google.cloud.tpu.v2alpha1.Node; import com.google.cloud.tpu.v2alpha1.OperationMetadata; import com.google.cloud.tpu.v2alpha1.QueuedResource; +import com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest; import com.google.cloud.tpu.v2alpha1.RuntimeVersion; import com.google.cloud.tpu.v2alpha1.SimulateMaintenanceEventRequest; import com.google.cloud.tpu.v2alpha1.StartNodeRequest; @@ -180,6 +181,16 @@ public class GrpcTpuStub extends TpuStub { .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) .build(); + private static final MethodDescriptor + resetQueuedResourceMethodDescriptor = + MethodDescriptor.newBuilder() + .setType(MethodDescriptor.MethodType.UNARY) + .setFullMethodName("google.cloud.tpu.v2alpha1.Tpu/ResetQueuedResource") + .setRequestMarshaller( + ProtoUtils.marshaller(ResetQueuedResourceRequest.getDefaultInstance())) + .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) + .build(); + private static final MethodDescriptor< GenerateServiceIdentityRequest, GenerateServiceIdentityResponse> generateServiceIdentityMethodDescriptor = @@ -304,6 +315,9 @@ public class GrpcTpuStub extends TpuStub { private final UnaryCallable deleteQueuedResourceCallable; private final OperationCallable deleteQueuedResourceOperationCallable; + private final UnaryCallable resetQueuedResourceCallable; + private final OperationCallable + resetQueuedResourceOperationCallable; private final UnaryCallable generateServiceIdentityCallable; private final UnaryCallable @@ -476,6 +490,16 @@ protected GrpcTpuStub( return params.build(); }) .build(); + GrpcCallSettings resetQueuedResourceTransportSettings = + GrpcCallSettings.newBuilder() + .setMethodDescriptor(resetQueuedResourceMethodDescriptor) + .setParamsExtractor( + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); + }) + .build(); GrpcCallSettings generateServiceIdentityTransportSettings = GrpcCallSettings @@ -665,6 +689,17 @@ protected GrpcTpuStub( settings.deleteQueuedResourceOperationSettings(), clientContext, operationsStub); + this.resetQueuedResourceCallable = + callableFactory.createUnaryCallable( + resetQueuedResourceTransportSettings, + settings.resetQueuedResourceSettings(), + clientContext); + this.resetQueuedResourceOperationCallable = + callableFactory.createOperationCallable( + resetQueuedResourceTransportSettings, + settings.resetQueuedResourceOperationSettings(), + clientContext, + operationsStub); this.generateServiceIdentityCallable = callableFactory.createUnaryCallable( generateServiceIdentityTransportSettings, @@ -841,6 +876,17 @@ public UnaryCallable deleteQueuedResourc return deleteQueuedResourceOperationCallable; } + @Override + public UnaryCallable resetQueuedResourceCallable() { + return resetQueuedResourceCallable; + } + + @Override + public OperationCallable + resetQueuedResourceOperationCallable() { + return resetQueuedResourceOperationCallable; + } + @Override public UnaryCallable generateServiceIdentityCallable() { diff --git a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/TpuStub.java b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/TpuStub.java index 5840bb723c1b..442a88388992 100644 --- a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/TpuStub.java +++ b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/TpuStub.java @@ -54,6 +54,7 @@ import com.google.cloud.tpu.v2alpha1.Node; import com.google.cloud.tpu.v2alpha1.OperationMetadata; import com.google.cloud.tpu.v2alpha1.QueuedResource; +import com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest; import com.google.cloud.tpu.v2alpha1.RuntimeVersion; import com.google.cloud.tpu.v2alpha1.SimulateMaintenanceEventRequest; import com.google.cloud.tpu.v2alpha1.StartNodeRequest; @@ -167,6 +168,16 @@ public UnaryCallable deleteQueuedResourc throw new UnsupportedOperationException("Not implemented: deleteQueuedResourceCallable()"); } + public OperationCallable + resetQueuedResourceOperationCallable() { + throw new UnsupportedOperationException( + "Not implemented: resetQueuedResourceOperationCallable()"); + } + + public UnaryCallable resetQueuedResourceCallable() { + throw new UnsupportedOperationException("Not implemented: resetQueuedResourceCallable()"); + } + public UnaryCallable generateServiceIdentityCallable() { throw new UnsupportedOperationException("Not implemented: generateServiceIdentityCallable()"); diff --git a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/TpuStubSettings.java b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/TpuStubSettings.java index 09fc1bae92b1..18da2ecefdaa 100644 --- a/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/TpuStubSettings.java +++ b/java-tpu/google-cloud-tpu/src/main/java/com/google/cloud/tpu/v2alpha1/stub/TpuStubSettings.java @@ -76,6 +76,7 @@ import com.google.cloud.tpu.v2alpha1.Node; import com.google.cloud.tpu.v2alpha1.OperationMetadata; import com.google.cloud.tpu.v2alpha1.QueuedResource; +import com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest; import com.google.cloud.tpu.v2alpha1.RuntimeVersion; import com.google.cloud.tpu.v2alpha1.SimulateMaintenanceEventRequest; import com.google.cloud.tpu.v2alpha1.StartNodeRequest; @@ -168,6 +169,10 @@ public class TpuStubSettings extends StubSettings { private final OperationCallSettings< DeleteQueuedResourceRequest, QueuedResource, OperationMetadata> deleteQueuedResourceOperationSettings; + private final UnaryCallSettings + resetQueuedResourceSettings; + private final OperationCallSettings + resetQueuedResourceOperationSettings; private final UnaryCallSettings generateServiceIdentitySettings; private final PagedCallSettings< @@ -586,6 +591,17 @@ public UnaryCallSettings deleteQueuedRes return deleteQueuedResourceOperationSettings; } + /** Returns the object with the settings used for calls to resetQueuedResource. */ + public UnaryCallSettings resetQueuedResourceSettings() { + return resetQueuedResourceSettings; + } + + /** Returns the object with the settings used for calls to resetQueuedResource. */ + public OperationCallSettings + resetQueuedResourceOperationSettings() { + return resetQueuedResourceOperationSettings; + } + /** Returns the object with the settings used for calls to generateServiceIdentity. */ public UnaryCallSettings generateServiceIdentitySettings() { @@ -742,6 +758,9 @@ protected TpuStubSettings(Builder settingsBuilder) throws IOException { deleteQueuedResourceSettings = settingsBuilder.deleteQueuedResourceSettings().build(); deleteQueuedResourceOperationSettings = settingsBuilder.deleteQueuedResourceOperationSettings().build(); + resetQueuedResourceSettings = settingsBuilder.resetQueuedResourceSettings().build(); + resetQueuedResourceOperationSettings = + settingsBuilder.resetQueuedResourceOperationSettings().build(); generateServiceIdentitySettings = settingsBuilder.generateServiceIdentitySettings().build(); listAcceleratorTypesSettings = settingsBuilder.listAcceleratorTypesSettings().build(); getAcceleratorTypeSettings = settingsBuilder.getAcceleratorTypeSettings().build(); @@ -794,6 +813,11 @@ public static class Builder extends StubSettings.Builder deleteQueuedResourceOperationSettings; + private final UnaryCallSettings.Builder + resetQueuedResourceSettings; + private final OperationCallSettings.Builder< + ResetQueuedResourceRequest, QueuedResource, OperationMetadata> + resetQueuedResourceOperationSettings; private final UnaryCallSettings.Builder< GenerateServiceIdentityRequest, GenerateServiceIdentityResponse> generateServiceIdentitySettings; @@ -875,6 +899,8 @@ protected Builder(ClientContext clientContext) { createQueuedResourceOperationSettings = OperationCallSettings.newBuilder(); deleteQueuedResourceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); deleteQueuedResourceOperationSettings = OperationCallSettings.newBuilder(); + resetQueuedResourceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); + resetQueuedResourceOperationSettings = OperationCallSettings.newBuilder(); generateServiceIdentitySettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); listAcceleratorTypesSettings = PagedCallSettings.newBuilder(LIST_ACCELERATOR_TYPES_PAGE_STR_FACT); @@ -901,6 +927,7 @@ protected Builder(ClientContext clientContext) { getQueuedResourceSettings, createQueuedResourceSettings, deleteQueuedResourceSettings, + resetQueuedResourceSettings, generateServiceIdentitySettings, listAcceleratorTypesSettings, getAcceleratorTypeSettings, @@ -936,6 +963,9 @@ protected Builder(TpuStubSettings settings) { deleteQueuedResourceSettings = settings.deleteQueuedResourceSettings.toBuilder(); deleteQueuedResourceOperationSettings = settings.deleteQueuedResourceOperationSettings.toBuilder(); + resetQueuedResourceSettings = settings.resetQueuedResourceSettings.toBuilder(); + resetQueuedResourceOperationSettings = + settings.resetQueuedResourceOperationSettings.toBuilder(); generateServiceIdentitySettings = settings.generateServiceIdentitySettings.toBuilder(); listAcceleratorTypesSettings = settings.listAcceleratorTypesSettings.toBuilder(); getAcceleratorTypeSettings = settings.getAcceleratorTypeSettings.toBuilder(); @@ -961,6 +991,7 @@ protected Builder(TpuStubSettings settings) { getQueuedResourceSettings, createQueuedResourceSettings, deleteQueuedResourceSettings, + resetQueuedResourceSettings, generateServiceIdentitySettings, listAcceleratorTypesSettings, getAcceleratorTypeSettings, @@ -1041,6 +1072,11 @@ private static Builder initDefaults(Builder builder) { .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_0_params")); + builder + .resetQueuedResourceSettings() + .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes")) + .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_0_params")); + builder .generateServiceIdentitySettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes")) @@ -1245,6 +1281,30 @@ private static Builder initDefaults(Builder builder) { .setTotalTimeout(Duration.ofMillis(300000L)) .build())); + builder + .resetQueuedResourceOperationSettings() + .setInitialCallSettings( + UnaryCallSettings + .newUnaryCallSettingsBuilder() + .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes")) + .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_0_params")) + .build()) + .setResponseTransformer( + ProtoOperationTransformers.ResponseTransformer.create(QueuedResource.class)) + .setMetadataTransformer( + ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) + .setPollingAlgorithm( + OperationTimedPollAlgorithm.create( + RetrySettings.newBuilder() + .setInitialRetryDelay(Duration.ofMillis(5000L)) + .setRetryDelayMultiplier(1.5) + .setMaxRetryDelay(Duration.ofMillis(45000L)) + .setInitialRpcTimeout(Duration.ZERO) + .setRpcTimeoutMultiplier(1.0) + .setMaxRpcTimeout(Duration.ZERO) + .setTotalTimeout(Duration.ofMillis(300000L)) + .build())); + builder .simulateMaintenanceEventOperationSettings() .setInitialCallSettings( @@ -1407,6 +1467,21 @@ public UnaryCallSettings.Builder updateNodeSetting return deleteQueuedResourceOperationSettings; } + /** Returns the builder for the settings used for calls to resetQueuedResource. */ + public UnaryCallSettings.Builder + resetQueuedResourceSettings() { + return resetQueuedResourceSettings; + } + + /** Returns the builder for the settings used for calls to resetQueuedResource. */ + @BetaApi( + "The surface for use by generated code is not stable yet and may change in the future.") + public OperationCallSettings.Builder< + ResetQueuedResourceRequest, QueuedResource, OperationMetadata> + resetQueuedResourceOperationSettings() { + return resetQueuedResourceOperationSettings; + } + /** Returns the builder for the settings used for calls to generateServiceIdentity. */ public UnaryCallSettings.Builder< GenerateServiceIdentityRequest, GenerateServiceIdentityResponse> diff --git a/java-tpu/google-cloud-tpu/src/test/java/com/google/cloud/tpu/v2alpha1/MockTpuImpl.java b/java-tpu/google-cloud-tpu/src/test/java/com/google/cloud/tpu/v2alpha1/MockTpuImpl.java index 110a7e2439ce..e7d2c48d1dcf 100644 --- a/java-tpu/google-cloud-tpu/src/test/java/com/google/cloud/tpu/v2alpha1/MockTpuImpl.java +++ b/java-tpu/google-cloud-tpu/src/test/java/com/google/cloud/tpu/v2alpha1/MockTpuImpl.java @@ -285,6 +285,27 @@ public void deleteQueuedResource( } } + @Override + public void resetQueuedResource( + ResetQueuedResourceRequest request, StreamObserver responseObserver) { + Object response = responses.poll(); + if (response instanceof Operation) { + requests.add(request); + responseObserver.onNext(((Operation) response)); + responseObserver.onCompleted(); + } else if (response instanceof Exception) { + responseObserver.onError(((Exception) response)); + } else { + responseObserver.onError( + new IllegalArgumentException( + String.format( + "Unrecognized response type %s for method ResetQueuedResource, expected %s or %s", + response == null ? "null" : response.getClass().getName(), + Operation.class.getName(), + Exception.class.getName()))); + } + } + @Override public void generateServiceIdentity( GenerateServiceIdentityRequest request, diff --git a/java-tpu/google-cloud-tpu/src/test/java/com/google/cloud/tpu/v2alpha1/TpuClientTest.java b/java-tpu/google-cloud-tpu/src/test/java/com/google/cloud/tpu/v2alpha1/TpuClientTest.java index 70043ba4c36c..596afc2e76fe 100644 --- a/java-tpu/google-cloud-tpu/src/test/java/com/google/cloud/tpu/v2alpha1/TpuClientTest.java +++ b/java-tpu/google-cloud-tpu/src/test/java/com/google/cloud/tpu/v2alpha1/TpuClientTest.java @@ -831,6 +831,7 @@ public void getQueuedResourceTest() throws Exception { QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) .setQueueingPolicy(QueuedResource.QueueingPolicy.newBuilder().build()) .setState(QueuedResourceState.newBuilder().build()) + .setReservationName("reservationName-337941385") .build(); mockTpu.addResponse(expectedResponse); @@ -873,6 +874,7 @@ public void getQueuedResourceTest2() throws Exception { QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) .setQueueingPolicy(QueuedResource.QueueingPolicy.newBuilder().build()) .setState(QueuedResourceState.newBuilder().build()) + .setReservationName("reservationName-337941385") .build(); mockTpu.addResponse(expectedResponse); @@ -914,6 +916,7 @@ public void createQueuedResourceTest() throws Exception { QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) .setQueueingPolicy(QueuedResource.QueueingPolicy.newBuilder().build()) .setState(QueuedResourceState.newBuilder().build()) + .setReservationName("reservationName-337941385") .build(); Operation resultOperation = Operation.newBuilder() @@ -971,6 +974,7 @@ public void createQueuedResourceTest2() throws Exception { QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) .setQueueingPolicy(QueuedResource.QueueingPolicy.newBuilder().build()) .setState(QueuedResourceState.newBuilder().build()) + .setReservationName("reservationName-337941385") .build(); Operation resultOperation = Operation.newBuilder() @@ -1028,6 +1032,7 @@ public void deleteQueuedResourceTest() throws Exception { QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) .setQueueingPolicy(QueuedResource.QueueingPolicy.newBuilder().build()) .setState(QueuedResourceState.newBuilder().build()) + .setReservationName("reservationName-337941385") .build(); Operation resultOperation = Operation.newBuilder() @@ -1079,6 +1084,7 @@ public void deleteQueuedResourceTest2() throws Exception { QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) .setQueueingPolicy(QueuedResource.QueueingPolicy.newBuilder().build()) .setState(QueuedResourceState.newBuilder().build()) + .setReservationName("reservationName-337941385") .build(); Operation resultOperation = Operation.newBuilder() @@ -1121,6 +1127,107 @@ public void deleteQueuedResourceExceptionTest2() throws Exception { } } + @Test + public void resetQueuedResourceTest() throws Exception { + QueuedResource expectedResponse = + QueuedResource.newBuilder() + .setName( + QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) + .setQueueingPolicy(QueuedResource.QueueingPolicy.newBuilder().build()) + .setState(QueuedResourceState.newBuilder().build()) + .setReservationName("reservationName-337941385") + .build(); + Operation resultOperation = + Operation.newBuilder() + .setName("resetQueuedResourceTest") + .setDone(true) + .setResponse(Any.pack(expectedResponse)) + .build(); + mockTpu.addResponse(resultOperation); + + QueuedResourceName name = QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]"); + + QueuedResource actualResponse = client.resetQueuedResourceAsync(name).get(); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockTpu.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + ResetQueuedResourceRequest actualRequest = ((ResetQueuedResourceRequest) actualRequests.get(0)); + + Assert.assertEquals(name.toString(), actualRequest.getName()); + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + public void resetQueuedResourceExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); + mockTpu.addException(exception); + + try { + QueuedResourceName name = + QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]"); + client.resetQueuedResourceAsync(name).get(); + Assert.fail("No exception raised"); + } catch (ExecutionException e) { + Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass()); + InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause()); + Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode()); + } + } + + @Test + public void resetQueuedResourceTest2() throws Exception { + QueuedResource expectedResponse = + QueuedResource.newBuilder() + .setName( + QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) + .setQueueingPolicy(QueuedResource.QueueingPolicy.newBuilder().build()) + .setState(QueuedResourceState.newBuilder().build()) + .setReservationName("reservationName-337941385") + .build(); + Operation resultOperation = + Operation.newBuilder() + .setName("resetQueuedResourceTest") + .setDone(true) + .setResponse(Any.pack(expectedResponse)) + .build(); + mockTpu.addResponse(resultOperation); + + String name = "name3373707"; + + QueuedResource actualResponse = client.resetQueuedResourceAsync(name).get(); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockTpu.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + ResetQueuedResourceRequest actualRequest = ((ResetQueuedResourceRequest) actualRequests.get(0)); + + Assert.assertEquals(name, actualRequest.getName()); + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + public void resetQueuedResourceExceptionTest2() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); + mockTpu.addException(exception); + + try { + String name = "name3373707"; + client.resetQueuedResourceAsync(name).get(); + Assert.fail("No exception raised"); + } catch (ExecutionException e) { + Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass()); + InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause()); + Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode()); + } + } + @Test public void generateServiceIdentityTest() throws Exception { GenerateServiceIdentityResponse expectedResponse = diff --git a/java-tpu/grpc-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/TpuGrpc.java b/java-tpu/grpc-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/TpuGrpc.java index 1beb317c5dec..cabd9b33866f 100644 --- a/java-tpu/grpc-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/TpuGrpc.java +++ b/java-tpu/grpc-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/TpuGrpc.java @@ -510,6 +510,52 @@ private TpuGrpc() {} return getDeleteQueuedResourceMethod; } + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest, + com.google.longrunning.Operation> + getResetQueuedResourceMethod; + + @io.grpc.stub.annotations.RpcMethod( + fullMethodName = SERVICE_NAME + '/' + "ResetQueuedResource", + requestType = com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest.class, + responseType = com.google.longrunning.Operation.class, + methodType = io.grpc.MethodDescriptor.MethodType.UNARY) + public static io.grpc.MethodDescriptor< + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest, + com.google.longrunning.Operation> + getResetQueuedResourceMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest, + com.google.longrunning.Operation> + getResetQueuedResourceMethod; + if ((getResetQueuedResourceMethod = TpuGrpc.getResetQueuedResourceMethod) == null) { + synchronized (TpuGrpc.class) { + if ((getResetQueuedResourceMethod = TpuGrpc.getResetQueuedResourceMethod) == null) { + TpuGrpc.getResetQueuedResourceMethod = + getResetQueuedResourceMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName( + generateFullMethodName(SERVICE_NAME, "ResetQueuedResource")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.longrunning.Operation.getDefaultInstance())) + .setSchemaDescriptor(new TpuMethodDescriptorSupplier("ResetQueuedResource")) + .build(); + } + } + } + return getResetQueuedResourceMethod; + } + private static volatile io.grpc.MethodDescriptor< com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityRequest, com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityResponse> @@ -1034,6 +1080,20 @@ default void deleteQueuedResource( getDeleteQueuedResourceMethod(), responseObserver); } + /** + * + * + * 
+     * Resets a QueuedResource TPU instance
+     *
+ */ + default void resetQueuedResource( + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest request, + io.grpc.stub.StreamObserver responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getResetQueuedResourceMethod(), responseObserver); + } + /** * * @@ -1338,6 +1398,22 @@ public void deleteQueuedResource( responseObserver); } + /** + * + * + * 
+     * Resets a QueuedResource TPU instance
+     *
+ */ + public void resetQueuedResource( + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest request, + io.grpc.stub.StreamObserver responseObserver) { + io.grpc.stub.ClientCalls.asyncUnaryCall( + getChannel().newCall(getResetQueuedResourceMethod(), getCallOptions()), + request, + responseObserver); + } + /** * * @@ -1619,6 +1695,19 @@ public com.google.longrunning.Operation deleteQueuedResource( getChannel(), getDeleteQueuedResourceMethod(), getCallOptions(), request); } + /** + * + * + * 
+     * Resets a QueuedResource TPU instance
+     *
+ */ + public com.google.longrunning.Operation resetQueuedResource( + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getResetQueuedResourceMethod(), getCallOptions(), request); + } + /** * * @@ -1875,6 +1964,19 @@ protected TpuFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callO getChannel().newCall(getDeleteQueuedResourceMethod(), getCallOptions()), request); } + /** + * + * + * 
+     * Resets a QueuedResource TPU instance
+     *
+ */ + public com.google.common.util.concurrent.ListenableFuture + resetQueuedResource(com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest request) { + return io.grpc.stub.ClientCalls.futureUnaryCall( + getChannel().newCall(getResetQueuedResourceMethod(), getCallOptions()), request); + } + /** * * @@ -1986,13 +2088,14 @@ protected TpuFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callO private static final int METHODID_GET_QUEUED_RESOURCE = 8; private static final int METHODID_CREATE_QUEUED_RESOURCE = 9; private static final int METHODID_DELETE_QUEUED_RESOURCE = 10; - private static final int METHODID_GENERATE_SERVICE_IDENTITY = 11; - private static final int METHODID_LIST_ACCELERATOR_TYPES = 12; - private static final int METHODID_GET_ACCELERATOR_TYPE = 13; - private static final int METHODID_LIST_RUNTIME_VERSIONS = 14; - private static final int METHODID_GET_RUNTIME_VERSION = 15; - private static final int METHODID_GET_GUEST_ATTRIBUTES = 16; - private static final int METHODID_SIMULATE_MAINTENANCE_EVENT = 17; + private static final int METHODID_RESET_QUEUED_RESOURCE = 11; + private static final int METHODID_GENERATE_SERVICE_IDENTITY = 12; + private static final int METHODID_LIST_ACCELERATOR_TYPES = 13; + private static final int METHODID_GET_ACCELERATOR_TYPE = 14; + private static final int METHODID_LIST_RUNTIME_VERSIONS = 15; + private static final int METHODID_GET_RUNTIME_VERSION = 16; + private static final int METHODID_GET_GUEST_ATTRIBUTES = 17; + private static final int METHODID_SIMULATE_MAINTENANCE_EVENT = 18; private static final class MethodHandlers implements io.grpc.stub.ServerCalls.UnaryMethod, @@ -2070,6 +2173,11 @@ public void invoke(Req request, io.grpc.stub.StreamObserver responseObserv (com.google.cloud.tpu.v2alpha1.DeleteQueuedResourceRequest) request, (io.grpc.stub.StreamObserver) responseObserver); break; + case METHODID_RESET_QUEUED_RESOURCE: + serviceImpl.resetQueuedResource( + (com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest) request, + (io.grpc.stub.StreamObserver) responseObserver); + break; case METHODID_GENERATE_SERVICE_IDENTITY: serviceImpl.generateServiceIdentity( (com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityRequest) request, @@ -2201,6 +2309,12 @@ public static final io.grpc.ServerServiceDefinition bindService(AsyncService ser new MethodHandlers< com.google.cloud.tpu.v2alpha1.DeleteQueuedResourceRequest, com.google.longrunning.Operation>(service, METHODID_DELETE_QUEUED_RESOURCE))) + .addMethod( + getResetQueuedResourceMethod(), + io.grpc.stub.ServerCalls.asyncUnaryCall( + new MethodHandlers< + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest, + com.google.longrunning.Operation>(service, METHODID_RESET_QUEUED_RESOURCE))) .addMethod( getGenerateServiceIdentityMethod(), io.grpc.stub.ServerCalls.asyncUnaryCall( @@ -2310,6 +2424,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() { .addMethod(getGetQueuedResourceMethod()) .addMethod(getCreateQueuedResourceMethod()) .addMethod(getDeleteQueuedResourceMethod()) + .addMethod(getResetQueuedResourceMethod()) .addMethod(getGenerateServiceIdentityMethod()) .addMethod(getListAcceleratorTypesMethod()) .addMethod(getGetAcceleratorTypeMethod()) diff --git a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CloudTpuProto.java b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CloudTpuProto.java index c3b4dcd9818e..198afd2f5267 100644 --- a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CloudTpuProto.java +++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CloudTpuProto.java @@ -187,6 +187,10 @@ public static void registerAllExtensions(com.google.protobuf.ExtensionRegistry r internal_static_google_cloud_tpu_v2alpha1_DeleteQueuedResourceRequest_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_cloud_tpu_v2alpha1_DeleteQueuedResourceRequest_fieldAccessorTable; + static final com.google.protobuf.Descriptors.Descriptor + internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_descriptor; + static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_cloud_tpu_v2alpha1_ServiceIdentity_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable @@ -342,7 +346,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "ED\020\000\022\r\n\tV1_ALPHA1\020\001\022\006\n\002V1\020\002\022\r\n\tV2_ALPHA1" + "\020\003:R\352AO\n\027tpu.googleapis.com/Node\0224projec" + "ts/{project}/locations/{location}/nodes/" - + "{node}\"\252\t\n\016QueuedResource\022\024\n\004name\030\001 \001(\tB" + + "{node}\"\304\t\n\016QueuedResource\022\024\n\004name\030\001 \001(\tB" + "\006\340A\003\340A\005\022<\n\003tpu\030\002 \001(\0132-.google.cloud.tpu." + "v2alpha1.QueuedResource.TpuH\000\022K\n\013best_ef" + "fort\030\003 \001(\01324.google.cloud.tpu.v2alpha1.Q" @@ -352,251 +356,260 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "y\030\005 \001(\01328.google.cloud.tpu.v2alpha1.Queu" + "edResource.QueueingPolicy\022B\n\005state\030\006 \001(\013" + "2..google.cloud.tpu.v2alpha1.QueuedResou" - + "rceStateB\003\340A\003\032\335\001\n\003Tpu\022I\n\tnode_spec\030\001 \003(\013" - + "26.google.cloud.tpu.v2alpha1.QueuedResou" - + "rce.Tpu.NodeSpec\032\212\001\n\010NodeSpec\0229\n\006parent\030" - + "\001 \001(\tB)\340A\002\372A#\n!locations.googleapis.com/" - + "Location\022\017\n\007node_id\030\002 \001(\t\0222\n\004node\030\003 \001(\0132" - + "\037.google.cloud.tpu.v2alpha1.NodeB\003\340A\002\032\014\n" - + "\nBestEffort\032Y\n\nGuaranteed\0224\n\014min_duratio" - + "n\030\001 \001(\0132\031.google.protobuf.DurationB\003\340A\001\022" - + "\025\n\010reserved\030\002 \001(\010B\003\340A\001\032\303\002\n\016QueueingPolic" - + "y\0229\n\024valid_until_duration\030\001 \001(\0132\031.google" - + ".protobuf.DurationH\000\0226\n\020valid_until_time" - + "\030\002 \001(\0132\032.google.protobuf.TimestampH\000\0229\n\024" - + "valid_after_duration\030\003 \001(\0132\031.google.prot" - + "obuf.DurationH\000\0226\n\020valid_after_time\030\004 \001(" - + "\0132\032.google.protobuf.TimestampH\000\022/\n\016valid" - + "_interval\030\005 \001(\0132\025.google.type.IntervalH\000" - + "B\032\n\030start_timing_constraints:q\352An\n!tpu.g" - + "oogleapis.com/QueuedResource\022Iprojects/{" - + "project}/locations/{location}/queuedReso" - + "urces/{queued_resource}B\n\n\010resourceB\006\n\004t" - + "ier\"\330\010\n\023QueuedResourceState\022C\n\005state\030\001 \001" - + "(\01624.google.cloud.tpu.v2alpha1.QueuedRes" - + "ourceState.State\022T\n\rcreating_data\030\002 \001(\0132" - + ";.google.cloud.tpu.v2alpha1.QueuedResour" - + "ceState.CreatingDataH\000\022T\n\raccepted_data\030" - + "\003 \001(\0132;.google.cloud.tpu.v2alpha1.Queued" - + "ResourceState.AcceptedDataH\000\022\\\n\021provisio" - + "ning_data\030\004 \001(\0132?.google.cloud.tpu.v2alp" - + "ha1.QueuedResourceState.ProvisioningData" - + "H\000\022P\n\013failed_data\030\005 \001(\01329.google.cloud.t" - + "pu.v2alpha1.QueuedResourceState.FailedDa" - + "taH\000\022T\n\rdeleting_data\030\006 \001(\0132;.google.clo" - + "ud.tpu.v2alpha1.QueuedResourceState.Dele" - + "tingDataH\000\022P\n\013active_data\030\007 \001(\01329.google" + + "rceStateB\003\340A\003\022\030\n\020reservation_name\030\010 \001(\t\032" + + "\335\001\n\003Tpu\022I\n\tnode_spec\030\001 \003(\01326.google.clou" + + "d.tpu.v2alpha1.QueuedResource.Tpu.NodeSp" + + "ec\032\212\001\n\010NodeSpec\0229\n\006parent\030\001 \001(\tB)\340A\002\372A#\n" + + "!locations.googleapis.com/Location\022\017\n\007no" + + "de_id\030\002 \001(\t\0222\n\004node\030\003 \001(\0132\037.google.cloud" + + ".tpu.v2alpha1.NodeB\003\340A\002\032\014\n\nBestEffort\032Y\n" + + "\nGuaranteed\0224\n\014min_duration\030\001 \001(\0132\031.goog" + + "le.protobuf.DurationB\003\340A\001\022\025\n\010reserved\030\002 " + + "\001(\010B\003\340A\001\032\303\002\n\016QueueingPolicy\0229\n\024valid_unt" + + "il_duration\030\001 \001(\0132\031.google.protobuf.Dura" + + "tionH\000\0226\n\020valid_until_time\030\002 \001(\0132\032.googl" + + "e.protobuf.TimestampH\000\0229\n\024valid_after_du" + + "ration\030\003 \001(\0132\031.google.protobuf.DurationH" + + "\000\0226\n\020valid_after_time\030\004 \001(\0132\032.google.pro" + + "tobuf.TimestampH\000\022/\n\016valid_interval\030\005 \001(" + + "\0132\025.google.type.IntervalH\000B\032\n\030start_timi" + + "ng_constraints:q\352An\n!tpu.googleapis.com/" + + "QueuedResource\022Iprojects/{project}/locat" + + "ions/{location}/queuedResources/{queued_" + + "resource}B\n\n\010resourceB\006\n\004tier\"\330\010\n\023Queued" + + "ResourceState\022C\n\005state\030\001 \001(\01624.google.cl" + + "oud.tpu.v2alpha1.QueuedResourceState.Sta" + + "te\022T\n\rcreating_data\030\002 \001(\0132;.google.cloud" + + ".tpu.v2alpha1.QueuedResourceState.Creati" + + "ngDataH\000\022T\n\raccepted_data\030\003 \001(\0132;.google" + ".cloud.tpu.v2alpha1.QueuedResourceState." - + "ActiveDataH\000\022X\n\017suspending_data\030\010 \001(\0132=." - + "google.cloud.tpu.v2alpha1.QueuedResource" - + "State.SuspendingDataH\000\022V\n\016suspended_data" - + "\030\t \001(\0132<.google.cloud.tpu.v2alpha1.Queue" - + "dResourceState.SuspendedDataH\000\032\016\n\014Creati" - + "ngData\032\016\n\014AcceptedData\032\022\n\020ProvisioningDa" - + "ta\032/\n\nFailedData\022!\n\005error\030\001 \001(\0132\022.google" - + ".rpc.Status\032\016\n\014DeletingData\032\014\n\nActiveDat" - + "a\032\020\n\016SuspendingData\032\017\n\rSuspendedData\"\221\001\n" - + "\005State\022\025\n\021STATE_UNSPECIFIED\020\000\022\014\n\010CREATIN" - + "G\020\001\022\014\n\010ACCEPTED\020\002\022\020\n\014PROVISIONING\020\003\022\n\n\006F" - + "AILED\020\004\022\014\n\010DELETING\020\005\022\n\n\006ACTIVE\020\006\022\016\n\nSUS" - + "PENDING\020\007\022\r\n\tSUSPENDED\020\010B\014\n\nstate_data\"j" - + "\n\020ListNodesRequest\022/\n\006parent\030\001 \001(\tB\037\340A\002\372" - + "A\031\022\027tpu.googleapis.com/Node\022\021\n\tpage_size" - + "\030\002 \001(\005\022\022\n\npage_token\030\003 \001(\t\"q\n\021ListNodesR" - + "esponse\022.\n\005nodes\030\001 \003(\0132\037.google.cloud.tp" - + "u.v2alpha1.Node\022\027\n\017next_page_token\030\002 \001(\t" - + "\022\023\n\013unreachable\030\003 \003(\t\"?\n\016GetNodeRequest\022" - + "-\n\004name\030\001 \001(\tB\037\340A\002\372A\031\n\027tpu.googleapis.co" - + "m/Node\"\247\001\n\021CreateNodeRequest\0229\n\006parent\030\001" - + " \001(\tB)\340A\002\372A#\n!locations.googleapis.com/L" - + "ocation\022\017\n\007node_id\030\002 \001(\t\0222\n\004node\030\003 \001(\0132\037" - + ".google.cloud.tpu.v2alpha1.NodeB\003\340A\002\022\022\n\n" - + "request_id\030\006 \001(\t\"V\n\021DeleteNodeRequest\022-\n" - + "\004name\030\001 \001(\tB\037\340A\002\372A\031\n\027tpu.googleapis.com/" - + "Node\022\022\n\nrequest_id\030\003 \001(\t\"@\n\017StopNodeRequ" - + "est\022-\n\004name\030\001 \001(\tB\037\340A\002\372A\031\n\027tpu.googleapi" - + "s.com/Node\"A\n\020StartNodeRequest\022-\n\004name\030\001" - + " \001(\tB\037\340A\002\372A\031\n\027tpu.googleapis.com/Node\"}\n" - + "\021UpdateNodeRequest\0224\n\013update_mask\030\001 \001(\0132" - + "\032.google.protobuf.FieldMaskB\003\340A\002\0222\n\004node" - + "\030\002 \001(\0132\037.google.cloud.tpu.v2alpha1.NodeB" - + "\003\340A\002\"~\n\032ListQueuedResourcesRequest\0229\n\006pa" - + "rent\030\001 \001(\tB)\340A\002\372A#\022!tpu.googleapis.com/Q" - + "ueuedResource\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage" - + "_token\030\003 \001(\t\"\220\001\n\033ListQueuedResourcesResp" - + "onse\022C\n\020queued_resources\030\001 \003(\0132).google." - + "cloud.tpu.v2alpha1.QueuedResource\022\027\n\017nex" - + "t_page_token\030\002 \001(\t\022\023\n\013unreachable\030\003 \003(\t\"" - + "S\n\030GetQueuedResourceRequest\0227\n\004name\030\001 \001(" - + "\tB)\340A\002\372A#\n!tpu.googleapis.com/QueuedReso" - + "urce\"\321\001\n\033CreateQueuedResourceRequest\0229\n\006" - + "parent\030\001 \001(\tB)\340A\002\372A#\n!locations.googleap" - + "is.com/Location\022\032\n\022queued_resource_id\030\002 " - + "\001(\t\022G\n\017queued_resource\030\003 \001(\0132).google.cl" - + "oud.tpu.v2alpha1.QueuedResourceB\003\340A\002\022\022\n\n" - + "request_id\030\004 \001(\t\"j\n\033DeleteQueuedResource" - + "Request\0227\n\004name\030\001 \001(\tB)\340A\002\372A#\n!tpu.googl" - + "eapis.com/QueuedResource\022\022\n\nrequest_id\030\002" - + " \001(\t\" \n\017ServiceIdentity\022\r\n\005email\030\001 \001(\t\"[" - + "\n\036GenerateServiceIdentityRequest\0229\n\006pare" - + "nt\030\001 \001(\tB)\340A\002\372A#\n!locations.googleapis.c" - + "om/Location\"_\n\037GenerateServiceIdentityRe" - + "sponse\022<\n\010identity\030\001 \001(\0132*.google.cloud." - + "tpu.v2alpha1.ServiceIdentity\"\356\001\n\017Acceler" - + "atorType\022\014\n\004name\030\001 \001(\t\022\014\n\004type\030\002 \001(\t\022I\n\023" - + "accelerator_configs\030\003 \003(\0132,.google.cloud" - + ".tpu.v2alpha1.AcceleratorConfig:t\352Aq\n\"tp" - + "u.googleapis.com/AcceleratorType\022Kprojec" - + "ts/{project}/locations/{location}/accele" - + "ratorTypes/{accelerator_type}\"U\n\031GetAcce" - + "leratorTypeRequest\0228\n\004name\030\001 \001(\tB*\340A\002\372A$" - + "\n\"tpu.googleapis.com/AcceleratorType\"\242\001\n" - + "\033ListAcceleratorTypesRequest\022:\n\006parent\030\001" - + " \001(\tB*\340A\002\372A$\022\"tpu.googleapis.com/Acceler" - + "atorType\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_toke" - + "n\030\003 \001(\t\022\016\n\006filter\030\005 \001(\t\022\020\n\010order_by\030\006 \001(" - + "\t\"\223\001\n\034ListAcceleratorTypesResponse\022E\n\021ac" - + "celerator_types\030\001 \003(\0132*.google.cloud.tpu" - + ".v2alpha1.AcceleratorType\022\027\n\017next_page_t" - + "oken\030\002 \001(\t\022\023\n\013unreachable\030\003 \003(\t\"\242\001\n\016Runt" - + "imeVersion\022\014\n\004name\030\001 \001(\t\022\017\n\007version\030\002 \001(" - + "\t:q\352An\n!tpu.googleapis.com/RuntimeVersio" - + "n\022Iprojects/{project}/locations/{locatio" - + "n}/runtimeVersions/{runtime_version}\"S\n\030" - + "GetRuntimeVersionRequest\0227\n\004name\030\001 \001(\tB)" - + "\340A\002\372A#\n!tpu.googleapis.com/RuntimeVersio" - + "n\"\240\001\n\032ListRuntimeVersionsRequest\0229\n\006pare" - + "nt\030\001 \001(\tB)\340A\002\372A#\022!tpu.googleapis.com/Run" - + "timeVersion\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_t" - + "oken\030\003 \001(\t\022\016\n\006filter\030\005 \001(\t\022\020\n\010order_by\030\006" - + " \001(\t\"\220\001\n\033ListRuntimeVersionsResponse\022C\n\020" - + "runtime_versions\030\001 \003(\0132).google.cloud.tp" - + "u.v2alpha1.RuntimeVersion\022\027\n\017next_page_t" - + "oken\030\002 \001(\t\022\023\n\013unreachable\030\003 \003(\t\"\326\001\n\021Oper" - + "ationMetadata\022/\n\013create_time\030\001 \001(\0132\032.goo" - + "gle.protobuf.Timestamp\022,\n\010end_time\030\002 \001(\013" - + "2\032.google.protobuf.Timestamp\022\016\n\006target\030\003" - + " \001(\t\022\014\n\004verb\030\004 \001(\t\022\025\n\rstatus_detail\030\005 \001(" - + "\t\022\030\n\020cancel_requested\030\006 \001(\010\022\023\n\013api_versi" - + "on\030\007 \001(\t\"\313\002\n\007Symptom\022/\n\013create_time\030\001 \001(" - + "\0132\032.google.protobuf.Timestamp\022D\n\014symptom" - + "_type\030\002 \001(\0162..google.cloud.tpu.v2alpha1." - + "Symptom.SymptomType\022\017\n\007details\030\003 \001(\t\022\021\n\t" - + "worker_id\030\004 \001(\t\"\244\001\n\013SymptomType\022\034\n\030SYMPT" - + "OM_TYPE_UNSPECIFIED\020\000\022\016\n\nLOW_MEMORY\020\001\022\021\n" - + "\rOUT_OF_MEMORY\020\002\022\025\n\021EXECUTE_TIMED_OUT\020\003\022" - + "\023\n\017MESH_BUILD_FAIL\020\004\022\025\n\021HBM_OUT_OF_MEMOR" - + "Y\020\005\022\021\n\rPROJECT_ABUSE\020\006\"r\n\031GetGuestAttrib" - + "utesRequest\022-\n\004name\030\001 \001(\tB\037\340A\002\372A\031\n\027tpu.g" - + "oogleapis.com/Node\022\022\n\nquery_path\030\002 \001(\t\022\022" - + "\n\nworker_ids\030\003 \003(\t\"b\n\032GetGuestAttributes" - + "Response\022D\n\020guest_attributes\030\001 \003(\0132*.goo" - + "gle.cloud.tpu.v2alpha1.GuestAttributes\"d" - + "\n\037SimulateMaintenanceEventRequest\022-\n\004nam" - + "e\030\001 \001(\tB\037\340A\002\372A\031\n\027tpu.googleapis.com/Node" - + "\022\022\n\nworker_ids\030\002 \003(\t\"\246\001\n\021AcceleratorConf" - + "ig\022D\n\004type\030\001 \001(\01621.google.cloud.tpu.v2al" - + "pha1.AcceleratorConfig.TypeB\003\340A\002\022\025\n\010topo" - + "logy\030\002 \001(\tB\003\340A\002\"4\n\004Type\022\024\n\020TYPE_UNSPECIF" - + "IED\020\000\022\006\n\002V2\020\002\022\006\n\002V3\020\004\022\006\n\002V4\020\007\"4\n\026Shielde" - + "dInstanceConfig\022\032\n\022enable_secure_boot\030\001 " - + "\001(\0102\267\035\n\003Tpu\022\250\001\n\tListNodes\022+.google.cloud" - + ".tpu.v2alpha1.ListNodesRequest\032,.google." - + "cloud.tpu.v2alpha1.ListNodesResponse\"@\202\323" - + "\344\223\0021\022//v2alpha1/{parent=projects/*/locat" - + "ions/*}/nodes\332A\006parent\022\225\001\n\007GetNode\022).goo" - + "gle.cloud.tpu.v2alpha1.GetNodeRequest\032\037." - + "google.cloud.tpu.v2alpha1.Node\">\202\323\344\223\0021\022/" - + "/v2alpha1/{name=projects/*/locations/*/n" - + "odes/*}\332A\004name\022\312\001\n\nCreateNode\022,.google.c" - + "loud.tpu.v2alpha1.CreateNodeRequest\032\035.go" - + "ogle.longrunning.Operation\"o\202\323\344\223\0027\"//v2a" - + "lpha1/{parent=projects/*/locations/*}/no" - + "des:\004node\332A\023parent,node,node_id\312A\031\n\004Node" - + "\022\021OperationMetadata\022\306\001\n\nDeleteNode\022,.goo" - + "gle.cloud.tpu.v2alpha1.DeleteNodeRequest" - + "\032\035.google.longrunning.Operation\"k\202\323\344\223\0021*" - + "//v2alpha1/{name=projects/*/locations/*/" - + "nodes/*}\332A\004name\312A*\n\025google.protobuf.Empt" - + "y\022\021OperationMetadata\022\262\001\n\010StopNode\022*.goog" - + "le.cloud.tpu.v2alpha1.StopNodeRequest\032\035." - + "google.longrunning.Operation\"[\202\323\344\223\0029\"4/v" - + "2alpha1/{name=projects/*/locations/*/nod" - + "es/*}:stop:\001*\312A\031\n\004Node\022\021OperationMetadat" - + "a\022\265\001\n\tStartNode\022+.google.cloud.tpu.v2alp" - + "ha1.StartNodeRequest\032\035.google.longrunnin" - + "g.Operation\"\\\202\323\344\223\002:\"5/v2alpha1/{name=pro" - + "jects/*/locations/*/nodes/*}:start:\001*\312A\031" - + "\n\004Node\022\021OperationMetadata\022\314\001\n\nUpdateNode" - + "\022,.google.cloud.tpu.v2alpha1.UpdateNodeR" - + "equest\032\035.google.longrunning.Operation\"q\202" - + "\323\344\223\002<24/v2alpha1/{node.name=projects/*/l" - + "ocations/*/nodes/*}:\004node\332A\020node,update_" - + "mask\312A\031\n\004Node\022\021OperationMetadata\022\320\001\n\023Lis" - + "tQueuedResources\0225.google.cloud.tpu.v2al" - + "pha1.ListQueuedResourcesRequest\0326.google" - + ".cloud.tpu.v2alpha1.ListQueuedResourcesR" - + "esponse\"J\202\323\344\223\002;\0229/v2alpha1/{parent=proje" - + "cts/*/locations/*}/queuedResources\332A\006par" - + "ent\022\275\001\n\021GetQueuedResource\0223.google.cloud" - + ".tpu.v2alpha1.GetQueuedResourceRequest\032)" - + ".google.cloud.tpu.v2alpha1.QueuedResourc" - + "e\"H\202\323\344\223\002;\0229/v2alpha1/{name=projects/*/lo" - + "cations/*/queuedResources/*}\332A\004name\022\224\002\n\024" - + "CreateQueuedResource\0226.google.cloud.tpu." - + "v2alpha1.CreateQueuedResourceRequest\032\035.g" - + "oogle.longrunning.Operation\"\244\001\202\323\344\223\002L\"9/v" - + "2alpha1/{parent=projects/*/locations/*}/" - + "queuedResources:\017queued_resource\332A)paren" - + "t,queued_resource,queued_resource_id\312A#\n" - + "\016QueuedResource\022\021OperationMetadata\022\335\001\n\024D" - + "eleteQueuedResource\0226.google.cloud.tpu.v" - + "2alpha1.DeleteQueuedResourceRequest\032\035.go" - + "ogle.longrunning.Operation\"n\202\323\344\223\002;*9/v2a" - + "lpha1/{name=projects/*/locations/*/queue" - + "dResources/*}\332A\004name\312A#\n\016QueuedResource\022" - + "\021OperationMetadata\022\336\001\n\027GenerateServiceId" - + "entity\0229.google.cloud.tpu.v2alpha1.Gener" - + "ateServiceIdentityRequest\032:.google.cloud" - + ".tpu.v2alpha1.GenerateServiceIdentityRes" - + "ponse\"L\202\323\344\223\002F\"A/v2alpha1/{parent=project" - + "s/*/locations/*}:generateServiceIdentity" - + ":\001*\022\324\001\n\024ListAcceleratorTypes\0226.google.cl" - + "oud.tpu.v2alpha1.ListAcceleratorTypesReq" - + "uest\0327.google.cloud.tpu.v2alpha1.ListAcc" - + "eleratorTypesResponse\"K\202\323\344\223\002<\022:/v2alpha1" - + "/{parent=projects/*/locations/*}/acceler" - + "atorTypes\332A\006parent\022\301\001\n\022GetAcceleratorTyp" - + "e\0224.google.cloud.tpu.v2alpha1.GetAcceler" - + "atorTypeRequest\032*.google.cloud.tpu.v2alp" - + "ha1.AcceleratorType\"I\202\323\344\223\002<\022:/v2alpha1/{" - + "name=projects/*/locations/*/acceleratorT" - + "ypes/*}\332A\004name\022\320\001\n\023ListRuntimeVersions\0225" - + ".google.cloud.tpu.v2alpha1.ListRuntimeVe" - + "rsionsRequest\0326.google.cloud.tpu.v2alpha" - + "1.ListRuntimeVersionsResponse\"J\202\323\344\223\002;\0229/" + + "AcceptedDataH\000\022\\\n\021provisioning_data\030\004 \001(" + + "\0132?.google.cloud.tpu.v2alpha1.QueuedReso" + + "urceState.ProvisioningDataH\000\022P\n\013failed_d" + + "ata\030\005 \001(\01329.google.cloud.tpu.v2alpha1.Qu" + + "euedResourceState.FailedDataH\000\022T\n\rdeleti" + + "ng_data\030\006 \001(\0132;.google.cloud.tpu.v2alpha" + + "1.QueuedResourceState.DeletingDataH\000\022P\n\013" + + "active_data\030\007 \001(\01329.google.cloud.tpu.v2a" + + "lpha1.QueuedResourceState.ActiveDataH\000\022X" + + "\n\017suspending_data\030\010 \001(\0132=.google.cloud.t" + + "pu.v2alpha1.QueuedResourceState.Suspendi" + + "ngDataH\000\022V\n\016suspended_data\030\t \001(\0132<.googl" + + "e.cloud.tpu.v2alpha1.QueuedResourceState" + + ".SuspendedDataH\000\032\016\n\014CreatingData\032\016\n\014Acce" + + "ptedData\032\022\n\020ProvisioningData\032/\n\nFailedDa" + + "ta\022!\n\005error\030\001 \001(\0132\022.google.rpc.Status\032\016\n" + + "\014DeletingData\032\014\n\nActiveData\032\020\n\016Suspendin" + + "gData\032\017\n\rSuspendedData\"\221\001\n\005State\022\025\n\021STAT" + + "E_UNSPECIFIED\020\000\022\014\n\010CREATING\020\001\022\014\n\010ACCEPTE" + + "D\020\002\022\020\n\014PROVISIONING\020\003\022\n\n\006FAILED\020\004\022\014\n\010DEL" + + "ETING\020\005\022\n\n\006ACTIVE\020\006\022\016\n\nSUSPENDING\020\007\022\r\n\tS" + + "USPENDED\020\010B\014\n\nstate_data\"j\n\020ListNodesReq" + + "uest\022/\n\006parent\030\001 \001(\tB\037\340A\002\372A\031\022\027tpu.google" + + "apis.com/Node\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage" + + "_token\030\003 \001(\t\"q\n\021ListNodesResponse\022.\n\005nod" + + "es\030\001 \003(\0132\037.google.cloud.tpu.v2alpha1.Nod" + + "e\022\027\n\017next_page_token\030\002 \001(\t\022\023\n\013unreachabl" + + "e\030\003 \003(\t\"?\n\016GetNodeRequest\022-\n\004name\030\001 \001(\tB" + + "\037\340A\002\372A\031\n\027tpu.googleapis.com/Node\"\247\001\n\021Cre" + + "ateNodeRequest\0229\n\006parent\030\001 \001(\tB)\340A\002\372A#\n!" + + "locations.googleapis.com/Location\022\017\n\007nod" + + "e_id\030\002 \001(\t\0222\n\004node\030\003 \001(\0132\037.google.cloud." + + "tpu.v2alpha1.NodeB\003\340A\002\022\022\n\nrequest_id\030\006 \001" + + "(\t\"V\n\021DeleteNodeRequest\022-\n\004name\030\001 \001(\tB\037\340" + + "A\002\372A\031\n\027tpu.googleapis.com/Node\022\022\n\nreques" + + "t_id\030\003 \001(\t\"@\n\017StopNodeRequest\022-\n\004name\030\001 " + + "\001(\tB\037\340A\002\372A\031\n\027tpu.googleapis.com/Node\"A\n\020" + + "StartNodeRequest\022-\n\004name\030\001 \001(\tB\037\340A\002\372A\031\n\027" + + "tpu.googleapis.com/Node\"}\n\021UpdateNodeReq" + + "uest\0224\n\013update_mask\030\001 \001(\0132\032.google.proto" + + "buf.FieldMaskB\003\340A\002\0222\n\004node\030\002 \001(\0132\037.googl" + + "e.cloud.tpu.v2alpha1.NodeB\003\340A\002\"~\n\032ListQu" + + "euedResourcesRequest\0229\n\006parent\030\001 \001(\tB)\340A" + + "\002\372A#\022!tpu.googleapis.com/QueuedResource\022" + + "\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_token\030\003 \001(\t\"\220" + + "\001\n\033ListQueuedResourcesResponse\022C\n\020queued" + + "_resources\030\001 \003(\0132).google.cloud.tpu.v2al" + + "pha1.QueuedResource\022\027\n\017next_page_token\030\002" + + " \001(\t\022\023\n\013unreachable\030\003 \003(\t\"S\n\030GetQueuedRe" + + "sourceRequest\0227\n\004name\030\001 \001(\tB)\340A\002\372A#\n!tpu" + + ".googleapis.com/QueuedResource\"\321\001\n\033Creat" + + "eQueuedResourceRequest\0229\n\006parent\030\001 \001(\tB)" + + "\340A\002\372A#\n!locations.googleapis.com/Locatio" + + "n\022\032\n\022queued_resource_id\030\002 \001(\t\022G\n\017queued_" + + "resource\030\003 \001(\0132).google.cloud.tpu.v2alph" + + "a1.QueuedResourceB\003\340A\002\022\022\n\nrequest_id\030\004 \001" + + "(\t\"j\n\033DeleteQueuedResourceRequest\0227\n\004nam" + + "e\030\001 \001(\tB)\340A\002\372A#\n!tpu.googleapis.com/Queu" + + "edResource\022\022\n\nrequest_id\030\002 \001(\t\"U\n\032ResetQ" + + "ueuedResourceRequest\0227\n\004name\030\001 \001(\tB)\340A\002\372" + + "A#\n!tpu.googleapis.com/QueuedResource\" \n" + + "\017ServiceIdentity\022\r\n\005email\030\001 \001(\t\"[\n\036Gener" + + "ateServiceIdentityRequest\0229\n\006parent\030\001 \001(" + + "\tB)\340A\002\372A#\n!locations.googleapis.com/Loca" + + "tion\"_\n\037GenerateServiceIdentityResponse\022" + + "<\n\010identity\030\001 \001(\0132*.google.cloud.tpu.v2a" + + "lpha1.ServiceIdentity\"\356\001\n\017AcceleratorTyp" + + "e\022\014\n\004name\030\001 \001(\t\022\014\n\004type\030\002 \001(\t\022I\n\023acceler" + + "ator_configs\030\003 \003(\0132,.google.cloud.tpu.v2" + + "alpha1.AcceleratorConfig:t\352Aq\n\"tpu.googl" + + "eapis.com/AcceleratorType\022Kprojects/{pro" + + "ject}/locations/{location}/acceleratorTy" + + "pes/{accelerator_type}\"U\n\031GetAccelerator" + + "TypeRequest\0228\n\004name\030\001 \001(\tB*\340A\002\372A$\n\"tpu.g" + + "oogleapis.com/AcceleratorType\"\242\001\n\033ListAc" + + "celeratorTypesRequest\022:\n\006parent\030\001 \001(\tB*\340" + + "A\002\372A$\022\"tpu.googleapis.com/AcceleratorTyp" + + "e\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_token\030\003 \001(\t" + + "\022\016\n\006filter\030\005 \001(\t\022\020\n\010order_by\030\006 \001(\t\"\223\001\n\034L" + + "istAcceleratorTypesResponse\022E\n\021accelerat" + + "or_types\030\001 \003(\0132*.google.cloud.tpu.v2alph" + + "a1.AcceleratorType\022\027\n\017next_page_token\030\002 " + + "\001(\t\022\023\n\013unreachable\030\003 \003(\t\"\242\001\n\016RuntimeVers" + + "ion\022\014\n\004name\030\001 \001(\t\022\017\n\007version\030\002 \001(\t:q\352An\n" + + "!tpu.googleapis.com/RuntimeVersion\022Iproj" + + "ects/{project}/locations/{location}/runt" + + "imeVersions/{runtime_version}\"S\n\030GetRunt" + + "imeVersionRequest\0227\n\004name\030\001 \001(\tB)\340A\002\372A#\n" + + "!tpu.googleapis.com/RuntimeVersion\"\240\001\n\032L" + + "istRuntimeVersionsRequest\0229\n\006parent\030\001 \001(" + + "\tB)\340A\002\372A#\022!tpu.googleapis.com/RuntimeVer" + + "sion\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_token\030\003 " + + "\001(\t\022\016\n\006filter\030\005 \001(\t\022\020\n\010order_by\030\006 \001(\t\"\220\001" + + "\n\033ListRuntimeVersionsResponse\022C\n\020runtime" + + "_versions\030\001 \003(\0132).google.cloud.tpu.v2alp" + + "ha1.RuntimeVersion\022\027\n\017next_page_token\030\002 " + + "\001(\t\022\023\n\013unreachable\030\003 \003(\t\"\326\001\n\021OperationMe" + + "tadata\022/\n\013create_time\030\001 \001(\0132\032.google.pro" + + "tobuf.Timestamp\022,\n\010end_time\030\002 \001(\0132\032.goog" + + "le.protobuf.Timestamp\022\016\n\006target\030\003 \001(\t\022\014\n" + + "\004verb\030\004 \001(\t\022\025\n\rstatus_detail\030\005 \001(\t\022\030\n\020ca" + + "ncel_requested\030\006 \001(\010\022\023\n\013api_version\030\007 \001(" + + "\t\"\313\002\n\007Symptom\022/\n\013create_time\030\001 \001(\0132\032.goo" + + "gle.protobuf.Timestamp\022D\n\014symptom_type\030\002" + + " \001(\0162..google.cloud.tpu.v2alpha1.Symptom" + + ".SymptomType\022\017\n\007details\030\003 \001(\t\022\021\n\tworker_" + + "id\030\004 \001(\t\"\244\001\n\013SymptomType\022\034\n\030SYMPTOM_TYPE" + + "_UNSPECIFIED\020\000\022\016\n\nLOW_MEMORY\020\001\022\021\n\rOUT_OF" + + "_MEMORY\020\002\022\025\n\021EXECUTE_TIMED_OUT\020\003\022\023\n\017MESH" + + "_BUILD_FAIL\020\004\022\025\n\021HBM_OUT_OF_MEMORY\020\005\022\021\n\r" + + "PROJECT_ABUSE\020\006\"r\n\031GetGuestAttributesReq" + + "uest\022-\n\004name\030\001 \001(\tB\037\340A\002\372A\031\n\027tpu.googleap" + + "is.com/Node\022\022\n\nquery_path\030\002 \001(\t\022\022\n\nworke" + + "r_ids\030\003 \003(\t\"b\n\032GetGuestAttributesRespons" + + "e\022D\n\020guest_attributes\030\001 \003(\0132*.google.clo" + + "ud.tpu.v2alpha1.GuestAttributes\"d\n\037Simul" + + "ateMaintenanceEventRequest\022-\n\004name\030\001 \001(\t" + + "B\037\340A\002\372A\031\n\027tpu.googleapis.com/Node\022\022\n\nwor" + + "ker_ids\030\002 \003(\t\"\246\001\n\021AcceleratorConfig\022D\n\004t" + + "ype\030\001 \001(\01621.google.cloud.tpu.v2alpha1.Ac" + + "celeratorConfig.TypeB\003\340A\002\022\025\n\010topology\030\002 " + + "\001(\tB\003\340A\002\"4\n\004Type\022\024\n\020TYPE_UNSPECIFIED\020\000\022\006" + + "\n\002V2\020\002\022\006\n\002V3\020\004\022\006\n\002V4\020\007\"4\n\026ShieldedInstan" + + "ceConfig\022\032\n\022enable_secure_boot\030\001 \001(\0102\236\037\n" + + "\003Tpu\022\250\001\n\tListNodes\022+.google.cloud.tpu.v2" + + "alpha1.ListNodesRequest\032,.google.cloud.t" + + "pu.v2alpha1.ListNodesResponse\"@\202\323\344\223\0021\022//" + + "v2alpha1/{parent=projects/*/locations/*}" + + "/nodes\332A\006parent\022\225\001\n\007GetNode\022).google.clo" + + "ud.tpu.v2alpha1.GetNodeRequest\032\037.google." + + "cloud.tpu.v2alpha1.Node\">\202\323\344\223\0021\022//v2alph" + + "a1/{name=projects/*/locations/*/nodes/*}" + + "\332A\004name\022\312\001\n\nCreateNode\022,.google.cloud.tp" + + "u.v2alpha1.CreateNodeRequest\032\035.google.lo" + + "ngrunning.Operation\"o\202\323\344\223\0027\"//v2alpha1/{" + + "parent=projects/*/locations/*}/nodes:\004no" + + "de\332A\023parent,node,node_id\312A\031\n\004Node\022\021Opera" + + "tionMetadata\022\306\001\n\nDeleteNode\022,.google.clo" + + "ud.tpu.v2alpha1.DeleteNodeRequest\032\035.goog" + + "le.longrunning.Operation\"k\202\323\344\223\0021*//v2alp" + + "ha1/{name=projects/*/locations/*/nodes/*" + + "}\332A\004name\312A*\n\025google.protobuf.Empty\022\021Oper" + + "ationMetadata\022\262\001\n\010StopNode\022*.google.clou" + + "d.tpu.v2alpha1.StopNodeRequest\032\035.google." + + "longrunning.Operation\"[\202\323\344\223\0029\"4/v2alpha1" + + "/{name=projects/*/locations/*/nodes/*}:s" + + "top:\001*\312A\031\n\004Node\022\021OperationMetadata\022\265\001\n\tS" + + "tartNode\022+.google.cloud.tpu.v2alpha1.Sta" + + "rtNodeRequest\032\035.google.longrunning.Opera" + + "tion\"\\\202\323\344\223\002:\"5/v2alpha1/{name=projects/*" + + "/locations/*/nodes/*}:start:\001*\312A\031\n\004Node\022" + + "\021OperationMetadata\022\314\001\n\nUpdateNode\022,.goog" + + "le.cloud.tpu.v2alpha1.UpdateNodeRequest\032" + + "\035.google.longrunning.Operation\"q\202\323\344\223\002<24" + + "/v2alpha1/{node.name=projects/*/location" + + "s/*/nodes/*}:\004node\332A\020node,update_mask\312A\031" + + "\n\004Node\022\021OperationMetadata\022\320\001\n\023ListQueued" + + "Resources\0225.google.cloud.tpu.v2alpha1.Li" + + "stQueuedResourcesRequest\0326.google.cloud." + + "tpu.v2alpha1.ListQueuedResourcesResponse" + + "\"J\202\323\344\223\002;\0229/v2alpha1/{parent=projects/*/l" + + "ocations/*}/queuedResources\332A\006parent\022\275\001\n" + + "\021GetQueuedResource\0223.google.cloud.tpu.v2" + + "alpha1.GetQueuedResourceRequest\032).google" + + ".cloud.tpu.v2alpha1.QueuedResource\"H\202\323\344\223" + + "\002;\0229/v2alpha1/{name=projects/*/locations" + + "/*/queuedResources/*}\332A\004name\022\224\002\n\024CreateQ" + + "ueuedResource\0226.google.cloud.tpu.v2alpha" + + "1.CreateQueuedResourceRequest\032\035.google.l" + + "ongrunning.Operation\"\244\001\202\323\344\223\002L\"9/v2alpha1" + + "/{parent=projects/*/locations/*}/queuedR" + + "esources:\017queued_resource\332A)parent,queue" + + "d_resource,queued_resource_id\312A#\n\016Queued" + + "Resource\022\021OperationMetadata\022\335\001\n\024DeleteQu" + + "euedResource\0226.google.cloud.tpu.v2alpha1" + + ".DeleteQueuedResourceRequest\032\035.google.lo" + + "ngrunning.Operation\"n\202\323\344\223\002;*9/v2alpha1/{" + + "name=projects/*/locations/*/queuedResour" + + "ces/*}\332A\004name\312A#\n\016QueuedResource\022\021Operat" + + "ionMetadata\022\344\001\n\023ResetQueuedResource\0225.go" + + "ogle.cloud.tpu.v2alpha1.ResetQueuedResou" + + "rceRequest\032\035.google.longrunning.Operatio" + + "n\"w\202\323\344\223\002D\"?/v2alpha1/{name=projects/*/lo" + + "cations/*/queuedResources/*}:reset:\001*\332A\004" + + "name\312A#\n\016QueuedResource\022\021OperationMetada" + + "ta\022\336\001\n\027GenerateServiceIdentity\0229.google." + + "cloud.tpu.v2alpha1.GenerateServiceIdenti" + + "tyRequest\032:.google.cloud.tpu.v2alpha1.Ge" + + "nerateServiceIdentityResponse\"L\202\323\344\223\002F\"A/" + "v2alpha1/{parent=projects/*/locations/*}" - + "/runtimeVersions\332A\006parent\022\275\001\n\021GetRuntime" - + "Version\0223.google.cloud.tpu.v2alpha1.GetR" - + "untimeVersionRequest\032).google.cloud.tpu." - + "v2alpha1.RuntimeVersion\"H\202\323\344\223\002;\0229/v2alph" - + "a1/{name=projects/*/locations/*/runtimeV" - + "ersions/*}\332A\004name\022\320\001\n\022GetGuestAttributes" - + "\0224.google.cloud.tpu.v2alpha1.GetGuestAtt" - + "ributesRequest\0325.google.cloud.tpu.v2alph" - + "a1.GetGuestAttributesResponse\"M\202\323\344\223\002G\"B/" - + "v2alpha1/{name=projects/*/locations/*/no" - + "des/*}:getGuestAttributes:\001*\022\346\001\n\030Simulat" - + "eMaintenanceEvent\022:.google.cloud.tpu.v2a" - + "lpha1.SimulateMaintenanceEventRequest\032\035." - + "google.longrunning.Operation\"o\202\323\344\223\002M\"H/v" - + "2alpha1/{name=projects/*/locations/*/nod" - + "es/*}:simulateMaintenanceEvent:\001*\312A\031\n\004No" - + "de\022\021OperationMetadata\032F\312A\022tpu.googleapis" - + ".com\322A.https://www.googleapis.com/auth/c" - + "loud-platformBa\n\035com.google.cloud.tpu.v2" - + "alpha1B\rCloudTpuProtoP\001Z/cloud.google.co" - + "m/go/tpu/apiv2alpha1/tpupb;tpupbb\006proto3" + + ":generateServiceIdentity:\001*\022\324\001\n\024ListAcce" + + "leratorTypes\0226.google.cloud.tpu.v2alpha1" + + ".ListAcceleratorTypesRequest\0327.google.cl" + + "oud.tpu.v2alpha1.ListAcceleratorTypesRes" + + "ponse\"K\202\323\344\223\002<\022:/v2alpha1/{parent=project" + + "s/*/locations/*}/acceleratorTypes\332A\006pare" + + "nt\022\301\001\n\022GetAcceleratorType\0224.google.cloud" + + ".tpu.v2alpha1.GetAcceleratorTypeRequest\032" + + "*.google.cloud.tpu.v2alpha1.AcceleratorT" + + "ype\"I\202\323\344\223\002<\022:/v2alpha1/{name=projects/*/" + + "locations/*/acceleratorTypes/*}\332A\004name\022\320" + + "\001\n\023ListRuntimeVersions\0225.google.cloud.tp" + + "u.v2alpha1.ListRuntimeVersionsRequest\0326." + + "google.cloud.tpu.v2alpha1.ListRuntimeVer" + + "sionsResponse\"J\202\323\344\223\002;\0229/v2alpha1/{parent" + + "=projects/*/locations/*}/runtimeVersions" + + "\332A\006parent\022\275\001\n\021GetRuntimeVersion\0223.google" + + ".cloud.tpu.v2alpha1.GetRuntimeVersionReq" + + "uest\032).google.cloud.tpu.v2alpha1.Runtime" + + "Version\"H\202\323\344\223\002;\0229/v2alpha1/{name=project" + + "s/*/locations/*/runtimeVersions/*}\332A\004nam" + + "e\022\320\001\n\022GetGuestAttributes\0224.google.cloud." + + "tpu.v2alpha1.GetGuestAttributesRequest\0325" + + ".google.cloud.tpu.v2alpha1.GetGuestAttri" + + "butesResponse\"M\202\323\344\223\002G\"B/v2alpha1/{name=p" + + "rojects/*/locations/*/nodes/*}:getGuestA" + + "ttributes:\001*\022\346\001\n\030SimulateMaintenanceEven" + + "t\022:.google.cloud.tpu.v2alpha1.SimulateMa" + + "intenanceEventRequest\032\035.google.longrunni" + + "ng.Operation\"o\202\323\344\223\002M\"H/v2alpha1/{name=pr" + + "ojects/*/locations/*/nodes/*}:simulateMa" + + "intenanceEvent:\001*\312A\031\n\004Node\022\021OperationMet" + + "adata\032F\312A\022tpu.googleapis.com\322A.https://w" + + "ww.googleapis.com/auth/cloud-platformBa\n" + + "\035com.google.cloud.tpu.v2alpha1B\rCloudTpu" + + "ProtoP\001Z/cloud.google.com/go/tpu/apiv2al" + + "pha1/tpupb;tpupbb\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom( @@ -744,6 +757,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Guaranteed", "QueueingPolicy", "State", + "ReservationName", "Resource", "Tier", }); @@ -979,8 +993,16 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { new java.lang.String[] { "Name", "RequestId", }); - internal_static_google_cloud_tpu_v2alpha1_ServiceIdentity_descriptor = + internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_descriptor = getDescriptor().getMessageTypes().get(25); + internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_fieldAccessorTable = + new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_descriptor, + new java.lang.String[] { + "Name", + }); + internal_static_google_cloud_tpu_v2alpha1_ServiceIdentity_descriptor = + getDescriptor().getMessageTypes().get(26); internal_static_google_cloud_tpu_v2alpha1_ServiceIdentity_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_ServiceIdentity_descriptor, @@ -988,7 +1010,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Email", }); internal_static_google_cloud_tpu_v2alpha1_GenerateServiceIdentityRequest_descriptor = - getDescriptor().getMessageTypes().get(26); + getDescriptor().getMessageTypes().get(27); internal_static_google_cloud_tpu_v2alpha1_GenerateServiceIdentityRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_GenerateServiceIdentityRequest_descriptor, @@ -996,7 +1018,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Parent", }); internal_static_google_cloud_tpu_v2alpha1_GenerateServiceIdentityResponse_descriptor = - getDescriptor().getMessageTypes().get(27); + getDescriptor().getMessageTypes().get(28); internal_static_google_cloud_tpu_v2alpha1_GenerateServiceIdentityResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_GenerateServiceIdentityResponse_descriptor, @@ -1004,7 +1026,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Identity", }); internal_static_google_cloud_tpu_v2alpha1_AcceleratorType_descriptor = - getDescriptor().getMessageTypes().get(28); + getDescriptor().getMessageTypes().get(29); internal_static_google_cloud_tpu_v2alpha1_AcceleratorType_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_AcceleratorType_descriptor, @@ -1012,7 +1034,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Name", "Type", "AcceleratorConfigs", }); internal_static_google_cloud_tpu_v2alpha1_GetAcceleratorTypeRequest_descriptor = - getDescriptor().getMessageTypes().get(29); + getDescriptor().getMessageTypes().get(30); internal_static_google_cloud_tpu_v2alpha1_GetAcceleratorTypeRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_GetAcceleratorTypeRequest_descriptor, @@ -1020,7 +1042,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Name", }); internal_static_google_cloud_tpu_v2alpha1_ListAcceleratorTypesRequest_descriptor = - getDescriptor().getMessageTypes().get(30); + getDescriptor().getMessageTypes().get(31); internal_static_google_cloud_tpu_v2alpha1_ListAcceleratorTypesRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_ListAcceleratorTypesRequest_descriptor, @@ -1028,7 +1050,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Parent", "PageSize", "PageToken", "Filter", "OrderBy", }); internal_static_google_cloud_tpu_v2alpha1_ListAcceleratorTypesResponse_descriptor = - getDescriptor().getMessageTypes().get(31); + getDescriptor().getMessageTypes().get(32); internal_static_google_cloud_tpu_v2alpha1_ListAcceleratorTypesResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_ListAcceleratorTypesResponse_descriptor, @@ -1036,7 +1058,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "AcceleratorTypes", "NextPageToken", "Unreachable", }); internal_static_google_cloud_tpu_v2alpha1_RuntimeVersion_descriptor = - getDescriptor().getMessageTypes().get(32); + getDescriptor().getMessageTypes().get(33); internal_static_google_cloud_tpu_v2alpha1_RuntimeVersion_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_RuntimeVersion_descriptor, @@ -1044,7 +1066,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Name", "Version", }); internal_static_google_cloud_tpu_v2alpha1_GetRuntimeVersionRequest_descriptor = - getDescriptor().getMessageTypes().get(33); + getDescriptor().getMessageTypes().get(34); internal_static_google_cloud_tpu_v2alpha1_GetRuntimeVersionRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_GetRuntimeVersionRequest_descriptor, @@ -1052,7 +1074,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Name", }); internal_static_google_cloud_tpu_v2alpha1_ListRuntimeVersionsRequest_descriptor = - getDescriptor().getMessageTypes().get(34); + getDescriptor().getMessageTypes().get(35); internal_static_google_cloud_tpu_v2alpha1_ListRuntimeVersionsRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_ListRuntimeVersionsRequest_descriptor, @@ -1060,7 +1082,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Parent", "PageSize", "PageToken", "Filter", "OrderBy", }); internal_static_google_cloud_tpu_v2alpha1_ListRuntimeVersionsResponse_descriptor = - getDescriptor().getMessageTypes().get(35); + getDescriptor().getMessageTypes().get(36); internal_static_google_cloud_tpu_v2alpha1_ListRuntimeVersionsResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_ListRuntimeVersionsResponse_descriptor, @@ -1068,7 +1090,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "RuntimeVersions", "NextPageToken", "Unreachable", }); internal_static_google_cloud_tpu_v2alpha1_OperationMetadata_descriptor = - getDescriptor().getMessageTypes().get(36); + getDescriptor().getMessageTypes().get(37); internal_static_google_cloud_tpu_v2alpha1_OperationMetadata_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_OperationMetadata_descriptor, @@ -1082,7 +1104,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "ApiVersion", }); internal_static_google_cloud_tpu_v2alpha1_Symptom_descriptor = - getDescriptor().getMessageTypes().get(37); + getDescriptor().getMessageTypes().get(38); internal_static_google_cloud_tpu_v2alpha1_Symptom_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_Symptom_descriptor, @@ -1090,7 +1112,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "CreateTime", "SymptomType", "Details", "WorkerId", }); internal_static_google_cloud_tpu_v2alpha1_GetGuestAttributesRequest_descriptor = - getDescriptor().getMessageTypes().get(38); + getDescriptor().getMessageTypes().get(39); internal_static_google_cloud_tpu_v2alpha1_GetGuestAttributesRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_GetGuestAttributesRequest_descriptor, @@ -1098,7 +1120,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Name", "QueryPath", "WorkerIds", }); internal_static_google_cloud_tpu_v2alpha1_GetGuestAttributesResponse_descriptor = - getDescriptor().getMessageTypes().get(39); + getDescriptor().getMessageTypes().get(40); internal_static_google_cloud_tpu_v2alpha1_GetGuestAttributesResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_GetGuestAttributesResponse_descriptor, @@ -1106,7 +1128,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "GuestAttributes", }); internal_static_google_cloud_tpu_v2alpha1_SimulateMaintenanceEventRequest_descriptor = - getDescriptor().getMessageTypes().get(40); + getDescriptor().getMessageTypes().get(41); internal_static_google_cloud_tpu_v2alpha1_SimulateMaintenanceEventRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_SimulateMaintenanceEventRequest_descriptor, @@ -1114,7 +1136,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Name", "WorkerIds", }); internal_static_google_cloud_tpu_v2alpha1_AcceleratorConfig_descriptor = - getDescriptor().getMessageTypes().get(41); + getDescriptor().getMessageTypes().get(42); internal_static_google_cloud_tpu_v2alpha1_AcceleratorConfig_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_AcceleratorConfig_descriptor, @@ -1122,7 +1144,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "Type", "Topology", }); internal_static_google_cloud_tpu_v2alpha1_ShieldedInstanceConfig_descriptor = - getDescriptor().getMessageTypes().get(42); + getDescriptor().getMessageTypes().get(43); internal_static_google_cloud_tpu_v2alpha1_ShieldedInstanceConfig_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_cloud_tpu_v2alpha1_ShieldedInstanceConfig_descriptor, diff --git a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CreateQueuedResourceRequest.java b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CreateQueuedResourceRequest.java index ef0f7afdf513..3fc27fcfa92a 100644 --- a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CreateQueuedResourceRequest.java +++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CreateQueuedResourceRequest.java @@ -133,7 +133,7 @@ public com.google.protobuf.ByteString getParentBytes() { * * * 
-   * The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
+   * The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
    * regex format.
    *
* @@ -157,7 +157,7 @@ public java.lang.String getQueuedResourceId() { * * * 
-   * The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
+   * The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
    * regex format.
    *
* @@ -830,7 +830,7 @@ public Builder setParentBytes(com.google.protobuf.ByteString value) { * * * 
-     * The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
+     * The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
      * regex format.
      *
* @@ -853,7 +853,7 @@ public java.lang.String getQueuedResourceId() { * * * 
-     * The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
+     * The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
      * regex format.
      *
* @@ -876,7 +876,7 @@ public com.google.protobuf.ByteString getQueuedResourceIdBytes() { * * * 
-     * The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
+     * The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
      * regex format.
      *
* @@ -898,7 +898,7 @@ public Builder setQueuedResourceId(java.lang.String value) { * * * 
-     * The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
+     * The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
      * regex format.
      *
* @@ -916,7 +916,7 @@ public Builder clearQueuedResourceId() { * * * 
-     * The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
+     * The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
      * regex format.
      *
* diff --git a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CreateQueuedResourceRequestOrBuilder.java b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CreateQueuedResourceRequestOrBuilder.java index 14bc6d7bcb85..00332158714b 100644 --- a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CreateQueuedResourceRequestOrBuilder.java +++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/CreateQueuedResourceRequestOrBuilder.java @@ -56,7 +56,7 @@ public interface CreateQueuedResourceRequestOrBuilder * * * 
-   * The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
+   * The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
    * regex format.
    *
* @@ -69,7 +69,7 @@ public interface CreateQueuedResourceRequestOrBuilder * * * 
-   * The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
+   * The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
    * regex format.
    *
* diff --git a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResource.java b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResource.java index b492b971ca70..9e5a1a0b7b56 100644 --- a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResource.java +++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResource.java @@ -40,6 +40,7 @@ private QueuedResource(com.google.protobuf.GeneratedMessageV3.Builder builder private QueuedResource() { name_ = ""; + reservationName_ = ""; } @java.lang.Override @@ -6246,6 +6247,59 @@ public com.google.cloud.tpu.v2alpha1.QueuedResourceStateOrBuilder getStateOrBuil : state_; } + public static final int RESERVATION_NAME_FIELD_NUMBER = 8; + + @SuppressWarnings("serial") + private volatile java.lang.Object reservationName_ = ""; + /** + * + * + * 
+   * Name of the reservation in which the resource should be provisioned.
+   * Format: projects/{project}/locations/{zone}/reservations/{reservation}
+   *
+ * + * string reservation_name = 8; + * + * @return The reservationName. + */ + @java.lang.Override + public java.lang.String getReservationName() { + java.lang.Object ref = reservationName_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + reservationName_ = s; + return s; + } + } + /** + * + * + * 
+   * Name of the reservation in which the resource should be provisioned.
+   * Format: projects/{project}/locations/{zone}/reservations/{reservation}
+   *
+ * + * string reservation_name = 8; + * + * @return The bytes for reservationName. + */ + @java.lang.Override + public com.google.protobuf.ByteString getReservationNameBytes() { + java.lang.Object ref = reservationName_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); + reservationName_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + private byte memoizedIsInitialized = -1; @java.lang.Override @@ -6278,6 +6332,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io if (state_ != null) { output.writeMessage(6, getState()); } + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(reservationName_)) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 8, reservationName_); + } getUnknownFields().writeTo(output); } @@ -6311,6 +6368,9 @@ public int getSerializedSize() { if (state_ != null) { size += com.google.protobuf.CodedOutputStream.computeMessageSize(6, getState()); } + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(reservationName_)) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(8, reservationName_); + } size += getUnknownFields().getSerializedSize(); memoizedSize = size; return size; @@ -6336,6 +6396,7 @@ public boolean equals(final java.lang.Object obj) { if (hasState()) { if (!getState().equals(other.getState())) return false; } + if (!getReservationName().equals(other.getReservationName())) return false; if (!getResourceCase().equals(other.getResourceCase())) return false; switch (resourceCase_) { case 2: @@ -6376,6 +6437,8 @@ public int hashCode() { hash = (37 * hash) + STATE_FIELD_NUMBER; hash = (53 * hash) + getState().hashCode(); } + hash = (37 * hash) + RESERVATION_NAME_FIELD_NUMBER; + hash = (53 * hash) + getReservationName().hashCode(); switch (resourceCase_) { case 2: hash = (37 * hash) + TPU_FIELD_NUMBER; @@ -6556,6 +6619,7 @@ public Builder clear() { stateBuilder_.dispose(); stateBuilder_ = null; } + reservationName_ = ""; resourceCase_ = 0; resource_ = null; tierCase_ = 0; @@ -6607,6 +6671,9 @@ private void buildPartial0(com.google.cloud.tpu.v2alpha1.QueuedResource result) if (((from_bitField0_ & 0x00000020) != 0)) { result.state_ = stateBuilder_ == null ? state_ : stateBuilder_.build(); } + if (((from_bitField0_ & 0x00000040) != 0)) { + result.reservationName_ = reservationName_; + } } private void buildPartialOneofs(com.google.cloud.tpu.v2alpha1.QueuedResource result) { @@ -6681,6 +6748,11 @@ public Builder mergeFrom(com.google.cloud.tpu.v2alpha1.QueuedResource other) { if (other.hasState()) { mergeState(other.getState()); } + if (!other.getReservationName().isEmpty()) { + reservationName_ = other.reservationName_; + bitField0_ |= 0x00000040; + onChanged(); + } switch (other.getResourceCase()) { case TPU: { @@ -6770,6 +6842,12 @@ public Builder mergeFrom( bitField0_ |= 0x00000020; break; } // case 50 + case 66: + { + reservationName_ = input.readStringRequireUtf8(); + bitField0_ |= 0x00000040; + break; + } // case 66 default: { if (!super.parseUnknownField(input, extensionRegistry, tag)) { @@ -7956,6 +8034,117 @@ public com.google.cloud.tpu.v2alpha1.QueuedResourceStateOrBuilder getStateOrBuil return stateBuilder_; } + private java.lang.Object reservationName_ = ""; + /** + * + * + * 
+     * Name of the reservation in which the resource should be provisioned.
+     * Format: projects/{project}/locations/{zone}/reservations/{reservation}
+     *
+ * + * string reservation_name = 8; + * + * @return The reservationName. + */ + public java.lang.String getReservationName() { + java.lang.Object ref = reservationName_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + reservationName_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * + * + * 
+     * Name of the reservation in which the resource should be provisioned.
+     * Format: projects/{project}/locations/{zone}/reservations/{reservation}
+     *
+ * + * string reservation_name = 8; + * + * @return The bytes for reservationName. + */ + public com.google.protobuf.ByteString getReservationNameBytes() { + java.lang.Object ref = reservationName_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); + reservationName_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * + * + * 
+     * Name of the reservation in which the resource should be provisioned.
+     * Format: projects/{project}/locations/{zone}/reservations/{reservation}
+     *
+ * + * string reservation_name = 8; + * + * @param value The reservationName to set. + * @return This builder for chaining. + */ + public Builder setReservationName(java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + reservationName_ = value; + bitField0_ |= 0x00000040; + onChanged(); + return this; + } + /** + * + * + * 
+     * Name of the reservation in which the resource should be provisioned.
+     * Format: projects/{project}/locations/{zone}/reservations/{reservation}
+     *
+ * + * string reservation_name = 8; + * + * @return This builder for chaining. + */ + public Builder clearReservationName() { + reservationName_ = getDefaultInstance().getReservationName(); + bitField0_ = (bitField0_ & ~0x00000040); + onChanged(); + return this; + } + /** + * + * + * 
+     * Name of the reservation in which the resource should be provisioned.
+     * Format: projects/{project}/locations/{zone}/reservations/{reservation}
+     *
+ * + * string reservation_name = 8; + * + * @param value The bytes for reservationName to set. + * @return This builder for chaining. + */ + public Builder setReservationNameBytes(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + reservationName_ = value; + bitField0_ |= 0x00000040; + onChanged(); + return this; + } + @java.lang.Override public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) { return super.setUnknownFields(unknownFields); diff --git a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceOrBuilder.java b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceOrBuilder.java index d9f40f6dfe23..a6c58abad058 100644 --- a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceOrBuilder.java +++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceOrBuilder.java @@ -233,6 +233,33 @@ public interface QueuedResourceOrBuilder */ com.google.cloud.tpu.v2alpha1.QueuedResourceStateOrBuilder getStateOrBuilder(); + /** + * + * + * 
+   * Name of the reservation in which the resource should be provisioned.
+   * Format: projects/{project}/locations/{zone}/reservations/{reservation}
+   *
+ * + * string reservation_name = 8; + * + * @return The reservationName. + */ + java.lang.String getReservationName(); + /** + * + * + * 
+   * Name of the reservation in which the resource should be provisioned.
+   * Format: projects/{project}/locations/{zone}/reservations/{reservation}
+   *
+ * + * string reservation_name = 8; + * + * @return The bytes for reservationName. + */ + com.google.protobuf.ByteString getReservationNameBytes(); + public com.google.cloud.tpu.v2alpha1.QueuedResource.ResourceCase getResourceCase(); public com.google.cloud.tpu.v2alpha1.QueuedResource.TierCase getTierCase(); diff --git a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/ResetQueuedResourceRequest.java b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/ResetQueuedResourceRequest.java new file mode 100644 index 000000000000..ac081e969586 --- /dev/null +++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/ResetQueuedResourceRequest.java @@ -0,0 +1,646 @@ +/* + * Copyright 2020 Google LLC + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: google/cloud/tpu/v2alpha1/cloud_tpu.proto + +package com.google.cloud.tpu.v2alpha1; + +/** + * + * + * 
+ * Request for
+ * [ResetQueuedResource][google.cloud.tpu.v2alpha1.Tpu.ResetQueuedResource].
+ *
+ * + * Protobuf type {@code google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest} + */ +public final class ResetQueuedResourceRequest extends com.google.protobuf.GeneratedMessageV3 + implements + // @@protoc_insertion_point(message_implements:google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest) + ResetQueuedResourceRequestOrBuilder { + private static final long serialVersionUID = 0L; + // Use ResetQueuedResourceRequest.newBuilder() to construct. + private ResetQueuedResourceRequest(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + + private ResetQueuedResourceRequest() { + name_ = ""; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance(UnusedPrivateParameter unused) { + return new ResetQueuedResourceRequest(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet getUnknownFields() { + return this.unknownFields; + } + + public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { + return com.google.cloud.tpu.v2alpha1.CloudTpuProto + .internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return com.google.cloud.tpu.v2alpha1.CloudTpuProto + .internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest.class, + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest.Builder.class); + } + + public static final int NAME_FIELD_NUMBER = 1; + + @SuppressWarnings("serial") + private volatile java.lang.Object name_ = ""; + /** + * + * + * 
+   * Required. The name of the queued resource.
+   *
+ * + * + * string name = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... } + * + * + * @return The name. + */ + @java.lang.Override + public java.lang.String getName() { + java.lang.Object ref = name_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + name_ = s; + return s; + } + } + /** + * + * + * 
+   * Required. The name of the queued resource.
+   *
+ * + * + * string name = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... } + * + * + * @return The bytes for name. + */ + @java.lang.Override + public com.google.protobuf.ByteString getNameBytes() { + java.lang.Object ref = name_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); + name_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(name_)) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 1, name_); + } + getUnknownFields().writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(name_)) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, name_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest)) { + return super.equals(obj); + } + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest other = + (com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest) obj; + + if (!getName().equals(other.getName())) return false; + if (!getUnknownFields().equals(other.getUnknownFields())) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + NAME_FIELD_NUMBER; + hash = (53 * hash) + getName().hashCode(); + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom( + java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom( + java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom( + byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom( + java.io.InputStream input) throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom( + java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseWithIOException( + PARSER, input, extensionRegistry); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseDelimitedFrom( + java.io.InputStream input) throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(PARSER, input); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseDelimitedFrom( + java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException( + PARSER, input, extensionRegistry); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom( + com.google.protobuf.CodedInputStream input) throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseWithIOException( + PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { + return newBuilder(); + } + + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + + public static Builder newBuilder( + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * + * + * 
+   * Request for
+   * [ResetQueuedResource][google.cloud.tpu.v2alpha1.Tpu.ResetQueuedResource].
+   *
+ * + * Protobuf type {@code google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest} + */ + public static final class Builder extends com.google.protobuf.GeneratedMessageV3.Builder + implements + // @@protoc_insertion_point(builder_implements:google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest) + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequestOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { + return com.google.cloud.tpu.v2alpha1.CloudTpuProto + .internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return com.google.cloud.tpu.v2alpha1.CloudTpuProto + .internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest.class, + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest.Builder.class); + } + + // Construct using com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest.newBuilder() + private Builder() {} + + private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + } + + @java.lang.Override + public Builder clear() { + super.clear(); + bitField0_ = 0; + name_ = ""; + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() { + return com.google.cloud.tpu.v2alpha1.CloudTpuProto + .internal_static_google_cloud_tpu_v2alpha1_ResetQueuedResourceRequest_descriptor; + } + + @java.lang.Override + public com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest getDefaultInstanceForType() { + return com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest.getDefaultInstance(); + } + + @java.lang.Override + public com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest build() { + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest buildPartial() { + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest result = + new com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest(this); + if (bitField0_ != 0) { + buildPartial0(result); + } + onBuilt(); + return result; + } + + private void buildPartial0(com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest result) { + int from_bitField0_ = bitField0_; + if (((from_bitField0_ & 0x00000001) != 0)) { + result.name_ = name_; + } + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) { + return super.setField(field, value); + } + + @java.lang.Override + public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + + @java.lang.Override + public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) { + return super.addRepeatedField(field, value); + } + + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest) { + return mergeFrom((com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest) other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest other) { + if (other == com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest.getDefaultInstance()) + return this; + if (!other.getName().isEmpty()) { + name_ = other.name_; + bitField0_ |= 0x00000001; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: + { + name_ = input.readStringRequireUtf8(); + bitField0_ |= 0x00000001; + break; + } // case 10 + default: + { + if (!super.parseUnknownField(input, extensionRegistry, tag)) { + done = true; // was an endgroup tag + } + break; + } // default: + } // switch (tag) + } // while (!done) + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.unwrapIOException(); + } finally { + onChanged(); + } // finally + return this; + } + + private int bitField0_; + + private java.lang.Object name_ = ""; + /** + * + * + * 
+     * Required. The name of the queued resource.
+     *
+ * + * + * string name = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... } + * + * + * @return The name. + */ + public java.lang.String getName() { + java.lang.Object ref = name_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + name_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * + * + * 
+     * Required. The name of the queued resource.
+     *
+ * + * + * string name = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... } + * + * + * @return The bytes for name. + */ + public com.google.protobuf.ByteString getNameBytes() { + java.lang.Object ref = name_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); + name_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * + * + * 
+     * Required. The name of the queued resource.
+     *
+ * + * + * string name = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... } + * + * + * @param value The name to set. + * @return This builder for chaining. + */ + public Builder setName(java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + name_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + /** + * + * + * 
+     * Required. The name of the queued resource.
+     *
+ * + * + * string name = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... } + * + * + * @return This builder for chaining. + */ + public Builder clearName() { + name_ = getDefaultInstance().getName(); + bitField0_ = (bitField0_ & ~0x00000001); + onChanged(); + return this; + } + /** + * + * + * 
+     * Required. The name of the queued resource.
+     *
+ * + * + * string name = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... } + * + * + * @param value The bytes for name to set. + * @return This builder for chaining. + */ + public Builder setNameBytes(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + name_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + + @java.lang.Override + public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + // @@protoc_insertion_point(builder_scope:google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest) + } + + // @@protoc_insertion_point(class_scope:google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest) + private static final com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest DEFAULT_INSTANCE; + + static { + DEFAULT_INSTANCE = new com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest(); + } + + public static com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser PARSER = + new com.google.protobuf.AbstractParser() { + @java.lang.Override + public ResetQueuedResourceRequest parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + Builder builder = newBuilder(); + try { + builder.mergeFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(builder.buildPartial()); + } catch (com.google.protobuf.UninitializedMessageException e) { + throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial()); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException(e) + .setUnfinishedMessage(builder.buildPartial()); + } + return builder.buildPartial(); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } +} diff --git a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/ResetQueuedResourceRequestOrBuilder.java b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/ResetQueuedResourceRequestOrBuilder.java new file mode 100644 index 000000000000..33e32d511095 --- /dev/null +++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/ResetQueuedResourceRequestOrBuilder.java @@ -0,0 +1,54 @@ +/* + * Copyright 2020 Google LLC + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: google/cloud/tpu/v2alpha1/cloud_tpu.proto + +package com.google.cloud.tpu.v2alpha1; + +public interface ResetQueuedResourceRequestOrBuilder + extends + // @@protoc_insertion_point(interface_extends:google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest) + com.google.protobuf.MessageOrBuilder { + + /** + * + * + * 
+   * Required. The name of the queued resource.
+   *
+ * + * + * string name = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... } + * + * + * @return The name. + */ + java.lang.String getName(); + /** + * + * + * 
+   * Required. The name of the queued resource.
+   *
+ * + * + * string name = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... } + * + * + * @return The bytes for name. + */ + com.google.protobuf.ByteString getNameBytes(); +} diff --git a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/proto/google/cloud/tpu/v2alpha1/cloud_tpu.proto b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/proto/google/cloud/tpu/v2alpha1/cloud_tpu.proto index db6b9326a6e2..7d2037e9f538 100644 --- a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/proto/google/cloud/tpu/v2alpha1/cloud_tpu.proto +++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/proto/google/cloud/tpu/v2alpha1/cloud_tpu.proto @@ -164,6 +164,20 @@ service Tpu { }; } + // Resets a QueuedResource TPU instance + rpc ResetQueuedResource(ResetQueuedResourceRequest) + returns (google.longrunning.Operation) { + option (google.api.http) = { + post: "/v2alpha1/{name=projects/*/locations/*/queuedResources/*}:reset" + body: "*" + }; + option (google.api.method_signature) = "name"; + option (google.longrunning.operation_info) = { + response_type: "QueuedResource" + metadata_type: "OperationMetadata" + }; + } + // Generates the Cloud TPU service identity for the project. rpc GenerateServiceIdentity(GenerateServiceIdentityRequest) returns (GenerateServiceIdentityResponse) { @@ -629,6 +643,10 @@ message QueuedResource { // Output only. State of the QueuedResource request. QueuedResourceState state = 6 [(google.api.field_behavior) = OUTPUT_ONLY]; + + // Name of the reservation in which the resource should be provisioned. + // Format: projects/{project}/locations/{zone}/reservations/{reservation} + string reservation_name = 8; } // QueuedResourceState defines the details of the QueuedResource request. @@ -884,7 +902,7 @@ message CreateQueuedResourceRequest { } ]; - // The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$ + // The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$` // regex format. string queued_resource_id = 2; @@ -910,6 +928,18 @@ message DeleteQueuedResourceRequest { string request_id = 2; } +// Request for +// [ResetQueuedResource][google.cloud.tpu.v2alpha1.Tpu.ResetQueuedResource]. +message ResetQueuedResourceRequest { + // Required. The name of the queued resource. + string name = 1 [ + (google.api.field_behavior) = REQUIRED, + (google.api.resource_reference) = { + type: "tpu.googleapis.com/QueuedResource" + } + ]; +} + // The per-product per-project service identity for Cloud TPU service. message ServiceIdentity { // The email address of the service identity. diff --git a/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/AsyncResetQueuedResource.java b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/AsyncResetQueuedResource.java new file mode 100644 index 000000000000..d502917452b7 --- /dev/null +++ b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/AsyncResetQueuedResource.java @@ -0,0 +1,50 @@ +/* + * 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. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.google.cloud.tpu.v2alpha1.samples; + +// [START tpu_v2alpha1_generated_Tpu_ResetQueuedResource_async] +import com.google.api.core.ApiFuture; +import com.google.cloud.tpu.v2alpha1.QueuedResourceName; +import com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest; +import com.google.cloud.tpu.v2alpha1.TpuClient; +import com.google.longrunning.Operation; + +public class AsyncResetQueuedResource { + + public static void main(String[] args) throws Exception { + asyncResetQueuedResource(); + } + + public static void asyncResetQueuedResource() throws Exception { + // This snippet has been automatically generated and should be regarded as a code template only. + // It will require modifications to work: + // - It may require correct/in-range values for request initialization. + // - It may require specifying regional endpoints when creating the service client as shown in + // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library + try (TpuClient tpuClient = TpuClient.create()) { + ResetQueuedResourceRequest request = + ResetQueuedResourceRequest.newBuilder() + .setName( + QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) + .build(); + ApiFuture future = tpuClient.resetQueuedResourceCallable().futureCall(request); + // Do something. + Operation response = future.get(); + } + } +} +// [END tpu_v2alpha1_generated_Tpu_ResetQueuedResource_async] diff --git a/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/AsyncResetQueuedResourceLRO.java b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/AsyncResetQueuedResourceLRO.java new file mode 100644 index 000000000000..b089c07b6635 --- /dev/null +++ b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/AsyncResetQueuedResourceLRO.java @@ -0,0 +1,52 @@ +/* + * 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. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.google.cloud.tpu.v2alpha1.samples; + +// [START tpu_v2alpha1_generated_Tpu_ResetQueuedResource_LRO_async] +import com.google.api.gax.longrunning.OperationFuture; +import com.google.cloud.tpu.v2alpha1.OperationMetadata; +import com.google.cloud.tpu.v2alpha1.QueuedResource; +import com.google.cloud.tpu.v2alpha1.QueuedResourceName; +import com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest; +import com.google.cloud.tpu.v2alpha1.TpuClient; + +public class AsyncResetQueuedResourceLRO { + + public static void main(String[] args) throws Exception { + asyncResetQueuedResourceLRO(); + } + + public static void asyncResetQueuedResourceLRO() throws Exception { + // This snippet has been automatically generated and should be regarded as a code template only. + // It will require modifications to work: + // - It may require correct/in-range values for request initialization. + // - It may require specifying regional endpoints when creating the service client as shown in + // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library + try (TpuClient tpuClient = TpuClient.create()) { + ResetQueuedResourceRequest request = + ResetQueuedResourceRequest.newBuilder() + .setName( + QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) + .build(); + OperationFuture future = + tpuClient.resetQueuedResourceOperationCallable().futureCall(request); + // Do something. + QueuedResource response = future.get(); + } + } +} +// [END tpu_v2alpha1_generated_Tpu_ResetQueuedResource_LRO_async] diff --git a/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/SyncResetQueuedResource.java b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/SyncResetQueuedResource.java new file mode 100644 index 000000000000..3d16315681b8 --- /dev/null +++ b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/SyncResetQueuedResource.java @@ -0,0 +1,47 @@ +/* + * 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. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.google.cloud.tpu.v2alpha1.samples; + +// [START tpu_v2alpha1_generated_Tpu_ResetQueuedResource_sync] +import com.google.cloud.tpu.v2alpha1.QueuedResource; +import com.google.cloud.tpu.v2alpha1.QueuedResourceName; +import com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest; +import com.google.cloud.tpu.v2alpha1.TpuClient; + +public class SyncResetQueuedResource { + + public static void main(String[] args) throws Exception { + syncResetQueuedResource(); + } + + public static void syncResetQueuedResource() throws Exception { + // This snippet has been automatically generated and should be regarded as a code template only. + // It will require modifications to work: + // - It may require correct/in-range values for request initialization. + // - It may require specifying regional endpoints when creating the service client as shown in + // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library + try (TpuClient tpuClient = TpuClient.create()) { + ResetQueuedResourceRequest request = + ResetQueuedResourceRequest.newBuilder() + .setName( + QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString()) + .build(); + QueuedResource response = tpuClient.resetQueuedResourceAsync(request).get(); + } + } +} +// [END tpu_v2alpha1_generated_Tpu_ResetQueuedResource_sync] diff --git a/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/SyncResetQueuedResourceQueuedresourcename.java b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/SyncResetQueuedResourceQueuedresourcename.java new file mode 100644 index 000000000000..cd8fac520dae --- /dev/null +++ b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/SyncResetQueuedResourceQueuedresourcename.java @@ -0,0 +1,43 @@ +/* + * 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. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.google.cloud.tpu.v2alpha1.samples; + +// [START tpu_v2alpha1_generated_Tpu_ResetQueuedResource_Queuedresourcename_sync] +import com.google.cloud.tpu.v2alpha1.QueuedResource; +import com.google.cloud.tpu.v2alpha1.QueuedResourceName; +import com.google.cloud.tpu.v2alpha1.TpuClient; + +public class SyncResetQueuedResourceQueuedresourcename { + + public static void main(String[] args) throws Exception { + syncResetQueuedResourceQueuedresourcename(); + } + + public static void syncResetQueuedResourceQueuedresourcename() throws Exception { + // This snippet has been automatically generated and should be regarded as a code template only. + // It will require modifications to work: + // - It may require correct/in-range values for request initialization. + // - It may require specifying regional endpoints when creating the service client as shown in + // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library + try (TpuClient tpuClient = TpuClient.create()) { + QueuedResourceName name = + QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]"); + QueuedResource response = tpuClient.resetQueuedResourceAsync(name).get(); + } + } +} +// [END tpu_v2alpha1_generated_Tpu_ResetQueuedResource_Queuedresourcename_sync] diff --git a/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/SyncResetQueuedResourceString.java b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/SyncResetQueuedResourceString.java new file mode 100644 index 000000000000..81da1f6e3f97 --- /dev/null +++ b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/SyncResetQueuedResourceString.java @@ -0,0 +1,43 @@ +/* + * 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. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.google.cloud.tpu.v2alpha1.samples; + +// [START tpu_v2alpha1_generated_Tpu_ResetQueuedResource_String_sync] +import com.google.cloud.tpu.v2alpha1.QueuedResource; +import com.google.cloud.tpu.v2alpha1.QueuedResourceName; +import com.google.cloud.tpu.v2alpha1.TpuClient; + +public class SyncResetQueuedResourceString { + + public static void main(String[] args) throws Exception { + syncResetQueuedResourceString(); + } + + public static void syncResetQueuedResourceString() throws Exception { + // This snippet has been automatically generated and should be regarded as a code template only. + // It will require modifications to work: + // - It may require correct/in-range values for request initialization. + // - It may require specifying regional endpoints when creating the service client as shown in + // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library + try (TpuClient tpuClient = TpuClient.create()) { + String name = + QueuedResourceName.of("[PROJECT]", "[LOCATION]", "[QUEUED_RESOURCE]").toString(); + QueuedResource response = tpuClient.resetQueuedResourceAsync(name).get(); + } + } +} +// [END tpu_v2alpha1_generated_Tpu_ResetQueuedResource_String_sync]