diff --git a/README.md b/README.md
index a943a6ca..dcdf8aae 100644
--- a/README.md
+++ b/README.md
@@ -17,7 +17,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file
com.google.cloud
libraries-bom
- 7.0.0
+ 7.0.1
pom
import
diff --git a/proto-google-cloud-tasks-v2beta2/clirr-ignored-differences.xml b/proto-google-cloud-tasks-v2beta2/clirr-ignored-differences.xml
new file mode 100644
index 00000000..25b8a3ae
--- /dev/null
+++ b/proto-google-cloud-tasks-v2beta2/clirr-ignored-differences.xml
@@ -0,0 +1,19 @@
+
+
+
+
+ 7012
+ com/google/cloud/tasks/v2beta2/*OrBuilder
+ * get*(*)
+
+
+ 7012
+ com/google/cloud/tasks/v2beta2/*OrBuilder
+ boolean contains*(*)
+
+
+ 7012
+ com/google/cloud/tasks/v2beta2/*OrBuilder
+ boolean has*(*)
+
+
\ No newline at end of file
diff --git a/proto-google-cloud-tasks-v2beta3/clirr-ignored-differences.xml b/proto-google-cloud-tasks-v2beta3/clirr-ignored-differences.xml
new file mode 100644
index 00000000..2a5fe4ff
--- /dev/null
+++ b/proto-google-cloud-tasks-v2beta3/clirr-ignored-differences.xml
@@ -0,0 +1,19 @@
+
+
+
+
+ 7012
+ com/google/cloud/tasks/v2beta3/*OrBuilder
+ * get*(*)
+
+
+ 7012
+ com/google/cloud/tasks/v2beta3/*OrBuilder
+ boolean contains*(*)
+
+
+ 7012
+ com/google/cloud/tasks/v2beta3/*OrBuilder
+ boolean has*(*)
+
+
\ No newline at end of file
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequest.java b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequest.java
index e8134928..5e8ef02f 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequest.java
+++ b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequest.java
@@ -45,10 +45,10 @@
* The [AppEngineRouting][google.cloud.tasks.v2beta3.AppEngineRouting] used to construct the URL that the task is
* delivered to can be set at the queue-level or task-level:
* * If set,
- * [app_engine_routing_override][google.cloud.tasks.v2beta3.AppEngineHttpQueue.app_engine_routing_override]
- * is used for all tasks in the queue, no matter what the setting
- * is for the
- * [task-level app_engine_routing][google.cloud.tasks.v2beta3.AppEngineHttpRequest.app_engine_routing].
+ * [app_engine_routing_override][google.cloud.tasks.v2beta3.AppEngineHttpQueue.app_engine_routing_override]
+ * is used for all tasks in the queue, no matter what the setting
+ * is for the
+ * [task-level app_engine_routing][google.cloud.tasks.v2beta3.AppEngineHttpRequest.app_engine_routing].
* The `url` that the task will be sent to is:
* * `url =` [host][google.cloud.tasks.v2beta3.AppEngineRouting.host] `+`
* [relative_uri][google.cloud.tasks.v2beta3.AppEngineHttpRequest.relative_uri]
@@ -224,14 +224,11 @@ protected com.google.protobuf.MapField internalGetMapField(int number) {
*
* The HTTP method to use for the request. The default is POST.
* The app's request handler for the task's target URL must be able to handle
- * HTTP requests with this http_method, otherwise the task attempt will fail
- * with error code 405 (Method Not Allowed). See
- * [Writing a push task request
+ * HTTP requests with this http_method, otherwise the task attempt fails with
+ * error code 405 (Method Not Allowed). See [Writing a push task request
* handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- * and the documentation for the request handlers in the language your app is
- * written in e.g.
- * [Python Request
- * Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ * and the App Engine documentation for your runtime on [How Requests are
+ * Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
*
*
* .google.cloud.tasks.v2beta3.HttpMethod http_method = 1;
@@ -248,14 +245,11 @@ public int getHttpMethodValue() {
*
* The HTTP method to use for the request. The default is POST.
* The app's request handler for the task's target URL must be able to handle
- * HTTP requests with this http_method, otherwise the task attempt will fail
- * with error code 405 (Method Not Allowed). See
- * [Writing a push task request
+ * HTTP requests with this http_method, otherwise the task attempt fails with
+ * error code 405 (Method Not Allowed). See [Writing a push task request
* handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- * and the documentation for the request handlers in the language your app is
- * written in e.g.
- * [Python Request
- * Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ * and the App Engine documentation for your runtime on [How Requests are
+ * Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
*
*
* .google.cloud.tasks.v2beta3.HttpMethod http_method = 1;
@@ -870,10 +864,10 @@ protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.Build
* The [AppEngineRouting][google.cloud.tasks.v2beta3.AppEngineRouting] used to construct the URL that the task is
* delivered to can be set at the queue-level or task-level:
* * If set,
- * [app_engine_routing_override][google.cloud.tasks.v2beta3.AppEngineHttpQueue.app_engine_routing_override]
- * is used for all tasks in the queue, no matter what the setting
- * is for the
- * [task-level app_engine_routing][google.cloud.tasks.v2beta3.AppEngineHttpRequest.app_engine_routing].
+ * [app_engine_routing_override][google.cloud.tasks.v2beta3.AppEngineHttpQueue.app_engine_routing_override]
+ * is used for all tasks in the queue, no matter what the setting
+ * is for the
+ * [task-level app_engine_routing][google.cloud.tasks.v2beta3.AppEngineHttpRequest.app_engine_routing].
* The `url` that the task will be sent to is:
* * `url =` [host][google.cloud.tasks.v2beta3.AppEngineRouting.host] `+`
* [relative_uri][google.cloud.tasks.v2beta3.AppEngineHttpRequest.relative_uri]
@@ -1111,14 +1105,11 @@ public Builder mergeFrom(
*
* The HTTP method to use for the request. The default is POST.
* The app's request handler for the task's target URL must be able to handle
- * HTTP requests with this http_method, otherwise the task attempt will fail
- * with error code 405 (Method Not Allowed). See
- * [Writing a push task request
+ * HTTP requests with this http_method, otherwise the task attempt fails with
+ * error code 405 (Method Not Allowed). See [Writing a push task request
* handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- * and the documentation for the request handlers in the language your app is
- * written in e.g.
- * [Python Request
- * Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ * and the App Engine documentation for your runtime on [How Requests are
+ * Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
*
*
* .google.cloud.tasks.v2beta3.HttpMethod http_method = 1;
@@ -1135,14 +1126,11 @@ public int getHttpMethodValue() {
*
* The HTTP method to use for the request. The default is POST.
* The app's request handler for the task's target URL must be able to handle
- * HTTP requests with this http_method, otherwise the task attempt will fail
- * with error code 405 (Method Not Allowed). See
- * [Writing a push task request
+ * HTTP requests with this http_method, otherwise the task attempt fails with
+ * error code 405 (Method Not Allowed). See [Writing a push task request
* handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- * and the documentation for the request handlers in the language your app is
- * written in e.g.
- * [Python Request
- * Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ * and the App Engine documentation for your runtime on [How Requests are
+ * Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
*
*
* .google.cloud.tasks.v2beta3.HttpMethod http_method = 1;
@@ -1162,14 +1150,11 @@ public Builder setHttpMethodValue(int value) {
*
* The HTTP method to use for the request. The default is POST.
* The app's request handler for the task's target URL must be able to handle
- * HTTP requests with this http_method, otherwise the task attempt will fail
- * with error code 405 (Method Not Allowed). See
- * [Writing a push task request
+ * HTTP requests with this http_method, otherwise the task attempt fails with
+ * error code 405 (Method Not Allowed). See [Writing a push task request
* handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- * and the documentation for the request handlers in the language your app is
- * written in e.g.
- * [Python Request
- * Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ * and the App Engine documentation for your runtime on [How Requests are
+ * Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
*
*
* .google.cloud.tasks.v2beta3.HttpMethod http_method = 1;
@@ -1189,14 +1174,11 @@ public com.google.cloud.tasks.v2beta3.HttpMethod getHttpMethod() {
*
* The HTTP method to use for the request. The default is POST.
* The app's request handler for the task's target URL must be able to handle
- * HTTP requests with this http_method, otherwise the task attempt will fail
- * with error code 405 (Method Not Allowed). See
- * [Writing a push task request
+ * HTTP requests with this http_method, otherwise the task attempt fails with
+ * error code 405 (Method Not Allowed). See [Writing a push task request
* handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- * and the documentation for the request handlers in the language your app is
- * written in e.g.
- * [Python Request
- * Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ * and the App Engine documentation for your runtime on [How Requests are
+ * Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
*
*
* .google.cloud.tasks.v2beta3.HttpMethod http_method = 1;
@@ -1219,14 +1201,11 @@ public Builder setHttpMethod(com.google.cloud.tasks.v2beta3.HttpMethod value) {
*
* The HTTP method to use for the request. The default is POST.
* The app's request handler for the task's target URL must be able to handle
- * HTTP requests with this http_method, otherwise the task attempt will fail
- * with error code 405 (Method Not Allowed). See
- * [Writing a push task request
+ * HTTP requests with this http_method, otherwise the task attempt fails with
+ * error code 405 (Method Not Allowed). See [Writing a push task request
* handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- * and the documentation for the request handlers in the language your app is
- * written in e.g.
- * [Python Request
- * Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ * and the App Engine documentation for your runtime on [How Requests are
+ * Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
*
*
* .google.cloud.tasks.v2beta3.HttpMethod http_method = 1;
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequestOrBuilder.java b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequestOrBuilder.java
index bc6bfe95..80e3b9fb 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequestOrBuilder.java
+++ b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequestOrBuilder.java
@@ -29,14 +29,11 @@ public interface AppEngineHttpRequestOrBuilder
*
* The HTTP method to use for the request. The default is POST.
* The app's request handler for the task's target URL must be able to handle
- * HTTP requests with this http_method, otherwise the task attempt will fail
- * with error code 405 (Method Not Allowed). See
- * [Writing a push task request
+ * HTTP requests with this http_method, otherwise the task attempt fails with
+ * error code 405 (Method Not Allowed). See [Writing a push task request
* handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- * and the documentation for the request handlers in the language your app is
- * written in e.g.
- * [Python Request
- * Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ * and the App Engine documentation for your runtime on [How Requests are
+ * Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
*
*
* .google.cloud.tasks.v2beta3.HttpMethod http_method = 1;
@@ -50,14 +47,11 @@ public interface AppEngineHttpRequestOrBuilder
*
* The HTTP method to use for the request. The default is POST.
* The app's request handler for the task's target URL must be able to handle
- * HTTP requests with this http_method, otherwise the task attempt will fail
- * with error code 405 (Method Not Allowed). See
- * [Writing a push task request
+ * HTTP requests with this http_method, otherwise the task attempt fails with
+ * error code 405 (Method Not Allowed). See [Writing a push task request
* handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- * and the documentation for the request handlers in the language your app is
- * written in e.g.
- * [Python Request
- * Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ * and the App Engine documentation for your runtime on [How Requests are
+ * Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
*
*
* .google.cloud.tasks.v2beta3.HttpMethod http_method = 1;
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Queue.java b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Queue.java
index 8df1e47a..c1507464 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Queue.java
+++ b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Queue.java
@@ -42,6 +42,7 @@ private Queue(com.google.protobuf.GeneratedMessageV3.Builder builder) {
private Queue() {
name_ = "";
state_ = 0;
+ type_ = 0;
}
@java.lang.Override
@@ -168,6 +169,13 @@ private Queue(
stackdriverLoggingConfig_ = subBuilder.buildPartial();
}
+ break;
+ }
+ case 88:
+ {
+ int rawValue = input.readEnum();
+
+ type_ = rawValue;
break;
}
default:
@@ -419,6 +427,163 @@ private State(int value) {
// @@protoc_insertion_point(enum_scope:google.cloud.tasks.v2beta3.Queue.State)
}
+ /**
+ *
+ *
+ *
+ * The type of the queue.
+ *
+ *
+ * Protobuf enum {@code google.cloud.tasks.v2beta3.Queue.Type}
+ */
+ public enum Type implements com.google.protobuf.ProtocolMessageEnum {
+ /**
+ *
+ *
+ *
+ * Default value.
+ *
+ *
+ * TYPE_UNSPECIFIED = 0;
+ */
+ TYPE_UNSPECIFIED(0),
+ /**
+ *
+ *
+ *
+ * A pull queue.
+ *
+ *
+ * PULL = 1;
+ */
+ PULL(1),
+ /**
+ *
+ *
+ *
+ * A push queue.
+ *
+ *
+ * PUSH = 2;
+ */
+ PUSH(2),
+ UNRECOGNIZED(-1),
+ ;
+
+ /**
+ *
+ *
+ *
+ * Default value.
+ *
+ *
+ * TYPE_UNSPECIFIED = 0;
+ */
+ public static final int TYPE_UNSPECIFIED_VALUE = 0;
+ /**
+ *
+ *
+ *
+ * A pull queue.
+ *
+ *
+ * PULL = 1;
+ */
+ public static final int PULL_VALUE = 1;
+ /**
+ *
+ *
+ *
+ * A push queue.
+ *
+ *
+ * PUSH = 2;
+ */
+ public static final int PUSH_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 Type 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 Type forNumber(int value) {
+ switch (value) {
+ case 0:
+ return TYPE_UNSPECIFIED;
+ case 1:
+ return PULL;
+ case 2:
+ return PUSH;
+ default:
+ return null;
+ }
+ }
+
+ public static com.google.protobuf.Internal.EnumLiteMap internalGetValueMap() {
+ return internalValueMap;
+ }
+
+ private static final com.google.protobuf.Internal.EnumLiteMap internalValueMap =
+ new com.google.protobuf.Internal.EnumLiteMap() {
+ public Type findValueByNumber(int number) {
+ return Type.forNumber(number);
+ }
+ };
+
+ public final com.google.protobuf.Descriptors.EnumValueDescriptor getValueDescriptor() {
+ if (this == UNRECOGNIZED) {
+ throw new java.lang.IllegalStateException(
+ "Can't get the descriptor of an unrecognized enum value.");
+ }
+ return getDescriptor().getValues().get(ordinal());
+ }
+
+ public final com.google.protobuf.Descriptors.EnumDescriptor getDescriptorForType() {
+ return getDescriptor();
+ }
+
+ public static final com.google.protobuf.Descriptors.EnumDescriptor getDescriptor() {
+ return com.google.cloud.tasks.v2beta3.Queue.getDescriptor().getEnumTypes().get(1);
+ }
+
+ private static final Type[] VALUES = values();
+
+ public static Type valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
+ if (desc.getType() != getDescriptor()) {
+ throw new java.lang.IllegalArgumentException("EnumValueDescriptor is not for this type.");
+ }
+ if (desc.getIndex() == -1) {
+ return UNRECOGNIZED;
+ }
+ return VALUES[desc.getIndex()];
+ }
+
+ private final int value;
+
+ private Type(int value) {
+ this.value = value;
+ }
+
+ // @@protoc_insertion_point(enum_scope:google.cloud.tasks.v2beta3.Queue.Type)
+ }
+
private int queueTypeCase_ = 0;
private java.lang.Object queueType_;
@@ -948,6 +1113,52 @@ public com.google.cloud.tasks.v2beta3.StackdriverLoggingConfig getStackdriverLog
return getStackdriverLoggingConfig();
}
+ public static final int TYPE_FIELD_NUMBER = 11;
+ private int type_;
+ /**
+ *
+ *
+ *
+ * Immutable. The type of a queue (push or pull).
+ * `Queue.type` is an immutable property of the queue that is set at the queue
+ * creation time. When left unspecified, the default value of `PUSH` is
+ * selected.
+ *
+ *
+ *
+ * .google.cloud.tasks.v2beta3.Queue.Type type = 11 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The enum numeric value on the wire for type.
+ */
+ @java.lang.Override
+ public int getTypeValue() {
+ return type_;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. The type of a queue (push or pull).
+ * `Queue.type` is an immutable property of the queue that is set at the queue
+ * creation time. When left unspecified, the default value of `PUSH` is
+ * selected.
+ *
+ *
+ *
+ * .google.cloud.tasks.v2beta3.Queue.Type type = 11 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The type.
+ */
+ @java.lang.Override
+ public com.google.cloud.tasks.v2beta3.Queue.Type getType() {
+ @SuppressWarnings("deprecation")
+ com.google.cloud.tasks.v2beta3.Queue.Type result =
+ com.google.cloud.tasks.v2beta3.Queue.Type.valueOf(type_);
+ return result == null ? com.google.cloud.tasks.v2beta3.Queue.Type.UNRECOGNIZED : result;
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
@@ -983,6 +1194,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
if (stackdriverLoggingConfig_ != null) {
output.writeMessage(10, getStackdriverLoggingConfig());
}
+ if (type_ != com.google.cloud.tasks.v2beta3.Queue.Type.TYPE_UNSPECIFIED.getNumber()) {
+ output.writeEnum(11, type_);
+ }
unknownFields.writeTo(output);
}
@@ -1017,6 +1231,9 @@ public int getSerializedSize() {
com.google.protobuf.CodedOutputStream.computeMessageSize(
10, getStackdriverLoggingConfig());
}
+ if (type_ != com.google.cloud.tasks.v2beta3.Queue.Type.TYPE_UNSPECIFIED.getNumber()) {
+ size += com.google.protobuf.CodedOutputStream.computeEnumSize(11, type_);
+ }
size += unknownFields.getSerializedSize();
memoizedSize = size;
return size;
@@ -1050,6 +1267,7 @@ public boolean equals(final java.lang.Object obj) {
if (hasStackdriverLoggingConfig()) {
if (!getStackdriverLoggingConfig().equals(other.getStackdriverLoggingConfig())) return false;
}
+ if (type_ != other.type_) return false;
if (!getQueueTypeCase().equals(other.getQueueTypeCase())) return false;
switch (queueTypeCase_) {
case 3:
@@ -1089,6 +1307,8 @@ public int hashCode() {
hash = (37 * hash) + STACKDRIVER_LOGGING_CONFIG_FIELD_NUMBER;
hash = (53 * hash) + getStackdriverLoggingConfig().hashCode();
}
+ hash = (37 * hash) + TYPE_FIELD_NUMBER;
+ hash = (53 * hash) + type_;
switch (queueTypeCase_) {
case 3:
hash = (37 * hash) + APP_ENGINE_HTTP_QUEUE_FIELD_NUMBER;
@@ -1271,6 +1491,8 @@ public Builder clear() {
stackdriverLoggingConfig_ = null;
stackdriverLoggingConfigBuilder_ = null;
}
+ type_ = 0;
+
queueTypeCase_ = 0;
queueType_ = null;
return this;
@@ -1328,6 +1550,7 @@ public com.google.cloud.tasks.v2beta3.Queue buildPartial() {
} else {
result.stackdriverLoggingConfig_ = stackdriverLoggingConfigBuilder_.build();
}
+ result.type_ = type_;
result.queueTypeCase_ = queueTypeCase_;
onBuilt();
return result;
@@ -1397,6 +1620,9 @@ public Builder mergeFrom(com.google.cloud.tasks.v2beta3.Queue other) {
if (other.hasStackdriverLoggingConfig()) {
mergeStackdriverLoggingConfig(other.getStackdriverLoggingConfig());
}
+ if (other.type_ != 0) {
+ setTypeValue(other.getTypeValue());
+ }
switch (other.getQueueTypeCase()) {
case APP_ENGINE_HTTP_QUEUE:
{
@@ -3054,6 +3280,122 @@ public Builder clearStackdriverLoggingConfig() {
return stackdriverLoggingConfigBuilder_;
}
+ private int type_ = 0;
+ /**
+ *
+ *
+ *
+ * Immutable. The type of a queue (push or pull).
+ * `Queue.type` is an immutable property of the queue that is set at the queue
+ * creation time. When left unspecified, the default value of `PUSH` is
+ * selected.
+ *
+ *
+ *
+ * .google.cloud.tasks.v2beta3.Queue.Type type = 11 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The enum numeric value on the wire for type.
+ */
+ @java.lang.Override
+ public int getTypeValue() {
+ return type_;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. The type of a queue (push or pull).
+ * `Queue.type` is an immutable property of the queue that is set at the queue
+ * creation time. When left unspecified, the default value of `PUSH` is
+ * selected.
+ *
+ *
+ *
+ * .google.cloud.tasks.v2beta3.Queue.Type type = 11 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @param value The enum numeric value on the wire for type to set.
+ * @return This builder for chaining.
+ */
+ public Builder setTypeValue(int value) {
+
+ type_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. The type of a queue (push or pull).
+ * `Queue.type` is an immutable property of the queue that is set at the queue
+ * creation time. When left unspecified, the default value of `PUSH` is
+ * selected.
+ *
+ *
+ *
+ * .google.cloud.tasks.v2beta3.Queue.Type type = 11 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The type.
+ */
+ @java.lang.Override
+ public com.google.cloud.tasks.v2beta3.Queue.Type getType() {
+ @SuppressWarnings("deprecation")
+ com.google.cloud.tasks.v2beta3.Queue.Type result =
+ com.google.cloud.tasks.v2beta3.Queue.Type.valueOf(type_);
+ return result == null ? com.google.cloud.tasks.v2beta3.Queue.Type.UNRECOGNIZED : result;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. The type of a queue (push or pull).
+ * `Queue.type` is an immutable property of the queue that is set at the queue
+ * creation time. When left unspecified, the default value of `PUSH` is
+ * selected.
+ *
+ *
+ *
+ * .google.cloud.tasks.v2beta3.Queue.Type type = 11 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @param value The type to set.
+ * @return This builder for chaining.
+ */
+ public Builder setType(com.google.cloud.tasks.v2beta3.Queue.Type value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ type_ = value.getNumber();
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. The type of a queue (push or pull).
+ * `Queue.type` is an immutable property of the queue that is set at the queue
+ * creation time. When left unspecified, the default value of `PUSH` is
+ * selected.
+ *
+ *
+ *
+ * .google.cloud.tasks.v2beta3.Queue.Type type = 11 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearType() {
+
+ type_ = 0;
+ onChanged();
+ return this;
+ }
+
@java.lang.Override
public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueOrBuilder.java b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueOrBuilder.java
index a8db4420..50251c2d 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueOrBuilder.java
+++ b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueOrBuilder.java
@@ -406,5 +406,40 @@ public interface QueueOrBuilder
com.google.cloud.tasks.v2beta3.StackdriverLoggingConfigOrBuilder
getStackdriverLoggingConfigOrBuilder();
+ /**
+ *
+ *
+ *
+ * Immutable. The type of a queue (push or pull).
+ * `Queue.type` is an immutable property of the queue that is set at the queue
+ * creation time. When left unspecified, the default value of `PUSH` is
+ * selected.
+ *
+ *
+ *
+ * .google.cloud.tasks.v2beta3.Queue.Type type = 11 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The enum numeric value on the wire for type.
+ */
+ int getTypeValue();
+ /**
+ *
+ *
+ *
+ * Immutable. The type of a queue (push or pull).
+ * `Queue.type` is an immutable property of the queue that is set at the queue
+ * creation time. When left unspecified, the default value of `PUSH` is
+ * selected.
+ *
+ *
+ *
+ * .google.cloud.tasks.v2beta3.Queue.Type type = 11 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The type.
+ */
+ com.google.cloud.tasks.v2beta3.Queue.Type getType();
+
public com.google.cloud.tasks.v2beta3.Queue.QueueTypeCase getQueueTypeCase();
}
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueProto.java b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueProto.java
index 200fe511..340ab7c3 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueProto.java
+++ b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueProto.java
@@ -53,44 +53,48 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
static {
java.lang.String[] descriptorData = {
"\n&google/cloud/tasks/v2beta3/queue.proto"
- + "\022\032google.cloud.tasks.v2beta3\032\031google/api"
- + "/resource.proto\032\'google/cloud/tasks/v2be"
- + "ta3/target.proto\032\036google/protobuf/durati"
- + "on.proto\032\037google/protobuf/timestamp.prot"
- + "o\032\034google/api/annotations.proto\"\327\004\n\005Queu"
- + "e\022\014\n\004name\030\001 \001(\t\022O\n\025app_engine_http_queue"
- + "\030\003 \001(\0132..google.cloud.tasks.v2beta3.AppE"
- + "ngineHttpQueueH\000\022;\n\013rate_limits\030\004 \001(\0132&."
- + "google.cloud.tasks.v2beta3.RateLimits\022=\n"
- + "\014retry_config\030\005 \001(\0132\'.google.cloud.tasks"
- + ".v2beta3.RetryConfig\0226\n\005state\030\006 \001(\0162\'.go"
- + "ogle.cloud.tasks.v2beta3.Queue.State\022.\n\n"
- + "purge_time\030\007 \001(\0132\032.google.protobuf.Times"
- + "tamp\022X\n\032stackdriver_logging_config\030\n \001(\013"
- + "24.google.cloud.tasks.v2beta3.Stackdrive"
- + "rLoggingConfig\"E\n\005State\022\025\n\021STATE_UNSPECI"
- + "FIED\020\000\022\013\n\007RUNNING\020\001\022\n\n\006PAUSED\020\002\022\014\n\010DISAB"
- + "LED\020\003:\\\352AY\n\037cloudtasks.googleapis.com/Qu"
- + "eue\0226projects/{project}/locations/{locat"
- + "ion}/queues/{queue}B\014\n\nqueue_type\"j\n\nRat"
- + "eLimits\022!\n\031max_dispatches_per_second\030\001 \001"
- + "(\001\022\026\n\016max_burst_size\030\002 \001(\005\022!\n\031max_concur"
- + "rent_dispatches\030\003 \001(\005\"\321\001\n\013RetryConfig\022\024\n"
- + "\014max_attempts\030\001 \001(\005\0225\n\022max_retry_duratio"
- + "n\030\002 \001(\0132\031.google.protobuf.Duration\022.\n\013mi"
- + "n_backoff\030\003 \001(\0132\031.google.protobuf.Durati"
- + "on\022.\n\013max_backoff\030\004 \001(\0132\031.google.protobu"
- + "f.Duration\022\025\n\rmax_doublings\030\005 \001(\005\"2\n\030Sta"
- + "ckdriverLoggingConfig\022\026\n\016sampling_ratio\030"
- + "\001 \001(\001Bo\n\036com.google.cloud.tasks.v2beta3B"
- + "\nQueueProtoP\001Z?google.golang.org/genprot"
- + "o/googleapis/cloud/tasks/v2beta3;tasksb\006"
- + "proto3"
+ + "\022\032google.cloud.tasks.v2beta3\032\037google/api"
+ + "/field_behavior.proto\032\031google/api/resour"
+ + "ce.proto\032\'google/cloud/tasks/v2beta3/tar"
+ + "get.proto\032\036google/protobuf/duration.prot"
+ + "o\032\037google/protobuf/timestamp.proto\032\034goog"
+ + "le/api/annotations.proto\"\304\005\n\005Queue\022\014\n\004na"
+ + "me\030\001 \001(\t\022O\n\025app_engine_http_queue\030\003 \001(\0132"
+ + "..google.cloud.tasks.v2beta3.AppEngineHt"
+ + "tpQueueH\000\022;\n\013rate_limits\030\004 \001(\0132&.google."
+ + "cloud.tasks.v2beta3.RateLimits\022=\n\014retry_"
+ + "config\030\005 \001(\0132\'.google.cloud.tasks.v2beta"
+ + "3.RetryConfig\0226\n\005state\030\006 \001(\0162\'.google.cl"
+ + "oud.tasks.v2beta3.Queue.State\022.\n\npurge_t"
+ + "ime\030\007 \001(\0132\032.google.protobuf.Timestamp\022X\n"
+ + "\032stackdriver_logging_config\030\n \001(\01324.goog"
+ + "le.cloud.tasks.v2beta3.StackdriverLoggin"
+ + "gConfig\0229\n\004type\030\013 \001(\0162&.google.cloud.tas"
+ + "ks.v2beta3.Queue.TypeB\003\340A\005\"E\n\005State\022\025\n\021S"
+ + "TATE_UNSPECIFIED\020\000\022\013\n\007RUNNING\020\001\022\n\n\006PAUSE"
+ + "D\020\002\022\014\n\010DISABLED\020\003\"0\n\004Type\022\024\n\020TYPE_UNSPEC"
+ + "IFIED\020\000\022\010\n\004PULL\020\001\022\010\n\004PUSH\020\002:\\\352AY\n\037cloudt"
+ + "asks.googleapis.com/Queue\0226projects/{pro"
+ + "ject}/locations/{location}/queues/{queue"
+ + "}B\014\n\nqueue_type\"j\n\nRateLimits\022!\n\031max_dis"
+ + "patches_per_second\030\001 \001(\001\022\026\n\016max_burst_si"
+ + "ze\030\002 \001(\005\022!\n\031max_concurrent_dispatches\030\003 "
+ + "\001(\005\"\321\001\n\013RetryConfig\022\024\n\014max_attempts\030\001 \001("
+ + "\005\0225\n\022max_retry_duration\030\002 \001(\0132\031.google.p"
+ + "rotobuf.Duration\022.\n\013min_backoff\030\003 \001(\0132\031."
+ + "google.protobuf.Duration\022.\n\013max_backoff\030"
+ + "\004 \001(\0132\031.google.protobuf.Duration\022\025\n\rmax_"
+ + "doublings\030\005 \001(\005\"2\n\030StackdriverLoggingCon"
+ + "fig\022\026\n\016sampling_ratio\030\001 \001(\001Bo\n\036com.googl"
+ + "e.cloud.tasks.v2beta3B\nQueueProtoP\001Z?goo"
+ + "gle.golang.org/genproto/googleapis/cloud"
+ + "/tasks/v2beta3;tasksb\006proto3"
};
descriptor =
com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
descriptorData,
new com.google.protobuf.Descriptors.FileDescriptor[] {
+ com.google.api.FieldBehaviorProto.getDescriptor(),
com.google.api.ResourceProto.getDescriptor(),
com.google.cloud.tasks.v2beta3.TargetProto.getDescriptor(),
com.google.protobuf.DurationProto.getDescriptor(),
@@ -110,6 +114,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
"State",
"PurgeTime",
"StackdriverLoggingConfig",
+ "Type",
"QueueType",
});
internal_static_google_cloud_tasks_v2beta3_RateLimits_descriptor =
@@ -138,9 +143,11 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
});
com.google.protobuf.ExtensionRegistry registry =
com.google.protobuf.ExtensionRegistry.newInstance();
+ registry.add(com.google.api.FieldBehaviorProto.fieldBehavior);
registry.add(com.google.api.ResourceProto.resource);
com.google.protobuf.Descriptors.FileDescriptor.internalUpdateFileDescriptor(
descriptor, registry);
+ com.google.api.FieldBehaviorProto.getDescriptor();
com.google.api.ResourceProto.getDescriptor();
com.google.cloud.tasks.v2beta3.TargetProto.getDescriptor();
com.google.protobuf.DurationProto.getDescriptor();
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/RetryConfig.java b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/RetryConfig.java
index d1fd0887..0a1be47f 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/RetryConfig.java
+++ b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/RetryConfig.java
@@ -431,7 +431,7 @@ public com.google.protobuf.DurationOrBuilder getMaxBackoffOrBuilder() {
* A task's retry interval starts at
* [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff], then doubles
* `max_doublings` times, then increases linearly, and finally
- * retries retries at intervals of
+ * retries at intervals of
* [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] up to
* [max_attempts][google.cloud.tasks.v2beta3.RetryConfig.max_attempts] times.
* For example, if [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff] is 10s,
@@ -1801,7 +1801,7 @@ public com.google.protobuf.DurationOrBuilder getMaxBackoffOrBuilder() {
* A task's retry interval starts at
* [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff], then doubles
* `max_doublings` times, then increases linearly, and finally
- * retries retries at intervals of
+ * retries at intervals of
* [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] up to
* [max_attempts][google.cloud.tasks.v2beta3.RetryConfig.max_attempts] times.
* For example, if [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff] is 10s,
@@ -1836,7 +1836,7 @@ public int getMaxDoublings() {
* A task's retry interval starts at
* [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff], then doubles
* `max_doublings` times, then increases linearly, and finally
- * retries retries at intervals of
+ * retries at intervals of
* [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] up to
* [max_attempts][google.cloud.tasks.v2beta3.RetryConfig.max_attempts] times.
* For example, if [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff] is 10s,
@@ -1874,7 +1874,7 @@ public Builder setMaxDoublings(int value) {
* A task's retry interval starts at
* [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff], then doubles
* `max_doublings` times, then increases linearly, and finally
- * retries retries at intervals of
+ * retries at intervals of
* [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] up to
* [max_attempts][google.cloud.tasks.v2beta3.RetryConfig.max_attempts] times.
* For example, if [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff] is 10s,
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/RetryConfigOrBuilder.java b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/RetryConfigOrBuilder.java
index ec8dfc34..29a36745 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/RetryConfigOrBuilder.java
+++ b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/RetryConfigOrBuilder.java
@@ -254,7 +254,7 @@ public interface RetryConfigOrBuilder
* A task's retry interval starts at
* [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff], then doubles
* `max_doublings` times, then increases linearly, and finally
- * retries retries at intervals of
+ * retries at intervals of
* [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] up to
* [max_attempts][google.cloud.tasks.v2beta3.RetryConfig.max_attempts] times.
* For example, if [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff] is 10s,
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Task.java b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Task.java
index 99c13283..c97c3691 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Task.java
+++ b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Task.java
@@ -773,8 +773,8 @@ public com.google.protobuf.TimestampOrBuilder getCreateTimeOrBuilder() {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -813,8 +813,8 @@ public boolean hasDispatchDeadline() {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -855,8 +855,8 @@ public com.google.protobuf.Duration getDispatchDeadline() {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -2684,8 +2684,8 @@ public com.google.protobuf.TimestampOrBuilder getCreateTimeOrBuilder() {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -2723,8 +2723,8 @@ public boolean hasDispatchDeadline() {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -2768,8 +2768,8 @@ public com.google.protobuf.Duration getDispatchDeadline() {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -2815,8 +2815,8 @@ public Builder setDispatchDeadline(com.google.protobuf.Duration value) {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -2859,8 +2859,8 @@ public Builder setDispatchDeadline(com.google.protobuf.Duration.Builder builderF
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -2910,8 +2910,8 @@ public Builder mergeDispatchDeadline(com.google.protobuf.Duration value) {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -2955,8 +2955,8 @@ public Builder clearDispatchDeadline() {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -2994,8 +2994,8 @@ public com.google.protobuf.Duration.Builder getDispatchDeadlineBuilder() {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -3037,8 +3037,8 @@ public com.google.protobuf.DurationOrBuilder getDispatchDeadlineOrBuilder() {
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskOrBuilder.java b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskOrBuilder.java
index fb07aa15..a182290d 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskOrBuilder.java
+++ b/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskOrBuilder.java
@@ -243,8 +243,8 @@ public interface TaskOrBuilder
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -280,8 +280,8 @@ public interface TaskOrBuilder
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
@@ -317,8 +317,8 @@ public interface TaskOrBuilder
* respond by this deadline then the request is cancelled and the attempt
* is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
* task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
- * Note that when the request is cancelled, Cloud Tasks will stop listing for
- * the response, but whether the worker stops processing depends on the
+ * Note that when the request is cancelled, Cloud Tasks will stop listening
+ * for the response, but whether the worker stops processing depends on the
* worker. For example, if the worker is stuck, it may not react to cancelled
* requests.
* The default and maximum values depend on the type of request:
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/cloudtasks.proto b/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/cloudtasks.proto
index 711c7a61..de3460f6 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/cloudtasks.proto
+++ b/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/cloudtasks.proto
@@ -1,4 +1,4 @@
-// Copyright 2019 Google LLC.
+// 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.
@@ -11,7 +11,6 @@
// 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.
-//
syntax = "proto3";
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/queue.proto b/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/queue.proto
index 777e9b8b..b24b7063 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/queue.proto
+++ b/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/queue.proto
@@ -1,4 +1,4 @@
-// Copyright 2019 Google LLC.
+// 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.
@@ -11,12 +11,12 @@
// 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.
-//
syntax = "proto3";
package google.cloud.tasks.v2beta3;
+import "google/api/field_behavior.proto";
import "google/api/resource.proto";
import "google/cloud/tasks/v2beta3/target.proto";
import "google/protobuf/duration.proto";
@@ -74,6 +74,18 @@ message Queue {
DISABLED = 3;
}
+ // The type of the queue.
+ enum Type {
+ // Default value.
+ TYPE_UNSPECIFIED = 0;
+
+ // A pull queue.
+ PULL = 1;
+
+ // A push queue.
+ PUSH = 2;
+ }
+
// Caller-specified and required in [CreateQueue][google.cloud.tasks.v2beta3.CloudTasks.CreateQueue],
// after which it becomes output only.
//
@@ -166,6 +178,13 @@ message Queue {
// [Stackdriver Logging](https://cloud.google.com/logging/docs/). If this
// field is unset, then no logs are written.
StackdriverLoggingConfig stackdriver_logging_config = 10;
+
+ // Immutable. The type of a queue (push or pull).
+ //
+ // `Queue.type` is an immutable property of the queue that is set at the queue
+ // creation time. When left unspecified, the default value of `PUSH` is
+ // selected.
+ Type type = 11 [(google.api.field_behavior) = IMMUTABLE];
}
// Rate limits.
@@ -322,7 +341,7 @@ message RetryConfig {
// A task's retry interval starts at
// [min_backoff][google.cloud.tasks.v2beta3.RetryConfig.min_backoff], then doubles
// `max_doublings` times, then increases linearly, and finally
- // retries retries at intervals of
+ // retries at intervals of
// [max_backoff][google.cloud.tasks.v2beta3.RetryConfig.max_backoff] up to
// [max_attempts][google.cloud.tasks.v2beta3.RetryConfig.max_attempts] times.
//
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/target.proto b/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/target.proto
index 60eccf35..cc0c5cfe 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/target.proto
+++ b/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/target.proto
@@ -1,4 +1,4 @@
-// Copyright 2019 Google LLC.
+// 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.
@@ -11,7 +11,6 @@
// 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.
-//
syntax = "proto3";
@@ -182,10 +181,10 @@ message AppEngineHttpQueue {
// delivered to can be set at the queue-level or task-level:
//
// * If set,
-// [app_engine_routing_override][google.cloud.tasks.v2beta3.AppEngineHttpQueue.app_engine_routing_override]
-// is used for all tasks in the queue, no matter what the setting
-// is for the
-// [task-level app_engine_routing][google.cloud.tasks.v2beta3.AppEngineHttpRequest.app_engine_routing].
+// [app_engine_routing_override][google.cloud.tasks.v2beta3.AppEngineHttpQueue.app_engine_routing_override]
+// is used for all tasks in the queue, no matter what the setting
+// is for the
+// [task-level app_engine_routing][google.cloud.tasks.v2beta3.AppEngineHttpRequest.app_engine_routing].
//
//
// The `url` that the task will be sent to is:
@@ -218,14 +217,11 @@ message AppEngineHttpRequest {
// The HTTP method to use for the request. The default is POST.
//
// The app's request handler for the task's target URL must be able to handle
- // HTTP requests with this http_method, otherwise the task attempt will fail
- // with error code 405 (Method Not Allowed). See
- // [Writing a push task request
+ // HTTP requests with this http_method, otherwise the task attempt fails with
+ // error code 405 (Method Not Allowed). See [Writing a push task request
// handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
- // and the documentation for the request handlers in the language your app is
- // written in e.g.
- // [Python Request
- // Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
+ // and the App Engine documentation for your runtime on [How Requests are
+ // Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
HttpMethod http_method = 1;
// Task-level setting for App Engine routing.
diff --git a/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/task.proto b/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/task.proto
index 573cc850..96d552e0 100644
--- a/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/task.proto
+++ b/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/task.proto
@@ -1,4 +1,4 @@
-// Copyright 2019 Google LLC.
+// 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.
@@ -11,7 +11,6 @@
// 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.
-//
syntax = "proto3";
@@ -117,8 +116,8 @@ message Task {
// is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
// task according to the [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
//
- // Note that when the request is cancelled, Cloud Tasks will stop listing for
- // the response, but whether the worker stops processing depends on the
+ // Note that when the request is cancelled, Cloud Tasks will stop listening
+ // for the response, but whether the worker stops processing depends on the
// worker. For example, if the worker is stuck, it may not react to cancelled
// requests.
//
diff --git a/synth.metadata b/synth.metadata
index 7d34bcb5..d68154bd 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,15 +4,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-tasks.git",
- "sha": "c4a4f32b31348e57e2ebdf2bf489f17d3dc3a08d"
+ "sha": "31c1c522dbf3fb8560a78d615f4cbf57dc0a5ac0"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "923b983673af7348eb4e517d9e083a5aa69e1101",
- "internalRef": "316908733"
+ "sha": "eb37e688331443969eed9b969531751154a956d5",
+ "internalRef": "317130948"
}
},
{