Autogenerated update (2017-08-25)
Add: - adexperiencereport_v1 - androiddeviceprovisioning_v1 - androidmanagement_v1 - bigquerydatatransfer_v1 - cloudtrace_v2 - clouduseraccounts_vm_alpha - consumersurveys_v2 - dlp_v2beta1 - oslogin_v1alpha - playcustomapp_v1 - playmoviespartner_v1 - safebrowsing_v4 - spectrum_v1explorer - speech_v1 - streetviewpublish_v1 - vault_v1 - videointelligence_v1beta1 Update: - acceleratedmobilepageurl_v1 - adexchangebuyer2_v2beta1 - adexchangebuyer_v1_4 - adsense_v1_4 - adsensehost_v4_1 - analytics_v3 - analyticsreporting_v4 - androidenterprise_v1 - androidpublisher_v2 - appengine_v1 - appsactivity_v1 - appstate_v1 - bigquery_v2 - calendar_v3 - classroom_v1 - cloudbilling_v1 - cloudbuild_v1 - clouddebugger_v2 - clouderrorreporting_v1beta1 - cloudfunctions_v1 - cloudkms_v1 - cloudmonitoring_v2beta2 - cloudresourcemanager_v1 - compute_beta - compute_v1 - container_v1 - content_v2 - dataflow_v1b3 - dataproc_v1 - datastore_v1 - deploymentmanager_v2 - dfareporting_v2_8 - dns_v1 - doubleclicksearch_v2 - drive_v3 - firebasedynamiclinks_v1 - firebaserules_v1 - fitness_v1 - games_configuration_v1configuration - games_management_v1management - games_v1 - genomics_v1 - gmail_v1 - iam_v1 - identitytoolkit_v3 - language_v1 - logging_v2 - manufacturers_v1 - ml_v1 - monitoring_v3 - oauth2_v2 - partners_v2 - people_v1 - plus_domains_v1 - plus_v1 - proximitybeacon_v1beta1 - pubsub_v1 - runtimeconfig_v1 - script_v1 - searchconsole_v1 - servicecontrol_v1 - servicemanagement_v1 - serviceuser_v1 - sheets_v4 - slides_v1 - sourcerepo_v1 - spanner_v1 - sqladmin_v1beta4 - storage_v1 - storagetransfer_v1 - toolresults_v1beta3 - vision_v1 - webmasters_v3 - youtube_analytics_v1 - youtube_partner_v1 - youtubereporting_v1
This commit is contained in:
Google APIs committed
1 parent
ce32deabcf
commit
2dd396ce6e
315 files changed
+158012
-116092
No files matched your search
@@ -22,16 +22,15 @@ module Google
|
||||
module Apis
|
||||
module PubsubV1
|
||||
|
||||
# Response for the `Publish` method.
|
||||
class PublishResponse
|
||||
# Request for the Acknowledge method.
|
||||
class AcknowledgeRequest
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The server-assigned ID of each published message, in the same order as
|
||||
# the messages in the request. IDs are guaranteed to be unique within
|
||||
# the topic.
|
||||
# Corresponds to the JSON property `messageIds`
|
||||
# The acknowledgment ID for the messages being acknowledged that was returned
|
||||
# by the Pub/Sub system in the `Pull` response. Must not be empty.
|
||||
# Corresponds to the JSON property `ackIds`
|
||||
# @return [Array<String>]
|
||||
attr_accessor :message_ids
|
||||
attr_accessor :ack_ids
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
@@ -39,89 +38,196 @@ module Google
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@message_ids = args[:message_ids] if args.key?(:message_ids)
|
||||
@ack_ids = args[:ack_ids] if args.key?(:ack_ids)
|
||||
end
|
||||
end
|
||||
|
||||
# A subscription resource.
|
||||
class Subscription
|
||||
# Associates `members` with a `role`.
|
||||
class Binding
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The name of the topic from which this subscription is receiving messages.
|
||||
# Format is `projects/`project`/topics/`topic``.
|
||||
# The value of this field will be `_deleted-topic_` if the topic has been
|
||||
# deleted.
|
||||
# Corresponds to the JSON property `topic`
|
||||
# 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@gmail.com` or `joe@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`.
|
||||
# * `domain:`domain``: A Google Apps domain name 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`.
|
||||
# Required
|
||||
# Corresponds to the JSON property `role`
|
||||
# @return [String]
|
||||
attr_accessor :topic
|
||||
attr_accessor :role
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@members = args[:members] if args.key?(:members)
|
||||
@role = args[:role] if args.key?(:role)
|
||||
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
|
||||
|
||||
# Response for the `ListSubscriptions` method.
|
||||
class ListSubscriptionsResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# If not empty, indicates that there may be more subscriptions that match
|
||||
# the request; this value should be passed in a new
|
||||
# `ListSubscriptionsRequest` to get more subscriptions.
|
||||
# Corresponds to the JSON property `nextPageToken`
|
||||
# @return [String]
|
||||
attr_accessor :next_page_token
|
||||
|
||||
# The subscriptions that match the request.
|
||||
# Corresponds to the JSON property `subscriptions`
|
||||
# @return [Array<Google::Apis::PubsubV1::Subscription>]
|
||||
attr_accessor :subscriptions
|
||||
|
||||
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)
|
||||
@subscriptions = args[:subscriptions] if args.key?(:subscriptions)
|
||||
end
|
||||
end
|
||||
|
||||
# Response for the `ListTopicSubscriptions` method.
|
||||
class ListTopicSubscriptionsResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# If not empty, indicates that there may be more subscriptions that match
|
||||
# the request; this value should be passed in a new
|
||||
# `ListTopicSubscriptionsRequest` to get more subscriptions.
|
||||
# Corresponds to the JSON property `nextPageToken`
|
||||
# @return [String]
|
||||
attr_accessor :next_page_token
|
||||
|
||||
# The names of the subscriptions that match the request.
|
||||
# Corresponds to the JSON property `subscriptions`
|
||||
# @return [Array<String>]
|
||||
attr_accessor :subscriptions
|
||||
|
||||
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)
|
||||
@subscriptions = args[:subscriptions] if args.key?(:subscriptions)
|
||||
end
|
||||
end
|
||||
|
||||
# Response for the `ListTopics` method.
|
||||
class ListTopicsResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# If not empty, indicates that there may be more topics that match the
|
||||
# request; this value should be passed in a new `ListTopicsRequest`.
|
||||
# Corresponds to the JSON property `nextPageToken`
|
||||
# @return [String]
|
||||
attr_accessor :next_page_token
|
||||
|
||||
# The resulting topics.
|
||||
# Corresponds to the JSON property `topics`
|
||||
# @return [Array<Google::Apis::PubsubV1::Topic>]
|
||||
attr_accessor :topics
|
||||
|
||||
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)
|
||||
@topics = args[:topics] if args.key?(:topics)
|
||||
end
|
||||
end
|
||||
|
||||
# Request for the ModifyAckDeadline method.
|
||||
class ModifyAckDeadlineRequest
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The new ack deadline with respect to the time this request was sent to
|
||||
# the Pub/Sub system. For example, if the value is 10, the new
|
||||
# ack deadline will expire 10 seconds after the `ModifyAckDeadline` call
|
||||
# was made. Specifying zero may immediately make the message available for
|
||||
# another pull request.
|
||||
# The minimum deadline you can specify is 0 seconds.
|
||||
# The maximum deadline you can specify is 600 seconds (10 minutes).
|
||||
# Corresponds to the JSON property `ackDeadlineSeconds`
|
||||
# @return [Fixnum]
|
||||
attr_accessor :ack_deadline_seconds
|
||||
|
||||
# List of acknowledgment IDs.
|
||||
# Corresponds to the JSON property `ackIds`
|
||||
# @return [Array<String>]
|
||||
attr_accessor :ack_ids
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@ack_deadline_seconds = args[:ack_deadline_seconds] if args.key?(:ack_deadline_seconds)
|
||||
@ack_ids = args[:ack_ids] if args.key?(:ack_ids)
|
||||
end
|
||||
end
|
||||
|
||||
# Request for the ModifyPushConfig method.
|
||||
class ModifyPushConfigRequest
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Configuration for a push delivery endpoint.
|
||||
# Corresponds to the JSON property `pushConfig`
|
||||
# @return [Google::Apis::PubsubV1::PushConfig]
|
||||
attr_accessor :push_config
|
||||
|
||||
# This value is the maximum time after a subscriber receives a message
|
||||
# before the subscriber should acknowledge the message. After message
|
||||
# delivery but before the ack deadline expires and before the message is
|
||||
# acknowledged, it is an outstanding message and will not be delivered
|
||||
# again during that time (on a best-effort basis).
|
||||
# For pull subscriptions, this value is used as the initial value for the ack
|
||||
# deadline. To override this value for a given message, call
|
||||
# `ModifyAckDeadline` with the corresponding `ack_id` if using
|
||||
# pull.
|
||||
# The minimum custom deadline you can specify is 10 seconds.
|
||||
# The maximum custom deadline you can specify is 600 seconds (10 minutes).
|
||||
# If this parameter is 0, a default value of 10 seconds is used.
|
||||
# For push delivery, this value is also used to set the request timeout for
|
||||
# the call to the push endpoint.
|
||||
# If the subscriber never acknowledges the message, the Pub/Sub
|
||||
# system will eventually redeliver the message.
|
||||
# Corresponds to the JSON property `ackDeadlineSeconds`
|
||||
# @return [Fixnum]
|
||||
attr_accessor :ack_deadline_seconds
|
||||
|
||||
# The name of the subscription. It must have the format
|
||||
# `"projects/`project`/subscriptions/`subscription`"`. ``subscription`` must
|
||||
# start with a letter, and contain only letters (`[A-Za-z]`), numbers
|
||||
# (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`),
|
||||
# plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters
|
||||
# in length, and it must not start with `"goog"`.
|
||||
# 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)
|
||||
@topic = args[:topic] if args.key?(:topic)
|
||||
@push_config = args[:push_config] if args.key?(:push_config)
|
||||
@ack_deadline_seconds = args[:ack_deadline_seconds] if args.key?(:ack_deadline_seconds)
|
||||
@name = args[:name] if args.key?(:name)
|
||||
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
|
||||
|
||||
@@ -154,6 +260,12 @@ module Google
|
||||
class Policy
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Associates a list of `members` to a `role`.
|
||||
# `bindings` with no members will result in an error.
|
||||
# Corresponds to the JSON property `bindings`
|
||||
# @return [Array<Google::Apis::PubsubV1::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
|
||||
@@ -173,37 +285,26 @@ module Google
|
||||
# @return [Fixnum]
|
||||
attr_accessor :version
|
||||
|
||||
# Associates a list of `members` to a `role`.
|
||||
# `bindings` with no members will result in an error.
|
||||
# Corresponds to the JSON property `bindings`
|
||||
# @return [Array<Google::Apis::PubsubV1::Binding>]
|
||||
attr_accessor :bindings
|
||||
|
||||
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)
|
||||
@bindings = args[:bindings] if args.key?(:bindings)
|
||||
end
|
||||
end
|
||||
|
||||
# A topic resource.
|
||||
class Topic
|
||||
# Request for the Publish method.
|
||||
class PublishRequest
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The name of the topic. It must have the format
|
||||
# `"projects/`project`/topics/`topic`"`. ``topic`` must start with a letter,
|
||||
# and contain only letters (`[A-Za-z]`), numbers (`[0-9]`), dashes (`-`),
|
||||
# underscores (`_`), periods (`.`), tildes (`~`), plus (`+`) or percent
|
||||
# signs (`%`). It must be between 3 and 255 characters in length, and it
|
||||
# must not start with `"goog"`.
|
||||
# Corresponds to the JSON property `name`
|
||||
# @return [String]
|
||||
attr_accessor :name
|
||||
# The messages to publish.
|
||||
# Corresponds to the JSON property `messages`
|
||||
# @return [Array<Google::Apis::PubsubV1::Message>]
|
||||
attr_accessor :messages
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
@@ -211,29 +312,20 @@ module Google
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@name = args[:name] if args.key?(:name)
|
||||
@messages = args[:messages] if args.key?(:messages)
|
||||
end
|
||||
end
|
||||
|
||||
# Request for the ModifyAckDeadline method.
|
||||
class ModifyAckDeadlineRequest
|
||||
# Response for the `Publish` method.
|
||||
class PublishResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The new ack deadline with respect to the time this request was sent to
|
||||
# the Pub/Sub system. For example, if the value is 10, the new
|
||||
# ack deadline will expire 10 seconds after the `ModifyAckDeadline` call
|
||||
# was made. Specifying zero may immediately make the message available for
|
||||
# another pull request.
|
||||
# The minimum deadline you can specify is 0 seconds.
|
||||
# The maximum deadline you can specify is 600 seconds (10 minutes).
|
||||
# Corresponds to the JSON property `ackDeadlineSeconds`
|
||||
# @return [Fixnum]
|
||||
attr_accessor :ack_deadline_seconds
|
||||
|
||||
# List of acknowledgment IDs.
|
||||
# Corresponds to the JSON property `ackIds`
|
||||
# The server-assigned ID of each published message, in the same order as
|
||||
# the messages in the request. IDs are guaranteed to be unique within
|
||||
# the topic.
|
||||
# Corresponds to the JSON property `messageIds`
|
||||
# @return [Array<String>]
|
||||
attr_accessor :ack_ids
|
||||
attr_accessor :message_ids
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
@@ -241,8 +333,172 @@ module Google
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@ack_deadline_seconds = args[:ack_deadline_seconds] if args.key?(:ack_deadline_seconds)
|
||||
@ack_ids = args[:ack_ids] if args.key?(:ack_ids)
|
||||
@message_ids = args[:message_ids] if args.key?(:message_ids)
|
||||
end
|
||||
end
|
||||
|
||||
# A message data and its attributes. The message payload must not be empty;
|
||||
# it must contain either a non-empty data field, or at least one attribute.
|
||||
class Message
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Optional attributes for this message.
|
||||
# Corresponds to the JSON property `attributes`
|
||||
# @return [Hash<String,String>]
|
||||
attr_accessor :attributes
|
||||
|
||||
# The message payload.
|
||||
# Corresponds to the JSON property `data`
|
||||
# NOTE: Values are automatically base64 encoded/decoded in the client library.
|
||||
# @return [String]
|
||||
attr_accessor :data
|
||||
|
||||
# ID of this message, assigned by the server when the message is published.
|
||||
# Guaranteed to be unique within the topic. This value may be read by a
|
||||
# subscriber that receives a `PubsubMessage` via a `Pull` call or a push
|
||||
# delivery. It must not be populated by the publisher in a `Publish` call.
|
||||
# Corresponds to the JSON property `messageId`
|
||||
# @return [String]
|
||||
attr_accessor :message_id
|
||||
|
||||
# The time at which the message was published, populated by the server when
|
||||
# it receives the `Publish` call. It must not be populated by the
|
||||
# publisher in a `Publish` call.
|
||||
# Corresponds to the JSON property `publishTime`
|
||||
# @return [String]
|
||||
attr_accessor :publish_time
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@attributes = args[:attributes] if args.key?(:attributes)
|
||||
@data = args[:data] if args.key?(:data)
|
||||
@message_id = args[:message_id] if args.key?(:message_id)
|
||||
@publish_time = args[:publish_time] if args.key?(:publish_time)
|
||||
end
|
||||
end
|
||||
|
||||
# Request for the `Pull` method.
|
||||
class PullRequest
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The maximum number of messages returned for this request. The Pub/Sub
|
||||
# system may return fewer than the number specified.
|
||||
# Corresponds to the JSON property `maxMessages`
|
||||
# @return [Fixnum]
|
||||
attr_accessor :max_messages
|
||||
|
||||
# If this field set to true, the system will respond immediately even if
|
||||
# it there are no messages available to return in the `Pull` response.
|
||||
# Otherwise, the system may wait (for a bounded amount of time) until at
|
||||
# least one message is available, rather than returning no messages. The
|
||||
# client may cancel the request if it does not wish to wait any longer for
|
||||
# the response.
|
||||
# Corresponds to the JSON property `returnImmediately`
|
||||
# @return [Boolean]
|
||||
attr_accessor :return_immediately
|
||||
alias_method :return_immediately?, :return_immediately
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@max_messages = args[:max_messages] if args.key?(:max_messages)
|
||||
@return_immediately = args[:return_immediately] if args.key?(:return_immediately)
|
||||
end
|
||||
end
|
||||
|
||||
# Response for the `Pull` method.
|
||||
class PullResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Received Pub/Sub messages. The Pub/Sub system will return zero messages if
|
||||
# there are no more available in the backlog. The Pub/Sub system may return
|
||||
# fewer than the `maxMessages` requested even if there are more messages
|
||||
# available in the backlog.
|
||||
# Corresponds to the JSON property `receivedMessages`
|
||||
# @return [Array<Google::Apis::PubsubV1::ReceivedMessage>]
|
||||
attr_accessor :received_messages
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@received_messages = args[:received_messages] if args.key?(:received_messages)
|
||||
end
|
||||
end
|
||||
|
||||
# Configuration for a push delivery endpoint.
|
||||
class PushConfig
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Endpoint configuration attributes.
|
||||
# Every endpoint has a set of API supported attributes that can be used to
|
||||
# control different aspects of the message delivery.
|
||||
# The currently supported attribute is `x-goog-version`, which you can
|
||||
# use to change the format of the pushed message. This attribute
|
||||
# indicates the version of the data expected by the endpoint. This
|
||||
# controls the shape of the pushed message (i.e., its fields and metadata).
|
||||
# The endpoint version is based on the version of the Pub/Sub API.
|
||||
# If not present during the `CreateSubscription` call, it will default to
|
||||
# the version of the API used to make such call. If not present during a
|
||||
# `ModifyPushConfig` call, its value will not be changed. `GetSubscription`
|
||||
# calls will always return a valid version, even if the subscription was
|
||||
# created without this attribute.
|
||||
# The possible values for this attribute are:
|
||||
# * `v1beta1`: uses the push format defined in the v1beta1 Pub/Sub API.
|
||||
# * `v1` or `v1beta2`: uses the push format defined in the v1 Pub/Sub API.
|
||||
# Corresponds to the JSON property `attributes`
|
||||
# @return [Hash<String,String>]
|
||||
attr_accessor :attributes
|
||||
|
||||
# A URL locating the endpoint to which messages should be pushed.
|
||||
# For example, a Webhook endpoint might use "https://example.com/push".
|
||||
# Corresponds to the JSON property `pushEndpoint`
|
||||
# @return [String]
|
||||
attr_accessor :push_endpoint
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@attributes = args[:attributes] if args.key?(:attributes)
|
||||
@push_endpoint = args[:push_endpoint] if args.key?(:push_endpoint)
|
||||
end
|
||||
end
|
||||
|
||||
# A message and its corresponding acknowledgment ID.
|
||||
class ReceivedMessage
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# This ID can be used to acknowledge the received message.
|
||||
# Corresponds to the JSON property `ackId`
|
||||
# @return [String]
|
||||
attr_accessor :ack_id
|
||||
|
||||
# A message data and its attributes. The message payload must not be empty;
|
||||
# it must contain either a non-empty data field, or at least one attribute.
|
||||
# Corresponds to the JSON property `message`
|
||||
# @return [Google::Apis::PubsubV1::Message]
|
||||
attr_accessor :message
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@ack_id = args[:ack_id] if args.key?(:ack_id)
|
||||
@message = args[:message] if args.key?(:message)
|
||||
end
|
||||
end
|
||||
|
||||
@@ -290,97 +546,77 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
# Request for the ModifyPushConfig method.
|
||||
class ModifyPushConfigRequest
|
||||
# A subscription resource.
|
||||
class Subscription
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# This value is the maximum time after a subscriber receives a message
|
||||
# before the subscriber should acknowledge the message. After message
|
||||
# delivery but before the ack deadline expires and before the message is
|
||||
# acknowledged, it is an outstanding message and will not be delivered
|
||||
# again during that time (on a best-effort basis).
|
||||
# For pull subscriptions, this value is used as the initial value for the ack
|
||||
# deadline. To override this value for a given message, call
|
||||
# `ModifyAckDeadline` with the corresponding `ack_id` if using
|
||||
# pull.
|
||||
# The minimum custom deadline you can specify is 10 seconds.
|
||||
# The maximum custom deadline you can specify is 600 seconds (10 minutes).
|
||||
# If this parameter is 0, a default value of 10 seconds is used.
|
||||
# For push delivery, this value is also used to set the request timeout for
|
||||
# the call to the push endpoint.
|
||||
# If the subscriber never acknowledges the message, the Pub/Sub
|
||||
# system will eventually redeliver the message.
|
||||
# Corresponds to the JSON property `ackDeadlineSeconds`
|
||||
# @return [Fixnum]
|
||||
attr_accessor :ack_deadline_seconds
|
||||
|
||||
# The name of the subscription. It must have the format
|
||||
# `"projects/`project`/subscriptions/`subscription`"`. ``subscription`` must
|
||||
# start with a letter, and contain only letters (`[A-Za-z]`), numbers
|
||||
# (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`),
|
||||
# plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters
|
||||
# in length, and it must not start with `"goog"`.
|
||||
# Corresponds to the JSON property `name`
|
||||
# @return [String]
|
||||
attr_accessor :name
|
||||
|
||||
# Configuration for a push delivery endpoint.
|
||||
# Corresponds to the JSON property `pushConfig`
|
||||
# @return [Google::Apis::PubsubV1::PushConfig]
|
||||
attr_accessor :push_config
|
||||
|
||||
# The name of the topic from which this subscription is receiving messages.
|
||||
# Format is `projects/`project`/topics/`topic``.
|
||||
# The value of this field will be `_deleted-topic_` if the topic has been
|
||||
# deleted.
|
||||
# Corresponds to the JSON property `topic`
|
||||
# @return [String]
|
||||
attr_accessor :topic
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@ack_deadline_seconds = args[:ack_deadline_seconds] if args.key?(:ack_deadline_seconds)
|
||||
@name = args[:name] if args.key?(:name)
|
||||
@push_config = args[:push_config] if args.key?(:push_config)
|
||||
@topic = args[:topic] if args.key?(:topic)
|
||||
end
|
||||
end
|
||||
|
||||
# A message data and its attributes. The message payload must not be empty;
|
||||
# it must contain either a non-empty data field, or at least one attribute.
|
||||
class Message
|
||||
# Request message for `TestIamPermissions` method.
|
||||
class TestIamPermissionsRequest
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# ID of this message, assigned by the server when the message is published.
|
||||
# Guaranteed to be unique within the topic. This value may be read by a
|
||||
# subscriber that receives a `PubsubMessage` via a `Pull` call or a push
|
||||
# delivery. It must not be populated by the publisher in a `Publish` call.
|
||||
# Corresponds to the JSON property `messageId`
|
||||
# @return [String]
|
||||
attr_accessor :message_id
|
||||
|
||||
# Optional attributes for this message.
|
||||
# Corresponds to the JSON property `attributes`
|
||||
# @return [Hash<String,String>]
|
||||
attr_accessor :attributes
|
||||
|
||||
# The time at which the message was published, populated by the server when
|
||||
# it receives the `Publish` call. It must not be populated by the
|
||||
# publisher in a `Publish` call.
|
||||
# Corresponds to the JSON property `publishTime`
|
||||
# @return [String]
|
||||
attr_accessor :publish_time
|
||||
|
||||
# The message payload.
|
||||
# Corresponds to the JSON property `data`
|
||||
# NOTE: Values are automatically base64 encoded/decoded in the client library.
|
||||
# @return [String]
|
||||
attr_accessor :data
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@message_id = args[:message_id] if args.key?(:message_id)
|
||||
@attributes = args[:attributes] if args.key?(:attributes)
|
||||
@publish_time = args[:publish_time] if args.key?(:publish_time)
|
||||
@data = args[:data] if args.key?(:data)
|
||||
end
|
||||
end
|
||||
|
||||
# Associates `members` with a `role`.
|
||||
class Binding
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Role that is assigned to `members`.
|
||||
# For example, `roles/viewer`, `roles/editor`, or `roles/owner`.
|
||||
# Required
|
||||
# Corresponds to the JSON property `role`
|
||||
# @return [String]
|
||||
attr_accessor :role
|
||||
|
||||
# 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@gmail.com` or `joe@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`.
|
||||
# * `domain:`domain``: A Google Apps domain name that represents all the
|
||||
# users of that domain. For example, `google.com` or `example.com`.
|
||||
# Corresponds to the JSON property `members`
|
||||
# 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 :members
|
||||
attr_accessor :permissions
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
@@ -388,189 +624,7 @@ module Google
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@role = args[:role] if args.key?(:role)
|
||||
@members = args[:members] if args.key?(:members)
|
||||
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
|
||||
|
||||
# Request for the Acknowledge method.
|
||||
class AcknowledgeRequest
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The acknowledgment ID for the messages being acknowledged that was returned
|
||||
# by the Pub/Sub system in the `Pull` response. Must not be empty.
|
||||
# Corresponds to the JSON property `ackIds`
|
||||
# @return [Array<String>]
|
||||
attr_accessor :ack_ids
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@ack_ids = args[:ack_ids] if args.key?(:ack_ids)
|
||||
end
|
||||
end
|
||||
|
||||
# Response for the `ListTopics` method.
|
||||
class ListTopicsResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# If not empty, indicates that there may be more topics that match the
|
||||
# request; this value should be passed in a new `ListTopicsRequest`.
|
||||
# Corresponds to the JSON property `nextPageToken`
|
||||
# @return [String]
|
||||
attr_accessor :next_page_token
|
||||
|
||||
# The resulting topics.
|
||||
# Corresponds to the JSON property `topics`
|
||||
# @return [Array<Google::Apis::PubsubV1::Topic>]
|
||||
attr_accessor :topics
|
||||
|
||||
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)
|
||||
@topics = args[:topics] if args.key?(:topics)
|
||||
end
|
||||
end
|
||||
|
||||
# Response for the `ListTopicSubscriptions` method.
|
||||
class ListTopicSubscriptionsResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# If not empty, indicates that there may be more subscriptions that match
|
||||
# the request; this value should be passed in a new
|
||||
# `ListTopicSubscriptionsRequest` to get more subscriptions.
|
||||
# Corresponds to the JSON property `nextPageToken`
|
||||
# @return [String]
|
||||
attr_accessor :next_page_token
|
||||
|
||||
# The names of the subscriptions that match the request.
|
||||
# Corresponds to the JSON property `subscriptions`
|
||||
# @return [Array<String>]
|
||||
attr_accessor :subscriptions
|
||||
|
||||
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)
|
||||
@subscriptions = args[:subscriptions] if args.key?(:subscriptions)
|
||||
end
|
||||
end
|
||||
|
||||
# Response for the `Pull` method.
|
||||
class PullResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Received Pub/Sub messages. The Pub/Sub system will return zero messages if
|
||||
# there are no more available in the backlog. The Pub/Sub system may return
|
||||
# fewer than the `maxMessages` requested even if there are more messages
|
||||
# available in the backlog.
|
||||
# Corresponds to the JSON property `receivedMessages`
|
||||
# @return [Array<Google::Apis::PubsubV1::ReceivedMessage>]
|
||||
attr_accessor :received_messages
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@received_messages = args[:received_messages] if args.key?(:received_messages)
|
||||
end
|
||||
end
|
||||
|
||||
# A message and its corresponding acknowledgment ID.
|
||||
class ReceivedMessage
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# This ID can be used to acknowledge the received message.
|
||||
# Corresponds to the JSON property `ackId`
|
||||
# @return [String]
|
||||
attr_accessor :ack_id
|
||||
|
||||
# A message data and its attributes. The message payload must not be empty;
|
||||
# it must contain either a non-empty data field, or at least one attribute.
|
||||
# Corresponds to the JSON property `message`
|
||||
# @return [Google::Apis::PubsubV1::Message]
|
||||
attr_accessor :message
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@ack_id = args[:ack_id] if args.key?(:ack_id)
|
||||
@message = args[:message] if args.key?(:message)
|
||||
end
|
||||
end
|
||||
|
||||
# Configuration for a push delivery endpoint.
|
||||
class PushConfig
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Endpoint configuration attributes.
|
||||
# Every endpoint has a set of API supported attributes that can be used to
|
||||
# control different aspects of the message delivery.
|
||||
# The currently supported attribute is `x-goog-version`, which you can
|
||||
# use to change the format of the pushed message. This attribute
|
||||
# indicates the version of the data expected by the endpoint. This
|
||||
# controls the shape of the pushed message (i.e., its fields and metadata).
|
||||
# The endpoint version is based on the version of the Pub/Sub API.
|
||||
# If not present during the `CreateSubscription` call, it will default to
|
||||
# the version of the API used to make such call. If not present during a
|
||||
# `ModifyPushConfig` call, its value will not be changed. `GetSubscription`
|
||||
# calls will always return a valid version, even if the subscription was
|
||||
# created without this attribute.
|
||||
# The possible values for this attribute are:
|
||||
# * `v1beta1`: uses the push format defined in the v1beta1 Pub/Sub API.
|
||||
# * `v1` or `v1beta2`: uses the push format defined in the v1 Pub/Sub API.
|
||||
# Corresponds to the JSON property `attributes`
|
||||
# @return [Hash<String,String>]
|
||||
attr_accessor :attributes
|
||||
|
||||
# A URL locating the endpoint to which messages should be pushed.
|
||||
# For example, a Webhook endpoint might use "https://example.com/push".
|
||||
# Corresponds to the JSON property `pushEndpoint`
|
||||
# @return [String]
|
||||
attr_accessor :push_endpoint
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@attributes = args[:attributes] if args.key?(:attributes)
|
||||
@push_endpoint = args[:push_endpoint] if args.key?(:push_endpoint)
|
||||
@permissions = args[:permissions] if args.key?(:permissions)
|
||||
end
|
||||
end
|
||||
|
||||
@@ -594,53 +648,19 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
# Request for the `Pull` method.
|
||||
class PullRequest
|
||||
# A topic resource.
|
||||
class Topic
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# If this field set to true, the system will respond immediately even if
|
||||
# it there are no messages available to return in the `Pull` response.
|
||||
# Otherwise, the system may wait (for a bounded amount of time) until at
|
||||
# least one message is available, rather than returning no messages. The
|
||||
# client may cancel the request if it does not wish to wait any longer for
|
||||
# the response.
|
||||
# Corresponds to the JSON property `returnImmediately`
|
||||
# @return [Boolean]
|
||||
attr_accessor :return_immediately
|
||||
alias_method :return_immediately?, :return_immediately
|
||||
|
||||
# The maximum number of messages returned for this request. The Pub/Sub
|
||||
# system may return fewer than the number specified.
|
||||
# Corresponds to the JSON property `maxMessages`
|
||||
# @return [Fixnum]
|
||||
attr_accessor :max_messages
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@return_immediately = args[:return_immediately] if args.key?(:return_immediately)
|
||||
@max_messages = args[:max_messages] if args.key?(:max_messages)
|
||||
end
|
||||
end
|
||||
|
||||
# Response for the `ListSubscriptions` method.
|
||||
class ListSubscriptionsResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# If not empty, indicates that there may be more subscriptions that match
|
||||
# the request; this value should be passed in a new
|
||||
# `ListSubscriptionsRequest` to get more subscriptions.
|
||||
# Corresponds to the JSON property `nextPageToken`
|
||||
# The name of the topic. It must have the format
|
||||
# `"projects/`project`/topics/`topic`"`. ``topic`` must start with a letter,
|
||||
# and contain only letters (`[A-Za-z]`), numbers (`[0-9]`), dashes (`-`),
|
||||
# underscores (`_`), periods (`.`), tildes (`~`), plus (`+`) or percent
|
||||
# signs (`%`). It must be between 3 and 255 characters in length, and it
|
||||
# must not start with `"goog"`.
|
||||
# Corresponds to the JSON property `name`
|
||||
# @return [String]
|
||||
attr_accessor :next_page_token
|
||||
|
||||
# The subscriptions that match the request.
|
||||
# Corresponds to the JSON property `subscriptions`
|
||||
# @return [Array<Google::Apis::PubsubV1::Subscription>]
|
||||
attr_accessor :subscriptions
|
||||
attr_accessor :name
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
@@ -648,27 +668,7 @@ module Google
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@next_page_token = args[:next_page_token] if args.key?(:next_page_token)
|
||||
@subscriptions = args[:subscriptions] if args.key?(:subscriptions)
|
||||
end
|
||||
end
|
||||
|
||||
# Request for the Publish method.
|
||||
class PublishRequest
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The messages to publish.
|
||||
# Corresponds to the JSON property `messages`
|
||||
# @return [Array<Google::Apis::PubsubV1::Message>]
|
||||
attr_accessor :messages
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@messages = args[:messages] if args.key?(:messages)
|
||||
@name = args[:name] if args.key?(:name)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -22,55 +22,7 @@ module Google
|
||||
module Apis
|
||||
module PubsubV1
|
||||
|
||||
class PublishResponse
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Subscription
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class TestIamPermissionsRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Policy
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Topic
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class ModifyAckDeadlineRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class SetIamPolicyRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class ModifyPushConfigRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Message
|
||||
class AcknowledgeRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
@@ -88,13 +40,7 @@ module Google
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class AcknowledgeRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class ListTopicsResponse
|
||||
class ListSubscriptionsResponse
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
@@ -106,37 +52,25 @@ module Google
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class PullResponse
|
||||
class ListTopicsResponse
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class ReceivedMessage
|
||||
class ModifyAckDeadlineRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class PushConfig
|
||||
class ModifyPushConfigRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class TestIamPermissionsResponse
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class PullRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class ListSubscriptionsResponse
|
||||
class Policy
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
@@ -149,93 +83,69 @@ module Google
|
||||
end
|
||||
|
||||
class PublishResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :message_ids, as: 'messageIds'
|
||||
end
|
||||
end
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
class Subscription
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :topic, as: 'topic'
|
||||
property :push_config, as: 'pushConfig', class: Google::Apis::PubsubV1::PushConfig, decorator: Google::Apis::PubsubV1::PushConfig::Representation
|
||||
|
||||
property :ack_deadline_seconds, as: 'ackDeadlineSeconds'
|
||||
property :name, as: 'name'
|
||||
end
|
||||
end
|
||||
|
||||
class TestIamPermissionsRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :permissions, as: 'permissions'
|
||||
end
|
||||
end
|
||||
|
||||
class Policy
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :etag, :base64 => true, as: 'etag'
|
||||
property :version, as: 'version'
|
||||
collection :bindings, as: 'bindings', class: Google::Apis::PubsubV1::Binding, decorator: Google::Apis::PubsubV1::Binding::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class Topic
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :name, as: 'name'
|
||||
end
|
||||
end
|
||||
|
||||
class ModifyAckDeadlineRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :ack_deadline_seconds, as: 'ackDeadlineSeconds'
|
||||
collection :ack_ids, as: 'ackIds'
|
||||
end
|
||||
end
|
||||
|
||||
class SetIamPolicyRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :policy, as: 'policy', class: Google::Apis::PubsubV1::Policy, decorator: Google::Apis::PubsubV1::Policy::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class ModifyPushConfigRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :push_config, as: 'pushConfig', class: Google::Apis::PubsubV1::PushConfig, decorator: Google::Apis::PubsubV1::PushConfig::Representation
|
||||
|
||||
end
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Message
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :message_id, as: 'messageId'
|
||||
hash :attributes, as: 'attributes'
|
||||
property :publish_time, as: 'publishTime'
|
||||
property :data, :base64 => true, as: 'data'
|
||||
end
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Binding
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :role, as: 'role'
|
||||
collection :members, as: 'members'
|
||||
end
|
||||
class PullRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Empty
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
end
|
||||
class PullResponse
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class PushConfig
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class ReceivedMessage
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class SetIamPolicyRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Subscription
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class TestIamPermissionsRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class TestIamPermissionsResponse
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Topic
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class AcknowledgeRequest
|
||||
@@ -245,60 +155,17 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
class ListTopicsResponse
|
||||
class Binding
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :next_page_token, as: 'nextPageToken'
|
||||
collection :topics, as: 'topics', class: Google::Apis::PubsubV1::Topic, decorator: Google::Apis::PubsubV1::Topic::Representation
|
||||
|
||||
collection :members, as: 'members'
|
||||
property :role, as: 'role'
|
||||
end
|
||||
end
|
||||
|
||||
class ListTopicSubscriptionsResponse
|
||||
class Empty
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :next_page_token, as: 'nextPageToken'
|
||||
collection :subscriptions, as: 'subscriptions'
|
||||
end
|
||||
end
|
||||
|
||||
class PullResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :received_messages, as: 'receivedMessages', class: Google::Apis::PubsubV1::ReceivedMessage, decorator: Google::Apis::PubsubV1::ReceivedMessage::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class ReceivedMessage
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :ack_id, as: 'ackId'
|
||||
property :message, as: 'message', class: Google::Apis::PubsubV1::Message, decorator: Google::Apis::PubsubV1::Message::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class PushConfig
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
hash :attributes, as: 'attributes'
|
||||
property :push_endpoint, as: 'pushEndpoint'
|
||||
end
|
||||
end
|
||||
|
||||
class TestIamPermissionsResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :permissions, as: 'permissions'
|
||||
end
|
||||
end
|
||||
|
||||
class PullRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :return_immediately, as: 'returnImmediately'
|
||||
property :max_messages, as: 'maxMessages'
|
||||
end
|
||||
end
|
||||
|
||||
@@ -311,6 +178,49 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
class ListTopicSubscriptionsResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :next_page_token, as: 'nextPageToken'
|
||||
collection :subscriptions, as: 'subscriptions'
|
||||
end
|
||||
end
|
||||
|
||||
class ListTopicsResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :next_page_token, as: 'nextPageToken'
|
||||
collection :topics, as: 'topics', class: Google::Apis::PubsubV1::Topic, decorator: Google::Apis::PubsubV1::Topic::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class ModifyAckDeadlineRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :ack_deadline_seconds, as: 'ackDeadlineSeconds'
|
||||
collection :ack_ids, as: 'ackIds'
|
||||
end
|
||||
end
|
||||
|
||||
class ModifyPushConfigRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :push_config, as: 'pushConfig', class: Google::Apis::PubsubV1::PushConfig, decorator: Google::Apis::PubsubV1::PushConfig::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class Policy
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :bindings, as: 'bindings', class: Google::Apis::PubsubV1::Binding, decorator: Google::Apis::PubsubV1::Binding::Representation
|
||||
|
||||
property :etag, :base64 => true, as: 'etag'
|
||||
property :version, as: 'version'
|
||||
end
|
||||
end
|
||||
|
||||
class PublishRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
@@ -318,6 +228,96 @@ module Google
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class PublishResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :message_ids, as: 'messageIds'
|
||||
end
|
||||
end
|
||||
|
||||
class Message
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
hash :attributes, as: 'attributes'
|
||||
property :data, :base64 => true, as: 'data'
|
||||
property :message_id, as: 'messageId'
|
||||
property :publish_time, as: 'publishTime'
|
||||
end
|
||||
end
|
||||
|
||||
class PullRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :max_messages, as: 'maxMessages'
|
||||
property :return_immediately, as: 'returnImmediately'
|
||||
end
|
||||
end
|
||||
|
||||
class PullResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :received_messages, as: 'receivedMessages', class: Google::Apis::PubsubV1::ReceivedMessage, decorator: Google::Apis::PubsubV1::ReceivedMessage::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class PushConfig
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
hash :attributes, as: 'attributes'
|
||||
property :push_endpoint, as: 'pushEndpoint'
|
||||
end
|
||||
end
|
||||
|
||||
class ReceivedMessage
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :ack_id, as: 'ackId'
|
||||
property :message, as: 'message', class: Google::Apis::PubsubV1::Message, decorator: Google::Apis::PubsubV1::Message::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class SetIamPolicyRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :policy, as: 'policy', class: Google::Apis::PubsubV1::Policy, decorator: Google::Apis::PubsubV1::Policy::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class Subscription
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :ack_deadline_seconds, as: 'ackDeadlineSeconds'
|
||||
property :name, as: 'name'
|
||||
property :push_config, as: 'pushConfig', class: Google::Apis::PubsubV1::PushConfig, decorator: Google::Apis::PubsubV1::PushConfig::Representation
|
||||
|
||||
property :topic, as: 'topic'
|
||||
end
|
||||
end
|
||||
|
||||
class TestIamPermissionsRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :permissions, as: 'permissions'
|
||||
end
|
||||
end
|
||||
|
||||
class TestIamPermissionsResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :permissions, as: 'permissions'
|
||||
end
|
||||
end
|
||||
|
||||
class Topic
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :name, as: 'name'
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
File diff suppressed because it is too large.
Load diff
Reference in new issue
Block a user