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 OperationFutureSample 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 OperationFutureSample 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 OperationFutureSample 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 OperationCallableSample 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+ * Resets a QueuedResource TPU instance + *+ */ + default void resetQueuedResource( + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest request, + io.grpc.stub.StreamObserver
+ * Resets a QueuedResource TPU instance + *+ */ + public void resetQueuedResource( + com.google.cloud.tpu.v2alpha1.ResetQueuedResourceRequest request, + io.grpc.stub.StreamObserver
+ * 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
+ * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return Whether the multiNodeParams field is set.
+ */
+ boolean hasMultiNodeParams();
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return The multiNodeParams.
+ */
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ getMultiNodeParams();
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParamsOrBuilder
+ getMultiNodeParamsOrBuilder();
+
/**
*
*
@@ -290,30 +333,861 @@ private NodeSpec(com.google.protobuf.GeneratedMessageV3.Builder builder) {
super(builder);
}
- private NodeSpec() {
- parent_ = "";
- nodeId_ = "";
- }
+ private NodeSpec() {
+ parent_ = "";
+ nodeId_ = "";
+ }
+
+ @java.lang.Override
+ @SuppressWarnings({"unused"})
+ protected java.lang.Object newInstance(UnusedPrivateParameter unused) {
+ return new NodeSpec();
+ }
+
+ public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
+ return com.google.cloud.tpu.v2alpha1.CloudTpuProto
+ .internal_static_google_cloud_tpu_v2alpha1_QueuedResource_Tpu_NodeSpec_descriptor;
+ }
+
+ @java.lang.Override
+ protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return com.google.cloud.tpu.v2alpha1.CloudTpuProto
+ .internal_static_google_cloud_tpu_v2alpha1_QueuedResource_Tpu_NodeSpec_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.class,
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.Builder.class);
+ }
+
+ public interface MultiNodeParamsOrBuilder
+ extends
+ // @@protoc_insertion_point(interface_extends:google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ *
+ *
+ * + * Required. Number of nodes with this spec. The system will attempt + * to provison "node_count" nodes as part of the request. + * This needs to be > 1. + *+ * + *
int32 node_count = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * @return The nodeCount.
+ */
+ int getNodeCount();
+
+ /**
+ *
+ *
+ * + * Prefix of node_ids in case of multi-node request + * Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format. + * If node_count = 3 and node_id_prefix = "np", node ids of nodes + * created will be "np-0", "np-1", "np-2". If this field is not + * provided we use queued_resource_id as the node_id_prefix. + *+ * + *
string node_id_prefix = 2;
+ *
+ * @return The nodeIdPrefix.
+ */
+ java.lang.String getNodeIdPrefix();
+ /**
+ *
+ *
+ * + * Prefix of node_ids in case of multi-node request + * Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format. + * If node_count = 3 and node_id_prefix = "np", node ids of nodes + * created will be "np-0", "np-1", "np-2". If this field is not + * provided we use queued_resource_id as the node_id_prefix. + *+ * + *
string node_id_prefix = 2;
+ *
+ * @return The bytes for nodeIdPrefix.
+ */
+ com.google.protobuf.ByteString getNodeIdPrefixBytes();
+ }
+ /**
+ *
+ *
+ * + * Parameters to specify for multi-node QueuedResource requests. This + * field must be populated in case of multi-node requests instead of + * node_id. It's an error to specify both node_id and multi_node_params. + *+ * + * Protobuf type {@code google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams} + */ + public static final class MultiNodeParams extends com.google.protobuf.GeneratedMessageV3 + implements + // @@protoc_insertion_point(message_implements:google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams) + MultiNodeParamsOrBuilder { + private static final long serialVersionUID = 0L; + // Use MultiNodeParams.newBuilder() to construct. + private MultiNodeParams(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + + private MultiNodeParams() { + nodeIdPrefix_ = ""; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance(UnusedPrivateParameter unused) { + return new MultiNodeParams(); + } + + public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { + return com.google.cloud.tpu.v2alpha1.CloudTpuProto + .internal_static_google_cloud_tpu_v2alpha1_QueuedResource_Tpu_NodeSpec_MultiNodeParams_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return com.google.cloud.tpu.v2alpha1.CloudTpuProto + .internal_static_google_cloud_tpu_v2alpha1_QueuedResource_Tpu_NodeSpec_MultiNodeParams_fieldAccessorTable + .ensureFieldAccessorsInitialized( + com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams.class, + com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams.Builder + .class); + } + + public static final int NODE_COUNT_FIELD_NUMBER = 1; + private int nodeCount_ = 0; + /** + * + * + *
+ * Required. Number of nodes with this spec. The system will attempt + * to provison "node_count" nodes as part of the request. + * This needs to be > 1. + *+ * + *
int32 node_count = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * @return The nodeCount.
+ */
+ @java.lang.Override
+ public int getNodeCount() {
+ return nodeCount_;
+ }
+
+ public static final int NODE_ID_PREFIX_FIELD_NUMBER = 2;
+
+ @SuppressWarnings("serial")
+ private volatile java.lang.Object nodeIdPrefix_ = "";
+ /**
+ *
+ *
+ * + * Prefix of node_ids in case of multi-node request + * Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format. + * If node_count = 3 and node_id_prefix = "np", node ids of nodes + * created will be "np-0", "np-1", "np-2". If this field is not + * provided we use queued_resource_id as the node_id_prefix. + *+ * + *
string node_id_prefix = 2;
+ *
+ * @return The nodeIdPrefix.
+ */
+ @java.lang.Override
+ public java.lang.String getNodeIdPrefix() {
+ java.lang.Object ref = nodeIdPrefix_;
+ 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();
+ nodeIdPrefix_ = s;
+ return s;
+ }
+ }
+ /**
+ *
+ *
+ * + * Prefix of node_ids in case of multi-node request + * Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format. + * If node_count = 3 and node_id_prefix = "np", node ids of nodes + * created will be "np-0", "np-1", "np-2". If this field is not + * provided we use queued_resource_id as the node_id_prefix. + *+ * + *
string node_id_prefix = 2;
+ *
+ * @return The bytes for nodeIdPrefix.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString getNodeIdPrefixBytes() {
+ java.lang.Object ref = nodeIdPrefix_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
+ nodeIdPrefix_ = 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 (nodeCount_ != 0) {
+ output.writeInt32(1, nodeCount_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(nodeIdPrefix_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 2, nodeIdPrefix_);
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ @java.lang.Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (nodeCount_ != 0) {
+ size += com.google.protobuf.CodedOutputStream.computeInt32Size(1, nodeCount_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(nodeIdPrefix_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, nodeIdPrefix_);
+ }
+ 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.QueuedResource.Tpu.NodeSpec.MultiNodeParams)) {
+ return super.equals(obj);
+ }
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams other =
+ (com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams) obj;
+
+ if (getNodeCount() != other.getNodeCount()) return false;
+ if (!getNodeIdPrefix().equals(other.getNodeIdPrefix())) 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) + NODE_COUNT_FIELD_NUMBER;
+ hash = (53 * hash) + getNodeCount();
+ hash = (37 * hash) + NODE_ID_PREFIX_FIELD_NUMBER;
+ hash = (53 * hash) + getNodeIdPrefix().hashCode();
+ hash = (29 * hash) + getUnknownFields().hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ parseFrom(java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ 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.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ parseFrom(com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ 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.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ 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.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ parseFrom(java.io.InputStream input) throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input);
+ }
+
+ public static com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ 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.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(
+ PARSER, input);
+ }
+
+ public static com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ 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.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ 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.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ 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.QueuedResource.Tpu.NodeSpec.MultiNodeParams 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;
+ }
+ /**
+ *
+ *
+ * + * Parameters to specify for multi-node QueuedResource requests. This + * field must be populated in case of multi-node requests instead of + * node_id. It's an error to specify both node_id and multi_node_params. + *+ * + * Protobuf type {@code + * google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams} + */ + public static final class Builder + extends com.google.protobuf.GeneratedMessageV3.Builder
+ * Required. Number of nodes with this spec. The system will attempt + * to provison "node_count" nodes as part of the request. + * This needs to be > 1. + *+ * + *
int32 node_count = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * @return The nodeCount.
+ */
+ @java.lang.Override
+ public int getNodeCount() {
+ return nodeCount_;
+ }
+ /**
+ *
+ *
+ * + * Required. Number of nodes with this spec. The system will attempt + * to provison "node_count" nodes as part of the request. + * This needs to be > 1. + *+ * + *
int32 node_count = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * @param value The nodeCount to set.
+ * @return This builder for chaining.
+ */
+ public Builder setNodeCount(int value) {
+
+ nodeCount_ = value;
+ bitField0_ |= 0x00000001;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ * + * Required. Number of nodes with this spec. The system will attempt + * to provison "node_count" nodes as part of the request. + * This needs to be > 1. + *+ * + *
int32 node_count = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearNodeCount() {
+ bitField0_ = (bitField0_ & ~0x00000001);
+ nodeCount_ = 0;
+ onChanged();
+ return this;
+ }
- @java.lang.Override
- @SuppressWarnings({"unused"})
- protected java.lang.Object newInstance(UnusedPrivateParameter unused) {
- return new NodeSpec();
- }
+ private java.lang.Object nodeIdPrefix_ = "";
+ /**
+ *
+ *
+ * + * Prefix of node_ids in case of multi-node request + * Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format. + * If node_count = 3 and node_id_prefix = "np", node ids of nodes + * created will be "np-0", "np-1", "np-2". If this field is not + * provided we use queued_resource_id as the node_id_prefix. + *+ * + *
string node_id_prefix = 2;
+ *
+ * @return The nodeIdPrefix.
+ */
+ public java.lang.String getNodeIdPrefix() {
+ java.lang.Object ref = nodeIdPrefix_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ nodeIdPrefix_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ *
+ *
+ * + * Prefix of node_ids in case of multi-node request + * Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format. + * If node_count = 3 and node_id_prefix = "np", node ids of nodes + * created will be "np-0", "np-1", "np-2". If this field is not + * provided we use queued_resource_id as the node_id_prefix. + *+ * + *
string node_id_prefix = 2;
+ *
+ * @return The bytes for nodeIdPrefix.
+ */
+ public com.google.protobuf.ByteString getNodeIdPrefixBytes() {
+ java.lang.Object ref = nodeIdPrefix_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
+ nodeIdPrefix_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ *
+ *
+ * + * Prefix of node_ids in case of multi-node request + * Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format. + * If node_count = 3 and node_id_prefix = "np", node ids of nodes + * created will be "np-0", "np-1", "np-2". If this field is not + * provided we use queued_resource_id as the node_id_prefix. + *+ * + *
string node_id_prefix = 2;
+ *
+ * @param value The nodeIdPrefix to set.
+ * @return This builder for chaining.
+ */
+ public Builder setNodeIdPrefix(java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ nodeIdPrefix_ = value;
+ bitField0_ |= 0x00000002;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ * + * Prefix of node_ids in case of multi-node request + * Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format. + * If node_count = 3 and node_id_prefix = "np", node ids of nodes + * created will be "np-0", "np-1", "np-2". If this field is not + * provided we use queued_resource_id as the node_id_prefix. + *+ * + *
string node_id_prefix = 2;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearNodeIdPrefix() {
+ nodeIdPrefix_ = getDefaultInstance().getNodeIdPrefix();
+ bitField0_ = (bitField0_ & ~0x00000002);
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ * + * Prefix of node_ids in case of multi-node request + * Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format. + * If node_count = 3 and node_id_prefix = "np", node ids of nodes + * created will be "np-0", "np-1", "np-2". If this field is not + * provided we use queued_resource_id as the node_id_prefix. + *+ * + *
string node_id_prefix = 2;
+ *
+ * @param value The bytes for nodeIdPrefix to set.
+ * @return This builder for chaining.
+ */
+ public Builder setNodeIdPrefixBytes(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ nodeIdPrefix_ = value;
+ bitField0_ |= 0x00000002;
+ onChanged();
+ return this;
+ }
- public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
- return com.google.cloud.tpu.v2alpha1.CloudTpuProto
- .internal_static_google_cloud_tpu_v2alpha1_QueuedResource_Tpu_NodeSpec_descriptor;
- }
+ @java.lang.Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
- @java.lang.Override
- protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return com.google.cloud.tpu.v2alpha1.CloudTpuProto
- .internal_static_google_cloud_tpu_v2alpha1_QueuedResource_Tpu_NodeSpec_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.class,
- com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.Builder.class);
+ @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.QueuedResource.Tpu.NodeSpec.MultiNodeParams)
+ }
+
+ // @@protoc_insertion_point(class_scope:google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams)
+ private static final com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec
+ .MultiNodeParams
+ DEFAULT_INSTANCE;
+
+ static {
+ DEFAULT_INSTANCE =
+ new com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams();
+ }
+
+ public static com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser+ * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return Whether the multiNodeParams field is set.
+ */
+ @java.lang.Override
+ public boolean hasMultiNodeParams() {
+ return multiNodeParams_ != null;
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return The multiNodeParams.
+ */
+ @java.lang.Override
+ public com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ getMultiNodeParams() {
+ return multiNodeParams_ == null
+ ? com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ .getDefaultInstance()
+ : multiNodeParams_;
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ @java.lang.Override
+ public com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParamsOrBuilder
+ getMultiNodeParamsOrBuilder() {
+ return multiNodeParams_ == null
+ ? com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ .getDefaultInstance()
+ : multiNodeParams_;
+ }
+
public static final int NODE_FIELD_NUMBER = 3;
private com.google.cloud.tpu.v2alpha1.Node node_;
/**
@@ -500,6 +1435,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
if (node_ != null) {
output.writeMessage(3, getNode());
}
+ if (multiNodeParams_ != null) {
+ output.writeMessage(6, getMultiNodeParams());
+ }
getUnknownFields().writeTo(output);
}
@@ -518,6 +1456,9 @@ public int getSerializedSize() {
if (node_ != null) {
size += com.google.protobuf.CodedOutputStream.computeMessageSize(3, getNode());
}
+ if (multiNodeParams_ != null) {
+ size += com.google.protobuf.CodedOutputStream.computeMessageSize(6, getMultiNodeParams());
+ }
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
@@ -536,6 +1477,10 @@ public boolean equals(final java.lang.Object obj) {
if (!getParent().equals(other.getParent())) return false;
if (!getNodeId().equals(other.getNodeId())) return false;
+ if (hasMultiNodeParams() != other.hasMultiNodeParams()) return false;
+ if (hasMultiNodeParams()) {
+ if (!getMultiNodeParams().equals(other.getMultiNodeParams())) return false;
+ }
if (hasNode() != other.hasNode()) return false;
if (hasNode()) {
if (!getNode().equals(other.getNode())) return false;
@@ -555,6 +1500,10 @@ public int hashCode() {
hash = (53 * hash) + getParent().hashCode();
hash = (37 * hash) + NODE_ID_FIELD_NUMBER;
hash = (53 * hash) + getNodeId().hashCode();
+ if (hasMultiNodeParams()) {
+ hash = (37 * hash) + MULTI_NODE_PARAMS_FIELD_NUMBER;
+ hash = (53 * hash) + getMultiNodeParams().hashCode();
+ }
if (hasNode()) {
hash = (37 * hash) + NODE_FIELD_NUMBER;
hash = (53 * hash) + getNode().hashCode();
@@ -705,6 +1654,11 @@ public Builder clear() {
bitField0_ = 0;
parent_ = "";
nodeId_ = "";
+ multiNodeParams_ = null;
+ if (multiNodeParamsBuilder_ != null) {
+ multiNodeParamsBuilder_.dispose();
+ multiNodeParamsBuilder_ = null;
+ }
node_ = null;
if (nodeBuilder_ != null) {
nodeBuilder_.dispose();
@@ -755,6 +1709,12 @@ private void buildPartial0(
result.nodeId_ = nodeId_;
}
if (((from_bitField0_ & 0x00000004) != 0)) {
+ result.multiNodeParams_ =
+ multiNodeParamsBuilder_ == null
+ ? multiNodeParams_
+ : multiNodeParamsBuilder_.build();
+ }
+ if (((from_bitField0_ & 0x00000008) != 0)) {
result.node_ = nodeBuilder_ == null ? node_ : nodeBuilder_.build();
}
}
@@ -818,6 +1778,9 @@ public Builder mergeFrom(com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSp
bitField0_ |= 0x00000002;
onChanged();
}
+ if (other.hasMultiNodeParams()) {
+ mergeMultiNodeParams(other.getMultiNodeParams());
+ }
if (other.hasNode()) {
mergeNode(other.getNode());
}
@@ -862,9 +1825,16 @@ public Builder mergeFrom(
case 26:
{
input.readMessage(getNodeFieldBuilder().getBuilder(), extensionRegistry);
- bitField0_ |= 0x00000004;
+ bitField0_ |= 0x00000008;
break;
} // case 26
+ case 50:
+ {
+ input.readMessage(
+ getMultiNodeParamsFieldBuilder().getBuilder(), extensionRegistry);
+ bitField0_ |= 0x00000004;
+ break;
+ } // case 50
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -1121,6 +2091,221 @@ public Builder setNodeIdBytes(com.google.protobuf.ByteString value) {
return this;
}
+ private com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ multiNodeParams_;
+ private com.google.protobuf.SingleFieldBuilderV3<
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams,
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams.Builder,
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParamsOrBuilder>
+ multiNodeParamsBuilder_;
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return Whether the multiNodeParams field is set.
+ */
+ public boolean hasMultiNodeParams() {
+ return ((bitField0_ & 0x00000004) != 0);
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return The multiNodeParams.
+ */
+ public com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ getMultiNodeParams() {
+ if (multiNodeParamsBuilder_ == null) {
+ return multiNodeParams_ == null
+ ? com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ .getDefaultInstance()
+ : multiNodeParams_;
+ } else {
+ return multiNodeParamsBuilder_.getMessage();
+ }
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public Builder setMultiNodeParams(
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams value) {
+ if (multiNodeParamsBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ multiNodeParams_ = value;
+ } else {
+ multiNodeParamsBuilder_.setMessage(value);
+ }
+ bitField0_ |= 0x00000004;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public Builder setMultiNodeParams(
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams.Builder
+ builderForValue) {
+ if (multiNodeParamsBuilder_ == null) {
+ multiNodeParams_ = builderForValue.build();
+ } else {
+ multiNodeParamsBuilder_.setMessage(builderForValue.build());
+ }
+ bitField0_ |= 0x00000004;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public Builder mergeMultiNodeParams(
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams value) {
+ if (multiNodeParamsBuilder_ == null) {
+ if (((bitField0_ & 0x00000004) != 0)
+ && multiNodeParams_ != null
+ && multiNodeParams_
+ != com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ .getDefaultInstance()) {
+ getMultiNodeParamsBuilder().mergeFrom(value);
+ } else {
+ multiNodeParams_ = value;
+ }
+ } else {
+ multiNodeParamsBuilder_.mergeFrom(value);
+ }
+ bitField0_ |= 0x00000004;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public Builder clearMultiNodeParams() {
+ bitField0_ = (bitField0_ & ~0x00000004);
+ multiNodeParams_ = null;
+ if (multiNodeParamsBuilder_ != null) {
+ multiNodeParamsBuilder_.dispose();
+ multiNodeParamsBuilder_ = null;
+ }
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams.Builder
+ getMultiNodeParamsBuilder() {
+ bitField0_ |= 0x00000004;
+ onChanged();
+ return getMultiNodeParamsFieldBuilder().getBuilder();
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParamsOrBuilder
+ getMultiNodeParamsOrBuilder() {
+ if (multiNodeParamsBuilder_ != null) {
+ return multiNodeParamsBuilder_.getMessageOrBuilder();
+ } else {
+ return multiNodeParams_ == null
+ ? com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ .getDefaultInstance()
+ : multiNodeParams_;
+ }
+ }
+ /**
+ *
+ *
+ * + * Optional. Fields to specify in case of multi-node request. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams multi_node_params = 6 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ private com.google.protobuf.SingleFieldBuilderV3<
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams,
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams.Builder,
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParamsOrBuilder>
+ getMultiNodeParamsFieldBuilder() {
+ if (multiNodeParamsBuilder_ == null) {
+ multiNodeParamsBuilder_ =
+ new com.google.protobuf.SingleFieldBuilderV3<
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams,
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec.MultiNodeParams
+ .Builder,
+ com.google.cloud.tpu.v2alpha1.QueuedResource.Tpu.NodeSpec
+ .MultiNodeParamsOrBuilder>(
+ getMultiNodeParams(), getParentForChildren(), isClean());
+ multiNodeParams_ = null;
+ }
+ return multiNodeParamsBuilder_;
+ }
+
private com.google.cloud.tpu.v2alpha1.Node node_;
private com.google.protobuf.SingleFieldBuilderV3<
com.google.cloud.tpu.v2alpha1.Node,
@@ -1140,7 +2325,7 @@ public Builder setNodeIdBytes(com.google.protobuf.ByteString value) {
* @return Whether the node field is set.
*/
public boolean hasNode() {
- return ((bitField0_ & 0x00000004) != 0);
+ return ((bitField0_ & 0x00000008) != 0);
}
/**
*
@@ -1180,7 +2365,7 @@ public Builder setNode(com.google.cloud.tpu.v2alpha1.Node value) {
} else {
nodeBuilder_.setMessage(value);
}
- bitField0_ |= 0x00000004;
+ bitField0_ |= 0x00000008;
onChanged();
return this;
}
@@ -1200,7 +2385,7 @@ public Builder setNode(com.google.cloud.tpu.v2alpha1.Node.Builder builderForValu
} else {
nodeBuilder_.setMessage(builderForValue.build());
}
- bitField0_ |= 0x00000004;
+ bitField0_ |= 0x00000008;
onChanged();
return this;
}
@@ -1216,7 +2401,7 @@ public Builder setNode(com.google.cloud.tpu.v2alpha1.Node.Builder builderForValu
*/
public Builder mergeNode(com.google.cloud.tpu.v2alpha1.Node value) {
if (nodeBuilder_ == null) {
- if (((bitField0_ & 0x00000004) != 0)
+ if (((bitField0_ & 0x00000008) != 0)
&& node_ != null
&& node_ != com.google.cloud.tpu.v2alpha1.Node.getDefaultInstance()) {
getNodeBuilder().mergeFrom(value);
@@ -1226,7 +2411,7 @@ public Builder mergeNode(com.google.cloud.tpu.v2alpha1.Node value) {
} else {
nodeBuilder_.mergeFrom(value);
}
- bitField0_ |= 0x00000004;
+ bitField0_ |= 0x00000008;
onChanged();
return this;
}
@@ -1241,7 +2426,7 @@ public Builder mergeNode(com.google.cloud.tpu.v2alpha1.Node value) {
*
*/
public Builder clearNode() {
- bitField0_ = (bitField0_ & ~0x00000004);
+ bitField0_ = (bitField0_ & ~0x00000008);
node_ = null;
if (nodeBuilder_ != null) {
nodeBuilder_.dispose();
@@ -1261,7 +2446,7 @@ public Builder clearNode() {
*
*/
public com.google.cloud.tpu.v2alpha1.Node.Builder getNodeBuilder() {
- bitField0_ |= 0x00000004;
+ bitField0_ |= 0x00000008;
onChanged();
return getNodeFieldBuilder().getBuilder();
}
diff --git a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceState.java b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceState.java
index 3c40fa68acba..302a9f9f2d0f 100644
--- a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceState.java
+++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceState.java
@@ -39,6 +39,7 @@ private QueuedResourceState(com.google.protobuf.GeneratedMessageV3.Builder bu
private QueuedResourceState() {
state_ = 0;
+ stateInitiator_ = 0;
}
@java.lang.Override
@@ -375,6 +376,165 @@ private State(int value) {
// @@protoc_insertion_point(enum_scope:google.cloud.tpu.v2alpha1.QueuedResourceState.State)
}
+ /**
+ *
+ *
+ * + * The initiator of the QueuedResource's SUSPENDING/SUSPENDED state. + *+ * + * Protobuf enum {@code google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator} + */ + public enum StateInitiator implements com.google.protobuf.ProtocolMessageEnum { + /** + * + * + *
+ * The state initiator is unspecified. + *+ * + *
STATE_INITIATOR_UNSPECIFIED = 0;
+ */
+ STATE_INITIATOR_UNSPECIFIED(0),
+ /**
+ *
+ *
+ * + * The current QueuedResource state was initiated by the user. + *+ * + *
USER = 1;
+ */
+ USER(1),
+ /**
+ *
+ *
+ * + * The current QueuedResource state was initiated by the service. + *+ * + *
SERVICE = 2;
+ */
+ SERVICE(2),
+ UNRECOGNIZED(-1),
+ ;
+
+ /**
+ *
+ *
+ * + * The state initiator is unspecified. + *+ * + *
STATE_INITIATOR_UNSPECIFIED = 0;
+ */
+ public static final int STATE_INITIATOR_UNSPECIFIED_VALUE = 0;
+ /**
+ *
+ *
+ * + * The current QueuedResource state was initiated by the user. + *+ * + *
USER = 1;
+ */
+ public static final int USER_VALUE = 1;
+ /**
+ *
+ *
+ * + * The current QueuedResource state was initiated by the service. + *+ * + *
SERVICE = 2;
+ */
+ public static final int SERVICE_VALUE = 2;
+
+ public final int getNumber() {
+ if (this == UNRECOGNIZED) {
+ throw new java.lang.IllegalArgumentException(
+ "Can't get the number of an unknown enum value.");
+ }
+ return value;
+ }
+
+ /**
+ * @param value The numeric wire value of the corresponding enum entry.
+ * @return The enum associated with the given numeric wire value.
+ * @deprecated Use {@link #forNumber(int)} instead.
+ */
+ @java.lang.Deprecated
+ public static StateInitiator valueOf(int value) {
+ return forNumber(value);
+ }
+
+ /**
+ * @param value The numeric wire value of the corresponding enum entry.
+ * @return The enum associated with the given numeric wire value.
+ */
+ public static StateInitiator forNumber(int value) {
+ switch (value) {
+ case 0:
+ return STATE_INITIATOR_UNSPECIFIED;
+ case 1:
+ return USER;
+ case 2:
+ return SERVICE;
+ default:
+ return null;
+ }
+ }
+
+ public static com.google.protobuf.Internal.EnumLiteMap+ * Output only. The initiator of the QueuedResources's current state. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator state_initiator = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
+ *
+ *
+ * @return The enum numeric value on the wire for stateInitiator.
+ */
+ @java.lang.Override
+ public int getStateInitiatorValue() {
+ return stateInitiator_;
+ }
+ /**
+ *
+ *
+ * + * Output only. The initiator of the QueuedResources's current state. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator state_initiator = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
+ *
+ *
+ * @return The stateInitiator.
+ */
+ @java.lang.Override
+ public com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator getStateInitiator() {
+ com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator result =
+ com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator.forNumber(stateInitiator_);
+ return result == null
+ ? com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator.UNRECOGNIZED
+ : result;
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
@@ -4686,6 +4887,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
output.writeMessage(
9, (com.google.cloud.tpu.v2alpha1.QueuedResourceState.SuspendedData) stateData_);
}
+ if (stateInitiator_
+ != com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator
+ .STATE_INITIATOR_UNSPECIFIED
+ .getNumber()) {
+ output.writeEnum(10, stateInitiator_);
+ }
getUnknownFields().writeTo(output);
}
@@ -4739,6 +4946,12 @@ public int getSerializedSize() {
com.google.protobuf.CodedOutputStream.computeMessageSize(
9, (com.google.cloud.tpu.v2alpha1.QueuedResourceState.SuspendedData) stateData_);
}
+ if (stateInitiator_
+ != com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator
+ .STATE_INITIATOR_UNSPECIFIED
+ .getNumber()) {
+ size += com.google.protobuf.CodedOutputStream.computeEnumSize(10, stateInitiator_);
+ }
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
@@ -4756,6 +4969,7 @@ public boolean equals(final java.lang.Object obj) {
(com.google.cloud.tpu.v2alpha1.QueuedResourceState) obj;
if (state_ != other.state_) return false;
+ if (stateInitiator_ != other.stateInitiator_) return false;
if (!getStateDataCase().equals(other.getStateDataCase())) return false;
switch (stateDataCase_) {
case 2:
@@ -4798,6 +5012,8 @@ public int hashCode() {
hash = (19 * hash) + getDescriptor().hashCode();
hash = (37 * hash) + STATE_FIELD_NUMBER;
hash = (53 * hash) + state_;
+ hash = (37 * hash) + STATE_INITIATOR_FIELD_NUMBER;
+ hash = (53 * hash) + stateInitiator_;
switch (stateDataCase_) {
case 2:
hash = (37 * hash) + CREATING_DATA_FIELD_NUMBER;
@@ -4998,6 +5214,7 @@ public Builder clear() {
if (suspendedDataBuilder_ != null) {
suspendedDataBuilder_.clear();
}
+ stateInitiator_ = 0;
stateDataCase_ = 0;
stateData_ = null;
return this;
@@ -5040,6 +5257,9 @@ private void buildPartial0(com.google.cloud.tpu.v2alpha1.QueuedResourceState res
if (((from_bitField0_ & 0x00000001) != 0)) {
result.state_ = state_;
}
+ if (((from_bitField0_ & 0x00000200) != 0)) {
+ result.stateInitiator_ = stateInitiator_;
+ }
}
private void buildPartialOneofs(com.google.cloud.tpu.v2alpha1.QueuedResourceState result) {
@@ -5120,6 +5340,9 @@ public Builder mergeFrom(com.google.cloud.tpu.v2alpha1.QueuedResourceState other
if (other.state_ != 0) {
setStateValue(other.getStateValue());
}
+ if (other.stateInitiator_ != 0) {
+ setStateInitiatorValue(other.getStateInitiatorValue());
+ }
switch (other.getStateDataCase()) {
case CREATING_DATA:
{
@@ -5247,6 +5470,12 @@ public Builder mergeFrom(
stateDataCase_ = 9;
break;
} // case 74
+ case 80:
+ {
+ stateInitiator_ = input.readEnum();
+ bitField0_ |= 0x00000200;
+ break;
+ } // case 80
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -7128,6 +7357,110 @@ public Builder clearSuspendedData() {
return suspendedDataBuilder_;
}
+ private int stateInitiator_ = 0;
+ /**
+ *
+ *
+ * + * Output only. The initiator of the QueuedResources's current state. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator state_initiator = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
+ *
+ *
+ * @return The enum numeric value on the wire for stateInitiator.
+ */
+ @java.lang.Override
+ public int getStateInitiatorValue() {
+ return stateInitiator_;
+ }
+ /**
+ *
+ *
+ * + * Output only. The initiator of the QueuedResources's current state. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator state_initiator = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
+ *
+ *
+ * @param value The enum numeric value on the wire for stateInitiator to set.
+ * @return This builder for chaining.
+ */
+ public Builder setStateInitiatorValue(int value) {
+ stateInitiator_ = value;
+ bitField0_ |= 0x00000200;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ * + * Output only. The initiator of the QueuedResources's current state. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator state_initiator = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
+ *
+ *
+ * @return The stateInitiator.
+ */
+ @java.lang.Override
+ public com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator getStateInitiator() {
+ com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator result =
+ com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator.forNumber(
+ stateInitiator_);
+ return result == null
+ ? com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator.UNRECOGNIZED
+ : result;
+ }
+ /**
+ *
+ *
+ * + * Output only. The initiator of the QueuedResources's current state. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator state_initiator = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
+ *
+ *
+ * @param value The stateInitiator to set.
+ * @return This builder for chaining.
+ */
+ public Builder setStateInitiator(
+ com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000200;
+ stateInitiator_ = value.getNumber();
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ * + * Output only. The initiator of the QueuedResources's current state. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator state_initiator = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
+ *
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearStateInitiator() {
+ bitField0_ = (bitField0_ & ~0x00000200);
+ stateInitiator_ = 0;
+ 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/QueuedResourceStateOrBuilder.java b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceStateOrBuilder.java
index 39a59795aa8e..df8643fe388b 100644
--- a/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceStateOrBuilder.java
+++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/QueuedResourceStateOrBuilder.java
@@ -337,5 +337,34 @@ public interface QueuedResourceStateOrBuilder
com.google.cloud.tpu.v2alpha1.QueuedResourceState.SuspendedDataOrBuilder
getSuspendedDataOrBuilder();
+ /**
+ *
+ *
+ * + * Output only. The initiator of the QueuedResources's current state. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator state_initiator = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
+ *
+ *
+ * @return The enum numeric value on the wire for stateInitiator.
+ */
+ int getStateInitiatorValue();
+ /**
+ *
+ *
+ * + * Output only. The initiator of the QueuedResources's current state. + *+ * + *
+ * .google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator state_initiator = 10 [(.google.api.field_behavior) = OUTPUT_ONLY];
+ *
+ *
+ * @return The stateInitiator.
+ */
+ com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateInitiator getStateInitiator();
+
com.google.cloud.tpu.v2alpha1.QueuedResourceState.StateDataCase getStateDataCase();
}
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..c22bb3ad5320
--- /dev/null
+++ b/java-tpu/proto-google-cloud-tpu-v2alpha1/src/main/java/com/google/cloud/tpu/v2alpha1/ResetQueuedResourceRequest.java
@@ -0,0 +1,641 @@
+/*
+ * Copyright 2023 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(); + } + + 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
+ * 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+ * 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 e94c32202d41..12cc0a9e1238 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) {
@@ -544,6 +558,23 @@ message QueuedResource {
// single node or multiple nodes.
// NodeSpec provides the specification for node(s) to be created.
message NodeSpec {
+ // Parameters to specify for multi-node QueuedResource requests. This
+ // field must be populated in case of multi-node requests instead of
+ // node_id. It's an error to specify both node_id and multi_node_params.
+ message MultiNodeParams {
+ // Required. Number of nodes with this spec. The system will attempt
+ // to provison "node_count" nodes as part of the request.
+ // This needs to be > 1.
+ int32 node_count = 1 [(google.api.field_behavior) = REQUIRED];
+
+ // Prefix of node_ids in case of multi-node request
+ // Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format.
+ // If node_count = 3 and node_id_prefix = "np", node ids of nodes
+ // created will be "np-0", "np-1", "np-2". If this field is not
+ // provided we use queued_resource_id as the node_id_prefix.
+ string node_id_prefix = 2;
+ }
+
// Required. The parent resource name.
string parent = 1 [
(google.api.field_behavior) = REQUIRED,
@@ -558,6 +589,10 @@ message QueuedResource {
// instead. It's an error to specify both node_id and multi_node_params.
string node_id = 2;
+ // Optional. Fields to specify in case of multi-node request.
+ MultiNodeParams multi_node_params = 6
+ [(google.api.field_behavior) = OPTIONAL];
+
// Required. The node.
Node node = 3 [(google.api.field_behavior) = REQUIRED];
}
@@ -714,6 +749,18 @@ message QueuedResourceState {
// Further data for the suspended state.
message SuspendedData {}
+ // The initiator of the QueuedResource's SUSPENDING/SUSPENDED state.
+ enum StateInitiator {
+ // The state initiator is unspecified.
+ STATE_INITIATOR_UNSPECIFIED = 0;
+
+ // The current QueuedResource state was initiated by the user.
+ USER = 1;
+
+ // The current QueuedResource state was initiated by the service.
+ SERVICE = 2;
+ }
+
// State of the QueuedResource request.
State state = 1;
@@ -743,6 +790,10 @@ message QueuedResourceState {
// Further data for the suspended state.
SuspendedData suspended_data = 9;
}
+
+ // Output only. The initiator of the QueuedResources's current state.
+ StateInitiator state_initiator = 10
+ [(google.api.field_behavior) = OUTPUT_ONLY];
}
// Request for [ListNodes][google.cloud.tpu.v2alpha1.Tpu.ListNodes].
@@ -930,6 +981,18 @@ message DeleteQueuedResourceRequest {
bool force = 3;
}
+// 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..78c224e153f6
--- /dev/null
+++ b/java-tpu/samples/snippets/generated/com/google/cloud/tpu/v2alpha1/tpu/resetqueuedresource/AsyncResetQueuedResource.java
@@ -0,0 +1,50 @@
+/*
+ * Copyright 2023 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