Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[CHANGE ME] Re-generated google-cloud-pubsub to pick up changes in the API or client library generator. #4828

Merged
merged 1 commit into from Feb 17, 2020
Merged

[CHANGE ME] Re-generated google-cloud-pubsub to pick up changes in the API or client library generator. #4828

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
72 changes: 36 additions & 36 deletions google-cloud-pubsub/lib/google/cloud/pubsub/v1/doc/google/pubsub/v1/pubsub.rb
View file
Open in desktop
Expand Up @@ -29,7 +29,7 @@ class MessageStoragePolicy; end
# A topic resource.
# @!attribute [rw] name
# @return [String]
# The name of the topic. It must have the format
# Required. 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
Expand Down Expand Up @@ -95,17 +95,17 @@ class PubsubMessage; end
# Request for the GetTopic method.
# @!attribute [rw] topic
# @return [String]
# The name of the topic to get.
# Required. The name of the topic to get.
# Format is `projects/{project}/topics/{topic}`.
class GetTopicRequest; end

# Request for the UpdateTopic method.
# @!attribute [rw] topic
# @return [Google::Cloud::PubSub::V1::Topic]
# The updated topic object.
# Required. The updated topic object.
# @!attribute [rw] update_mask
# @return [Google::Protobuf::FieldMask]
# Indicates which fields in the provided topic to update. Must be specified
# Required. Indicates which fields in the provided topic to update. Must be specified
# and non-empty. Note that if `update_mask` contains
# "message_storage_policy" then the new value will be determined based on the
# policy configured at the project or organization level. The
Expand All @@ -115,11 +115,11 @@ class UpdateTopicRequest; end
# Request for the Publish method.
# @!attribute [rw] topic
# @return [String]
# The messages in the request will be published on this topic.
# Required. The messages in the request will be published on this topic.
# Format is `projects/{project}/topics/{topic}`.
# @!attribute [rw] messages
# @return [Array<Google::Cloud::PubSub::V1::PubsubMessage>]
# The messages to publish.
# Required. The messages to publish.
class PublishRequest; end

# Response for the `Publish` method.
Expand All @@ -133,7 +133,7 @@ class PublishResponse; end
# Request for the `ListTopics` method.
# @!attribute [rw] project
# @return [String]
# The name of the project in which to list topics.
# Required. The name of the project in which to list topics.
# Format is `projects/{project-id}`.
# @!attribute [rw] page_size
# @return [Integer]
Expand All @@ -158,7 +158,7 @@ class ListTopicsResponse; end
# Request for the `ListTopicSubscriptions` method.
# @!attribute [rw] topic
# @return [String]
# The name of the topic that subscriptions are attached to.
# Required. The name of the topic that subscriptions are attached to.
# Format is `projects/{project}/topics/{topic}`.
# @!attribute [rw] page_size
# @return [Integer]
Expand Down Expand Up @@ -210,22 +210,22 @@ class ListTopicSnapshotsResponse; end
# Request for the `DeleteTopic` method.
# @!attribute [rw] topic
# @return [String]
# Name of the topic to delete.
# Required. Name of the topic to delete.
# Format is `projects/{project}/topics/{topic}`.
class DeleteTopicRequest; end

# A subscription resource.
# @!attribute [rw] name
# @return [String]
# The name of the subscription. It must have the format
# Required. 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"`
# in length, and it must not start with `"goog"`.
# @!attribute [rw] topic
# @return [String]
# The name of the topic from which this subscription is receiving messages.
# Required. 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.
Expand Down Expand Up @@ -438,24 +438,24 @@ class ReceivedMessage; end
# Request for the GetSubscription method.
# @!attribute [rw] subscription
# @return [String]
# The name of the subscription to get.
# Required. The name of the subscription to get.
# Format is `projects/{project}/subscriptions/{sub}`.
class GetSubscriptionRequest; end

