- Resource: Queue
- HttpTarget
- UriOverride
- Scheme
- PathOverride
- QueryOverride
- UriOverrideEnforceMode
- HeaderOverride
- Header
- RateLimits
- RetryConfig
- State
- StackdriverLoggingConfig
- Methods
Resource: Queue
A queue is a container of related tasks. Queues are configured to manage how those tasks are dispatched. Configurable properties include rate limits, retry options, queue types, and others.
JSON representation |
---|
{ "name": string, "appEngineRoutingOverride": { object ( |
Fields | |
---|---|
name |
Caller-specified and required in The queue name. The queue name must have the following format:
|
appEngineRoutingOverride |
Overrides for If set, |
httpTarget |
Modifies HTTP target for HTTP tasks. |
rateLimits |
Rate limits for task dispatches.
The queue's actual dispatch rate is the result of:
|
retryConfig |
Settings that determine the retry behavior.
|
state |
Output only. The state of the queue.
|
purgeTime |
Output only. The last time this queue was purged. All tasks that were A queue can be purged using Purge time will be truncated to the nearest microsecond. Purge time will be unset if the queue has never been purged. A timestamp in RFC3339 UTC "Zulu" format, with nanosecond resolution and up to nine fractional digits. Examples: |
stackdriverLoggingConfig |
Configuration options for writing logs to Stackdriver Logging. If this field is unset, then no logs are written. |
HttpTarget
HTTP target.
When specified as a [Queue][target_type], all the tasks with [HttpRequest] will be overridden according to the target.
JSON representation |
---|
{ "uriOverride": { object ( |
Fields | |
---|---|
uriOverride |
URI override. When specified, overrides the execution URI for all the tasks in the queue. |
httpMethod |
The HTTP method to use for the request. When specified, it overrides |
headerOverrides[] |
HTTP target headers. This map contains the header field names and values. Headers will be set when running the These headers represent a subset of the headers that will be configured for the task's HTTP request. Some HTTP request headers will be ignored or replaced. A partial list of headers that will be ignored or replaced is: * Several predefined headers, prefixed with "X-CloudTasks-", can be used to define properties of the task. * Host: This will be computed by Cloud Tasks and derived from [HttpRequest.url][google.cloud.tasks.v2.Target.HttpRequest.url]. * Content-Length: This will be computed by Cloud Tasks.
Headers which can have multiple values (according to RFC2616) can be specified using comma-separated values. The size of the headers must be less than 80KB. Queue-level headers to override headers of all the tasks in the queue. Do not put business sensitive or personally identifying data in the HTTP Header Override Configuration or other similar fields in accordance with Section 12 (Resource Fields) of the Service Specific Terms. |
Union field If specified, all |
|
oauthToken |
If specified, an OAuth token is generated and attached as the This type of authorization should generally be used only when calling Google APIs hosted on *.googleapis.com. Note that both the service account email and the scope MUST be specified when using the queue-level authorization override. |
oidcToken |
If specified, an OIDC token is generated and attached as an This type of authorization can be used for many scenarios, including calling Cloud Run, or endpoints where you intend to validate the token yourself. Note that both the service account email and the audience MUST be specified when using the queue-level authorization override. |
UriOverride
URI Override.
When specified, all the HTTP tasks inside the queue will be partially or fully overridden depending on the configured values.
JSON representation |
---|
{ "pathOverride": { object ( |
Fields | |
---|---|
pathOverride |
URI path. When specified, replaces the existing path of the task URL. Setting the path value to an empty string clears the URI path segment. |
queryOverride |
URI query. When specified, replaces the query part of the task URI. Setting the query value to an empty string clears the URI query segment. |
uriOverrideEnforceMode |
URI Override Enforce Mode When specified, determines the Target UriOverride mode. If not specified, it defaults to ALWAYS. |
scheme |
Scheme override. When specified, the task URI scheme is replaced by the provided value (HTTP or HTTPS). |
host |
Host override. When specified, replaces the host part of the task URL. For example, if the task URL is "https://www.google.com," and host value is set to "example.net", the overridden URI will be changed to "https://example.net." Host value cannot be an empty string (INVALID_ARGUMENT). |
port |
Port override. When specified, replaces the port part of the task URI. For instance, for a URI http://www.google.com/foo and port=123, the overridden URI becomes http://www.google.com:123/foo. Note that the port value must be a positive integer. Setting the port to 0 (Zero) clears the URI port. |
Scheme
The Scheme for an HTTP request. By default, it is HTTPS.
Enums | |
---|---|
SCHEME_UNSPECIFIED |
Scheme unspecified. Defaults to HTTPS. |
HTTP |
Convert the scheme to HTTP, e.g., https://www.google.ca will change to http://www.google.ca. |
HTTPS |
Convert the scheme to HTTPS, e.g., http://www.google.ca will change to https://www.google.ca. |
PathOverride
PathOverride.
Path message defines path override for HTTP targets.
JSON representation |
---|
{ "path": string } |
Fields | |
---|---|
path |
The URI path (e.g., /users/1234). Default is an empty string. |
QueryOverride
QueryOverride.
Query message defines query override for HTTP targets.
JSON representation |
---|
{ "queryParams": string } |
Fields | |
---|---|
queryParams |
The query parameters (e.g., qparam1=123&qparam2=456). Default is an empty string. |
UriOverrideEnforceMode
UriOverrideEnforceMode defines when the URI override is enforced.
Enums | |
---|---|
URI_OVERRIDE_ENFORCE_MODE_UNSPECIFIED |
UriOverrideEnforceMode Unspecified. Defaults to ALWAYS. |
IF_NOT_EXISTS |
In the IF_NOT_EXISTS mode, queue-level configuration is only applied where task-level configuration does not exist. |
ALWAYS |
In the ALWAYS mode, queue-level configuration overrides all task-level configuration |
HeaderOverride
Wraps the Header object.
JSON representation |
---|
{
"header": {
object ( |
Fields | |
---|---|
header |
Header embodying a key and a value. Do not put business sensitive or personally identifying data in the HTTP Header Override Configuration or other similar fields in accordance with Section 12 (Resource Fields) of the Service Specific Terms. |
Header
Defines a header message. A header can have a key and a value.
JSON representation |
---|
{ "key": string, "value": string } |
Fields | |
---|---|
key |
The Key of the header. |
value |
The Value of the header. |
RateLimits
Rate limits.
This message determines the maximum rate that tasks can be dispatched by a queue, regardless of whether the dispatch is a first task attempt or a retry.
Note: The debugging command, RunTask
, will run a task even if the queue has reached its RateLimits
.
JSON representation |
---|
{ "maxDispatchesPerSecond": number, "maxBurstSize": integer, "maxConcurrentDispatches": integer } |
Fields | |
---|---|
maxDispatchesPerSecond |
The maximum rate at which tasks are dispatched from this queue. If unspecified when the queue is created, Cloud Tasks will pick the default.
This field has the same meaning as rate in queue.yaml/xml. |
maxBurstSize |
Output only. The max burst size. Max burst size limits how fast tasks in queue are processed when many tasks are in the queue and the rate is high. This field allows the queue to have a high rate so processing starts shortly after a task is enqueued, but still limits resource usage when many tasks are enqueued in a short period of time. The token bucket algorithm is used to control the rate of task dispatches. Each queue has a token bucket that holds tokens, up to the maximum specified by Cloud Tasks will pick the value of For queues that were created or updated using |
maxConcurrentDispatches |
The maximum number of concurrent tasks that Cloud Tasks allows to be dispatched for this queue. After this threshold has been reached, Cloud Tasks stops dispatching tasks until the number of concurrent requests decreases. If unspecified when the queue is created, Cloud Tasks will pick the default. The maximum allowed value is 5,000. This field has the same meaning as max_concurrent_requests in queue.yaml/xml. |
RetryConfig
Retry config.
These settings determine when a failed task attempt is retried.
JSON representation |
---|
{ "maxAttempts": integer, "maxRetryDuration": string, "minBackoff": string, "maxBackoff": string, "maxDoublings": integer } |
Fields | |
---|---|
maxAttempts |
Number of attempts per task. Cloud Tasks will attempt the task If unspecified when the queue is created, Cloud Tasks will pick the default. -1 indicates unlimited attempts. This field has the same meaning as task_retry_limit in queue.yaml/xml. |
maxRetryDuration |
If positive, If zero, then the task age is unlimited. If unspecified when the queue is created, Cloud Tasks will pick the default. The value must be given as a string that indicates the length of time (in seconds) followed by This field has the same meaning as taskAgeLimit in queue.yaml/xml. |
minBackoff |
A task will be If unspecified when the queue is created, Cloud Tasks will pick the default. The value must be given as a string that indicates the length of time (in seconds) followed by This field has the same meaning as min_backoff_seconds in queue.yaml/xml. |
maxBackoff |
A task will be If unspecified when the queue is created, Cloud Tasks will pick the default. The value must be given as a string that indicates the length of time (in seconds) followed by This field has the same meaning as max_backoff_seconds in queue.yaml/xml. |
maxDoublings |
The time between retries will double A task's retry interval starts at For example, if If unspecified when the queue is created, Cloud Tasks will pick the default. This field has the same meaning as maxDoublings in queue.yaml/xml. |
State
State of the queue.
Enums | |
---|---|
STATE_UNSPECIFIED |
Unspecified state. |
RUNNING |
The queue is running. Tasks can be dispatched. If the queue was created using Cloud Tasks and the queue has had no activity (method calls or task dispatches) for 30 days, the queue may take a few minutes to re-activate. Some method calls may return |
PAUSED |
Tasks are paused by the user. If the queue is paused then Cloud Tasks will stop delivering tasks from it, but more tasks can still be added to it by the user. |
DISABLED |
The queue is disabled. A queue becomes 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 |
StackdriverLoggingConfig
Configuration options for writing logs to Stackdriver Logging.
JSON representation |
---|
{ "samplingRatio": number } |
Fields | |
---|---|
samplingRatio |
Specifies the fraction of operations to write to Stackdriver Logging. This field may contain any value between 0.0 and 1.0, inclusive. 0.0 is the default and means that no operations are logged. |
Methods |
|
---|---|
|
Creates a queue. |
|
Deletes a queue. |
|
Gets a queue. |
|
Gets the access control policy for a Queue . |
|
Lists queues. |
|
Updates a queue. |
|
Pauses the queue. |
|
Purges a queue by deleting all of its tasks. |
|
Resume a queue. |
|
Sets the access control policy for a Queue . |
|
Returns permissions that a caller has on a Queue . |