chore(pubsub): white space changes and column restriction to 80

cy-yun · cy-yun · commit 9aafea67ce5c · 2025-08-05T14:14:35.000-07:00
diff --git a/google-cloud-pubsub/samples/pubsub_commit_avro_schema.rb b/google-cloud-pubsub/samples/pubsub_commit_avro_schema.rb
@@ -20,19 +20,17 @@ def commit_avro_schema schema_id:, avsc_file:
   # avsc_file = "path/to/a/avsc_file.avsc"
 
   pubsub = Google::Cloud::Pubsub.new
-
   schemas = pubsub.schemas
 
   schema = schemas.get_schema name: pubsub.schema_path(schema_id)
 
   definition = File.read avsc_file
-
   schema.definition = definition
 
   result = schemas.commit_schema name: schema.name,
                                  schema: schema
 
   puts "Schema commited with revision #{result.revision_id}."
-  result
   # [END pubsub_commit_avro_schema]
+  result
 end
diff --git a/google-cloud-pubsub/samples/pubsub_create_proto_schema.rb b/google-cloud-pubsub/samples/pubsub_create_proto_schema.rb
@@ -20,14 +20,13 @@ def create_proto_schema schema_id:, proto_file:
   # proto_file = "path/to/a/proto/file/(.proto)/formatted/in/protocol/buffers"
 
   pubsub = Google::Cloud::PubSub.new
+  schemas = pubsub.schemas
 
   definition = File.read proto_file
   schema = Google::Cloud::PubSub::V1::Schema.new name: schema_id,
                                                  type: :PROTOCOL_BUFFER,
                                                  definition: definition
 
-  schemas = pubsub.schemas
-
   schema = schemas.create_schema parent: pubsub.project_path,
                                  schema: schema,
                                  schema_id: schema_id
diff --git a/google-cloud-pubsub/samples/pubsub_create_topic_with_aws_msk_ingestion.rb b/google-cloud-pubsub/samples/pubsub_create_topic_with_aws_msk_ingestion.rb
@@ -14,15 +14,19 @@
 
 require "google/cloud/pubsub"
 
-def create_topic_with_aws_msk_ingestion topic_id:, cluster_arn:, msk_topic:, aws_role_arn:, gcp_service_account:
+def create_topic_with_aws_msk_ingestion topic_id:,
+                                        cluster_arn:,
+                                        msk_topic:,
+                                        aws_role_arn:,
+                                        gcp_service_account:
   # [START pubsub_create_topic_with_aws_msk_ingestion]
   # topic_id = "your-topic-id"
-  # cluster_arn = "arn:aws:kafka:us-east-1:111111111111:cluster/cluster-name/11111111-1111-1"
+  # cluster_arn = "arn:aws:kafka:us-east-1:111111111111:" \
+  #               "cluster/cluster-name/11111111-1111-1"
   # msk_topic = "msk-topic-name"
   # aws_role_arn = "arn:aws:iam::111111111111:role/role-name"
   # gcp_service_account = "service-account@project.iam.gserviceaccount.com"
   pubsub = Google::Cloud::Pubsub.new
-
   topic_admin = pubsub.topic_admin
 
   topic = topic_admin.create_topic name: pubsub.topic_path(topic_id),
diff --git a/google-cloud-pubsub/samples/pubsub_create_topic_with_azure_event_hubs_ingestion.rb b/google-cloud-pubsub/samples/pubsub_create_topic_with_azure_event_hubs_ingestion.rb
@@ -14,8 +14,14 @@
 
 require "google/cloud/pubsub"
 
-def create_topic_with_azure_event_hubs_ingestion topic_id:, resource_group:, namespace:, event_hub:, client_id:,
-                                                 tenant_id:, subscription_id:, gcp_service_account:
+def create_topic_with_azure_event_hubs_ingestion topic_id:,
+                                                 resource_group:,
+                                                 namespace:,
+                                                 event_hub:,
+                                                 client_id:,
+                                                 tenant_id:,
+                                                 subscription_id:,
+                                                 gcp_service_account:
   # [START pubsub_create_topic_with_azure_event_hubs_ingestion]
   # topic_id = "your-topic-id"
   # resource_group = "resource-group"