# Request for the UpdateSubscription method.
# @!attribute [rw] subscription
# @return [Google::Cloud::PubSub::V1::Subscription]
# The updated subscription object.
# Required. The updated subscription object.
# @!attribute [rw] update_mask
# @return [Google::Protobuf::FieldMask]
# Indicates which fields in the provided subscription to update.
# Required. Indicates which fields in the provided subscription to update.
# Must be specified and non-empty.
class UpdateSubscriptionRequest; end

# Request for the `ListSubscriptions` method.
# @!attribute [rw] project
# @return [String]
# The name of the project in which to list subscriptions.
# Required. The name of the project in which to list subscriptions.
# Format is `projects/{project-id}`.
# @!attribute [rw] page_size
# @return [Integer]
Expand All @@ -481,18 +481,18 @@ class ListSubscriptionsResponse; end
# Request for the DeleteSubscription method.
# @!attribute [rw] subscription
# @return [String]
# The subscription to delete.
# Required. The subscription to delete.
# Format is `projects/{project}/subscriptions/{sub}`.
class DeleteSubscriptionRequest; end

# Request for the ModifyPushConfig method.
# @!attribute [rw] subscription
# @return [String]
# The name of the subscription.
# Required. The name of the subscription.
# Format is `projects/{project}/subscriptions/{sub}`.
# @!attribute [rw] push_config
# @return [Google::Cloud::PubSub::V1::PushConfig]
# The push configuration for future deliveries.
# Required. The push configuration for future deliveries.
#
# An empty `pushConfig` indicates that the Pub/Sub system should
# stop pushing messages from the given subscription and allow
Expand All @@ -503,7 +503,7 @@ class ModifyPushConfigRequest; end
# Request for the `Pull` method.
# @!attribute [rw] subscription
# @return [String]
# The subscription from which messages should be pulled.
# Required. The subscription from which messages should be pulled.
# Format is `projects/{project}/subscriptions/{sub}`.
# @!attribute [rw] return_immediately
# @return [true, false]
Expand All @@ -513,7 +513,7 @@ class ModifyPushConfigRequest; end
# least one message is available, rather than returning no messages.
# @!attribute [rw] max_messages
# @return [Integer]
# The maximum number of messages to return for this request. Must be a
# Required. The maximum number of messages to return for this request. Must be a
# positive integer. The Pub/Sub system may return fewer than the number
# specified.
class PullRequest; end
Expand All @@ -530,14 +530,14 @@ class PullResponse; end
# Request for the ModifyAckDeadline method.
# @!attribute [rw] subscription
# @return [String]
# The name of the subscription.
# Required. The name of the subscription.
# Format is `projects/{project}/subscriptions/{sub}`.
# @!attribute [rw] ack_ids
# @return [Array<String>]
# List of acknowledgment IDs.
# Required. List of acknowledgment IDs.
# @!attribute [rw] ack_deadline_seconds
# @return [Integer]
# The new ack deadline with respect to the time this request was sent to
# Required. 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 might immediately make the message available for
Expand All @@ -550,11 +550,11 @@ class ModifyAckDeadlineRequest; end
# Request for the Acknowledge method.
# @!attribute [rw] subscription
# @return [String]
# The subscription whose message is being acknowledged.
# Required. The subscription whose message is being acknowledged.
# Format is `projects/{project}/subscriptions/{sub}`.
# @!attribute [rw] ack_ids
# @return [Array<String>]
# The acknowledgment ID for the messages being acknowledged that was returned
# Required. The acknowledgment ID for the messages being acknowledged that was returned
# by the Pub/Sub system in the `Pull` response. Must not be empty.
class AcknowledgeRequest; end

