Skip to content

Commit 5520722

Browse files
fix: increase streaming pull timeout (googleapis#32300)
* feat: Add irb as explicit dependency for Ruby 4.0 compatibility PiperOrigin-RevId: 885280435 Source-Link: googleapis/googleapis@f29d228 Source-Link: https://github.com/googleapis/googleapis-gen/commit/fca7136c1c0aa900ca4fa0a4ba14f1aeb29b0bfd Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiZmNhNzEzNmMxYzBhYTkwMGNhNGZhMGE0YmExNGYxYWViMjliMGJmZCJ9 feat: Update minimum Ruby to v3.2 and required dependencies for Ruby v4.0 PiperOrigin-RevId: 883373063 Source-Link: googleapis/googleapis@e1443bf Source-Link: https://github.com/googleapis/googleapis-gen/commit/8ecc70c2922cfc4649a0454bc8d2e1f3a58a9d78 Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiOGVjYzcwYzI5MjJjZmM0NjQ5YTA0NTRiYzhkMmUxZjNhNThhOWQ3OCJ9 feat: upgrade protobuf from v25.7 to v31.0 PiperOrigin-RevId: 881595129 Source-Link: googleapis/googleapis@d90d23f Source-Link: https://github.com/googleapis/googleapis-gen/commit/f1a94433664f8650a4acb73d609b943d2ecbb6e0 Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiZjFhOTQ0MzM2NjRmODY1MGE0YWNiNzNkNjA5Yjk0M2QyZWNiYjZlMCJ9 feat: Add BigtableConfig type PiperOrigin-RevId: 878685355 Source-Link: googleapis/googleapis@23ec7b6 Source-Link: https://github.com/googleapis/googleapis-gen/commit/823674a65881436b96d5fb92b73c5bc904f33dec Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiODIzNjc0YTY1ODgxNDM2Yjk2ZDVmYjkyYjczYzViYzkwNGYzM2RlYyJ9 feat: Add AIInference MessageTransform type docs: A comment for field `topic` in message `.google.pubsub.v1.Subscription` is updated docs: A comment for field `analytics_hub_subscription_info` in message `.google.pubsub.v1.Subscription` is updated docs: A comment for field `subscription` in message `.google.pubsub.v1.CreateSnapshotRequest` is updated PiperOrigin-RevId: 853856321 Source-Link: googleapis/googleapis@9fb55c4 Source-Link: https://github.com/googleapis/googleapis-gen/commit/8585165b2104f9e92040e5a9f2937b63bdbc0354 Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiODU4NTE2NWIyMTA0ZjllOTIwNDBlNWE5ZjI5MzdiNjNiZGJjMDM1NCJ9 feat: add custom prompt config in the request and return prompt in the response feat: update min_speaker_count and max_speaker_count to be optional docs: Clarify that min_speaker_count and max_speaker_count in SpeakerDiarizationConfig are not currently used docs: Update guidance on how to enable speaker diarization; to enable, set the diarization_config field to an empty SpeakerDiarizationConfig message PiperOrigin-RevId: 852383212 Source-Link: googleapis/googleapis@1a14153 Source-Link: https://github.com/googleapis/googleapis-gen/commit/c84243caa11c7fc89056e0bd07b4c4c6aea0510b Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiYzg0MjQzY2FhMTFjN2ZjODkwNTZlMGJkMDdiNGM0YzZhZWEwNTEwYiJ9 docs: add tags documentation links to Pub/Sub resource tags fields PiperOrigin-RevId: 845891076 Source-Link: googleapis/googleapis@ff251e7 Source-Link: https://github.com/googleapis/googleapis-gen/commit/639aa15bac1ad9d72131c487fb9d592bbeeac692 Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiNjM5YWExNWJhYzFhZDlkNzIxMzFjNDg3ZmI5ZDU5MmJiZWVhYzY5MiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: publish client batch config schema feat: publish new error reasons docs: fix documentation formatting docs: update various comments docs: update license year PiperOrigin-RevId: 889289393 Source-Link: googleapis/googleapis@94bc991 Source-Link: https://github.com/googleapis/googleapis-gen/commit/db7143a338a7c75839b4698cb3ea6f1013b4c3c7 Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiZGI3MTQzYTMzOGE3Yzc1ODM5YjQ2OThjYjNlYTZmMTAxM2I0YzNjNyJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * docs: update SelectiveGapicGeneration usage doc PiperOrigin-RevId: 892649773 Source-Link: googleapis/googleapis@06a20b2 Source-Link: https://github.com/googleapis/googleapis-gen/commit/d9ae66451f81c9df99dbdc9b23bd75d007380f4e Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiZDlhZTY2NDUxZjgxYzlkZjk5ZGJkYzliMjNiZDc1ZDAwNzM4MGY0ZSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * docs: Fix documentation URL AIInference MessageTransform service_account_email field PiperOrigin-RevId: 895485801 Source-Link: googleapis/googleapis@afb6d4b Source-Link: https://github.com/googleapis/googleapis-gen/commit/052d9ab506341bbefaef788cc84eb355c745d046 Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiMDUyZDlhYjUwNjM0MWJiZWZhZWY3ODhjYzg0ZWIzNTVjNzQ1ZDA0NiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * fix: increase streaming pull timeout PiperOrigin-RevId: 899201961 Source-Link: googleapis/googleapis@8c6e404 Source-Link: https://github.com/googleapis/googleapis-gen/commit/89c64c250a302e6475b438fb414c4b8762b1cb09 Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLXB1YnN1Yi12MS8uT3dsQm90LnlhbWwiLCJoIjoiODljNjRjMjUwYTMwMmU2NDc1YjQzOGZiNDE0YzRiODc2MmIxY2IwOSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent d660c6a commit 5520722

12 files changed

Lines changed: 470 additions & 123 deletions

File tree

google-cloud-pubsub-v1/.owlbot-manifest.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@
4040
"proto_docs/google/protobuf/duration.rb",
4141
"proto_docs/google/protobuf/empty.rb",
4242
"proto_docs/google/protobuf/field_mask.rb",
43+
"proto_docs/google/protobuf/struct.rb",
4344
"proto_docs/google/protobuf/timestamp.rb",
4445
"proto_docs/google/pubsub/v1/pubsub.rb",
4546
"proto_docs/google/pubsub/v1/schema.rb",

google-cloud-pubsub-v1/Gemfile

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,13 @@ source "https://rubygems.org"
22

33
gemspec
44

5-
gem "google-style", "~> 1.31.1"
6-
gem "minitest", "~> 5.22"
5+
gem "google-style", "~> 1.32.0"
6+
gem "irb", "~> 1.17"
7+
gem "minitest", "~> 6.0.2"
78
gem "minitest-focus", "~> 1.4"
9+
gem "minitest-mock", "~> 5.27"
810
gem "minitest-rg", "~> 5.3"
11+
gem "ostruct", "~> 0.5.5"
912
gem "rake", ">= 13.0"
1013
gem "redcarpet", "~> 3.6"
1114
gem "yard", "~> 0.9"

google-cloud-pubsub-v1/google-cloud-pubsub-v1.gemspec

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ Gem::Specification.new do |gem|
2121
["README.md", "LICENSE.md", "AUTHENTICATION.md", ".yardopts"]
2222
gem.require_paths = ["lib"]
2323

24-
gem.required_ruby_version = ">= 3.1"
24+
gem.required_ruby_version = ">= 3.2"
2525

2626
gem.add_dependency "gapic-common", "~> 1.2"
2727
gem.add_dependency "google-cloud-errors", "~> 1.0"

google-cloud-pubsub-v1/lib/google/cloud/pubsub/v1/subscription_admin/client.rb

Lines changed: 20 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ def self.configure
113113
initial_delay: 0.1, max_delay: 60.0, multiplier: 1.3, retry_codes: [2, 10, 14, 13]
114114
}
115115