diff --git a/google-cloud-pubsub/samples/pubsub_create_topic_with_cloud_storage_ingestion.rb b/google-cloud-pubsub/samples/pubsub_create_topic_with_cloud_storage_ingestion.rb
@@ -14,7 +14,11 @@
 
 require "google/cloud/pubsub"
 
-def create_topic_with_cloud_storage_ingestion topic_id:, bucket:, input_format:, text_delimiter:, match_glob:,
+def create_topic_with_cloud_storage_ingestion topic_id:,
+                                              bucket:,
+                                              input_format:,
+                                              text_delimiter:,
+                                              match_glob:,
                                               minimum_object_create_time:
   # [START pubsub_create_topic_with_cloud_storage_ingestion]
   # topic_id = "your-topic-id"
@@ -24,33 +28,34 @@ def create_topic_with_cloud_storage_ingestion topic_id:, bucket:, input_format:,
   # match_glob = "**.txt"
   # minimum_object_create_time = Google::Protobuf::Timestamp.new
   pubsub = Google::Cloud::Pubsub.new
-
   topic_admin = pubsub.topic_admin
-
   cloud_storage =
-    Google::Cloud::PubSub::V1::IngestionDataSourceSettings::CloudStorage.new bucket: bucket,
-                                                                             minimum_object_create_time:
-                                                                             minimum_object_create_time
+    Google::Cloud::PubSub::V1::IngestionDataSourceSettings::CloudStorage
+
+  settings = cloud_storage.new \
+    bucket: bucket,
+    minimum_object_create_time: minimum_object_create_time
 
   case input_format
   when "text"
-    cloud_storage.text_format =
-      Google::Cloud::PubSub::V1::IngestionDataSourceSettings::CloudStorage::TextFormat.new delimiter: text_delimiter
+    settings.text_format = cloud_storage::TextFormat.new \
+      delimiter: text_delimiter
   when "avro"
-    cloud_storage.avro_format = Google::Cloud::PubSub::V1::IngestionDataSourceSettings::CloudStorage::AvroFormat.new
+    settings.avro_format = cloud_storage::AvroFormat.new
   when "pubsub_avro"
-    cloud_storage.pubsub_avro_format = Google::Cloud::PubSub::V1::IngestionDataSourceSettings::CloudStorage::PubSubAvroFormat.new
+    settings.pubsub_avro_format = cloud_storage::PubSubAvroFormat.new
   else
-    raise "input_format must be in ('text', 'avro', 'pubsub_avro'); got value: #{input_format}"
+    raise "input_format must be in ('text', 'avro', 'pubsub_avro');" \
+          "got value: #{input_format}"
   end
 
   if !match_glob.nil? && !match_glob.empty?
-    cloud_storage.match_glob = match_glob
+    settings.match_glob = match_glob
   end
 
   topic = topic_admin.create_topic name: pubsub.topic_path(topic_id),
                                    ingestion_data_source_settings: {
-                                     cloud_storage: cloud_storage
+                                     cloud_storage: settings
                                    }
 
   puts "Topic with Cloud Storage Ingestion #{topic.name} created."
diff --git a/google-cloud-pubsub/samples/pubsub_create_topic_with_confluent_cloud_ingestion.rb b/google-cloud-pubsub/samples/pubsub_create_topic_with_confluent_cloud_ingestion.rb
@@ -14,8 +14,12 @@
 
 require "google/cloud/pubsub"
 
-def create_topic_with_confluent_cloud_ingestion topic_id:, bootstrap_server:, cluster_id:, confluent_topic:,
-                                                identity_pool_id:, gcp_service_account:
+def create_topic_with_confluent_cloud_ingestion topic_id:,
+                                                bootstrap_server:,
+                                                cluster_id:,
+                                                confluent_topic:,
+                                                identity_pool_id:,
+                                                gcp_service_account:
   # [START pubsub_create_topic_with_confluent_cloud_ingestion]
   # topic_id = "your-topic-id"
   # bootstrap_server = "bootstrap-server-id.us-south1.gcp.confluent.cloud:9092"
@@ -24,7 +28,6 @@ def create_topic_with_confluent_cloud_ingestion topic_id:, bootstrap_server:, cl
   # identity_pool_id = "identity-pool-id"
   # gcp_service_account = "service-account@project.iam.gserviceaccount.com"
   pubsub = Google::Cloud::Pubsub.new