Expand All @@ -563,7 +563,7 @@ class AcknowledgeRequest; end
# deadline modifications from the client to the server.
# @!attribute [rw] subscription
# @return [String]
# The subscription for which to initialize the new stream. This must be
# Required. The subscription for which to initialize the new stream. This must be
# provided in the first request on the stream, and must not be set in
# subsequent requests from client to server.
# Format is `projects/{project}/subscriptions/{sub}`.
Expand Down Expand Up @@ -596,7 +596,7 @@ class AcknowledgeRequest; end
# processing was interrupted.
# @!attribute [rw] stream_ack_deadline_seconds
# @return [Integer]
# The ack deadline to use for the stream. This must be provided in the
# Required. The ack deadline to use for the stream. This must be provided in the
# first request on the stream, but it can also be updated on subsequent
# requests from client to server. The minimum deadline you can specify is 10
# seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
Expand All @@ -620,15 +620,15 @@ class StreamingPullResponse; end
# Request for the `CreateSnapshot` method.
# @!attribute [rw] name
# @return [String]
# User-provided name for this snapshot. If the name is not provided in the
# Required. User-provided name for this snapshot. If the name is not provided in the
# request, the server will assign a random name for this snapshot on the same
# project as the subscription. Note that for REST API requests, you must
# specify a name. See the <a
# href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource
# name rules</a>. Format is `projects/{project}/snapshots/{snap}`.
# @!attribute [rw] subscription
# @return [String]
# The subscription whose backlog the snapshot retains.
# Required. The subscription whose backlog the snapshot retains.
# Specifically, the created snapshot is guaranteed to retain:
# (a) The existing backlog on the subscription. More precisely, this is
# defined as the messages in the subscription's backlog that are
Expand All @@ -646,10 +646,10 @@ class CreateSnapshotRequest; end
# Request for the UpdateSnapshot method.
# @!attribute [rw] snapshot
# @return [Google::Cloud::PubSub::V1::Snapshot]
# The updated snapshot object.
# Required. The updated snapshot object.
# @!attribute [rw] update_mask
# @return [Google::Protobuf::FieldMask]
# Indicates which fields in the provided snapshot to update.
# Required. Indicates which fields in the provided snapshot to update.
# Must be specified and non-empty.
class UpdateSnapshotRequest; end

Expand Down Expand Up @@ -686,14 +686,14 @@ class Snapshot; end
# Request for the GetSnapshot method.
# @!attribute [rw] snapshot
# @return [String]
# The name of the snapshot to get.
# Required. The name of the snapshot to get.
# Format is `projects/{project}/snapshots/{snap}`.
class GetSnapshotRequest; end

# Request for the `ListSnapshots` method.
# @!attribute [rw] project
# @return [String]
# The name of the project in which to list snapshots.
# Required. The name of the project in which to list snapshots.
# Format is `projects/{project-id}`.
# @!attribute [rw] page_size
# @return [Integer]
Expand All @@ -718,14 +718,14 @@ class ListSnapshotsResponse; end
# Request for the `DeleteSnapshot` method.
# @!attribute [rw] snapshot
# @return [String]
# The name of the snapshot to delete.
# Required. The name of the snapshot to delete.
# Format is `projects/{project}/snapshots/{snap}`.
class DeleteSnapshotRequest; end