116-
default_config.rpcs.streaming_pull.timeout = 900.0
116+
default_config.rpcs.streaming_pull.timeout = 1800.0
117117
default_config.rpcs.streaming_pull.retry_policy = {
118118
initial_delay: 0.1, max_delay: 60.0, multiplier: 4, retry_codes: [4, 8, 10, 13, 14]
119119
}
@@ -304,7 +304,7 @@ def logger
304304
# @param options [::Gapic::CallOptions, ::Hash]
305305
# Overrides the default settings for this call, e.g, timeout, retries, etc. Optional.
306306
#
307-
# @overload create_subscription(name: nil, topic: nil, push_config: nil, bigquery_config: nil, cloud_storage_config: nil, ack_deadline_seconds: nil, retain_acked_messages: nil, message_retention_duration: nil, labels: nil, enable_message_ordering: nil, expiration_policy: nil, filter: nil, dead_letter_policy: nil, retry_policy: nil, detached: nil, enable_exactly_once_delivery: nil, message_transforms: nil, tags: nil)
307+
# @overload create_subscription(name: nil, topic: nil, push_config: nil, bigquery_config: nil, cloud_storage_config: nil, bigtable_config: nil, ack_deadline_seconds: nil, retain_acked_messages: nil, message_retention_duration: nil, labels: nil, enable_message_ordering: nil, expiration_policy: nil, filter: nil, dead_letter_policy: nil, retry_policy: nil, detached: nil, enable_exactly_once_delivery: nil, message_transforms: nil, tags: nil)
308308
# Pass arguments to `create_subscription` via keyword arguments. Note that at
309309
# least one keyword argument is required. To specify no parameters, or to keep all
310310
# the default parameter values, pass an empty Hash as a request object (see above).
@@ -329,6 +329,9 @@ def logger
329329
# @param cloud_storage_config [::Google::Cloud::PubSub::V1::CloudStorageConfig, ::Hash]
330330
# Optional. If delivery to Google Cloud Storage is used with this
331331
# subscription, this field is used to configure it.
332+
# @param bigtable_config [::Google::Cloud::PubSub::V1::BigtableConfig, ::Hash]
333+
# Optional. If delivery to Bigtable is used with this subscription, this
334+
# field is used to configure it.
332335
# @param ack_deadline_seconds [::Integer]
333336
# Optional. The approximate amount of time (on a best-effort basis) Pub/Sub
334337
# waits for the subscriber to acknowledge receipt before resending the
@@ -429,6 +432,8 @@ def logger
429432
# resource. For example:
430433
# "123/environment": "production",
431434
# "123/costCenter": "marketing"
435+
# See https://docs.cloud.google.com/pubsub/docs/tags for more information on
436+
# using tags with Pub/Sub resources.
432437
#
433438
# @yield [response, operation] Access the result along with the RPC operation
434439
# @yieldparam response [::Google::Cloud::PubSub::V1::Subscription]
@@ -513,7 +518,7 @@ def create_subscription request, options = nil
513518
# the default parameter values, pass an empty Hash as a request object (see above).
514519
#
515520
# @param subscription [::String]
516-
# Required. Identifier. The name of the subscription to get.
521+
# Required. The name of the subscription to get.
517522
# Format is `projects/{project}/subscriptions/{sub}`.
518523
#
519524
# @yield [response, operation] Access the result along with the RPC operation
@@ -689,8 +694,8 @@ def update_subscription request, options = nil
689694
# the default parameter values, pass an empty Hash as a request object (see above).
690695
#
691696
# @param project [::String]
692-
# Required. Identifier. The name of the project in which to list
693-
# subscriptions. Format is `projects/{project-id}`.
697+
# Required. The name of the project in which to list subscriptions.
698+
# Format is `projects/{project-id}`.
694699
# @param page_size [::Integer]
695700
# Optional. Maximum number of subscriptions to return.
696701
# @param page_token [::String]
@@ -791,7 +796,7 @@ def list_subscriptions request, options = nil
791796
# the default parameter values, pass an empty Hash as a request object (see above).
792797
#
793798
# @param subscription [::String]
794-
# Required. Identifier. The subscription to delete.
799+
# Required. The subscription to delete.
795800
# Format is `projects/{project}/subscriptions/{sub}`.
796801
#
797802
# @yield [response, operation] Access the result along with the RPC operation
@@ -1359,7 +1364,7 @@ def modify_push_config request, options = nil
13591364
# the default parameter values, pass an empty Hash as a request object (see above).
13601365
#
13611366
# @param snapshot [::String]
1362-
# Required. Identifier. The name of the snapshot to get.
1367+
# Required. The name of the snapshot to get.
13631368
# Format is `projects/{project}/snapshots/{snap}`.
13641369
#
13651370
# @yield [response, operation] Access the result along with the RPC operation
@@ -1449,7 +1454,7 @@ def get_snapshot request, options = nil
14491454
# the default parameter values, pass an empty Hash as a request object (see above).
14501455
#
14511456
# @param project [::String]
1452-
# Required. Identifier. The name of the project in which to list snapshots.
1457+
# Required. The name of the project in which to list snapshots.
14531458
# Format is `projects/{project-id}`.
14541459
# @param page_size [::Integer]
14551460
# Optional. Maximum number of snapshots to return.
@@ -1562,10 +1567,10 @@ def list_snapshots request, options = nil
15621567
# the default parameter values, pass an empty Hash as a request object (see above).
15631568
#
15641569
# @param name [::String]
1565-
# Required. Identifier. User-provided name for this snapshot. If the name is
1566-
# not provided in the request, the server will assign a random name for this
1567-
# snapshot on the same project as the subscription. Note that for REST API
1568-
# requests, you must specify a name. See the [resource name
1570+
# Required. User-provided name for this snapshot. If the name is not provided
1571+
# in the request, the server will assign a random name for this snapshot on
1572+
# the same project as the subscription. Note that for REST API requests, you
1573+
# must specify a name. See the [resource name
15691574
# rules](https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
15701575
# Format is `projects/{project}/snapshots/{snap}`.
15711576
# @param subscription [::String]
@@ -1586,6 +1591,8 @@ def list_snapshots request, options = nil
15861591
# resource. For example:
15871592
# "123/environment": "production",
15881593
# "123/costCenter": "marketing"
1594+
# See https://docs.cloud.google.com/pubsub/docs/tags for more information on
1595+
# using tags with Pub/Sub resources.
15891596
#
15901597
# @yield [response, operation] Access the result along with the RPC operation
15911598
# @yieldparam response [::Google::Cloud::PubSub::V1::Snapshot]
@@ -1771,7 +1778,7 @@ def update_snapshot request, options = nil
17711778
# the default parameter values, pass an empty Hash as a request object (see above).
17721779
#
17731780
# @param snapshot [::String]
1774-
# Required. Identifier. The name of the snapshot to delete.
1781+
# Required. The name of the snapshot to delete.
17751782
# Format is `projects/{project}/snapshots/{snap}`.
17761783
#
17771784
# @yield [response, operation] Access the result along with the RPC operation