-
   topic_admin = pubsub.topic_admin
 
   topic = topic_admin.create_topic name: pubsub.topic_path(topic_id),
diff --git a/google-cloud-pubsub/samples/pubsub_create_topic_with_kinesis_ingestion.rb b/google-cloud-pubsub/samples/pubsub_create_topic_with_kinesis_ingestion.rb
@@ -14,15 +14,19 @@
 
 require "google/cloud/pubsub"
 
-def create_topic_with_kinesis_ingestion topic_id:, stream_arn:, consumer_arn:, aws_role_arn:, gcp_service_account:
+def create_topic_with_kinesis_ingestion topic_id:,
+                                        stream_arn:,
+                                        consumer_arn:,
+                                        aws_role_arn:,
+                                        gcp_service_account:
   # [START pubsub_create_topic_with_kinesis_ingestion]
   # topic_id = "your-topic-id"
   # stream_arn = "arn:aws:kinesis:us-west-2:111111111111:stream/stream-name"
-  # consumer_arn = "arn:aws:kinesis:us-west-2:111111111111:stream/stream-name/consumer/consumer-1:1111111111"
+  # consumer_arn = "arn:aws:kinesis:us-west-2:111111111111:" \
+  #   "stream/stream-name/consumer/consumer-1:1111111111"
   # aws_role_arn = "arn:aws:iam::111111111111:role/role-name"
   # gcp_service_account = "service-account@project.iam.gserviceaccount.com"
   pubsub = Google::Cloud::Pubsub.new
-
   topic_admin = pubsub.topic_admin
 
   topic = topic_admin.create_topic name: pubsub.topic_path(topic_id),
diff --git a/google-cloud-pubsub/samples/pubsub_create_unwrapped_push_subscription.rb b/google-cloud-pubsub/samples/pubsub_create_unwrapped_push_subscription.rb
@@ -21,17 +21,17 @@ def create_unwrapped_push_subscription topic_id:, subscription_id:, endpoint:
   # endpoint          = "https://your-test-project.appspot.com/push"
 
   pubsub = Google::Cloud::Pubsub.new
-
   subscription_admin = pubsub.subscription_admin
 
-  subscription = subscription_admin.create_subscription name: pubsub.subscription_path(subscription_id),
-                                                        topic: pubsub.topic_path(topic_id),
-                                                        push_config: {
-                                                          push_endpoint: endpoint,
-                                                          no_wrapper: {
-                                                            write_metadata: true
-                                                          }
-                                                        }
+  subscription = subscription_admin.create_subscription \
+    name: pubsub.subscription_path(subscription_id),
+    topic: pubsub.topic_path(topic_id),
+    push_config: {
+      push_endpoint: endpoint,
+      no_wrapper: {
+        write_metadata: true
+      }
+    }
 
   puts "Unwrapped push subscription #{subscription_id} created."
   # [END pubsub_create_unwrapped_push_subscription]
diff --git a/google-cloud-pubsub/samples/pubsub_delete_schema_revision.rb b/google-cloud-pubsub/samples/pubsub_delete_schema_revision.rb
@@ -20,10 +20,10 @@ def delete_schema_revision schema_id:, revision_id:
   # revision_id = "your-revision-id"
 
   pubsub = Google::Cloud::Pubsub.new
-
   schemas = pubsub.schemas
 
-  result = schemas.delete_schema_revision name: pubsub.schema_path("#{schema_id}@#{revision_id}")
+  result = schemas.delete_schema_revision \
+    name: pubsub.schema_path("#{schema_id}@#{revision_id}")
 
   puts "Schema #{schema_id}@#{revision_id} deleted."
   # [END pubsub_delete_schema_revision]
diff --git a/google-cloud-pubsub/samples/pubsub_get_schema_revision.rb b/google-cloud-pubsub/samples/pubsub_get_schema_revision.rb
@@ -20,10 +20,10 @@ def get_schema_revision schema_id:, revision_id:
   # revision_id = "your-revision-id"
 
   pubsub = Google::Cloud::Pubsub.new
-
   schemas = pubsub.schemas
 
-  schema = schemas.get_schema name: pubsub.schema_path("#{schema_id}@#{revision_id}")
+  schema = schemas.get_schema \
+    name: pubsub.schema_path("#{schema_id}@#{revision_id}")
 
   puts "Schema #{schema.name} retrieved."
   # [END pubsub_get_schema_revision]
