classes.rb

# Copyright 2015 Google Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

require 'date'
require 'google/apis/core/base_service'
require 'google/apis/core/json_representation'
require 'google/apis/core/hashable'
require 'google/apis/errors'

module Google
  module Apis
    module CloudtasksV2
      
      # App Engine HTTP request. The message defines the HTTP request that is sent to
      # an App Engine app when the task is dispatched. Using AppEngineHttpRequest
      # requires [`appengine.applications.get`](https://cloud.google.com/appengine/
      # docs/admin-api/access-control) Google IAM permission for the project and the
      # following scope: `https://www.googleapis.com/auth/cloud-platform` The task
      # will be delivered to the App Engine app which belongs to the same project as
      # the queue. For more information, see [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 used to
      # construct the URL that the task is delivered to can be set at the queue-level
      # or task-level: * If app_engine_routing_override is set on the queue, this
      # value is used for all tasks in the queue, no matter what the setting is for
      # the task-level app_engine_routing. The `url` that the task will be sent to is:
      # * `url =` host `+` 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`]. The task attempt has failed if the app's handler
      # returns a non-2xx response code or Cloud Tasks does not receive response
      # before the deadline. Failed tasks will be retried according to the retry
      # configuration. `503` (Service Unavailable) is considered an App Engine system
      # error instead of an application error and will cause Cloud Tasks' traffic
      # congestion control to temporarily throttle the queue's dispatches. Unlike
      # other types of task targets, a `429` (Too Many Requests) response from an app
      # handler does not cause traffic congestion control to throttle the queue.
      class AppEngineHttpRequest
        include Google::Apis::Core::Hashable
      
        # App Engine Routing. 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), [App Engine Standard request routing](https://
        # cloud.google.com/appengine/docs/standard/python/how-requests-are-routed), and [
        # App Engine Flex request routing](https://cloud.google.com/appengine/docs/
        # flexible/python/how-requests-are-routed). Using AppEngineRouting requires [`
        # appengine.applications.get`](https://cloud.google.com/appengine/docs/admin-api/
        # access-control) Google IAM permission for the project and the following scope:
        # `https://www.googleapis.com/auth/cloud-platform`
        # Corresponds to the JSON property `appEngineRouting`
        # @return [Google::Apis::CloudtasksV2::AppEngineRouting]
        attr_accessor :app_engine_routing
      
        # HTTP request body. A request body is allowed only if the HTTP method is POST
        # or PUT. It is an error to set a body on a task with an incompatible HttpMethod.
        # Corresponds to the JSON property `body`
        # NOTE: Values are automatically base64 encoded/decoded in the client library.
        # @return [String]
        attr_accessor :body
      
        # HTTP request headers. This map contains the header field names and values.
        # Headers can be set when the task is created. Repeated headers are not
        # supported but a header value can contain commas. Cloud Tasks sets some headers
        # to default values: * `User-Agent`: By default, this header is `"AppEngine-
        # Google; (+http://code.google.com/appengine)"`. This header can be modified,
        # but Cloud Tasks will append `"AppEngine-Google; (+http://code.google.com/
        # appengine)"` to the modified `User-Agent`. If the task has a body, Cloud Tasks
        # sets the following headers: * `Content-Type`: By default, the `Content-Type`
        # header is set to `"application/octet-stream"`. The default can be overridden
        # by explicitly setting `Content-Type` to a particular media type when the task
        # is created. For example, `Content-Type` can be set to `"application/json"`. * `
        # Content-Length`: This is computed by Cloud Tasks. This value is output only.
        # It cannot be changed. The headers below cannot be set or overridden: * `Host` *
        # `X-Google-*` * `X-AppEngine-*` In addition, Cloud Tasks sets some headers
        # when the task is dispatched, such as headers containing information about the
        # task; see [request headers](https://cloud.google.com/tasks/docs/creating-
        # appengine-handlers#reading_request_headers). These headers are set only when
        # the task is dispatched, so they are not visible when the task is returned in a
        # Cloud Tasks response. Although there is no specific limit for the maximum
        # number of headers or the size, there is a limit on the maximum size of the
        # Task. For more information, see the CreateTask documentation.
        # Corresponds to the JSON property `headers`
        # @return [Hash<String,String>]
        attr_accessor :headers
      
        # The HTTP method to use for the request. The default is POST. The app's request
        # handler for the task's target URL must be able to handle HTTP requests with
        # this http_method, otherwise the task attempt fails with error code 405 (Method
        # Not Allowed). See [Writing a push task request handler](https://cloud.google.
        # com/appengine/docs/java/taskqueue/push/creating-handlers#
        # writing_a_push_task_request_handler) and the App Engine documentation for your
        # runtime on [How Requests are Handled](https://cloud.google.com/appengine/docs/
        # standard/python3/how-requests-are-handled).
        # Corresponds to the JSON property `httpMethod`
        # @return [String]
        attr_accessor :http_method
      
        # The relative URI. The relative URI must begin with "/" and must be a valid
        # HTTP relative URI. It can contain a path and query string arguments. If the
        # relative URI is empty, then the root path "/" will be used. No spaces are
        # allowed, and the maximum length allowed is 2083 characters.
        # Corresponds to the JSON property `relativeUri`
        # @return [String]
        attr_accessor :relative_uri
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @app_engine_routing = args[:app_engine_routing] if args.key?(:app_engine_routing)
          @body = args[:body] if args.key?(:body)
          @headers = args[:headers] if args.key?(:headers)
          @http_method = args[:http_method] if args.key?(:http_method)
          @relative_uri = args[:relative_uri] if args.key?(:relative_uri)
        end
      end
      
      # App Engine Routing. 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), [App Engine Standard request routing](https://
      # cloud.google.com/appengine/docs/standard/python/how-requests-are-routed), and [
      # App Engine Flex request routing](https://cloud.google.com/appengine/docs/
      # flexible/python/how-requests-are-routed). Using AppEngineRouting requires [`
      # appengine.applications.get`](https://cloud.google.com/appengine/docs/admin-api/
      # access-control) Google IAM permission for the project and the following scope:
      # `https://www.googleapis.com/auth/cloud-platform`
      class AppEngineRouting
        include Google::Apis::Core::Hashable
      
        # Output only. The host that the task is sent to. The host is constructed from
        # the domain name of the app associated with the queue's project ID (for example
        # .appspot.com), and the service, version, and instance. Tasks which were
        # created using the App Engine SDK might have a custom domain name. For more
        # information, see [How Requests are Routed](https://cloud.google.com/appengine/
        # docs/standard/python/how-requests-are-routed).
        # Corresponds to the JSON property `host`
        # @return [String]
        attr_accessor :host
      
        # App instance. By default, the task is sent to an instance which is available
        # when the task is attempted. Requests can only be sent to a specific instance
        # if [manual scaling is used in App Engine Standard](https://cloud.google.com/
        # appengine/docs/python/an-overview-of-app-engine?hl=en_US#
        # scaling_types_and_instance_classes). App Engine Flex does not support
        # instances. For more information, see [App Engine Standard request routing](
        # https://cloud.google.com/appengine/docs/standard/python/how-requests-are-
        # routed) and [App Engine Flex request routing](https://cloud.google.com/
        # appengine/docs/flexible/python/how-requests-are-routed).
        # Corresponds to the JSON property `instance`
        # @return [String]
        attr_accessor :instance
      
        # App service. By default, the task is sent to the service which is the default
        # service when the task is attempted. For some queues or tasks which were
        # created using the App Engine Task Queue API, host is not parsable into service,
        # version, and instance. For example, some tasks which were created using the
        # App Engine SDK use a custom domain name; custom domains are not parsed by
        # Cloud Tasks. If host is not parsable, then service, version, and instance are
        # the empty string.
        # Corresponds to the JSON property `service`
        # @return [String]
        attr_accessor :service
      
        # App version. By default, the task is sent to the version which is the default
        # version when the task is attempted. For some queues or tasks which were
        # created using the App Engine Task Queue API, host is not parsable into service,
        # version, and instance. For example, some tasks which were created using the
        # App Engine SDK use a custom domain name; custom domains are not parsed by
        # Cloud Tasks. If host is not parsable, then service, version, and instance are
        # the empty string.
        # Corresponds to the JSON property `version`
        # @return [String]
        attr_accessor :version
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @host = args[:host] if args.key?(:host)
          @instance = args[:instance] if args.key?(:instance)
          @service = args[:service] if args.key?(:service)
          @version = args[:version] if args.key?(:version)
        end
      end
      
      # The status of a task attempt.
      class Attempt
        include Google::Apis::Core::Hashable
      
        # Output only. The time that this attempt was dispatched. `dispatch_time` will
        # be truncated to the nearest microsecond.
        # Corresponds to the JSON property `dispatchTime`
        # @return [String]
        attr_accessor :dispatch_time
      
        # The `Status` type defines a logical error model that is suitable for different
        # programming environments, including REST APIs and RPC APIs. It is used by [
        # gRPC](https://github.com/grpc). Each `Status` message contains three pieces of
        # data: error code, error message, and error details. You can find out more
        # about this error model and how to work with it in the [API Design Guide](https:
        # //cloud.google.com/apis/design/errors).
        # Corresponds to the JSON property `responseStatus`
        # @return [Google::Apis::CloudtasksV2::Status]
        attr_accessor :response_status
      
        # Output only. The time that this attempt response was received. `response_time`
        # will be truncated to the nearest microsecond.
        # Corresponds to the JSON property `responseTime`
        # @return [String]
        attr_accessor :response_time
      
        # Output only. The time that this attempt was scheduled. `schedule_time` will be
        # truncated to the nearest microsecond.
        # Corresponds to the JSON property `scheduleTime`
        # @return [String]
        attr_accessor :schedule_time
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @dispatch_time = args[:dispatch_time] if args.key?(:dispatch_time)
          @response_status = args[:response_status] if args.key?(:response_status)
          @response_time = args[:response_time] if args.key?(:response_time)
          @schedule_time = args[:schedule_time] if args.key?(:schedule_time)
        end
      end
      
      # Associates `members` with a `role`.
      class Binding
        include Google::Apis::Core::Hashable
      
        # Represents a textual expression in the Common Expression Language (CEL) syntax.
        # CEL is a C-like expression language. The syntax and semantics of CEL are
        # documented at https://github.com/google/cel-spec. Example (Comparison): title:
        # "Summary size limit" description: "Determines if a summary is less than 100
        # chars" expression: "document.summary.size() < 100" Example (Equality): title: "
        # Requestor is owner" description: "Determines if requestor is the document
        # owner" expression: "document.owner == request.auth.claims.email" Example (
        # Logic): title: "Public documents" description: "Determine whether the document
        # should be publicly visible" expression: "document.type != 'private' &&
        # document.type != 'internal'" Example (Data Manipulation): title: "Notification
        # string" description: "Create a notification string with a timestamp."
        # expression: "'New message received at ' + string(document.create_time)" The
        # exact variables and functions that may be referenced within an expression are
        # determined by the service that evaluates it. See the service documentation for
        # additional information.
        # Corresponds to the JSON property `condition`
        # @return [Google::Apis::CloudtasksV2::Expr]
        attr_accessor :condition
      
        # Specifies the identities requesting access for a Cloud Platform resource. `
        # members` can have the following values: * `allUsers`: A special identifier
        # that represents anyone who is on the internet; with or without a Google
        # account. * `allAuthenticatedUsers`: A special identifier that represents
        # anyone who is authenticated with a Google account or a service account. * `
        # user:`emailid``: An email address that represents a specific Google account.
        # For example, `alice@example.com` . * `serviceAccount:`emailid``: An email
        # address that represents a service account. For example, `my-other-app@appspot.
        # gserviceaccount.com`. * `group:`emailid``: An email address that represents a
        # Google group. For example, `admins@example.com`. * `deleted:user:`emailid`?uid=
        # `uniqueid``: An email address (plus unique identifier) representing a user
        # that has been recently deleted. For example, `alice@example.com?uid=
        # 123456789012345678901`. If the user is recovered, this value reverts to `user:`
        # emailid`` and the recovered user retains the role in the binding. * `deleted:
        # serviceAccount:`emailid`?uid=`uniqueid``: An email address (plus unique
        # identifier) representing a service account that has been recently deleted. For
        # example, `my-other-app@appspot.gserviceaccount.com?uid=123456789012345678901`.
        # If the service account is undeleted, this value reverts to `serviceAccount:`
        # emailid`` and the undeleted service account retains the role in the binding. *
        # `deleted:group:`emailid`?uid=`uniqueid``: An email address (plus unique
        # identifier) representing a Google group that has been recently deleted. For
        # example, `admins@example.com?uid=123456789012345678901`. If the group is
        # recovered, this value reverts to `group:`emailid`` and the recovered group
        # retains the role in the binding. * `domain:`domain``: The G Suite domain (
        # primary) that represents all the users of that domain. For example, `google.
        # com` or `example.com`.
        # Corresponds to the JSON property `members`
        # @return [Array<String>]
        attr_accessor :members
      
        # Role that is assigned to `members`. For example, `roles/viewer`, `roles/editor`
        # , or `roles/owner`.
        # Corresponds to the JSON property `role`
        # @return [String]
        attr_accessor :role
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @condition = args[:condition] if args.key?(:condition)
          @members = args[:members] if args.key?(:members)
          @role = args[:role] if args.key?(:role)
        end
      end
      
      # Request message for CreateTask.
      class CreateTaskRequest
        include Google::Apis::Core::Hashable
      
        # The response_view specifies which subset of the Task will be returned. By
        # default response_view is BASIC; not all information is retrieved by default
        # because some data, such as payloads, might be desirable to return only when
        # needed because of its large size or because of the sensitivity of data that it
        # contains. Authorization for FULL requires `cloudtasks.tasks.fullView` [Google
        # IAM](https://cloud.google.com/iam/) permission on the Task resource.
        # Corresponds to the JSON property `responseView`
        # @return [String]
        attr_accessor :response_view
      
        # A unit of scheduled work.
        # Corresponds to the JSON property `task`
        # @return [Google::Apis::CloudtasksV2::Task]
        attr_accessor :task
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @response_view = args[:response_view] if args.key?(:response_view)
          @task = args[:task] if args.key?(:task)
        end
      end
      
      # A generic empty message that you can re-use to avoid defining duplicated empty
      # messages in your APIs. A typical example is to use it as the request or the
      # response type of an API method. For instance: service Foo ` rpc Bar(google.
      # protobuf.Empty) returns (google.protobuf.Empty); ` The JSON representation for
      # `Empty` is empty JSON object ````.
      class Empty
        include Google::Apis::Core::Hashable
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
        end
      end
      
      # Represents a textual expression in the Common Expression Language (CEL) syntax.
      # CEL is a C-like expression language. The syntax and semantics of CEL are
      # documented at https://github.com/google/cel-spec. Example (Comparison): title:
      # "Summary size limit" description: "Determines if a summary is less than 100
      # chars" expression: "document.summary.size() < 100" Example (Equality): title: "
      # Requestor is owner" description: "Determines if requestor is the document
      # owner" expression: "document.owner == request.auth.claims.email" Example (
      # Logic): title: "Public documents" description: "Determine whether the document
      # should be publicly visible" expression: "document.type != 'private' &&
      # document.type != 'internal'" Example (Data Manipulation): title: "Notification
      # string" description: "Create a notification string with a timestamp."
      # expression: "'New message received at ' + string(document.create_time)" The
      # exact variables and functions that may be referenced within an expression are
      # determined by the service that evaluates it. See the service documentation for
      # additional information.
      class Expr
        include Google::Apis::Core::Hashable
      
        # Optional. Description of the expression. This is a longer text which describes
        # the expression, e.g. when hovered over it in a UI.
        # Corresponds to the JSON property `description`
        # @return [String]
        attr_accessor :description
      
        # Textual representation of an expression in Common Expression Language syntax.
        # Corresponds to the JSON property `expression`
        # @return [String]
        attr_accessor :expression
      
        # Optional. String indicating the location of the expression for error reporting,
        # e.g. a file name and a position in the file.
        # Corresponds to the JSON property `location`
        # @return [String]
        attr_accessor :location
      
        # Optional. Title for the expression, i.e. a short string describing its purpose.
        # This can be used e.g. in UIs which allow to enter the expression.
        # Corresponds to the JSON property `title`
        # @return [String]
        attr_accessor :title
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @description = args[:description] if args.key?(:description)
          @expression = args[:expression] if args.key?(:expression)
          @location = args[:location] if args.key?(:location)
          @title = args[:title] if args.key?(:title)
        end
      end
      
      # Request message for `GetIamPolicy` method.
      class GetIamPolicyRequest
        include Google::Apis::Core::Hashable
      
        # Encapsulates settings provided to GetIamPolicy.
        # Corresponds to the JSON property `options`
        # @return [Google::Apis::CloudtasksV2::GetPolicyOptions]
        attr_accessor :options
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @options = args[:options] if args.key?(:options)
        end
      end
      
      # Encapsulates settings provided to GetIamPolicy.
      class GetPolicyOptions
        include Google::Apis::Core::Hashable
      
        # Optional. The policy format version to be returned. Valid values are 0, 1, and
        # 3. Requests specifying an invalid value will be rejected. Requests for
        # policies with any conditional bindings must specify version 3. Policies
        # without any conditional bindings may specify any valid value or leave the
        # field unset. To learn which resources support conditions in their IAM policies,
        # see the [IAM documentation](https://cloud.google.com/iam/help/conditions/
        # resource-policies).
        # Corresponds to the JSON property `requestedPolicyVersion`
        # @return [Fixnum]
        attr_accessor :requested_policy_version
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @requested_policy_version = args[:requested_policy_version] if args.key?(:requested_policy_version)
        end
      end
      
      # HTTP request. The task will be pushed to the worker as an HTTP request. If the
      # worker or the redirected worker acknowledges the task by returning a
      # successful HTTP response code ([`200` - `299`]), the task will be removed from
      # the queue. If any other HTTP response code is returned or no response is
      # received, the task will be retried according to the following: * User-
      # specified throttling: retry configuration, rate limits, and the queue's state.
      # * System throttling: To prevent the worker from overloading, Cloud Tasks may
      # temporarily reduce the queue's effective rate. User-specified settings will
      # not be changed. System throttling happens because: * Cloud Tasks backs off on
      # all errors. Normally the backoff specified in rate limits will be used. But if
      # the worker returns `429` (Too Many Requests), `503` (Service Unavailable), or
      # the rate of errors is high, Cloud Tasks will use a higher backoff rate. The
      # retry specified in the `Retry-After` HTTP response header is considered. * To
      # prevent traffic spikes and to smooth sudden increases in traffic, dispatches
      # ramp up slowly when the queue is newly created or idle and if large numbers of
      # tasks suddenly become available to dispatch (due to spikes in create task
      # rates, the queue being unpaused, or many tasks that are scheduled at the same
      # time).
      class HttpRequest
        include Google::Apis::Core::Hashable
      
        # HTTP request body. A request body is allowed only if the HTTP method is POST,
        # PUT, or PATCH. It is an error to set body on a task with an incompatible
        # HttpMethod.
        # Corresponds to the JSON property `body`
        # NOTE: Values are automatically base64 encoded/decoded in the client library.
        # @return [String]
        attr_accessor :body
      
        # HTTP request headers. This map contains the header field names and values.
        # Headers can be set when the task is created. These headers represent a subset
        # of the headers that will accompany 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: * Host: This will be computed by Cloud Tasks and
        # derived from HttpRequest.url. * Content-Length: This will be computed by Cloud
        # Tasks. * User-Agent: This will be set to `"Google-Cloud-Tasks"`. * X-Google-*:
        # Google use only. * X-AppEngine-*: Google use only. `Content-Type` won't be set
        # by Cloud Tasks. You can explicitly set `Content-Type` to a media type when the
        # task is created. For example, `Content-Type` can be set to `"application/octet-
        # stream"` or `"application/json"`. 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.
        # Corresponds to the JSON property `headers`
        # @return [Hash<String,String>]
        attr_accessor :headers
      
        # The HTTP method to use for the request. The default is POST.
        # Corresponds to the JSON property `httpMethod`
        # @return [String]
        attr_accessor :http_method
      
        # Contains information needed for generating an [OAuth token](https://developers.
        # google.com/identity/protocols/OAuth2). This type of authorization should
        # generally only be used when calling Google APIs hosted on *.googleapis.com.
        # Corresponds to the JSON property `oauthToken`
        # @return [Google::Apis::CloudtasksV2::OAuthToken]
        attr_accessor :oauth_token
      
        # Contains information needed for generating an [OpenID Connect token](https://
        # developers.google.com/identity/protocols/OpenIDConnect). This type of
        # authorization can be used for many scenarios, including calling Cloud Run, or
        # endpoints where you intend to validate the token yourself.
        # Corresponds to the JSON property `oidcToken`
        # @return [Google::Apis::CloudtasksV2::OidcToken]
        attr_accessor :oidc_token
      
        # Required. The full url path that the request will be sent to. This string must
        # begin with either "http://" or "https://". Some examples are: `http://acme.com`
        # and `https://acme.com/sales:8080`. Cloud Tasks will encode some characters
        # for safety and compatibility. The maximum allowed URL length is 2083
        # characters after encoding. The `Location` header response from a redirect
        # response [`300` - `399`] may be followed. The redirect is not counted as a
        # separate attempt.
        # Corresponds to the JSON property `url`
        # @return [String]
        attr_accessor :url
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @body = args[:body] if args.key?(:body)
          @headers = args[:headers] if args.key?(:headers)
          @http_method = args[:http_method] if args.key?(:http_method)
          @oauth_token = args[:oauth_token] if args.key?(:oauth_token)
          @oidc_token = args[:oidc_token] if args.key?(:oidc_token)
          @url = args[:url] if args.key?(:url)
        end
      end
      
      # The response message for Locations.ListLocations.
      class ListLocationsResponse
        include Google::Apis::Core::Hashable
      
        # A list of locations that matches the specified filter in the request.
        # Corresponds to the JSON property `locations`
        # @return [Array<Google::Apis::CloudtasksV2::Location>]
        attr_accessor :locations
      
        # The standard List next-page token.
        # Corresponds to the JSON property `nextPageToken`
        # @return [String]
        attr_accessor :next_page_token
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @locations = args[:locations] if args.key?(:locations)
          @next_page_token = args[:next_page_token] if args.key?(:next_page_token)
        end
      end
      
      # Response message for ListQueues.
      class ListQueuesResponse
        include Google::Apis::Core::Hashable
      
        # A token to retrieve next page of results. To return the next page of results,
        # call ListQueues with this value as the page_token. If the next_page_token is
        # empty, there are no more results. The page token is valid for only 2 hours.
        # Corresponds to the JSON property `nextPageToken`
        # @return [String]
        attr_accessor :next_page_token
      
        # The list of queues.
        # Corresponds to the JSON property `queues`
        # @return [Array<Google::Apis::CloudtasksV2::Queue>]
        attr_accessor :queues
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @next_page_token = args[:next_page_token] if args.key?(:next_page_token)
          @queues = args[:queues] if args.key?(:queues)
        end
      end
      
      # Response message for listing tasks using ListTasks.
      class ListTasksResponse
        include Google::Apis::Core::Hashable
      
        # A token to retrieve next page of results. To return the next page of results,
        # call ListTasks with this value as the page_token. If the next_page_token is
        # empty, there are no more results.
        # Corresponds to the JSON property `nextPageToken`
        # @return [String]
        attr_accessor :next_page_token
      
        # The list of tasks.
        # Corresponds to the JSON property `tasks`
        # @return [Array<Google::Apis::CloudtasksV2::Task>]
        attr_accessor :tasks
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @next_page_token = args[:next_page_token] if args.key?(:next_page_token)
          @tasks = args[:tasks] if args.key?(:tasks)
        end
      end
      
      # A resource that represents Google Cloud Platform location.
      class Location
        include Google::Apis::Core::Hashable
      
        # The friendly name for this location, typically a nearby city name. For example,
        # "Tokyo".
        # Corresponds to the JSON property `displayName`
        # @return [String]
        attr_accessor :display_name
      
        # Cross-service attributes for the location. For example `"cloud.googleapis.com/
        # region": "us-east1"`
        # Corresponds to the JSON property `labels`
        # @return [Hash<String,String>]
        attr_accessor :labels
      
        # The canonical id for this location. For example: `"us-east1"`.
        # Corresponds to the JSON property `locationId`
        # @return [String]
        attr_accessor :location_id
      
        # Service-specific metadata. For example the available capacity at the given
        # location.
        # Corresponds to the JSON property `metadata`
        # @return [Hash<String,Object>]
        attr_accessor :metadata
      
        # Resource name for the location, which may vary between implementations. For
        # example: `"projects/example-project/locations/us-east1"`
        # Corresponds to the JSON property `name`
        # @return [String]
        attr_accessor :name
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @display_name = args[:display_name] if args.key?(:display_name)
          @labels = args[:labels] if args.key?(:labels)
          @location_id = args[:location_id] if args.key?(:location_id)
          @metadata = args[:metadata] if args.key?(:metadata)
          @name = args[:name] if args.key?(:name)
        end
      end
      
      # Contains information needed for generating an [OAuth token](https://developers.
      # google.com/identity/protocols/OAuth2). This type of authorization should
      # generally only be used when calling Google APIs hosted on *.googleapis.com.
      class OAuthToken
        include Google::Apis::Core::Hashable
      
        # OAuth scope to be used for generating OAuth access token. If not specified, "
        # https://www.googleapis.com/auth/cloud-platform" will be used.
        # Corresponds to the JSON property `scope`
        # @return [String]
        attr_accessor :scope
      
        # [Service account email](https://cloud.google.com/iam/docs/service-accounts) to
        # be used for generating OAuth token. The service account must be within the
        # same project as the queue. The caller must have iam.serviceAccounts.actAs
        # permission for the service account.
        # Corresponds to the JSON property `serviceAccountEmail`
        # @return [String]
        attr_accessor :service_account_email
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @scope = args[:scope] if args.key?(:scope)
          @service_account_email = args[:service_account_email] if args.key?(:service_account_email)
        end
      end
      
      # Contains information needed for generating an [OpenID Connect token](https://
      # developers.google.com/identity/protocols/OpenIDConnect). This type of
      # authorization can be used for many scenarios, including calling Cloud Run, or
      # endpoints where you intend to validate the token yourself.
      class OidcToken
        include Google::Apis::Core::Hashable
      
        # Audience to be used when generating OIDC token. If not specified, the URI
        # specified in target will be used.
        # Corresponds to the JSON property `audience`
        # @return [String]
        attr_accessor :audience
      
        # [Service account email](https://cloud.google.com/iam/docs/service-accounts) to
        # be used for generating OIDC token. The service account must be within the same
        # project as the queue. The caller must have iam.serviceAccounts.actAs
        # permission for the service account.
        # Corresponds to the JSON property `serviceAccountEmail`
        # @return [String]
        attr_accessor :service_account_email
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @audience = args[:audience] if args.key?(:audience)
          @service_account_email = args[:service_account_email] if args.key?(:service_account_email)
        end
      end
      
      # Request message for PauseQueue.
      class PauseQueueRequest
        include Google::Apis::Core::Hashable
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
        end
      end
      
      # An Identity and Access Management (IAM) policy, which specifies access
      # controls for Google Cloud resources. A `Policy` is a collection of `bindings`.
      # A `binding` binds one or more `members` to a single `role`. Members can be
      # user accounts, service accounts, Google groups, and domains (such as G Suite).
      # A `role` is a named list of permissions; each `role` can be an IAM predefined
      # role or a user-created custom role. For some types of Google Cloud resources,
      # a `binding` can also specify a `condition`, which is a logical expression that
      # allows access to a resource only if the expression evaluates to `true`. A
      # condition can add constraints based on attributes of the request, the resource,
      # or both. To learn which resources support conditions in their IAM policies,
      # see the [IAM documentation](https://cloud.google.com/iam/help/conditions/
      # resource-policies). **JSON example:** ` "bindings": [ ` "role": "roles/
      # resourcemanager.organizationAdmin", "members": [ "user:mike@example.com", "
      # group:admins@example.com", "domain:google.com", "serviceAccount:my-project-id@
      # appspot.gserviceaccount.com" ] `, ` "role": "roles/resourcemanager.
      # organizationViewer", "members": [ "user:eve@example.com" ], "condition": ` "
      # title": "expirable access", "description": "Does not grant access after Sep
      # 2020", "expression": "request.time < timestamp('2020-10-01T00:00:00.000Z')", `
      # ` ], "etag": "BwWWja0YfJA=", "version": 3 ` **YAML example:** bindings: -
      # members: - user:mike@example.com - group:admins@example.com - domain:google.
      # com - serviceAccount:my-project-id@appspot.gserviceaccount.com role: roles/
      # resourcemanager.organizationAdmin - members: - user:eve@example.com role:
      # roles/resourcemanager.organizationViewer condition: title: expirable access
      # description: Does not grant access after Sep 2020 expression: request.time <
      # timestamp('2020-10-01T00:00:00.000Z') - etag: BwWWja0YfJA= - version: 3 For a
      # description of IAM and its features, see the [IAM documentation](https://cloud.
      # google.com/iam/docs/).
      class Policy
        include Google::Apis::Core::Hashable
      
        # Associates a list of `members` to a `role`. Optionally, may specify a `
        # condition` that determines how and when the `bindings` are applied. Each of
        # the `bindings` must contain at least one member.
        # Corresponds to the JSON property `bindings`
        # @return [Array<Google::Apis::CloudtasksV2::Binding>]
        attr_accessor :bindings
      
        # `etag` is used for optimistic concurrency control as a way to help prevent
        # simultaneous updates of a policy from overwriting each other. It is strongly
        # suggested that systems make use of the `etag` in the read-modify-write cycle
        # to perform policy updates in order to avoid race conditions: An `etag` is
        # returned in the response to `getIamPolicy`, and systems are expected to put
        # that etag in the request to `setIamPolicy` to ensure that their change will be
        # applied to the same version of the policy. **Important:** If you use IAM
        # Conditions, you must include the `etag` field whenever you call `setIamPolicy`.
        # If you omit this field, then IAM allows you to overwrite a version `3` policy
        # with a version `1` policy, and all of the conditions in the version `3` policy
        # are lost.
        # Corresponds to the JSON property `etag`
        # NOTE: Values are automatically base64 encoded/decoded in the client library.
        # @return [String]
        attr_accessor :etag
      
        # Specifies the format of the policy. Valid values are `0`, `1`, and `3`.
        # Requests that specify an invalid value are rejected. Any operation that
        # affects conditional role bindings must specify version `3`. This requirement
        # applies to the following operations: * Getting a policy that includes a
        # conditional role binding * Adding a conditional role binding to a policy *
        # Changing a conditional role binding in a policy * Removing any role binding,
        # with or without a condition, from a policy that includes conditions **
        # Important:** If you use IAM Conditions, you must include the `etag` field
        # whenever you call `setIamPolicy`. If you omit this field, then IAM allows you
        # to overwrite a version `3` policy with a version `1` policy, and all of the
        # conditions in the version `3` policy are lost. If a policy does not include
        # any conditions, operations on that policy may specify any valid version or
        # leave the field unset. To learn which resources support conditions in their
        # IAM policies, see the [IAM documentation](https://cloud.google.com/iam/help/
        # conditions/resource-policies).
        # Corresponds to the JSON property `version`
        # @return [Fixnum]
        attr_accessor :version
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @bindings = args[:bindings] if args.key?(:bindings)
          @etag = args[:etag] if args.key?(:etag)
          @version = args[:version] if args.key?(:version)
        end
      end
      
      # Request message for PurgeQueue.
      class PurgeQueueRequest
        include Google::Apis::Core::Hashable
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
        end
      end
      
      # 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.
      class Queue
        include Google::Apis::Core::Hashable
      
        # App Engine Routing. 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), [App Engine Standard request routing](https://
        # cloud.google.com/appengine/docs/standard/python/how-requests-are-routed), and [
        # App Engine Flex request routing](https://cloud.google.com/appengine/docs/
        # flexible/python/how-requests-are-routed). Using AppEngineRouting requires [`
        # appengine.applications.get`](https://cloud.google.com/appengine/docs/admin-api/
        # access-control) Google IAM permission for the project and the following scope:
        # `https://www.googleapis.com/auth/cloud-platform`
        # Corresponds to the JSON property `appEngineRoutingOverride`
        # @return [Google::Apis::CloudtasksV2::AppEngineRouting]
        attr_accessor :app_engine_routing_override
      
        # Caller-specified and required in CreateQueue, after which it becomes output
        # only. The queue name. The queue name must have the following format: `projects/
        # PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID` * `PROJECT_ID` can contain
        # letters ([A-Za-z]), numbers ([0-9]), hyphens (-), colons (:), or periods (.).
        # For more information, see [Identifying projects](https://cloud.google.com/
        # resource-manager/docs/creating-managing-projects#identifying_projects) * `
        # LOCATION_ID` is the canonical ID for the queue's location. The list of
        # available locations can be obtained by calling ListLocations. For more
        # information, see https://cloud.google.com/about/locations/. * `QUEUE_ID` can
        # contain letters ([A-Za-z]), numbers ([0-9]), or hyphens (-). The maximum
        # length is 100 characters.
        # Corresponds to the JSON property `name`
        # @return [String]
        attr_accessor :name
      
        # Output only. The last time this queue was purged. All tasks that were created
        # before this time were purged. A queue can be purged using PurgeQueue, the [App
        # Engine Task Queue SDK, or the Cloud Console](https://cloud.google.com/
        # appengine/docs/standard/python/taskqueue/push/deleting-tasks-and-queues#
        # purging_all_tasks_from_a_queue). Purge time will be truncated to the nearest
        # microsecond. Purge time will be unset if the queue has never been purged.
        # Corresponds to the JSON property `purgeTime`
        # @return [String]
        attr_accessor :purge_time
      
        # 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.
        # Corresponds to the JSON property `rateLimits`
        # @return [Google::Apis::CloudtasksV2::RateLimits]
        attr_accessor :rate_limits
      
        # Retry config. These settings determine when a failed task attempt is retried.
        # Corresponds to the JSON property `retryConfig`
        # @return [Google::Apis::CloudtasksV2::RetryConfig]
        attr_accessor :retry_config
      
        # Configuration options for writing logs to [Stackdriver Logging](https://cloud.
        # google.com/logging/docs/).
        # Corresponds to the JSON property `stackdriverLoggingConfig`
        # @return [Google::Apis::CloudtasksV2::StackdriverLoggingConfig]
        attr_accessor :stackdriver_logging_config
      
        # Output only. The state of the queue. `state` can only be changed by called
        # PauseQueue, ResumeQueue, or uploading [queue.yaml/xml](https://cloud.google.
        # com/appengine/docs/python/config/queueref). UpdateQueue cannot be used to
        # change `state`.
        # Corresponds to the JSON property `state`
        # @return [String]
        attr_accessor :state
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @app_engine_routing_override = args[:app_engine_routing_override] if args.key?(:app_engine_routing_override)
          @name = args[:name] if args.key?(:name)
          @purge_time = args[:purge_time] if args.key?(:purge_time)
          @rate_limits = args[:rate_limits] if args.key?(:rate_limits)
          @retry_config = args[:retry_config] if args.key?(:retry_config)
          @stackdriver_logging_config = args[:stackdriver_logging_config] if args.key?(:stackdriver_logging_config)
          @state = args[:state] if args.key?(:state)
        end
      end
      
      # 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.
      class RateLimits
        include Google::Apis::Core::Hashable
      
        # 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](https://wikipedia.org/
        # wiki/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 `max_burst_size`. Each time a task is dispatched, a token is removed from
        # the bucket. Tasks will be dispatched until the queue's bucket runs out of
        # tokens. The bucket will be continuously refilled with new tokens based on
        # max_dispatches_per_second. Cloud Tasks will pick the value of `max_burst_size`
        # based on the value of max_dispatches_per_second. For queues that were created
        # or updated using `queue.yaml/xml`, `max_burst_size` is equal to [bucket_size](
        # https://cloud.google.com/appengine/docs/standard/python/config/queueref#
        # bucket_size). Since `max_burst_size` is output only, if UpdateQueue is called
        # on a queue created by `queue.yaml/xml`, `max_burst_size` will be reset based
        # on the value of max_dispatches_per_second, regardless of whether
        # max_dispatches_per_second is updated.
        # Corresponds to the JSON property `maxBurstSize`
        # @return [Fixnum]
        attr_accessor :max_burst_size
      
        # 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](https://cloud.google.com/appengine/
        # docs/standard/python/config/queueref#max_concurrent_requests).
        # Corresponds to the JSON property `maxConcurrentDispatches`
        # @return [Fixnum]
        attr_accessor :max_concurrent_dispatches
      
        # The maximum rate at which tasks are dispatched from this queue. If unspecified
        # when the queue is created, Cloud Tasks will pick the default. * The maximum
        # allowed value is 500. This field has the same meaning as [rate in queue.yaml/
        # xml](https://cloud.google.com/appengine/docs/standard/python/config/queueref#
        # rate).
        # Corresponds to the JSON property `maxDispatchesPerSecond`
        # @return [Float]
        attr_accessor :max_dispatches_per_second
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @max_burst_size = args[:max_burst_size] if args.key?(:max_burst_size)
          @max_concurrent_dispatches = args[:max_concurrent_dispatches] if args.key?(:max_concurrent_dispatches)
          @max_dispatches_per_second = args[:max_dispatches_per_second] if args.key?(:max_dispatches_per_second)
        end
      end
      
      # Request message for ResumeQueue.
      class ResumeQueueRequest
        include Google::Apis::Core::Hashable
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
        end
      end
      
      # Retry config. These settings determine when a failed task attempt is retried.
      class RetryConfig
        include Google::Apis::Core::Hashable
      
        # Number of attempts per task. Cloud Tasks will attempt the task `max_attempts`
        # times (that is, if the first attempt fails, then there will be `max_attempts -
        # 1` retries). Must be >= -1. 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](https://cloud.google.
        # com/appengine/docs/standard/python/config/queueref#retry_parameters).
        # Corresponds to the JSON property `maxAttempts`
        # @return [Fixnum]
        attr_accessor :max_attempts
      
        # A task will be scheduled for retry between min_backoff and max_backoff
        # duration after it fails, if the queue's RetryConfig specifies that the task
        # should be retried. If unspecified when the queue is created, Cloud Tasks will
        # pick the default. `max_backoff` will be truncated to the nearest second. This
        # field has the same meaning as [max_backoff_seconds in queue.yaml/xml](https://
        # cloud.google.com/appengine/docs/standard/python/config/queueref#
        # retry_parameters).
        # Corresponds to the JSON property `maxBackoff`
        # @return [String]
        attr_accessor :max_backoff
      
        # The time between retries will double `max_doublings` times. A task's retry
        # interval starts at min_backoff, then doubles `max_doublings` times, then
        # increases linearly, and finally retries at intervals of max_backoff up to
        # max_attempts times. For example, if min_backoff is 10s, max_backoff is 300s,
        # and `max_doublings` is 3, then the a task will first be retried in 10s. The
        # retry interval will double three times, and then increase linearly by 2^3 *
        # 10s. Finally, the task will retry at intervals of max_backoff until the task
        # has been attempted max_attempts times. Thus, the requests will retry at 10s,
        # 20s, 40s, 80s, 160s, 240s, 300s, 300s, .... If unspecified when the queue is
        # created, Cloud Tasks will pick the default. This field has the same meaning as
        # [max_doublings in queue.yaml/xml](https://cloud.google.com/appengine/docs/
        # standard/python/config/queueref#retry_parameters).
        # Corresponds to the JSON property `maxDoublings`
        # @return [Fixnum]
        attr_accessor :max_doublings
      
        # If positive, `max_retry_duration` specifies the time limit for retrying a
        # failed task, measured from when the task was first attempted. Once `
        # max_retry_duration` time has passed *and* the task has been attempted
        # max_attempts times, no further attempts will be made and the task will be
        # deleted. If zero, then the task age is unlimited. If unspecified when the
        # queue is created, Cloud Tasks will pick the default. `max_retry_duration` will
        # be truncated to the nearest second. This field has the same meaning as [
        # task_age_limit in queue.yaml/xml](https://cloud.google.com/appengine/docs/
        # standard/python/config/queueref#retry_parameters).
        # Corresponds to the JSON property `maxRetryDuration`
        # @return [String]
        attr_accessor :max_retry_duration
      
        # A task will be scheduled for retry between min_backoff and max_backoff
        # duration after it fails, if the queue's RetryConfig specifies that the task
        # should be retried. If unspecified when the queue is created, Cloud Tasks will
        # pick the default. `min_backoff` will be truncated to the nearest second. This
        # field has the same meaning as [min_backoff_seconds in queue.yaml/xml](https://
        # cloud.google.com/appengine/docs/standard/python/config/queueref#
        # retry_parameters).
        # Corresponds to the JSON property `minBackoff`
        # @return [String]
        attr_accessor :min_backoff
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @max_attempts = args[:max_attempts] if args.key?(:max_attempts)
          @max_backoff = args[:max_backoff] if args.key?(:max_backoff)
          @max_doublings = args[:max_doublings] if args.key?(:max_doublings)
          @max_retry_duration = args[:max_retry_duration] if args.key?(:max_retry_duration)
          @min_backoff = args[:min_backoff] if args.key?(:min_backoff)
        end
      end
      
      # Request message for forcing a task to run now using RunTask.
      class RunTaskRequest
        include Google::Apis::Core::Hashable
      
        # The response_view specifies which subset of the Task will be returned. By
        # default response_view is BASIC; not all information is retrieved by default
        # because some data, such as payloads, might be desirable to return only when
        # needed because of its large size or because of the sensitivity of data that it
        # contains. Authorization for FULL requires `cloudtasks.tasks.fullView` [Google
        # IAM](https://cloud.google.com/iam/) permission on the Task resource.
        # Corresponds to the JSON property `responseView`
        # @return [String]
        attr_accessor :response_view
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @response_view = args[:response_view] if args.key?(:response_view)
        end
      end
      
      # Request message for `SetIamPolicy` method.
      class SetIamPolicyRequest
        include Google::Apis::Core::Hashable
      
        # An Identity and Access Management (IAM) policy, which specifies access
        # controls for Google Cloud resources. A `Policy` is a collection of `bindings`.
        # A `binding` binds one or more `members` to a single `role`. Members can be
        # user accounts, service accounts, Google groups, and domains (such as G Suite).
        # A `role` is a named list of permissions; each `role` can be an IAM predefined
        # role or a user-created custom role. For some types of Google Cloud resources,
        # a `binding` can also specify a `condition`, which is a logical expression that
        # allows access to a resource only if the expression evaluates to `true`. A
        # condition can add constraints based on attributes of the request, the resource,
        # or both. To learn which resources support conditions in their IAM policies,
        # see the [IAM documentation](https://cloud.google.com/iam/help/conditions/
        # resource-policies). **JSON example:** ` "bindings": [ ` "role": "roles/
        # resourcemanager.organizationAdmin", "members": [ "user:mike@example.com", "
        # group:admins@example.com", "domain:google.com", "serviceAccount:my-project-id@
        # appspot.gserviceaccount.com" ] `, ` "role": "roles/resourcemanager.
        # organizationViewer", "members": [ "user:eve@example.com" ], "condition": ` "
        # title": "expirable access", "description": "Does not grant access after Sep
        # 2020", "expression": "request.time < timestamp('2020-10-01T00:00:00.000Z')", `
        # ` ], "etag": "BwWWja0YfJA=", "version": 3 ` **YAML example:** bindings: -
        # members: - user:mike@example.com - group:admins@example.com - domain:google.
        # com - serviceAccount:my-project-id@appspot.gserviceaccount.com role: roles/
        # resourcemanager.organizationAdmin - members: - user:eve@example.com role:
        # roles/resourcemanager.organizationViewer condition: title: expirable access
        # description: Does not grant access after Sep 2020 expression: request.time <
        # timestamp('2020-10-01T00:00:00.000Z') - etag: BwWWja0YfJA= - version: 3 For a
        # description of IAM and its features, see the [IAM documentation](https://cloud.
        # google.com/iam/docs/).
        # Corresponds to the JSON property `policy`
        # @return [Google::Apis::CloudtasksV2::Policy]
        attr_accessor :policy
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @policy = args[:policy] if args.key?(:policy)
        end
      end
      
      # Configuration options for writing logs to [Stackdriver Logging](https://cloud.
      # google.com/logging/docs/).
      class StackdriverLoggingConfig
        include Google::Apis::Core::Hashable
      
        # Specifies the fraction of operations to write to [Stackdriver Logging](https://
        # cloud.google.com/logging/docs/). 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.
        # Corresponds to the JSON property `samplingRatio`
        # @return [Float]
        attr_accessor :sampling_ratio
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @sampling_ratio = args[:sampling_ratio] if args.key?(:sampling_ratio)
        end
      end
      
      # The `Status` type defines a logical error model that is suitable for different
      # programming environments, including REST APIs and RPC APIs. It is used by [
      # gRPC](https://github.com/grpc). Each `Status` message contains three pieces of
      # data: error code, error message, and error details. You can find out more
      # about this error model and how to work with it in the [API Design Guide](https:
      # //cloud.google.com/apis/design/errors).
      class Status
        include Google::Apis::Core::Hashable
      
        # The status code, which should be an enum value of google.rpc.Code.
        # Corresponds to the JSON property `code`
        # @return [Fixnum]
        attr_accessor :code
      
        # A list of messages that carry the error details. There is a common set of
        # message types for APIs to use.
        # Corresponds to the JSON property `details`
        # @return [Array<Hash<String,Object>>]
        attr_accessor :details
      
        # A developer-facing error message, which should be in English. Any user-facing
        # error message should be localized and sent in the google.rpc.Status.details
        # field, or localized by the client.
        # Corresponds to the JSON property `message`
        # @return [String]
        attr_accessor :message
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @code = args[:code] if args.key?(:code)
          @details = args[:details] if args.key?(:details)
          @message = args[:message] if args.key?(:message)
        end
      end
      
      # A unit of scheduled work.
      class Task
        include Google::Apis::Core::Hashable
      
        # App Engine HTTP request. The message defines the HTTP request that is sent to
        # an App Engine app when the task is dispatched. Using AppEngineHttpRequest
        # requires [`appengine.applications.get`](https://cloud.google.com/appengine/
        # docs/admin-api/access-control) Google IAM permission for the project and the
        # following scope: `https://www.googleapis.com/auth/cloud-platform` The task
        # will be delivered to the App Engine app which belongs to the same project as
        # the queue. For more information, see [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 used to
        # construct the URL that the task is delivered to can be set at the queue-level
        # or task-level: * If app_engine_routing_override is set on the queue, this
        # value is used for all tasks in the queue, no matter what the setting is for
        # the task-level app_engine_routing. The `url` that the task will be sent to is:
        # * `url =` host `+` 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`]. The task attempt has failed if the app's handler
        # returns a non-2xx response code or Cloud Tasks does not receive response
        # before the deadline. Failed tasks will be retried according to the retry
        # configuration. `503` (Service Unavailable) is considered an App Engine system
        # error instead of an application error and will cause Cloud Tasks' traffic
        # congestion control to temporarily throttle the queue's dispatches. Unlike
        # other types of task targets, a `429` (Too Many Requests) response from an app
        # handler does not cause traffic congestion control to throttle the queue.
        # Corresponds to the JSON property `appEngineHttpRequest`
        # @return [Google::Apis::CloudtasksV2::AppEngineHttpRequest]
        attr_accessor :app_engine_http_request
      
        # Output only. The time that the task was created. `create_time` will be
        # truncated to the nearest second.
        # Corresponds to the JSON property `createTime`
        # @return [String]
        attr_accessor :create_time
      
        # Output only. The number of attempts dispatched. This count includes attempts
        # which have been dispatched but haven't received a response.
        # Corresponds to the JSON property `dispatchCount`
        # @return [Fixnum]
        attr_accessor :dispatch_count
      
        # 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. Note that when the request is cancelled, Cloud Tasks will stop
        # listening for the response, but whether the worker stops processing depends on
        # the worker. For example, if the worker is stuck, it may not react to cancelled
        # requests. The default and maximum values depend on the type of request: * For
        # HTTP tasks, the default is 10 minutes. The deadline must be in the interval [
        # 15 seconds, 30 minutes]. * For App Engine tasks, 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.
        # Corresponds to the JSON property `dispatchDeadline`
        # @return [String]
        attr_accessor :dispatch_deadline
      
        # The status of a task attempt.
        # Corresponds to the JSON property `firstAttempt`
        # @return [Google::Apis::CloudtasksV2::Attempt]
        attr_accessor :first_attempt
      
        # HTTP request. The task will be pushed to the worker as an HTTP request. If the
        # worker or the redirected worker acknowledges the task by returning a
        # successful HTTP response code ([`200` - `299`]), the task will be removed from
        # the queue. If any other HTTP response code is returned or no response is
        # received, the task will be retried according to the following: * User-
        # specified throttling: retry configuration, rate limits, and the queue's state.
        # * System throttling: To prevent the worker from overloading, Cloud Tasks may
        # temporarily reduce the queue's effective rate. User-specified settings will
        # not be changed. System throttling happens because: * Cloud Tasks backs off on
        # all errors. Normally the backoff specified in rate limits will be used. But if
        # the worker returns `429` (Too Many Requests), `503` (Service Unavailable), or
        # the rate of errors is high, Cloud Tasks will use a higher backoff rate. The
        # retry specified in the `Retry-After` HTTP response header is considered. * To
        # prevent traffic spikes and to smooth sudden increases in traffic, dispatches
        # ramp up slowly when the queue is newly created or idle and if large numbers of
        # tasks suddenly become available to dispatch (due to spikes in create task
        # rates, the queue being unpaused, or many tasks that are scheduled at the same
        # time).
        # Corresponds to the JSON property `httpRequest`
        # @return [Google::Apis::CloudtasksV2::HttpRequest]
        attr_accessor :http_request
      
        # The status of a task attempt.
        # Corresponds to the JSON property `lastAttempt`
        # @return [Google::Apis::CloudtasksV2::Attempt]
        attr_accessor :last_attempt
      
        # Optionally caller-specified in CreateTask. The task name. The task name must
        # have the following format: `projects/PROJECT_ID/locations/LOCATION_ID/queues/
        # QUEUE_ID/tasks/TASK_ID` * `PROJECT_ID` can contain letters ([A-Za-z]), numbers
        # ([0-9]), hyphens (-), colons (:), or periods (.). For more information, see [
        # Identifying projects](https://cloud.google.com/resource-manager/docs/creating-
        # managing-projects#identifying_projects) * `LOCATION_ID` is the canonical ID
        # for the task's location. The list of available locations can be obtained by
        # calling ListLocations. For more information, see https://cloud.google.com/
        # about/locations/. * `QUEUE_ID` can contain letters ([A-Za-z]), numbers ([0-9]),
        # or hyphens (-). The maximum length is 100 characters. * `TASK_ID` can contain
        # only letters ([A-Za-z]), numbers ([0-9]), hyphens (-), or underscores (_). The
        # maximum length is 500 characters.
        # Corresponds to the JSON property `name`
        # @return [String]
        attr_accessor :name
      
        # Output only. The number of attempts which have received a response.
        # Corresponds to the JSON property `responseCount`
        # @return [Fixnum]
        attr_accessor :response_count
      
        # The time when the task is scheduled to be attempted or retried. `schedule_time`
        # will be truncated to the nearest microsecond.
        # Corresponds to the JSON property `scheduleTime`
        # @return [String]
        attr_accessor :schedule_time
      
        # Output only. The view specifies which subset of the Task has been returned.
        # Corresponds to the JSON property `view`
        # @return [String]
        attr_accessor :view
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @app_engine_http_request = args[:app_engine_http_request] if args.key?(:app_engine_http_request)
          @create_time = args[:create_time] if args.key?(:create_time)
          @dispatch_count = args[:dispatch_count] if args.key?(:dispatch_count)
          @dispatch_deadline = args[:dispatch_deadline] if args.key?(:dispatch_deadline)
          @first_attempt = args[:first_attempt] if args.key?(:first_attempt)
          @http_request = args[:http_request] if args.key?(:http_request)
          @last_attempt = args[:last_attempt] if args.key?(:last_attempt)
          @name = args[:name] if args.key?(:name)
          @response_count = args[:response_count] if args.key?(:response_count)
          @schedule_time = args[:schedule_time] if args.key?(:schedule_time)
          @view = args[:view] if args.key?(:view)
        end
      end
      
      # Request message for `TestIamPermissions` method.
      class TestIamPermissionsRequest
        include Google::Apis::Core::Hashable
      
        # The set of permissions to check for the `resource`. Permissions with wildcards
        # (such as '*' or 'storage.*') are not allowed. For more information see [IAM
        # Overview](https://cloud.google.com/iam/docs/overview#permissions).
        # Corresponds to the JSON property `permissions`
        # @return [Array<String>]
        attr_accessor :permissions
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @permissions = args[:permissions] if args.key?(:permissions)
        end
      end
      
      # Response message for `TestIamPermissions` method.
      class TestIamPermissionsResponse
        include Google::Apis::Core::Hashable
      
        # A subset of `TestPermissionsRequest.permissions` that the caller is allowed.
        # Corresponds to the JSON property `permissions`
        # @return [Array<String>]
        attr_accessor :permissions
      
        def initialize(**args)
           update!(**args)
        end
      
        # Update properties of this object
        def update!(**args)
          @permissions = args[:permissions] if args.key?(:permissions)
        end
      end
    end
  end
end