From 0f0f67a90e81065718f30a84b91e8f5f2fcba957 Mon Sep 17 00:00:00 2001 From: yoshi-automation Date: Sat, 26 Jan 2019 00:48:51 -0800 Subject: [PATCH] Regenerate tasks client --- .../tasks/v2beta3/AppEngineHttpRequest.java | 24 + .../cloud/tasks/v2beta3/AppEngineRouting.java | 20 +- .../google/cloud/tasks/v2beta3/Attempt.java | 24 +- .../cloud/tasks/v2beta3/AttemptOrBuilder.java | 6 +- .../cloud/tasks/v2beta3/HttpMethod.java | 44 ++ .../com/google/cloud/tasks/v2beta3/Queue.java | 244 +++++--- .../cloud/tasks/v2beta3/QueueOrBuilder.java | 57 +- .../cloud/tasks/v2beta3/TargetProto.java | 11 +- .../com/google/cloud/tasks/v2beta3/Task.java | 589 ++++++++++++++++-- .../cloud/tasks/v2beta3/TaskOrBuilder.java | 112 +++- .../google/cloud/tasks/v2beta3/TaskProto.java | 51 +- .../google/cloud/tasks/v2beta3/queue.proto | 37 +- .../google/cloud/tasks/v2beta3/target.proto | 29 +- .../google/cloud/tasks/v2beta3/task.proto | 43 +- .../google-cloud-tasks/synth.metadata | 10 +- 15 files changed, 1047 insertions(+), 254 deletions(-) diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequest.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequest.java index adfd0c0d992a..b1db0a4dab61 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequest.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineHttpRequest.java @@ -22,6 +22,11 @@ * [How Requests are Routed](https://cloud.google.com/appengine/docs/standard/python/how-requests-are-routed) * and how routing is affected by * [dispatch files](https://cloud.google.com/appengine/docs/python/config/dispatchref). + * Traffic is encrypted during transport and never leaves Google datacenters. + * Because this traffic is carried over a communication mechanism internal to + * Google, you cannot explicitly set the protocol (for example, HTTP or HTTPS). + * The request to the handler, however, will appear to have used the HTTP + * protocol. * 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, @@ -32,6 +37,13 @@ * 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] + * Tasks can be dispatched to secure app handlers, unsecure app handlers, and + * URIs restricted with + * [`login: admin`](https://cloud.google.com/appengine/docs/standard/python/config/appref). + * Because tasks are not run as any user, they cannot be dispatched to URIs + * restricted with + * [`login: required`](https://cloud.google.com/appengine/docs/standard/python/config/appref) + * Task dispatches also do not follow redirects. * The task attempt has succeeded if the app's request handler returns * an HTTP response code in the range [`200` - `299`]. `503` is * considered an App Engine system error instead of an application @@ -790,6 +802,11 @@ protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.Build * [How Requests are Routed](https://cloud.google.com/appengine/docs/standard/python/how-requests-are-routed) * and how routing is affected by * [dispatch files](https://cloud.google.com/appengine/docs/python/config/dispatchref). + * Traffic is encrypted during transport and never leaves Google datacenters. + * Because this traffic is carried over a communication mechanism internal to + * Google, you cannot explicitly set the protocol (for example, HTTP or HTTPS). + * The request to the handler, however, will appear to have used the HTTP + * protocol. * 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, @@ -800,6 +817,13 @@ protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.Build * 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] + * Tasks can be dispatched to secure app handlers, unsecure app handlers, and + * URIs restricted with + * [`login: admin`](https://cloud.google.com/appengine/docs/standard/python/config/appref). + * Because tasks are not run as any user, they cannot be dispatched to URIs + * restricted with + * [`login: required`](https://cloud.google.com/appengine/docs/standard/python/config/appref) + * Task dispatches also do not follow redirects. * The task attempt has succeeded if the app's request handler returns * an HTTP response code in the range [`200` - `299`]. `503` is * considered an App Engine system error instead of an application diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineRouting.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineRouting.java index 1121b453c742..c5a492f23e95 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineRouting.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AppEngineRouting.java @@ -8,14 +8,8 @@ * *
  * App Engine Routing.
- * Specifies the target URI. Since this target type dispatches tasks to secure
- * app handlers, unsecure app handlers, and URIs restricted with
- * [`login: admin`](https://cloud.google.com/appengine/docs/standard/python/config/appref)
- * the protocol (for example, HTTP or HTTPS) cannot be explictly specified.
- * Task dispatches do not follow redirects and cannot target URI paths
- * restricted with
- * [`login: required`](https://cloud.google.com/appengine/docs/standard/python/config/appref)
- * because tasks are not run as any user.
+ * Defines routing characteristics specific to App Engine - service, version,
+ * and instance.
  * For more information about services, versions, and instances see
  * [An Overview of App Engine](https://cloud.google.com/appengine/docs/python/an-overview-of-app-engine),
  * [Microservices Architecture on Google App Engine](https://cloud.google.com/appengine/docs/python/microservices-on-app-engine),
@@ -572,14 +566,8 @@ protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.Build
    *
    * 
    * App Engine Routing.
-   * Specifies the target URI. Since this target type dispatches tasks to secure
-   * app handlers, unsecure app handlers, and URIs restricted with
-   * [`login: admin`](https://cloud.google.com/appengine/docs/standard/python/config/appref)
-   * the protocol (for example, HTTP or HTTPS) cannot be explictly specified.
-   * Task dispatches do not follow redirects and cannot target URI paths
-   * restricted with
-   * [`login: required`](https://cloud.google.com/appengine/docs/standard/python/config/appref)
-   * because tasks are not run as any user.
+   * Defines routing characteristics specific to App Engine - service, version,
+   * and instance.
    * For more information about services, versions, and instances see
    * [An Overview of App Engine](https://cloud.google.com/appengine/docs/python/an-overview-of-app-engine),
    * [Microservices Architecture on Google App Engine](https://cloud.google.com/appengine/docs/python/microservices-on-app-engine),
diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Attempt.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Attempt.java
index cf5f399eacfc..87ed99dc269f 100644
--- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Attempt.java
+++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Attempt.java
@@ -280,7 +280,7 @@ public com.google.protobuf.TimestampOrBuilder getResponseTimeOrBuilder() {
    *
    *
    * 
-   * Output only. The response from the target for this attempt.
+   * Output only. The response from the worker for this attempt.
    * If `response_time` is unset, then the task has not been attempted or is
    * currently running and the `response_status` field is meaningless.
    * 
@@ -294,7 +294,7 @@ public boolean hasResponseStatus() { * * *
-   * Output only. The response from the target for this attempt.
+   * Output only. The response from the worker for this attempt.
    * If `response_time` is unset, then the task has not been attempted or is
    * currently running and the `response_status` field is meaningless.
    * 
@@ -308,7 +308,7 @@ public com.google.rpc.Status getResponseStatus() { * * *
-   * Output only. The response from the target for this attempt.
+   * Output only. The response from the worker for this attempt.
    * If `response_time` is unset, then the task has not been attempted or is
    * currently running and the `response_status` field is meaningless.
    * 
@@ -1309,7 +1309,7 @@ public com.google.protobuf.TimestampOrBuilder getResponseTimeOrBuilder() { * * *
-     * Output only. The response from the target for this attempt.
+     * Output only. The response from the worker for this attempt.
      * If `response_time` is unset, then the task has not been attempted or is
      * currently running and the `response_status` field is meaningless.
      * 
@@ -1323,7 +1323,7 @@ public boolean hasResponseStatus() { * * *
-     * Output only. The response from the target for this attempt.
+     * Output only. The response from the worker for this attempt.
      * If `response_time` is unset, then the task has not been attempted or is
      * currently running and the `response_status` field is meaningless.
      * 
@@ -1343,7 +1343,7 @@ public com.google.rpc.Status getResponseStatus() { * * *
-     * Output only. The response from the target for this attempt.
+     * Output only. The response from the worker for this attempt.
      * If `response_time` is unset, then the task has not been attempted or is
      * currently running and the `response_status` field is meaningless.
      * 
@@ -1367,7 +1367,7 @@ public Builder setResponseStatus(com.google.rpc.Status value) { * * *
-     * Output only. The response from the target for this attempt.
+     * Output only. The response from the worker for this attempt.
      * If `response_time` is unset, then the task has not been attempted or is
      * currently running and the `response_status` field is meaningless.
      * 
@@ -1388,7 +1388,7 @@ public Builder setResponseStatus(com.google.rpc.Status.Builder builderForValue) * * *
-     * Output only. The response from the target for this attempt.
+     * Output only. The response from the worker for this attempt.
      * If `response_time` is unset, then the task has not been attempted or is
      * currently running and the `response_status` field is meaningless.
      * 
@@ -1414,7 +1414,7 @@ public Builder mergeResponseStatus(com.google.rpc.Status value) { * * *
-     * Output only. The response from the target for this attempt.
+     * Output only. The response from the worker for this attempt.
      * If `response_time` is unset, then the task has not been attempted or is
      * currently running and the `response_status` field is meaningless.
      * 
@@ -1436,7 +1436,7 @@ public Builder clearResponseStatus() { * * *
-     * Output only. The response from the target for this attempt.
+     * Output only. The response from the worker for this attempt.
      * If `response_time` is unset, then the task has not been attempted or is
      * currently running and the `response_status` field is meaningless.
      * 
@@ -1452,7 +1452,7 @@ public com.google.rpc.Status.Builder getResponseStatusBuilder() { * * *
-     * Output only. The response from the target for this attempt.
+     * Output only. The response from the worker for this attempt.
      * If `response_time` is unset, then the task has not been attempted or is
      * currently running and the `response_status` field is meaningless.
      * 
@@ -1472,7 +1472,7 @@ public com.google.rpc.StatusOrBuilder getResponseStatusOrBuilder() { * * *
-     * Output only. The response from the target for this attempt.
+     * Output only. The response from the worker for this attempt.
      * If `response_time` is unset, then the task has not been attempted or is
      * currently running and the `response_status` field is meaningless.
      * 
diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AttemptOrBuilder.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AttemptOrBuilder.java index 163787e92915..cd572113f6a9 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AttemptOrBuilder.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/AttemptOrBuilder.java @@ -114,7 +114,7 @@ public interface AttemptOrBuilder * * *
-   * Output only. The response from the target for this attempt.
+   * Output only. The response from the worker for this attempt.
    * If `response_time` is unset, then the task has not been attempted or is
    * currently running and the `response_status` field is meaningless.
    * 
@@ -126,7 +126,7 @@ public interface AttemptOrBuilder * * *
-   * Output only. The response from the target for this attempt.
+   * Output only. The response from the worker for this attempt.
    * If `response_time` is unset, then the task has not been attempted or is
    * currently running and the `response_status` field is meaningless.
    * 
@@ -138,7 +138,7 @@ public interface AttemptOrBuilder * * *
-   * Output only. The response from the target for this attempt.
+   * Output only. The response from the worker for this attempt.
    * If `response_time` is unset, then the task has not been attempted or is
    * currently running and the `response_status` field is meaningless.
    * 
diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/HttpMethod.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/HttpMethod.java index e51b5f95602d..cae522cc6cce 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/HttpMethod.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/HttpMethod.java @@ -73,6 +73,26 @@ public enum HttpMethod implements com.google.protobuf.ProtocolMessageEnum { * DELETE = 5; */ DELETE(5), + /** + * + * + *
+   * HTTP PATCH
+   * 
+ * + * PATCH = 6; + */ + PATCH(6), + /** + * + * + *
+   * HTTP OPTIONS
+   * 
+ * + * OPTIONS = 7; + */ + OPTIONS(7), UNRECOGNIZED(-1), ; @@ -136,6 +156,26 @@ public enum HttpMethod implements com.google.protobuf.ProtocolMessageEnum { * DELETE = 5; */ public static final int DELETE_VALUE = 5; + /** + * + * + *
+   * HTTP PATCH
+   * 
+ * + * PATCH = 6; + */ + public static final int PATCH_VALUE = 6; + /** + * + * + *
+   * HTTP OPTIONS
+   * 
+ * + * OPTIONS = 7; + */ + public static final int OPTIONS_VALUE = 7; public final int getNumber() { if (this == UNRECOGNIZED) { @@ -165,6 +205,10 @@ public static HttpMethod forNumber(int value) { return PUT; case 5: return DELETE; + case 6: + return PATCH; + case 7: + return OPTIONS; default: return null; } diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Queue.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Queue.java index f2a2da25fa21..7e6dbbc8336b 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Queue.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Queue.java @@ -221,9 +221,11 @@ public enum State implements com.google.protobuf.ProtocolMessageEnum { *
      * The queue is disabled.
      * A queue becomes `DISABLED` when
-     * [queue.yaml](https://cloud.google.com/appengine/docs/python/config/queueref) or
-     * [queue.xml](https://cloud.google.com/appengine/docs/standard/java/config/queueref) is uploaded
-     * which does not contain the queue. You cannot directly disable a queue.
+     * [queue.yaml](https://cloud.google.com/appengine/docs/python/config/queueref)
+     * or
+     * [queue.xml](https://cloud.google.com/appengine/docs/standard/java/config/queueref)
+     * is uploaded which does not contain the queue. You cannot directly disable
+     * a queue.
      * When a queue is disabled, tasks can still be added to a queue
      * but the tasks are not dispatched.
      * To permanently delete this queue and all of its tasks, call
@@ -280,9 +282,11 @@ public enum State implements com.google.protobuf.ProtocolMessageEnum {
      * 
      * The queue is disabled.
      * A queue becomes `DISABLED` when
-     * [queue.yaml](https://cloud.google.com/appengine/docs/python/config/queueref) or
-     * [queue.xml](https://cloud.google.com/appengine/docs/standard/java/config/queueref) is uploaded
-     * which does not contain the queue. You cannot directly disable a queue.
+     * [queue.yaml](https://cloud.google.com/appengine/docs/python/config/queueref)
+     * or
+     * [queue.xml](https://cloud.google.com/appengine/docs/standard/java/config/queueref)
+     * is uploaded which does not contain the queue. You cannot directly disable
+     * a queue.
      * When a queue is disabled, tasks can still be added to a queue
      * but the tasks are not dispatched.
      * To permanently delete this queue and all of its tasks, call
@@ -479,8 +483,8 @@ public com.google.protobuf.ByteString getNameBytes() {
    *
    *
    * 
-   * App Engine HTTP queue.
-   * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+   * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+   * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
    * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -492,8 +496,8 @@ public boolean hasAppEngineHttpQueue() { * * *
-   * App Engine HTTP queue.
-   * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+   * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+   * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
    * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -508,8 +512,8 @@ public com.google.cloud.tasks.v2beta3.AppEngineHttpQueue getAppEngineHttpQueue() * * *
-   * App Engine HTTP queue.
-   * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+   * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+   * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
    * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -529,10 +533,9 @@ public com.google.cloud.tasks.v2beta3.AppEngineHttpQueue getAppEngineHttpQueue() * *
    * Rate limits for task dispatches.
-   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-   * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-   * control task attempts however they control how tasks are
-   * attempted in different ways:
+   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+   * related because they both control task attempts. However they control task
+   * attempts in different ways:
    * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
    *   dispatches from a queue (i.e. all traffic dispatched from the
    *   queue, regardless of whether the dispatch is from a first
@@ -541,6 +544,14 @@ public com.google.cloud.tasks.v2beta3.AppEngineHttpQueue getAppEngineHttpQueue()
    *   particular a task after its first attempt fails. That is,
    *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
    *   second attempt, third attempt, etc).
+   * The queue's actual dispatch rate is the result of:
+   * * Number of tasks in the queue
+   * * User-specified throttling: [rate limits][Queue.RateLimits]
+   *   [retry configuration][Queue.RetryConfig], and the
+   *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+   * * System throttling due to `429` (Too Many Requests) or `503` (Service
+   *   Unavailable) responses from the worker, high error rates, or to smooth
+   *   sudden large traffic spikes.
    * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -553,10 +564,9 @@ public boolean hasRateLimits() { * *
    * Rate limits for task dispatches.
-   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-   * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-   * control task attempts however they control how tasks are
-   * attempted in different ways:
+   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+   * related because they both control task attempts. However they control task
+   * attempts in different ways:
    * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
    *   dispatches from a queue (i.e. all traffic dispatched from the
    *   queue, regardless of whether the dispatch is from a first
@@ -565,6 +575,14 @@ public boolean hasRateLimits() {
    *   particular a task after its first attempt fails. That is,
    *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
    *   second attempt, third attempt, etc).
+   * The queue's actual dispatch rate is the result of:
+   * * Number of tasks in the queue
+   * * User-specified throttling: [rate limits][Queue.RateLimits]
+   *   [retry configuration][Queue.RetryConfig], and the
+   *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+   * * System throttling due to `429` (Too Many Requests) or `503` (Service
+   *   Unavailable) responses from the worker, high error rates, or to smooth
+   *   sudden large traffic spikes.
    * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -579,10 +597,9 @@ public com.google.cloud.tasks.v2beta3.RateLimits getRateLimits() { * *
    * Rate limits for task dispatches.
-   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-   * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-   * control task attempts however they control how tasks are
-   * attempted in different ways:
+   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+   * related because they both control task attempts. However they control task
+   * attempts in different ways:
    * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
    *   dispatches from a queue (i.e. all traffic dispatched from the
    *   queue, regardless of whether the dispatch is from a first
@@ -591,6 +608,14 @@ public com.google.cloud.tasks.v2beta3.RateLimits getRateLimits() {
    *   particular a task after its first attempt fails. That is,
    *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
    *   second attempt, third attempt, etc).
+   * The queue's actual dispatch rate is the result of:
+   * * Number of tasks in the queue
+   * * User-specified throttling: [rate limits][Queue.RateLimits]
+   *   [retry configuration][Queue.RetryConfig], and the
+   *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+   * * System throttling due to `429` (Too Many Requests) or `503` (Service
+   *   Unavailable) responses from the worker, high error rates, or to smooth
+   *   sudden large traffic spikes.
    * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -1406,8 +1431,8 @@ public Builder setNameBytes(com.google.protobuf.ByteString value) { * * *
-     * App Engine HTTP queue.
-     * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+     * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+     * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
      * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -1419,8 +1444,8 @@ public boolean hasAppEngineHttpQueue() { * * *
-     * App Engine HTTP queue.
-     * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+     * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+     * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
      * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -1442,8 +1467,8 @@ public com.google.cloud.tasks.v2beta3.AppEngineHttpQueue getAppEngineHttpQueue() * * *
-     * App Engine HTTP queue.
-     * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+     * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+     * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
      * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -1465,8 +1490,8 @@ public Builder setAppEngineHttpQueue(com.google.cloud.tasks.v2beta3.AppEngineHtt * * *
-     * App Engine HTTP queue.
-     * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+     * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+     * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
      * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -1486,8 +1511,8 @@ public Builder setAppEngineHttpQueue( * * *
-     * App Engine HTTP queue.
-     * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+     * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+     * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
      * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -1520,8 +1545,8 @@ public Builder mergeAppEngineHttpQueue( * * *
-     * App Engine HTTP queue.
-     * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+     * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+     * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
      * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -1546,8 +1571,8 @@ public Builder clearAppEngineHttpQueue() { * * *
-     * App Engine HTTP queue.
-     * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+     * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+     * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
      * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -1560,8 +1585,8 @@ public Builder clearAppEngineHttpQueue() { * * *
-     * App Engine HTTP queue.
-     * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+     * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+     * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
      * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -1581,8 +1606,8 @@ public Builder clearAppEngineHttpQueue() { * * *
-     * App Engine HTTP queue.
-     * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+     * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+     * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
      * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -1623,10 +1648,9 @@ public Builder clearAppEngineHttpQueue() { * *
      * Rate limits for task dispatches.
-     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-     * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-     * control task attempts however they control how tasks are
-     * attempted in different ways:
+     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+     * related because they both control task attempts. However they control task
+     * attempts in different ways:
      * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
      *   dispatches from a queue (i.e. all traffic dispatched from the
      *   queue, regardless of whether the dispatch is from a first
@@ -1635,6 +1659,14 @@ public Builder clearAppEngineHttpQueue() {
      *   particular a task after its first attempt fails. That is,
      *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
      *   second attempt, third attempt, etc).
+     * The queue's actual dispatch rate is the result of:
+     * * Number of tasks in the queue
+     * * User-specified throttling: [rate limits][Queue.RateLimits]
+     *   [retry configuration][Queue.RetryConfig], and the
+     *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+     * * System throttling due to `429` (Too Many Requests) or `503` (Service
+     *   Unavailable) responses from the worker, high error rates, or to smooth
+     *   sudden large traffic spikes.
      * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -1647,10 +1679,9 @@ public boolean hasRateLimits() { * *
      * Rate limits for task dispatches.
-     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-     * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-     * control task attempts however they control how tasks are
-     * attempted in different ways:
+     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+     * related because they both control task attempts. However they control task
+     * attempts in different ways:
      * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
      *   dispatches from a queue (i.e. all traffic dispatched from the
      *   queue, regardless of whether the dispatch is from a first
@@ -1659,6 +1690,14 @@ public boolean hasRateLimits() {
      *   particular a task after its first attempt fails. That is,
      *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
      *   second attempt, third attempt, etc).
+     * The queue's actual dispatch rate is the result of:
+     * * Number of tasks in the queue
+     * * User-specified throttling: [rate limits][Queue.RateLimits]
+     *   [retry configuration][Queue.RetryConfig], and the
+     *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+     * * System throttling due to `429` (Too Many Requests) or `503` (Service
+     *   Unavailable) responses from the worker, high error rates, or to smooth
+     *   sudden large traffic spikes.
      * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -1677,10 +1716,9 @@ public com.google.cloud.tasks.v2beta3.RateLimits getRateLimits() { * *
      * Rate limits for task dispatches.
-     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-     * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-     * control task attempts however they control how tasks are
-     * attempted in different ways:
+     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+     * related because they both control task attempts. However they control task
+     * attempts in different ways:
      * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
      *   dispatches from a queue (i.e. all traffic dispatched from the
      *   queue, regardless of whether the dispatch is from a first
@@ -1689,6 +1727,14 @@ public com.google.cloud.tasks.v2beta3.RateLimits getRateLimits() {
      *   particular a task after its first attempt fails. That is,
      *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
      *   second attempt, third attempt, etc).
+     * The queue's actual dispatch rate is the result of:
+     * * Number of tasks in the queue
+     * * User-specified throttling: [rate limits][Queue.RateLimits]
+     *   [retry configuration][Queue.RetryConfig], and the
+     *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+     * * System throttling due to `429` (Too Many Requests) or `503` (Service
+     *   Unavailable) responses from the worker, high error rates, or to smooth
+     *   sudden large traffic spikes.
      * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -1711,10 +1757,9 @@ public Builder setRateLimits(com.google.cloud.tasks.v2beta3.RateLimits value) { * *
      * Rate limits for task dispatches.
-     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-     * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-     * control task attempts however they control how tasks are
-     * attempted in different ways:
+     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+     * related because they both control task attempts. However they control task
+     * attempts in different ways:
      * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
      *   dispatches from a queue (i.e. all traffic dispatched from the
      *   queue, regardless of whether the dispatch is from a first
@@ -1723,6 +1768,14 @@ public Builder setRateLimits(com.google.cloud.tasks.v2beta3.RateLimits value) {
      *   particular a task after its first attempt fails. That is,
      *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
      *   second attempt, third attempt, etc).
+     * The queue's actual dispatch rate is the result of:
+     * * Number of tasks in the queue
+     * * User-specified throttling: [rate limits][Queue.RateLimits]
+     *   [retry configuration][Queue.RetryConfig], and the
+     *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+     * * System throttling due to `429` (Too Many Requests) or `503` (Service
+     *   Unavailable) responses from the worker, high error rates, or to smooth
+     *   sudden large traffic spikes.
      * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -1743,10 +1796,9 @@ public Builder setRateLimits( * *
      * Rate limits for task dispatches.
-     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-     * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-     * control task attempts however they control how tasks are
-     * attempted in different ways:
+     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+     * related because they both control task attempts. However they control task
+     * attempts in different ways:
      * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
      *   dispatches from a queue (i.e. all traffic dispatched from the
      *   queue, regardless of whether the dispatch is from a first
@@ -1755,6 +1807,14 @@ public Builder setRateLimits(
      *   particular a task after its first attempt fails. That is,
      *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
      *   second attempt, third attempt, etc).
+     * The queue's actual dispatch rate is the result of:
+     * * Number of tasks in the queue
+     * * User-specified throttling: [rate limits][Queue.RateLimits]
+     *   [retry configuration][Queue.RetryConfig], and the
+     *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+     * * System throttling due to `429` (Too Many Requests) or `503` (Service
+     *   Unavailable) responses from the worker, high error rates, or to smooth
+     *   sudden large traffic spikes.
      * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -1781,10 +1841,9 @@ public Builder mergeRateLimits(com.google.cloud.tasks.v2beta3.RateLimits value) * *
      * Rate limits for task dispatches.
-     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-     * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-     * control task attempts however they control how tasks are
-     * attempted in different ways:
+     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+     * related because they both control task attempts. However they control task
+     * attempts in different ways:
      * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
      *   dispatches from a queue (i.e. all traffic dispatched from the
      *   queue, regardless of whether the dispatch is from a first
@@ -1793,6 +1852,14 @@ public Builder mergeRateLimits(com.google.cloud.tasks.v2beta3.RateLimits value)
      *   particular a task after its first attempt fails. That is,
      *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
      *   second attempt, third attempt, etc).
+     * The queue's actual dispatch rate is the result of:
+     * * Number of tasks in the queue
+     * * User-specified throttling: [rate limits][Queue.RateLimits]
+     *   [retry configuration][Queue.RetryConfig], and the
+     *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+     * * System throttling due to `429` (Too Many Requests) or `503` (Service
+     *   Unavailable) responses from the worker, high error rates, or to smooth
+     *   sudden large traffic spikes.
      * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -1813,10 +1880,9 @@ public Builder clearRateLimits() { * *
      * Rate limits for task dispatches.
-     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-     * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-     * control task attempts however they control how tasks are
-     * attempted in different ways:
+     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+     * related because they both control task attempts. However they control task
+     * attempts in different ways:
      * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
      *   dispatches from a queue (i.e. all traffic dispatched from the
      *   queue, regardless of whether the dispatch is from a first
@@ -1825,6 +1891,14 @@ public Builder clearRateLimits() {
      *   particular a task after its first attempt fails. That is,
      *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
      *   second attempt, third attempt, etc).
+     * The queue's actual dispatch rate is the result of:
+     * * Number of tasks in the queue
+     * * User-specified throttling: [rate limits][Queue.RateLimits]
+     *   [retry configuration][Queue.RetryConfig], and the
+     *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+     * * System throttling due to `429` (Too Many Requests) or `503` (Service
+     *   Unavailable) responses from the worker, high error rates, or to smooth
+     *   sudden large traffic spikes.
      * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -1839,10 +1913,9 @@ public com.google.cloud.tasks.v2beta3.RateLimits.Builder getRateLimitsBuilder() * *
      * Rate limits for task dispatches.
-     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-     * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-     * control task attempts however they control how tasks are
-     * attempted in different ways:
+     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+     * related because they both control task attempts. However they control task
+     * attempts in different ways:
      * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
      *   dispatches from a queue (i.e. all traffic dispatched from the
      *   queue, regardless of whether the dispatch is from a first
@@ -1851,6 +1924,14 @@ public com.google.cloud.tasks.v2beta3.RateLimits.Builder getRateLimitsBuilder()
      *   particular a task after its first attempt fails. That is,
      *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
      *   second attempt, third attempt, etc).
+     * The queue's actual dispatch rate is the result of:
+     * * Number of tasks in the queue
+     * * User-specified throttling: [rate limits][Queue.RateLimits]
+     *   [retry configuration][Queue.RetryConfig], and the
+     *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+     * * System throttling due to `429` (Too Many Requests) or `503` (Service
+     *   Unavailable) responses from the worker, high error rates, or to smooth
+     *   sudden large traffic spikes.
      * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -1869,10 +1950,9 @@ public com.google.cloud.tasks.v2beta3.RateLimitsOrBuilder getRateLimitsOrBuilder * *
      * Rate limits for task dispatches.
-     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-     * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-     * control task attempts however they control how tasks are
-     * attempted in different ways:
+     * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+     * related because they both control task attempts. However they control task
+     * attempts in different ways:
      * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
      *   dispatches from a queue (i.e. all traffic dispatched from the
      *   queue, regardless of whether the dispatch is from a first
@@ -1881,6 +1961,14 @@ public com.google.cloud.tasks.v2beta3.RateLimitsOrBuilder getRateLimitsOrBuilder
      *   particular a task after its first attempt fails. That is,
      *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
      *   second attempt, third attempt, etc).
+     * The queue's actual dispatch rate is the result of:
+     * * Number of tasks in the queue
+     * * User-specified throttling: [rate limits][Queue.RateLimits]
+     *   [retry configuration][Queue.RetryConfig], and the
+     *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+     * * System throttling due to `429` (Too Many Requests) or `503` (Service
+     *   Unavailable) responses from the worker, high error rates, or to smooth
+     *   sudden large traffic spikes.
      * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueOrBuilder.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueOrBuilder.java index 13288cd55ef9..8cbc8f4e289a 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueOrBuilder.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/QueueOrBuilder.java @@ -61,8 +61,8 @@ public interface QueueOrBuilder * * *
-   * App Engine HTTP queue.
-   * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+   * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+   * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
    * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -72,8 +72,8 @@ public interface QueueOrBuilder * * *
-   * App Engine HTTP queue.
-   * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+   * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+   * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
    * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -83,8 +83,8 @@ public interface QueueOrBuilder * * *
-   * App Engine HTTP queue.
-   * An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type.
+   * [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to
+   * [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue.
    * 
* * .google.cloud.tasks.v2beta3.AppEngineHttpQueue app_engine_http_queue = 3; @@ -96,10 +96,9 @@ public interface QueueOrBuilder * *
    * Rate limits for task dispatches.
-   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-   * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-   * control task attempts however they control how tasks are
-   * attempted in different ways:
+   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+   * related because they both control task attempts. However they control task
+   * attempts in different ways:
    * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
    *   dispatches from a queue (i.e. all traffic dispatched from the
    *   queue, regardless of whether the dispatch is from a first
@@ -108,6 +107,14 @@ public interface QueueOrBuilder
    *   particular a task after its first attempt fails. That is,
    *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
    *   second attempt, third attempt, etc).
+   * The queue's actual dispatch rate is the result of:
+   * * Number of tasks in the queue
+   * * User-specified throttling: [rate limits][Queue.RateLimits]
+   *   [retry configuration][Queue.RetryConfig], and the
+   *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+   * * System throttling due to `429` (Too Many Requests) or `503` (Service
+   *   Unavailable) responses from the worker, high error rates, or to smooth
+   *   sudden large traffic spikes.
    * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -118,10 +125,9 @@ public interface QueueOrBuilder * *
    * Rate limits for task dispatches.
-   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-   * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-   * control task attempts however they control how tasks are
-   * attempted in different ways:
+   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+   * related because they both control task attempts. However they control task
+   * attempts in different ways:
    * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
    *   dispatches from a queue (i.e. all traffic dispatched from the
    *   queue, regardless of whether the dispatch is from a first
@@ -130,6 +136,14 @@ public interface QueueOrBuilder
    *   particular a task after its first attempt fails. That is,
    *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
    *   second attempt, third attempt, etc).
+   * The queue's actual dispatch rate is the result of:
+   * * Number of tasks in the queue
+   * * User-specified throttling: [rate limits][Queue.RateLimits]
+   *   [retry configuration][Queue.RetryConfig], and the
+   *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+   * * System throttling due to `429` (Too Many Requests) or `503` (Service
+   *   Unavailable) responses from the worker, high error rates, or to smooth
+   *   sudden large traffic spikes.
    * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; @@ -140,10 +154,9 @@ public interface QueueOrBuilder * *
    * Rate limits for task dispatches.
-   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and
-   * [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both
-   * control task attempts however they control how tasks are
-   * attempted in different ways:
+   * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are
+   * related because they both control task attempts. However they control task
+   * attempts in different ways:
    * * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of
    *   dispatches from a queue (i.e. all traffic dispatched from the
    *   queue, regardless of whether the dispatch is from a first
@@ -152,6 +165,14 @@ public interface QueueOrBuilder
    *   particular a task after its first attempt fails. That is,
    *   [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the
    *   second attempt, third attempt, etc).
+   * The queue's actual dispatch rate is the result of:
+   * * Number of tasks in the queue
+   * * User-specified throttling: [rate limits][Queue.RateLimits]
+   *   [retry configuration][Queue.RetryConfig], and the
+   *   [queue's state][google.cloud.tasks.v2beta3.Queue.state].
+   * * System throttling due to `429` (Too Many Requests) or `503` (Service
+   *   Unavailable) responses from the worker, high error rates, or to smooth
+   *   sudden large traffic spikes.
    * 
* * .google.cloud.tasks.v2beta3.RateLimits rate_limits = 4; diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TargetProto.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TargetProto.java index e7eb5748e789..5648bc9c4cab 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TargetProto.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TargetProto.java @@ -52,12 +52,13 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "\032.\n\014HeadersEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002" + " \001(\t:\0028\001\"T\n\020AppEngineRouting\022\017\n\007service\030" + "\001 \001(\t\022\017\n\007version\030\002 \001(\t\022\020\n\010instance\030\003 \001(\t" - + "\022\014\n\004host\030\004 \001(\t*[\n\nHttpMethod\022\033\n\027HTTP_MET" + + "\022\014\n\004host\030\004 \001(\t*s\n\nHttpMethod\022\033\n\027HTTP_MET" + "HOD_UNSPECIFIED\020\000\022\010\n\004POST\020\001\022\007\n\003GET\020\002\022\010\n\004" - + "HEAD\020\003\022\007\n\003PUT\020\004\022\n\n\006DELETE\020\005Bp\n\036com.googl" - + "e.cloud.tasks.v2beta3B\013TargetProtoP\001Z?go" - + "ogle.golang.org/genproto/googleapis/clou" - + "d/tasks/v2beta3;tasksb\006proto3" + + "HEAD\020\003\022\007\n\003PUT\020\004\022\n\n\006DELETE\020\005\022\t\n\005PATCH\020\006\022\013" + + "\n\007OPTIONS\020\007Bp\n\036com.google.cloud.tasks.v2" + + "beta3B\013TargetProtoP\001Z?google.golang.org/" + + "genproto/googleapis/cloud/tasks/v2beta3;" + + "tasksb\006proto3" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Task.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Task.java index fc23cf782ecd..bb1e6a303427 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Task.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/Task.java @@ -157,6 +157,21 @@ private Task( int rawValue = input.readEnum(); view_ = rawValue; + break; + } + case 98: + { + com.google.protobuf.Duration.Builder subBuilder = null; + if (dispatchDeadline_ != null) { + subBuilder = dispatchDeadline_.toBuilder(); + } + dispatchDeadline_ = + input.readMessage(com.google.protobuf.Duration.parser(), extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(dispatchDeadline_); + dispatchDeadline_ = subBuilder.buildPartial(); + } + break; } default: @@ -476,10 +491,7 @@ public com.google.protobuf.ByteString getNameBytes() { * * *
-   * App Engine HTTP request that is sent to the task's target. Can
-   * be set only if
-   * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-   * on the queue.
+   * HTTP request that is sent to the App Engine app handler.
    * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
    * 
* @@ -492,10 +504,7 @@ public boolean hasAppEngineHttpRequest() { * * *
-   * App Engine HTTP request that is sent to the task's target. Can
-   * be set only if
-   * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-   * on the queue.
+   * HTTP request that is sent to the App Engine app handler.
    * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
    * 
* @@ -511,10 +520,7 @@ public com.google.cloud.tasks.v2beta3.AppEngineHttpRequest getAppEngineHttpReque * * *
-   * App Engine HTTP request that is sent to the task's target. Can
-   * be set only if
-   * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-   * on the queue.
+   * HTTP request that is sent to the App Engine app handler.
    * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
    * 
* @@ -617,6 +623,113 @@ public com.google.protobuf.TimestampOrBuilder getCreateTimeOrBuilder() { return getCreateTime(); } + public static final int DISPATCH_DEADLINE_FIELD_NUMBER = 12; + private com.google.protobuf.Duration dispatchDeadline_; + /** + * + * + *
+   * The deadline for requests sent to the worker. If the worker does not
+   * 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
+   * 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:
+   * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+   *   request has the default deadline. The default deadline depends on the
+   *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+   *   of the service: 10 minutes for standard apps with automatic scaling, 24
+   *   hours for standard apps with manual and basic scaling, and 60 minutes for
+   *   flex apps. If the request deadline is set, it must be in the interval [15
+   *   seconds, 24 hours 15 seconds]. Regardless of the task's
+   *   `dispatch_deadline`, the app handler will not run for longer than than
+   *   the service's timeout. We recommend setting the `dispatch_deadline` to
+   *   at most a few seconds more than the app handler's timeout. For more
+   *   information see
+   *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+   * `dispatch_deadline` will be truncated to the nearest millisecond. The
+   * deadline is an approximate deadline.
+   * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public boolean hasDispatchDeadline() { + return dispatchDeadline_ != null; + } + /** + * + * + *
+   * The deadline for requests sent to the worker. If the worker does not
+   * 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
+   * 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:
+   * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+   *   request has the default deadline. The default deadline depends on the
+   *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+   *   of the service: 10 minutes for standard apps with automatic scaling, 24
+   *   hours for standard apps with manual and basic scaling, and 60 minutes for
+   *   flex apps. If the request deadline is set, it must be in the interval [15
+   *   seconds, 24 hours 15 seconds]. Regardless of the task's
+   *   `dispatch_deadline`, the app handler will not run for longer than than
+   *   the service's timeout. We recommend setting the `dispatch_deadline` to
+   *   at most a few seconds more than the app handler's timeout. For more
+   *   information see
+   *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+   * `dispatch_deadline` will be truncated to the nearest millisecond. The
+   * deadline is an approximate deadline.
+   * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public com.google.protobuf.Duration getDispatchDeadline() { + return dispatchDeadline_ == null + ? com.google.protobuf.Duration.getDefaultInstance() + : dispatchDeadline_; + } + /** + * + * + *
+   * The deadline for requests sent to the worker. If the worker does not
+   * 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
+   * 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:
+   * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+   *   request has the default deadline. The default deadline depends on the
+   *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+   *   of the service: 10 minutes for standard apps with automatic scaling, 24
+   *   hours for standard apps with manual and basic scaling, and 60 minutes for
+   *   flex apps. If the request deadline is set, it must be in the interval [15
+   *   seconds, 24 hours 15 seconds]. Regardless of the task's
+   *   `dispatch_deadline`, the app handler will not run for longer than than
+   *   the service's timeout. We recommend setting the `dispatch_deadline` to
+   *   at most a few seconds more than the app handler's timeout. For more
+   *   information see
+   *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+   * `dispatch_deadline` will be truncated to the nearest millisecond. The
+   * deadline is an approximate deadline.
+   * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public com.google.protobuf.DurationOrBuilder getDispatchDeadlineOrBuilder() { + return getDispatchDeadline(); + } + public static final int DISPATCH_COUNT_FIELD_NUMBER = 6; private int dispatchCount_; /** @@ -810,6 +923,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io if (view_ != com.google.cloud.tasks.v2beta3.Task.View.VIEW_UNSPECIFIED.getNumber()) { output.writeEnum(10, view_); } + if (dispatchDeadline_ != null) { + output.writeMessage(12, getDispatchDeadline()); + } unknownFields.writeTo(output); } @@ -848,6 +964,9 @@ public int getSerializedSize() { if (view_ != com.google.cloud.tasks.v2beta3.Task.View.VIEW_UNSPECIFIED.getNumber()) { size += com.google.protobuf.CodedOutputStream.computeEnumSize(10, view_); } + if (dispatchDeadline_ != null) { + size += com.google.protobuf.CodedOutputStream.computeMessageSize(12, getDispatchDeadline()); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -873,6 +992,10 @@ public boolean equals(final java.lang.Object obj) { if (hasCreateTime()) { result = result && getCreateTime().equals(other.getCreateTime()); } + result = result && (hasDispatchDeadline() == other.hasDispatchDeadline()); + if (hasDispatchDeadline()) { + result = result && getDispatchDeadline().equals(other.getDispatchDeadline()); + } result = result && (getDispatchCount() == other.getDispatchCount()); result = result && (getResponseCount() == other.getResponseCount()); result = result && (hasFirstAttempt() == other.hasFirstAttempt()); @@ -914,6 +1037,10 @@ public int hashCode() { hash = (37 * hash) + CREATE_TIME_FIELD_NUMBER; hash = (53 * hash) + getCreateTime().hashCode(); } + if (hasDispatchDeadline()) { + hash = (37 * hash) + DISPATCH_DEADLINE_FIELD_NUMBER; + hash = (53 * hash) + getDispatchDeadline().hashCode(); + } hash = (37 * hash) + DISPATCH_COUNT_FIELD_NUMBER; hash = (53 * hash) + getDispatchCount(); hash = (37 * hash) + RESPONSE_COUNT_FIELD_NUMBER; @@ -1094,6 +1221,12 @@ public Builder clear() { createTime_ = null; createTimeBuilder_ = null; } + if (dispatchDeadlineBuilder_ == null) { + dispatchDeadline_ = null; + } else { + dispatchDeadline_ = null; + dispatchDeadlineBuilder_ = null; + } dispatchCount_ = 0; responseCount_ = 0; @@ -1158,6 +1291,11 @@ public com.google.cloud.tasks.v2beta3.Task buildPartial() { } else { result.createTime_ = createTimeBuilder_.build(); } + if (dispatchDeadlineBuilder_ == null) { + result.dispatchDeadline_ = dispatchDeadline_; + } else { + result.dispatchDeadline_ = dispatchDeadlineBuilder_.build(); + } result.dispatchCount_ = dispatchCount_; result.responseCount_ = responseCount_; if (firstAttemptBuilder_ == null) { @@ -1231,6 +1369,9 @@ public Builder mergeFrom(com.google.cloud.tasks.v2beta3.Task other) { if (other.hasCreateTime()) { mergeCreateTime(other.getCreateTime()); } + if (other.hasDispatchDeadline()) { + mergeDispatchDeadline(other.getDispatchDeadline()); + } if (other.getDispatchCount() != 0) { setDispatchCount(other.getDispatchCount()); } @@ -1478,10 +1619,7 @@ public Builder setNameBytes(com.google.protobuf.ByteString value) { * * *
-     * App Engine HTTP request that is sent to the task's target. Can
-     * be set only if
-     * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-     * on the queue.
+     * HTTP request that is sent to the App Engine app handler.
      * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
      * 
* @@ -1494,10 +1632,7 @@ public boolean hasAppEngineHttpRequest() { * * *
-     * App Engine HTTP request that is sent to the task's target. Can
-     * be set only if
-     * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-     * on the queue.
+     * HTTP request that is sent to the App Engine app handler.
      * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
      * 
* @@ -1520,10 +1655,7 @@ public com.google.cloud.tasks.v2beta3.AppEngineHttpRequest getAppEngineHttpReque * * *
-     * App Engine HTTP request that is sent to the task's target. Can
-     * be set only if
-     * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-     * on the queue.
+     * HTTP request that is sent to the App Engine app handler.
      * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
      * 
* @@ -1547,10 +1679,7 @@ public Builder setAppEngineHttpRequest( * * *
-     * App Engine HTTP request that is sent to the task's target. Can
-     * be set only if
-     * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-     * on the queue.
+     * HTTP request that is sent to the App Engine app handler.
      * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
      * 
* @@ -1571,10 +1700,7 @@ public Builder setAppEngineHttpRequest( * * *
-     * App Engine HTTP request that is sent to the task's target. Can
-     * be set only if
-     * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-     * on the queue.
+     * HTTP request that is sent to the App Engine app handler.
      * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
      * 
* @@ -1608,10 +1734,7 @@ public Builder mergeAppEngineHttpRequest( * * *
-     * App Engine HTTP request that is sent to the task's target. Can
-     * be set only if
-     * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-     * on the queue.
+     * HTTP request that is sent to the App Engine app handler.
      * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
      * 
* @@ -1637,10 +1760,7 @@ public Builder clearAppEngineHttpRequest() { * * *
-     * App Engine HTTP request that is sent to the task's target. Can
-     * be set only if
-     * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-     * on the queue.
+     * HTTP request that is sent to the App Engine app handler.
      * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
      * 
* @@ -1654,10 +1774,7 @@ public Builder clearAppEngineHttpRequest() { * * *
-     * App Engine HTTP request that is sent to the task's target. Can
-     * be set only if
-     * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-     * on the queue.
+     * HTTP request that is sent to the App Engine app handler.
      * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
      * 
* @@ -1678,10 +1795,7 @@ public Builder clearAppEngineHttpRequest() { * * *
-     * App Engine HTTP request that is sent to the task's target. Can
-     * be set only if
-     * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-     * on the queue.
+     * HTTP request that is sent to the App Engine app handler.
      * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
      * 
* @@ -2099,6 +2213,385 @@ public com.google.protobuf.TimestampOrBuilder getCreateTimeOrBuilder() { return createTimeBuilder_; } + private com.google.protobuf.Duration dispatchDeadline_ = null; + private com.google.protobuf.SingleFieldBuilderV3< + com.google.protobuf.Duration, + com.google.protobuf.Duration.Builder, + com.google.protobuf.DurationOrBuilder> + dispatchDeadlineBuilder_; + /** + * + * + *
+     * The deadline for requests sent to the worker. If the worker does not
+     * 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
+     * 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:
+     * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+     *   request has the default deadline. The default deadline depends on the
+     *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+     *   of the service: 10 minutes for standard apps with automatic scaling, 24
+     *   hours for standard apps with manual and basic scaling, and 60 minutes for
+     *   flex apps. If the request deadline is set, it must be in the interval [15
+     *   seconds, 24 hours 15 seconds]. Regardless of the task's
+     *   `dispatch_deadline`, the app handler will not run for longer than than
+     *   the service's timeout. We recommend setting the `dispatch_deadline` to
+     *   at most a few seconds more than the app handler's timeout. For more
+     *   information see
+     *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+     * `dispatch_deadline` will be truncated to the nearest millisecond. The
+     * deadline is an approximate deadline.
+     * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public boolean hasDispatchDeadline() { + return dispatchDeadlineBuilder_ != null || dispatchDeadline_ != null; + } + /** + * + * + *
+     * The deadline for requests sent to the worker. If the worker does not
+     * 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
+     * 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:
+     * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+     *   request has the default deadline. The default deadline depends on the
+     *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+     *   of the service: 10 minutes for standard apps with automatic scaling, 24
+     *   hours for standard apps with manual and basic scaling, and 60 minutes for
+     *   flex apps. If the request deadline is set, it must be in the interval [15
+     *   seconds, 24 hours 15 seconds]. Regardless of the task's
+     *   `dispatch_deadline`, the app handler will not run for longer than than
+     *   the service's timeout. We recommend setting the `dispatch_deadline` to
+     *   at most a few seconds more than the app handler's timeout. For more
+     *   information see
+     *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+     * `dispatch_deadline` will be truncated to the nearest millisecond. The
+     * deadline is an approximate deadline.
+     * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public com.google.protobuf.Duration getDispatchDeadline() { + if (dispatchDeadlineBuilder_ == null) { + return dispatchDeadline_ == null + ? com.google.protobuf.Duration.getDefaultInstance() + : dispatchDeadline_; + } else { + return dispatchDeadlineBuilder_.getMessage(); + } + } + /** + * + * + *
+     * The deadline for requests sent to the worker. If the worker does not
+     * 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
+     * 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:
+     * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+     *   request has the default deadline. The default deadline depends on the
+     *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+     *   of the service: 10 minutes for standard apps with automatic scaling, 24
+     *   hours for standard apps with manual and basic scaling, and 60 minutes for
+     *   flex apps. If the request deadline is set, it must be in the interval [15
+     *   seconds, 24 hours 15 seconds]. Regardless of the task's
+     *   `dispatch_deadline`, the app handler will not run for longer than than
+     *   the service's timeout. We recommend setting the `dispatch_deadline` to
+     *   at most a few seconds more than the app handler's timeout. For more
+     *   information see
+     *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+     * `dispatch_deadline` will be truncated to the nearest millisecond. The
+     * deadline is an approximate deadline.
+     * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public Builder setDispatchDeadline(com.google.protobuf.Duration value) { + if (dispatchDeadlineBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + dispatchDeadline_ = value; + onChanged(); + } else { + dispatchDeadlineBuilder_.setMessage(value); + } + + return this; + } + /** + * + * + *
+     * The deadline for requests sent to the worker. If the worker does not
+     * 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
+     * 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:
+     * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+     *   request has the default deadline. The default deadline depends on the
+     *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+     *   of the service: 10 minutes for standard apps with automatic scaling, 24
+     *   hours for standard apps with manual and basic scaling, and 60 minutes for
+     *   flex apps. If the request deadline is set, it must be in the interval [15
+     *   seconds, 24 hours 15 seconds]. Regardless of the task's
+     *   `dispatch_deadline`, the app handler will not run for longer than than
+     *   the service's timeout. We recommend setting the `dispatch_deadline` to
+     *   at most a few seconds more than the app handler's timeout. For more
+     *   information see
+     *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+     * `dispatch_deadline` will be truncated to the nearest millisecond. The
+     * deadline is an approximate deadline.
+     * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public Builder setDispatchDeadline(com.google.protobuf.Duration.Builder builderForValue) { + if (dispatchDeadlineBuilder_ == null) { + dispatchDeadline_ = builderForValue.build(); + onChanged(); + } else { + dispatchDeadlineBuilder_.setMessage(builderForValue.build()); + } + + return this; + } + /** + * + * + *
+     * The deadline for requests sent to the worker. If the worker does not
+     * 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
+     * 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:
+     * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+     *   request has the default deadline. The default deadline depends on the
+     *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+     *   of the service: 10 minutes for standard apps with automatic scaling, 24
+     *   hours for standard apps with manual and basic scaling, and 60 minutes for
+     *   flex apps. If the request deadline is set, it must be in the interval [15
+     *   seconds, 24 hours 15 seconds]. Regardless of the task's
+     *   `dispatch_deadline`, the app handler will not run for longer than than
+     *   the service's timeout. We recommend setting the `dispatch_deadline` to
+     *   at most a few seconds more than the app handler's timeout. For more
+     *   information see
+     *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+     * `dispatch_deadline` will be truncated to the nearest millisecond. The
+     * deadline is an approximate deadline.
+     * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public Builder mergeDispatchDeadline(com.google.protobuf.Duration value) { + if (dispatchDeadlineBuilder_ == null) { + if (dispatchDeadline_ != null) { + dispatchDeadline_ = + com.google.protobuf.Duration.newBuilder(dispatchDeadline_) + .mergeFrom(value) + .buildPartial(); + } else { + dispatchDeadline_ = value; + } + onChanged(); + } else { + dispatchDeadlineBuilder_.mergeFrom(value); + } + + return this; + } + /** + * + * + *
+     * The deadline for requests sent to the worker. If the worker does not
+     * 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
+     * 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:
+     * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+     *   request has the default deadline. The default deadline depends on the
+     *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+     *   of the service: 10 minutes for standard apps with automatic scaling, 24
+     *   hours for standard apps with manual and basic scaling, and 60 minutes for
+     *   flex apps. If the request deadline is set, it must be in the interval [15
+     *   seconds, 24 hours 15 seconds]. Regardless of the task's
+     *   `dispatch_deadline`, the app handler will not run for longer than than
+     *   the service's timeout. We recommend setting the `dispatch_deadline` to
+     *   at most a few seconds more than the app handler's timeout. For more
+     *   information see
+     *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+     * `dispatch_deadline` will be truncated to the nearest millisecond. The
+     * deadline is an approximate deadline.
+     * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public Builder clearDispatchDeadline() { + if (dispatchDeadlineBuilder_ == null) { + dispatchDeadline_ = null; + onChanged(); + } else { + dispatchDeadline_ = null; + dispatchDeadlineBuilder_ = null; + } + + return this; + } + /** + * + * + *
+     * The deadline for requests sent to the worker. If the worker does not
+     * 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
+     * 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:
+     * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+     *   request has the default deadline. The default deadline depends on the
+     *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+     *   of the service: 10 minutes for standard apps with automatic scaling, 24
+     *   hours for standard apps with manual and basic scaling, and 60 minutes for
+     *   flex apps. If the request deadline is set, it must be in the interval [15
+     *   seconds, 24 hours 15 seconds]. Regardless of the task's
+     *   `dispatch_deadline`, the app handler will not run for longer than than
+     *   the service's timeout. We recommend setting the `dispatch_deadline` to
+     *   at most a few seconds more than the app handler's timeout. For more
+     *   information see
+     *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+     * `dispatch_deadline` will be truncated to the nearest millisecond. The
+     * deadline is an approximate deadline.
+     * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public com.google.protobuf.Duration.Builder getDispatchDeadlineBuilder() { + + onChanged(); + return getDispatchDeadlineFieldBuilder().getBuilder(); + } + /** + * + * + *
+     * The deadline for requests sent to the worker. If the worker does not
+     * 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
+     * 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:
+     * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+     *   request has the default deadline. The default deadline depends on the
+     *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+     *   of the service: 10 minutes for standard apps with automatic scaling, 24
+     *   hours for standard apps with manual and basic scaling, and 60 minutes for
+     *   flex apps. If the request deadline is set, it must be in the interval [15
+     *   seconds, 24 hours 15 seconds]. Regardless of the task's
+     *   `dispatch_deadline`, the app handler will not run for longer than than
+     *   the service's timeout. We recommend setting the `dispatch_deadline` to
+     *   at most a few seconds more than the app handler's timeout. For more
+     *   information see
+     *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+     * `dispatch_deadline` will be truncated to the nearest millisecond. The
+     * deadline is an approximate deadline.
+     * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + public com.google.protobuf.DurationOrBuilder getDispatchDeadlineOrBuilder() { + if (dispatchDeadlineBuilder_ != null) { + return dispatchDeadlineBuilder_.getMessageOrBuilder(); + } else { + return dispatchDeadline_ == null + ? com.google.protobuf.Duration.getDefaultInstance() + : dispatchDeadline_; + } + } + /** + * + * + *
+     * The deadline for requests sent to the worker. If the worker does not
+     * 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
+     * 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:
+     * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+     *   request has the default deadline. The default deadline depends on the
+     *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+     *   of the service: 10 minutes for standard apps with automatic scaling, 24
+     *   hours for standard apps with manual and basic scaling, and 60 minutes for
+     *   flex apps. If the request deadline is set, it must be in the interval [15
+     *   seconds, 24 hours 15 seconds]. Regardless of the task's
+     *   `dispatch_deadline`, the app handler will not run for longer than than
+     *   the service's timeout. We recommend setting the `dispatch_deadline` to
+     *   at most a few seconds more than the app handler's timeout. For more
+     *   information see
+     *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+     * `dispatch_deadline` will be truncated to the nearest millisecond. The
+     * deadline is an approximate deadline.
+     * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + private com.google.protobuf.SingleFieldBuilderV3< + com.google.protobuf.Duration, + com.google.protobuf.Duration.Builder, + com.google.protobuf.DurationOrBuilder> + getDispatchDeadlineFieldBuilder() { + if (dispatchDeadlineBuilder_ == null) { + dispatchDeadlineBuilder_ = + new com.google.protobuf.SingleFieldBuilderV3< + com.google.protobuf.Duration, + com.google.protobuf.Duration.Builder, + com.google.protobuf.DurationOrBuilder>( + getDispatchDeadline(), getParentForChildren(), isClean()); + dispatchDeadline_ = null; + } + return dispatchDeadlineBuilder_; + } + private int dispatchCount_; /** * diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskOrBuilder.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskOrBuilder.java index 1bc1624d989a..e4a3d509d648 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskOrBuilder.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskOrBuilder.java @@ -63,10 +63,7 @@ public interface TaskOrBuilder * * *
-   * App Engine HTTP request that is sent to the task's target. Can
-   * be set only if
-   * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-   * on the queue.
+   * HTTP request that is sent to the App Engine app handler.
    * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
    * 
* @@ -77,10 +74,7 @@ public interface TaskOrBuilder * * *
-   * App Engine HTTP request that is sent to the task's target. Can
-   * be set only if
-   * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-   * on the queue.
+   * HTTP request that is sent to the App Engine app handler.
    * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
    * 
* @@ -91,10 +85,7 @@ public interface TaskOrBuilder * * *
-   * App Engine HTTP request that is sent to the task's target. Can
-   * be set only if
-   * [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set
-   * on the queue.
+   * HTTP request that is sent to the App Engine app handler.
    * An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set.
    * 
* @@ -173,6 +164,103 @@ public interface TaskOrBuilder */ com.google.protobuf.TimestampOrBuilder getCreateTimeOrBuilder(); + /** + * + * + *
+   * The deadline for requests sent to the worker. If the worker does not
+   * 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
+   * 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:
+   * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+   *   request has the default deadline. The default deadline depends on the
+   *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+   *   of the service: 10 minutes for standard apps with automatic scaling, 24
+   *   hours for standard apps with manual and basic scaling, and 60 minutes for
+   *   flex apps. If the request deadline is set, it must be in the interval [15
+   *   seconds, 24 hours 15 seconds]. Regardless of the task's
+   *   `dispatch_deadline`, the app handler will not run for longer than than
+   *   the service's timeout. We recommend setting the `dispatch_deadline` to
+   *   at most a few seconds more than the app handler's timeout. For more
+   *   information see
+   *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+   * `dispatch_deadline` will be truncated to the nearest millisecond. The
+   * deadline is an approximate deadline.
+   * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + boolean hasDispatchDeadline(); + /** + * + * + *
+   * The deadline for requests sent to the worker. If the worker does not
+   * 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
+   * 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:
+   * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+   *   request has the default deadline. The default deadline depends on the
+   *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+   *   of the service: 10 minutes for standard apps with automatic scaling, 24
+   *   hours for standard apps with manual and basic scaling, and 60 minutes for
+   *   flex apps. If the request deadline is set, it must be in the interval [15
+   *   seconds, 24 hours 15 seconds]. Regardless of the task's
+   *   `dispatch_deadline`, the app handler will not run for longer than than
+   *   the service's timeout. We recommend setting the `dispatch_deadline` to
+   *   at most a few seconds more than the app handler's timeout. For more
+   *   information see
+   *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+   * `dispatch_deadline` will be truncated to the nearest millisecond. The
+   * deadline is an approximate deadline.
+   * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + com.google.protobuf.Duration getDispatchDeadline(); + /** + * + * + *
+   * The deadline for requests sent to the worker. If the worker does not
+   * 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
+   * 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:
+   * * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the
+   *   request has the default deadline. The default deadline depends on the
+   *   [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling)
+   *   of the service: 10 minutes for standard apps with automatic scaling, 24
+   *   hours for standard apps with manual and basic scaling, and 60 minutes for
+   *   flex apps. If the request deadline is set, it must be in the interval [15
+   *   seconds, 24 hours 15 seconds]. Regardless of the task's
+   *   `dispatch_deadline`, the app handler will not run for longer than than
+   *   the service's timeout. We recommend setting the `dispatch_deadline` to
+   *   at most a few seconds more than the app handler's timeout. For more
+   *   information see
+   *   [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts).
+   * `dispatch_deadline` will be truncated to the nearest millisecond. The
+   * deadline is an approximate deadline.
+   * 
+ * + * .google.protobuf.Duration dispatch_deadline = 12; + */ + com.google.protobuf.DurationOrBuilder getDispatchDeadlineOrBuilder(); + /** * * diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskProto.java b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskProto.java index fbffa013bcd0..4626a02162e9 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskProto.java +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/java/com/google/cloud/tasks/v2beta3/TaskProto.java @@ -32,29 +32,31 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "\n%google/cloud/tasks/v2beta3/task.proto\022" + "\032google.cloud.tasks.v2beta3\032\034google/api/" + "annotations.proto\032\'google/cloud/tasks/v2" - + "beta3/target.proto\032\037google/protobuf/time" - + "stamp.proto\032\027google/rpc/status.proto\"\354\003\n" - + "\004Task\022\014\n\004name\030\001 \001(\t\022S\n\027app_engine_http_r" - + "equest\030\003 \001(\01320.google.cloud.tasks.v2beta" - + "3.AppEngineHttpRequestH\000\0221\n\rschedule_tim" - + "e\030\004 \001(\0132\032.google.protobuf.Timestamp\022/\n\013c" - + "reate_time\030\005 \001(\0132\032.google.protobuf.Times" - + "tamp\022\026\n\016dispatch_count\030\006 \001(\005\022\026\n\016response" - + "_count\030\007 \001(\005\022:\n\rfirst_attempt\030\010 \001(\0132#.go" - + "ogle.cloud.tasks.v2beta3.Attempt\0229\n\014last" - + "_attempt\030\t \001(\0132#.google.cloud.tasks.v2be" - + "ta3.Attempt\0223\n\004view\030\n \001(\0162%.google.cloud" - + ".tasks.v2beta3.Task.View\"1\n\004View\022\024\n\020VIEW" - + "_UNSPECIFIED\020\000\022\t\n\005BASIC\020\001\022\010\n\004FULL\020\002B\016\n\014p" - + "ayload_type\"\317\001\n\007Attempt\0221\n\rschedule_time" - + "\030\001 \001(\0132\032.google.protobuf.Timestamp\0221\n\rdi" - + "spatch_time\030\002 \001(\0132\032.google.protobuf.Time" - + "stamp\0221\n\rresponse_time\030\003 \001(\0132\032.google.pr" - + "otobuf.Timestamp\022+\n\017response_status\030\004 \001(" - + "\0132\022.google.rpc.StatusBn\n\036com.google.clou" - + "d.tasks.v2beta3B\tTaskProtoP\001Z?google.gol" - + "ang.org/genproto/googleapis/cloud/tasks/" - + "v2beta3;tasksb\006proto3" + + "beta3/target.proto\032\036google/protobuf/dura" + + "tion.proto\032\037google/protobuf/timestamp.pr" + + "oto\032\027google/rpc/status.proto\"\242\004\n\004Task\022\014\n" + + "\004name\030\001 \001(\t\022S\n\027app_engine_http_request\030\003" + + " \001(\01320.google.cloud.tasks.v2beta3.AppEng" + + "ineHttpRequestH\000\0221\n\rschedule_time\030\004 \001(\0132" + + "\032.google.protobuf.Timestamp\022/\n\013create_ti" + + "me\030\005 \001(\0132\032.google.protobuf.Timestamp\0224\n\021" + + "dispatch_deadline\030\014 \001(\0132\031.google.protobu" + + "f.Duration\022\026\n\016dispatch_count\030\006 \001(\005\022\026\n\016re" + + "sponse_count\030\007 \001(\005\022:\n\rfirst_attempt\030\010 \001(" + + "\0132#.google.cloud.tasks.v2beta3.Attempt\0229" + + "\n\014last_attempt\030\t \001(\0132#.google.cloud.task" + + "s.v2beta3.Attempt\0223\n\004view\030\n \001(\0162%.google" + + ".cloud.tasks.v2beta3.Task.View\"1\n\004View\022\024" + + "\n\020VIEW_UNSPECIFIED\020\000\022\t\n\005BASIC\020\001\022\010\n\004FULL\020" + + "\002B\016\n\014payload_type\"\317\001\n\007Attempt\0221\n\rschedul" + + "e_time\030\001 \001(\0132\032.google.protobuf.Timestamp" + + "\0221\n\rdispatch_time\030\002 \001(\0132\032.google.protobu" + + "f.Timestamp\0221\n\rresponse_time\030\003 \001(\0132\032.goo" + + "gle.protobuf.Timestamp\022+\n\017response_statu" + + "s\030\004 \001(\0132\022.google.rpc.StatusBn\n\036com.googl" + + "e.cloud.tasks.v2beta3B\tTaskProtoP\001Z?goog" + + "le.golang.org/genproto/googleapis/cloud/" + + "tasks/v2beta3;tasksb\006proto3" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { @@ -69,6 +71,7 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors( new com.google.protobuf.Descriptors.FileDescriptor[] { com.google.api.AnnotationsProto.getDescriptor(), com.google.cloud.tasks.v2beta3.TargetProto.getDescriptor(), + com.google.protobuf.DurationProto.getDescriptor(), com.google.protobuf.TimestampProto.getDescriptor(), com.google.rpc.StatusProto.getDescriptor(), }, @@ -83,6 +86,7 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors( "AppEngineHttpRequest", "ScheduleTime", "CreateTime", + "DispatchDeadline", "DispatchCount", "ResponseCount", "FirstAttempt", @@ -100,6 +104,7 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors( }); com.google.api.AnnotationsProto.getDescriptor(); com.google.cloud.tasks.v2beta3.TargetProto.getDescriptor(); + com.google.protobuf.DurationProto.getDescriptor(); com.google.protobuf.TimestampProto.getDescriptor(); com.google.rpc.StatusProto.getDescriptor(); } diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/queue.proto b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/queue.proto index 5448e85d4fe9..4b6b92663651 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/queue.proto +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/queue.proto @@ -55,9 +55,11 @@ message Queue { // The queue is disabled. // // A queue becomes `DISABLED` when - // [queue.yaml](https://cloud.google.com/appengine/docs/python/config/queueref) or - // [queue.xml](https://cloud.google.com/appengine/docs/standard/java/config/queueref) is uploaded - // which does not contain the queue. You cannot directly disable a queue. + // [queue.yaml](https://cloud.google.com/appengine/docs/python/config/queueref) + // or + // [queue.xml](https://cloud.google.com/appengine/docs/standard/java/config/queueref) + // is uploaded which does not contain the queue. You cannot directly disable + // a queue. // // When a queue is disabled, tasks can still be added to a queue // but the tasks are not dispatched. @@ -87,26 +89,17 @@ message Queue { // hyphens (-). The maximum length is 100 characters. string name = 1; - // Caller-specified and required in [CreateQueue][google.cloud.tasks.v2beta3.CloudTasks.CreateQueue][], - // after which the queue config type becomes output only, though fields within - // the config are mutable. - // - // The queue's type. - // - // The type applies to all tasks in the queue. oneof queue_type { - // App Engine HTTP queue. - // - // An App Engine queue is a queue that has an [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] type. + // [AppEngineHttpQueue][google.cloud.tasks.v2beta3.AppEngineHttpQueue] settings apply only to + // [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest] in this queue. AppEngineHttpQueue app_engine_http_queue = 3; } // Rate limits for task dispatches. // - // [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and - // [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are related because they both - // control task attempts however they control how tasks are - // attempted in different ways: + // [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] and [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] are + // related because they both control task attempts. However they control task + // attempts in different ways: // // * [rate_limits][google.cloud.tasks.v2beta3.Queue.rate_limits] controls the total rate of // dispatches from a queue (i.e. all traffic dispatched from the @@ -116,6 +109,16 @@ message Queue { // particular a task after its first attempt fails. That is, // [retry_config][google.cloud.tasks.v2beta3.Queue.retry_config] controls task retries (the // second attempt, third attempt, etc). + // + // The queue's actual dispatch rate is the result of: + // + // * Number of tasks in the queue + // * User-specified throttling: [rate limits][Queue.RateLimits] + // [retry configuration][Queue.RetryConfig], and the + // [queue's state][google.cloud.tasks.v2beta3.Queue.state]. + // * System throttling due to `429` (Too Many Requests) or `503` (Service + // Unavailable) responses from the worker, high error rates, or to smooth + // sudden large traffic spikes. RateLimits rate_limits = 4; // Settings that determine the retry behavior. diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/target.proto b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/target.proto index 58092ed8bf30..087249f93d2c 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/target.proto +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/target.proto @@ -68,6 +68,11 @@ message AppEngineHttpQueue { // [How Requests are Routed](https://cloud.google.com/appengine/docs/standard/python/how-requests-are-routed) // and how routing is affected by // [dispatch files](https://cloud.google.com/appengine/docs/python/config/dispatchref). +// Traffic is encrypted during transport and never leaves Google datacenters. +// Because this traffic is carried over a communication mechanism internal to +// Google, you cannot explicitly set the protocol (for example, HTTP or HTTPS). +// The request to the handler, however, will appear to have used the HTTP +// protocol. // // 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: @@ -84,6 +89,14 @@ message AppEngineHttpQueue { // * `url =` [host][google.cloud.tasks.v2beta3.AppEngineRouting.host] `+` // [relative_uri][google.cloud.tasks.v2beta3.AppEngineHttpRequest.relative_uri] // +// Tasks can be dispatched to secure app handlers, unsecure app handlers, and +// URIs restricted with +// [`login: admin`](https://cloud.google.com/appengine/docs/standard/python/config/appref). +// Because tasks are not run as any user, they cannot be dispatched to URIs +// restricted with +// [`login: required`](https://cloud.google.com/appengine/docs/standard/python/config/appref) +// Task dispatches also do not follow redirects. +// // The task attempt has succeeded if the app's request handler returns // an HTTP response code in the range [`200` - `299`]. `503` is // considered an App Engine system error instead of an application @@ -171,14 +184,8 @@ message AppEngineHttpRequest { // App Engine Routing. // -// Specifies the target URI. Since this target type dispatches tasks to secure -// app handlers, unsecure app handlers, and URIs restricted with -// [`login: admin`](https://cloud.google.com/appengine/docs/standard/python/config/appref) -// the protocol (for example, HTTP or HTTPS) cannot be explictly specified. -// Task dispatches do not follow redirects and cannot target URI paths -// restricted with -// [`login: required`](https://cloud.google.com/appengine/docs/standard/python/config/appref) -// because tasks are not run as any user. +// Defines routing characteristics specific to App Engine - service, version, +// and instance. // // For more information about services, versions, and instances see // [An Overview of App Engine](https://cloud.google.com/appengine/docs/python/an-overview-of-app-engine), @@ -266,4 +273,10 @@ enum HttpMethod { // HTTP DELETE DELETE = 5; + + // HTTP PATCH + PATCH = 6; + + // HTTP OPTIONS + OPTIONS = 7; } diff --git a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/task.proto b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/task.proto index 2a7de02b9995..46026f70e62f 100644 --- a/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/task.proto +++ b/google-api-grpc/proto-google-cloud-tasks-v2beta3/src/main/proto/google/cloud/tasks/v2beta3/task.proto @@ -19,6 +19,7 @@ package google.cloud.tasks.v2beta3; import "google/api/annotations.proto"; import "google/cloud/tasks/v2beta3/target.proto"; +import "google/protobuf/duration.proto"; import "google/protobuf/timestamp.proto"; import "google/rpc/status.proto"; @@ -80,15 +81,9 @@ message Task { // hyphens (-), or underscores (_). The maximum length is 500 characters. string name = 1; - // Required. - // - // The task's payload is used by the task's target to process the task. - // A payload is valid only if it is compatible with the queue's target. + // Required. The message to send to the worker. oneof payload_type { - // App Engine HTTP request that is sent to the task's target. Can - // be set only if - // [app_engine_http_queue][google.cloud.tasks.v2beta3.Queue.app_engine_http_queue] is set - // on the queue. + // HTTP request that is sent to the App Engine app handler. // // An App Engine task is a task that has [AppEngineHttpRequest][google.cloud.tasks.v2beta3.AppEngineHttpRequest] set. AppEngineHttpRequest app_engine_http_request = 3; @@ -106,6 +101,36 @@ message Task { // `create_time` will be truncated to the nearest second. google.protobuf.Timestamp create_time = 5; + // The deadline for requests sent to the worker. If the worker does not + // 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 + // 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: + // + // + // * For [App Engine tasks][google.cloud.tasks.v2beta3.AppEngineHttpRequest], 0 indicates that the + // request has the default deadline. The default deadline depends on the + // [scaling type](https://cloud.google.com/appengine/docs/standard/go/how-instances-are-managed#instance_scaling) + // of the service: 10 minutes for standard apps with automatic scaling, 24 + // hours for standard apps with manual and basic scaling, and 60 minutes for + // flex apps. If the request deadline is set, it must be in the interval [15 + // seconds, 24 hours 15 seconds]. Regardless of the task's + // `dispatch_deadline`, the app handler will not run for longer than than + // the service's timeout. We recommend setting the `dispatch_deadline` to + // at most a few seconds more than the app handler's timeout. For more + // information see + // [Timeouts](https://cloud.google.com/tasks/docs/creating-appengine-handlers#timeouts). + // + // `dispatch_deadline` will be truncated to the nearest millisecond. The + // deadline is an approximate deadline. + google.protobuf.Duration dispatch_deadline = 12; + // Output only. The number of attempts dispatched. // // This count includes tasks which have been dispatched but haven't @@ -146,7 +171,7 @@ message Attempt { // `response_time` will be truncated to the nearest microsecond. google.protobuf.Timestamp response_time = 3; - // Output only. The response from the target for this attempt. + // Output only. The response from the worker for this attempt. // // If `response_time` is unset, then the task has not been attempted or is // currently running and the `response_status` field is meaningless. diff --git a/google-cloud-clients/google-cloud-tasks/synth.metadata b/google-cloud-clients/google-cloud-tasks/synth.metadata index cd7ae9e69070..f64d2446efe3 100644 --- a/google-cloud-clients/google-cloud-tasks/synth.metadata +++ b/google-cloud-clients/google-cloud-tasks/synth.metadata @@ -1,19 +1,19 @@ { - "updateTime": "2019-01-17T08:51:59.668739Z", + "updateTime": "2019-01-26T08:48:51.639044Z", "sources": [ { "generator": { "name": "artman", - "version": "0.16.6", - "dockerImage": "googleapis/artman@sha256:12722f2ca3fbc3b53cc6aa5f0e569d7d221b46bd876a2136497089dec5e3634e" + "version": "0.16.7", + "dockerImage": "googleapis/artman@sha256:d6c8ced606eb49973ca95d2af7c55a681acc042db0f87d135968349e7bf6dd80" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "0ac60e21a1aa86c07c1836865b35308ba8178b05", - "internalRef": "229626798" + "sha": "a6b4398490269577fc511f297b85763ba4701403", + "internalRef": "230969086" } } ],