chore(pubsub): Update network publish timeout in lower-level client

google-cloud-pubsub/lib/google/cloud/pubsub/v1/doc/google/pubsub/v1/pubsub.rb

@@ -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
@@ -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
@@ -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.
@@ -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]
@@ -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]
@@ -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.
@@ -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]
@@ -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
@@ -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]
@@ -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
@@ -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
@@ -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
 
@@ -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}`.
@@ -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).
@@ -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
@@ -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
 
@@ -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]
@@ -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.

google-cloud-pubsub/lib/google/cloud/pubsub/v1/publisher_client.rb

@@ -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
@@ -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
@@ -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]
@@ -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,
@@ -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
@@ -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
@@ -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,
@@ -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.
@@ -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.
@@ -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.

google-cloud-pubsub/lib/google/cloud/pubsub/v1/publisher_client_config.json

@@ -53,7 +53,7 @@
           "retry_params_name": "default"
         },
         "Publish": {
-          "timeout_millis": 60000,
+          "timeout_millis": 20000,
           "retry_codes_name": "publish",
           "retry_params_name": "messaging",
           "bundling": {