diff --git a/google-cloud-pubsub/samples/pubsub_optimistic_subscribe.rb b/google-cloud-pubsub/samples/pubsub_optimistic_subscribe.rb
@@ -39,10 +39,12 @@ def optimistic_subscribe topic_id:, subscription_id:
     listener.stop.wait!
   rescue Google::Cloud::NotFoundError => e
     puts "Subscription #{subscription_id} does not exist."
+
     subscription_admin = pubsub.subscription_admin
+    subscription = subscription_admin.create_subscription \
+      name: pubsub.subscription_path(subscription_id),
+      topic: pubsub.topic_path(topic_id)
 
-    subscription = subscription_admin.create_subscription name: pubsub.subscription_path(subscription_id),
-                                                          topic: pubsub.topic_path(topic_id)
     puts "Subscription #{subscription_id} created."
   end
   # [END pubsub_optimistic_subscribe]
diff --git a/google-cloud-pubsub/samples/pubsub_subscriber_exactly_once_delivery.rb b/google-cloud-pubsub/samples/pubsub_subscriber_exactly_once_delivery.rb
@@ -18,11 +18,12 @@ def subscriber_exactly_once_delivery project_id:, subscription_id:
   # [START pubsub_subscriber_exactly_once]
   # project_id = "your-project-id"
   # subscription_id = "your-subscription-id"
-  pubsub = Google::Cloud::Pubsub.new project_id: project_id, endpoint: "us-west1-pubsub.googleapis.com:443"
+  pubsub = Google::Cloud::Pubsub.new \
+    project_id: project_id,
+    endpoint: "us-west1-pubsub.googleapis.com:443"
   subscriber = pubsub.subscriber subscription_id
   listener = subscriber.listen do |received_message|
     puts "Received message: #{received_message.data}"
-
     # Pass in callback to access the acknowledge result.
     # For subscription with Exactly once delivery disabled the result will be success always.
     received_message.acknowledge! do |result|
diff --git a/google-cloud-pubsub/samples/pubsub_update_topic_type.rb b/google-cloud-pubsub/samples/pubsub_update_topic_type.rb
@@ -14,26 +14,30 @@
 
 require "google/cloud/pubsub"
 
-def update_topic_type topic_id:, stream_arn:, consumer_arn:, aws_role_arn:, gcp_service_account:
+def update_topic_type topic_id:,
+                      stream_arn:,
+                      consumer_arn:,
+                      aws_role_arn:,
+                      gcp_service_account:
   # [START pubsub_update_topic_type]
   # topic_id = "your-topic-id"
   # stream_arn = "arn:aws:kinesis:us-west-2:111111111111:stream/stream-name"
-  # consumer_arn = "arn:aws:kinesis:us-west-2:111111111111:stream/stream-name/consumer/consumer-1:1111111111"
+  # consumer_arn = "arn:aws:kinesis:us-west-2:111111111111:" \
+  #   "stream/stream-name/consumer/consumer-1:1111111111"
   # aws_role_arn = "arn:aws:iam::111111111111:role/role-name"
   # gcp_service_account = "service-account@project.iam.gserviceaccount.com"
   pubsub = Google::Cloud::Pubsub.new
-
   topic_admin = pubsub.topic_admin
 
-  ingestion_data_source_settings = Google::Cloud::PubSub::V1::IngestionDataSourceSettings.new aws_kinesis: {
-    stream_arn: stream_arn,
-    consumer_arn: consumer_arn,
-    aws_role_arn: aws_role_arn,
-    gcp_service_account: gcp_service_account
-  }
-
+  ingestion_data_source_settings =
+    Google::Cloud::PubSub::V1::IngestionDataSourceSettings.new \
+      aws_kinesis: {
+        stream_arn: stream_arn,
+        consumer_arn: consumer_arn,
+        aws_role_arn: aws_role_arn,
+        gcp_service_account: gcp_service_account
+      }
   topic = topic_admin.get_topic topic: pubsub.topic_path(topic_id)
-
   topic.ingestion_data_source_settings = ingestion_data_source_settings
 
   topic = topic_admin.update_topic topic: topic,