google-cloud-pubsub-v1/lib/google/cloud/pubsub/v1/topic_admin/client.rb

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -308,6 +308,8 @@ def logger
308308
# resource. For example:
309309
# "123/environment": "production",
310310
# "123/costCenter": "marketing"
311+
# See https://docs.cloud.google.com/pubsub/docs/tags for more information on
312+
# using tags with Pub/Sub resources.
311313
#
312314
# @yield [response, operation] Access the result along with the RPC operation
313315
# @yieldparam response [::Google::Cloud::PubSub::V1::Topic]
@@ -485,8 +487,8 @@ def update_topic request, options = nil
485487
# the default parameter values, pass an empty Hash as a request object (see above).
486488
#
487489
# @param topic [::String]
488-
# Required. Identifier. The messages in the request will be published on this
489-
# topic. Format is `projects/{project}/topics/{topic}`.
490+
# Required. The messages in the request will be published on this topic.
491+
# Format is `projects/{project}/topics/{topic}`.
490492
# @param messages [::Array<::Google::Cloud::PubSub::V1::PubsubMessage, ::Hash>]
491493
# Required. The messages to publish.
492494
#
@@ -573,7 +575,7 @@ def publish request, options = nil
573575
# the default parameter values, pass an empty Hash as a request object (see above).
574576
#
575577
# @param topic [::String]
576-
# Required. Identifier. The name of the topic to get.
578+
# Required. The name of the topic to get.
577579
# Format is `projects/{project}/topics/{topic}`.
578580
#
579581
# @yield [response, operation] Access the result along with the RPC operation
@@ -659,7 +661,7 @@ def get_topic request, options = nil
659661
# the default parameter values, pass an empty Hash as a request object (see above).
660662
#
661663
# @param project [::String]
662-
# Required. Identifier. The name of the project in which to list topics.
664+
# Required. The name of the project in which to list topics.
663665
# Format is `projects/{project-id}`.
664666
# @param page_size [::Integer]
665667
# Optional. Maximum number of topics to return.
@@ -949,7 +951,7 @@ def list_topic_snapshots request, options = nil
949951
# the default parameter values, pass an empty Hash as a request object (see above).
950952
#
951953
# @param topic [::String]
952-
# Required. Identifier. Name of the topic to delete.
954+
# Required. Name of the topic to delete.
953955
# Format is `projects/{project}/topics/{topic}`.
954956
#
955957
# @yield [response, operation] Access the result along with the RPC operation

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

Lines changed: 8 additions & 27 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

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

Lines changed: 2 additions & 24 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)