feat: Automated regeneration of pubsub v1 client (#25439)

Auto-created at 2026-01-25 09:27:58 +0000 using the toys pull request generator.

Author: yoshi-code-bot

api_names_out.yaml

@@ -334272,6 +334272,10 @@
 "/publicca:v1beta1/publicca.projects.locations.externalAccountKeys.create": create_project_location_external_account_key
 "/publicca:v1beta1/publicca.projects.locations.externalAccountKeys.create/parent": parent
 "/publicca:v1beta1/quotaUser": quota_user
+"/pubsub:v1/AIInference": ai_inference
+"/pubsub:v1/AIInference/endpoint": endpoint
+"/pubsub:v1/AIInference/serviceAccountEmail": service_account_email
+"/pubsub:v1/AIInference/unstructuredInference": unstructured_inference
 "/pubsub:v1/AcknowledgeRequest": acknowledge_request
 "/pubsub:v1/AcknowledgeRequest/ackIds": ack_ids
 "/pubsub:v1/AcknowledgeRequest/ackIds/ack_id": ack_id
@@ -334407,6 +334411,7 @@
 "/pubsub:v1/MessageStoragePolicy/allowedPersistenceRegions/allowed_persistence_region": allowed_persistence_region
 "/pubsub:v1/MessageStoragePolicy/enforceInTransit": enforce_in_transit
 "/pubsub:v1/MessageTransform": message_transform
+"/pubsub:v1/MessageTransform/aiInference": ai_inference
 "/pubsub:v1/MessageTransform/disabled": disabled
 "/pubsub:v1/MessageTransform/enabled": enabled
 "/pubsub:v1/MessageTransform/javascriptUdf": javascript_udf
@@ -334537,6 +334542,9 @@
 "/pubsub:v1/Topic/state": state
 "/pubsub:v1/Topic/tags": tags
 "/pubsub:v1/Topic/tags/tag": tag
+"/pubsub:v1/UnstructuredInference": unstructured_inference
+"/pubsub:v1/UnstructuredInference/parameters": parameters
+"/pubsub:v1/UnstructuredInference/parameters/parameter": parameter
 "/pubsub:v1/UpdateSnapshotRequest": update_snapshot_request
 "/pubsub:v1/UpdateSnapshotRequest/snapshot": snapshot
 "/pubsub:v1/UpdateSnapshotRequest/updateMask": update_mask

generated/google-apis-pubsub_v1/CHANGELOG.md

@@ -1,5 +1,9 @@
 # Release history for google-apis-pubsub_v1
 
+### v0.65.0 (2026-01-25)
+
+* Regenerated from discovery document revision 20260116
+
 ### v0.64.0 (2025-12-21)
 
 * Regenerated from discovery document revision 20251212

generated/google-apis-pubsub_v1/lib/google/apis/pubsub_v1/classes.rb

@@ -22,6 +22,45 @@ module Google
   module Apis
     module PubsubV1
 
+      # Configuration for making inference requests against Vertex AI models.
+      class AiInference
+        include Google::Apis::Core::Hashable
+      
+        # Required. An endpoint to a Vertex AI model of the form `projects/`project`/
+        # locations/`location`/endpoints/`endpoint`` or `projects/`project`/locations/`
+        # location`/publishers/`publisher`/models/`model``. Vertex AI API requests will
+        # be sent to this endpoint.
+        # Corresponds to the JSON property `endpoint`
+        # @return [String]
+        attr_accessor :endpoint
+      
+        # Optional. The service account to use to make prediction requests against
+        # endpoints. The resource creator or updater that specifies this field must have
+        # `iam.serviceAccounts.actAs` permission on the service account. If not
+        # specified, the Pub/Sub [service agent](`$universe.dns_names.
+        # final_documentation_domain`/iam/docs/service-agents), service-`project_number`@
+        # gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+        # Corresponds to the JSON property `serviceAccountEmail`
+        # @return [String]
+        attr_accessor :service_account_email
+      
+        # Configuration for making inferences using arbitrary JSON payloads.
+        # Corresponds to the JSON property `unstructuredInference`
+        # @return [Google::Apis::PubsubV1::UnstructuredInference]
+        attr_accessor :unstructured_inference
+      
+        def initialize(**args)
+           update!(**args)
+        end
+      
+        # Update properties of this object
+        def update!(**args)
+          @endpoint = args[:endpoint] if args.key?(:endpoint)
+          @service_account_email = args[:service_account_email] if args.key?(:service_account_email)
+          @unstructured_inference = args[:unstructured_inference] if args.key?(:unstructured_inference)
+        end
+      end
+      
       # Request for the Acknowledge method.
       class AcknowledgeRequest
         include Google::Apis::Core::Hashable
@@ -712,13 +751,13 @@ class CreateSnapshotRequest
         # @return [Hash<String,String>]
         attr_accessor :labels
 
-        # Required. Identifier. 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 unacknowledged upon the successful
-        # completion of the `CreateSnapshot` request; as well as: (b) Any messages
-        # published to the subscription's topic following the successful completion of
-        # the CreateSnapshot request. Format is `projects/`project`/subscriptions/`sub``.
+        # 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 unacknowledged upon the successful completion
+        # of the `CreateSnapshot` request; as well as: (b) Any messages published to the
+        # subscription's topic following the successful completion of the CreateSnapshot
+        # request. Format is `projects/`project`/subscriptions/`sub``.
         # Corresponds to the JSON property `subscription`
         # @return [String]
         attr_accessor :subscription
@@ -1199,6 +1238,11 @@ def update!(**args)
       class MessageTransform
         include Google::Apis::Core::Hashable
 
+        # Configuration for making inference requests against Vertex AI models.
+        # Corresponds to the JSON property `aiInference`
+        # @return [Google::Apis::PubsubV1::AiInference]
+        attr_accessor :ai_inference
+      
         # Optional. If true, the transform is disabled and will not be applied to
         # messages. Defaults to `false`.
         # Corresponds to the JSON property `disabled`
@@ -1225,6 +1269,7 @@ def initialize(**args)
 
         # Update properties of this object
         def update!(**args)
+          @ai_inference = args[:ai_inference] if args.key?(:ai_inference)
           @disabled = args[:disabled] if args.key?(:disabled)
           @enabled = args[:enabled] if args.key?(:enabled)
           @javascript_udf = args[:javascript_udf] if args.key?(:javascript_udf)
@@ -2194,9 +2239,9 @@ class Subscription
         # @return [Hash<String,String>]
         attr_accessor :tags
 
-        # Required. Identifier. 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.
+        # 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.
         # Corresponds to the JSON property `topic`
         # @return [String]
         attr_accessor :topic
@@ -2415,6 +2460,27 @@ def update!(**args)
         end
       end
 
+      # Configuration for making inferences using arbitrary JSON payloads.
+      class UnstructuredInference
+        include Google::Apis::Core::Hashable
+      
+        # Optional. A parameters object to be included in each inference request. The
+        # parameters object is combined with the data field of the Pub/Sub message to
+        # form the inference request.
+        # Corresponds to the JSON property `parameters`
+        # @return [Hash<String,Object>]
+        attr_accessor :parameters
+      
+        def initialize(**args)
+           update!(**args)
+        end
+      
+        # Update properties of this object
+        def update!(**args)
+          @parameters = args[:parameters] if args.key?(:parameters)
+        end
+      end
+      
       # Request for the UpdateSnapshot method.
       class UpdateSnapshotRequest
         include Google::Apis::Core::Hashable

generated/google-apis-pubsub_v1/lib/google/apis/pubsub_v1/gem_version.rb

@@ -16,13 +16,13 @@ module Google
   module Apis
     module PubsubV1
       # Version of the google-apis-pubsub_v1 gem
-      GEM_VERSION = "0.64.0"
+      GEM_VERSION = "0.65.0"
 
       # Version of the code generator used to generate this client
       GENERATOR_VERSION = "0.18.0"
 
       # Revision of the discovery document this client was generated from
-      REVISION = "20251212"
+      REVISION = "20260116"
     end
   end
 end

generated/google-apis-pubsub_v1/lib/google/apis/pubsub_v1/representations.rb

@@ -22,6 +22,12 @@ module Google
   module Apis
     module PubsubV1
 
+      class AiInference
+        class Representation < Google::Apis::Core::JsonRepresentation; end
+      
+        include Google::Apis::Core::JsonObjectSupport
+      end
+      
       class AcknowledgeRequest
         class Representation < Google::Apis::Core::JsonRepresentation; end
 
@@ -376,6 +382,12 @@ class Representation < Google::Apis::Core::JsonRepresentation; end
         include Google::Apis::Core::JsonObjectSupport
       end
 
+      class UnstructuredInference
+        class Representation < Google::Apis::Core::JsonRepresentation; end
+      
+        include Google::Apis::Core::JsonObjectSupport
+      end
+      
       class UpdateSnapshotRequest
         class Representation < Google::Apis::Core::JsonRepresentation; end
 
@@ -418,6 +430,16 @@ class Representation < Google::Apis::Core::JsonRepresentation; end
         include Google::Apis::Core::JsonObjectSupport
       end
 
+      class AiInference
+        # @private
+        class Representation < Google::Apis::Core::JsonRepresentation
+          property :endpoint, as: 'endpoint'
+          property :service_account_email, as: 'serviceAccountEmail'
+          property :unstructured_inference, as: 'unstructuredInference', class: Google::Apis::PubsubV1::UnstructuredInference, decorator: Google::Apis::PubsubV1::UnstructuredInference::Representation
+      
+        end
+      end
+      
       class AcknowledgeRequest
         # @private
         class Representation < Google::Apis::Core::JsonRepresentation
@@ -705,6 +727,8 @@ class Representation < Google::Apis::Core::JsonRepresentation
       class MessageTransform
         # @private
         class Representation < Google::Apis::Core::JsonRepresentation
+          property :ai_inference, as: 'aiInference', class: Google::Apis::PubsubV1::AiInference, decorator: Google::Apis::PubsubV1::AiInference::Representation
+      
           property :disabled, as: 'disabled'
           property :enabled, as: 'enabled'
           property :javascript_udf, as: 'javascriptUdf', class: Google::Apis::PubsubV1::JavaScriptUdf, decorator: Google::Apis::PubsubV1::JavaScriptUdf::Representation
@@ -989,6 +1013,13 @@ class Representation < Google::Apis::Core::JsonRepresentation
         end
       end
 
+      class UnstructuredInference
+        # @private
+        class Representation < Google::Apis::Core::JsonRepresentation
+          hash :parameters, as: 'parameters'
+        end
+      end
+      
       class UpdateSnapshotRequest
         # @private
         class Representation < Google::Apis::Core::JsonRepresentation

generated/google-apis-pubsub_v1/lib/google/apis/pubsub_v1/service.rb

@@ -549,12 +549,12 @@ def validate_schema_message(parent, validate_message_request_object = nil, field
         # object. Note that for REST API requests, you must specify a name in the
         # request.
         # @param [String] name
-        #   Required. Identifier. 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 [resource name rules](https://cloud.
-        #   google.com/pubsub/docs/pubsub-basics#resource_names). Format is `projects/`
-        #   project`/snapshots/`snap``.
+        #   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 [resource name rules](https://cloud.google.com/pubsub/
+        #   docs/pubsub-basics#resource_names). Format is `projects/`project`/snapshots/`
+        #   snap``.
         # @param [Google::Apis::PubsubV1::CreateSnapshotRequest] create_snapshot_request_object
         # @param [String] fields
         #   Selector specifying which fields to include in a partial response.
@@ -594,8 +594,8 @@ def create_snapshot(name, create_snapshot_request_object = nil, fields: nil, quo
         # with the same name, but the new one has no association with the old snapshot
         # or its subscription, unless the same subscription is specified.
         # @param [String] snapshot
-        #   Required. Identifier. The name of the snapshot to delete. Format is `projects/`
-        #   project`/snapshots/`snap``.
+        #   Required. The name of the snapshot to delete. Format is `projects/`project`/
+        #   snapshots/`snap``.
         # @param [String] fields
         #   Selector specifying which fields to include in a partial response.
         # @param [String] quota_user
@@ -629,8 +629,8 @@ def delete_project_snapshot(snapshot, fields: nil, quota_user: nil, options: nil
         # acknowledgment state of messages in an existing subscription to the state
         # captured by a snapshot.
         # @param [String] snapshot
-        #   Required. Identifier. The name of the snapshot to get. Format is `projects/`
-        #   project`/snapshots/`snap``.
+        #   Required. The name of the snapshot to get. Format is `projects/`project`/
+        #   snapshots/`snap``.
         # @param [String] fields
         #   Selector specifying which fields to include in a partial response.
         # @param [String] quota_user
@@ -708,8 +708,8 @@ def get_project_snapshot_iam_policy(resource, options_requested_policy_version:
         # message acknowledgments in bulk. That is, you can set the acknowledgment state
         # of messages in an existing subscription to the state captured by a snapshot.
         # @param [String] project
-        #   Required. Identifier. The name of the project in which to list snapshots.
-        #   Format is `projects/`project-id``.
+        #   Required. The name of the project in which to list snapshots. Format is `
+        #   projects/`project-id``.
         # @param [Fixnum] page_size
         #   Optional. Maximum number of snapshots to return.
         # @param [String] page_token
@@ -948,8 +948,8 @@ def create_subscription(name, subscription_object = nil, fields: nil, quota_user
         # but the new one has no association with the old subscription or its topic
         # unless the same topic is specified.
         # @param [String] subscription
-        #   Required. Identifier. The subscription to delete. Format is `projects/`project`
-        #   /subscriptions/`sub``.
+        #   Required. The subscription to delete. Format is `projects/`project`/
+        #   subscriptions/`sub``.
         # @param [String] fields
         #   Selector specifying which fields to include in a partial response.
         # @param [String] quota_user
@@ -1013,8 +1013,8 @@ def detach_project_subscription(subscription, fields: nil, quota_user: nil, opti
 
         # Gets the configuration details of a subscription.
         # @param [String] subscription
-        #   Required. Identifier. The name of the subscription to get. Format is `projects/
-        #   `project`/subscriptions/`sub``.
+        #   Required. The name of the subscription to get. Format is `projects/`project`/
+        #   subscriptions/`sub``.
         # @param [String] fields
         #   Selector specifying which fields to include in a partial response.
         # @param [String] quota_user
@@ -1089,8 +1089,8 @@ def get_project_subscription_iam_policy(resource, options_requested_policy_versi
 
         # Lists matching subscriptions.
         # @param [String] project
-        #   Required. Identifier. The name of the project in which to list subscriptions.
-        #   Format is `projects/`project-id``.
+        #   Required. The name of the project in which to list subscriptions. Format is `
+        #   projects/`project-id``.
         # @param [Fixnum] page_size
         #   Optional. Maximum number of subscriptions to return.
         # @param [String] page_token
@@ -1436,8 +1436,8 @@ def create_topic(name, topic_object = nil, fields: nil, quota_user: nil, options
         # subscriptions. Existing subscriptions to this topic are not deleted, but their
         # `topic` field is set to `_deleted-topic_`.
         # @param [String] topic
-        #   Required. Identifier. Name of the topic to delete. Format is `projects/`
-        #   project`/topics/`topic``.
+        #   Required. Name of the topic to delete. Format is `projects/`project`/topics/`
+        #   topic``.
         # @param [String] fields
         #   Selector specifying which fields to include in a partial response.
         # @param [String] quota_user
@@ -1467,8 +1467,8 @@ def delete_topic(topic, fields: nil, quota_user: nil, options: nil, &block)
 
         # Gets the configuration of a topic.
         # @param [String] topic
-        #   Required. Identifier. The name of the topic to get. Format is `projects/`
-        #   project`/topics/`topic``.
+        #   Required. The name of the topic to get. Format is `projects/`project`/topics/`
+        #   topic``.
         # @param [String] fields
         #   Selector specifying which fields to include in a partial response.
         # @param [String] quota_user
@@ -1543,8 +1543,8 @@ def get_project_topic_iam_policy(resource, options_requested_policy_version: nil
 
         # Lists matching topics.
         # @param [String] project
-        #   Required. Identifier. The name of the project in which to list topics. Format
-        #   is `projects/`project-id``.
+        #   Required. The name of the project in which to list topics. Format is `projects/
+        #   `project-id``.
         # @param [Fixnum] page_size
         #   Optional. Maximum number of topics to return.
         # @param [String] page_token
@@ -1622,8 +1622,8 @@ def patch_project_topic(name, update_topic_request_object = nil, fields: nil, qu
         # Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic does
         # not exist.
         # @param [String] topic
-        #   Required. Identifier. The messages in the request will be published on this
-        #   topic. Format is `projects/`project`/topics/`topic``.
+        #   Required. The messages in the request will be published on this topic. Format
+        #   is `projects/`project`/topics/`topic``.
         # @param [Google::Apis::PubsubV1::PublishRequest] publish_request_object
         # @param [String] fields
         #   Selector specifying which fields to include in a partial response.