# Request for the `Seek` method.
# @!attribute [rw] subscription
# @return [String]
# The subscription to affect.
# Required. The subscription to affect.
# @!attribute [rw] time
# @return [Google::Protobuf::Timestamp]
# The time to seek to.
Expand Down
40 changes: 21 additions & 19 deletions google-cloud-pubsub/lib/google/cloud/pubsub/v1/publisher_client.rb
View file
Open in desktop
Expand Up @@ -330,7 +330,7 @@ def initialize \
# resource name rules</a>.
#
# @param name [String]
# The name of the topic. It must have the format
# Required. 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
Expand Down Expand Up @@ -386,11 +386,11 @@ def create_topic \
# topic are not modifiable.
#
# @param topic [Google::Cloud::PubSub::V1::Topic | Hash]
# The updated topic object.
# Required. The updated topic object.
# A hash of the same form as `Google::Cloud::PubSub::V1::Topic`
# can also be provided.
# @param update_mask [Google::Protobuf::FieldMask | Hash]
# Indicates which fields in the provided topic to update. Must be specified
# Required. Indicates which fields in the provided topic to update. Must be specified
# and non-empty. Note that if `update_mask` contains
# "message_storage_policy" then the new value will be determined based on the
# policy configured at the project or organization level. The
Expand Down Expand Up @@ -434,10 +434,10 @@ def update_topic \
# does not exist.
#
# @param topic [String]
# The messages in the request will be published on this topic.
# Required. The messages in the request will be published on this topic.
# Format is `projects/{project}/topics/{topic}`.
# @param messages [Array<Google::Cloud::PubSub::V1::PubsubMessage | Hash>]
# The messages to publish.
# Required. The messages to publish.
# A hash of the same form as `Google::Cloud::PubSub::V1::PubsubMessage`
# can also be provided.
# @param options [Google::Gax::CallOptions]
Expand Down Expand Up @@ -474,7 +474,7 @@ def publish \
# Gets the configuration of a topic.
#
# @param topic [String]
# The name of the topic to get.
# Required. The name of the topic to get.
# Format is `projects/{project}/topics/{topic}`.
# @param options [Google::Gax::CallOptions]
# Overrides the default settings for this call, e.g, timeout,
Expand Down Expand Up @@ -505,7 +505,7 @@ def get_topic \
# Lists matching topics.
#
# @param project [String]
# The name of the project in which to list topics.
# Required. The name of the project in which to list topics.
# Format is `projects/{project-id}`.
# @param page_size [Integer]
# The maximum number of resources contained in the underlying API
Expand Down Expand Up @@ -560,7 +560,7 @@ def list_topics \
# Lists the names of the subscriptions on this topic.
#
# @param topic [String]
# The name of the topic that subscriptions are attached to.
# Required. The name of the topic that subscriptions are attached to.
# Format is `projects/{project}/topics/{topic}`.
# @param page_size [Integer]
# The maximum number of resources contained in the underlying API
Expand Down Expand Up @@ -619,7 +619,7 @@ def list_topic_subscriptions \
# not deleted, but their `topic` field is set to `_deleted-topic_`.
#
# @param topic [String]
# Name of the topic to delete.
# Required. Name of the topic to delete.
# Format is `projects/{project}/topics/{topic}`.
# @param options [Google::Gax::CallOptions]
# Overrides the default settings for this call, e.g, timeout,
Expand Down Expand Up @@ -647,8 +647,11 @@ def delete_topic \
nil
end

# Sets the access control policy on the specified resource. Replaces any
# existing policy.
# Sets the access control policy on the specified resource. Replaces
# any existing policy.
#
# Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and
# PERMISSION_DENIED
#
# @param resource [String]
# REQUIRED: The resource for which the policy is being specified.
Expand Down Expand Up @@ -691,9 +694,8 @@ def set_iam_policy \
@set_iam_policy.call(req, options, &block)
end

# Gets the access control policy for a resource.
# Returns an empty policy if the resource exists and does not have a policy
# set.
# Gets the access control policy for a resource. Returns an empty policy
# if the resource exists and does not have a policy set.
#
# @param resource [String]
# REQUIRED: The resource for which the policy is being requested.
Expand Down Expand Up @@ -731,13 +733,13 @@ def get_iam_policy \
@get_iam_policy.call(req, options, &block)
end

# Returns permissions that a caller has on the specified resource.
# If the resource does not exist, this will return an empty set of
# Returns permissions that a caller has on the specified resource. If the
# resource does not exist, this will return an empty set of
# permissions, not a NOT_FOUND error.
#
# Note: This operation is designed to be used for building permission-aware
# UIs and command-line tools, not for authorization checking. This operation
# may "fail open" without warning.
# Note: This operation is designed to be used for building
# permission-aware UIs and command-line tools, not for authorization
# checking. This operation may "fail open" without warning.
#
# @param resource [String]
# REQUIRED: The resource for which the policy detail is being requested.
Expand Down
2 changes: 1 addition & 1 deletion google-cloud-pubsub/lib/google/cloud/pubsub/v1/publisher_client_config.json
View file
Open in desktop
Expand Up @@ -53,7 +53,7 @@
"retry_params_name": "default"
},
"Publish": {
"timeout_millis": 60000,
"timeout_millis": 20000,
"retry_codes_name": "publish",
"retry_params_name": "messaging",
"bundling": {
Expand Down