feat: Automated regeneration of PubSub client (googleapis#12918)

Auto-created at 2025-02-04 13:15:21 +0000 using the toys pull request generator.

Author: yoshi-code-bot

clients/pub_sub/lib/google_api/pub_sub/v1/metadata.ex

@@ -20,7 +20,7 @@ defmodule GoogleApi.PubSub.V1 do
   API client metadata for GoogleApi.PubSub.V1.
   """
 
-  @discovery_revision "20241231"
+  @discovery_revision "20250128"
 
   def discovery_revision(), do: @discovery_revision
 end

clients/pub_sub/lib/google_api/pub_sub/v1/model/java_script_udf.ex

@@ -0,0 +1,49 @@
+# Copyright 2019 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+# NOTE: This file is auto generated by the elixir code generator program.
+# Do not edit this file manually.
+
+defmodule GoogleApi.PubSub.V1.Model.JavaScriptUDF do
+  @moduledoc """
+  User-defined JavaScript function that can transform or filter a Pub/Sub message.
+
+  ## Attributes
+
+  *   `code` (*type:* `String.t`, *default:* `nil`) - Required. JavaScript code that contains a function `function_name` with the below signature: /** * Transforms a Pub/Sub message. * @return {(Object)>|null)} - To * filter a message, return `null`. To transform a message return a map * with the following keys: * - (required) 'data' : {string} * - (optional) 'attributes' : {Object} * Returning empty `attributes` will remove all attributes from the * message. * * @param {(Object)>} Pub/Sub * message. Keys: * - (required) 'data' : {string} * - (required) 'attributes' : {Object} * * @param {Object} metadata - Pub/Sub message metadata. * Keys: * - (required) 'message_id' : {string} * - (optional) 'publish_time': {string} YYYY-MM-DDTHH:MM:SSZ format * - (optional) 'ordering_key': {string} */ function (message, metadata) { }
+  *   `functionName` (*type:* `String.t`, *default:* `nil`) - Required. Name of the JavasScript function that should applied to Pub/Sub messages.
+  """
+
+  use GoogleApi.Gax.ModelBase
+
+  @type t :: %__MODULE__{
+          :code => String.t() | nil,
+          :functionName => String.t() | nil
+        }
+
+  field(:code)
+  field(:functionName)
+end
+
+defimpl Poison.Decoder, for: GoogleApi.PubSub.V1.Model.JavaScriptUDF do
+  def decode(value, options) do
+    GoogleApi.PubSub.V1.Model.JavaScriptUDF.decode(value, options)
+  end
+end
+
+defimpl Poison.Encoder, for: GoogleApi.PubSub.V1.Model.JavaScriptUDF do
+  def encode(value, options) do
+    GoogleApi.Gax.ModelBase.encode(value, options)
+  end
+end

clients/pub_sub/lib/google_api/pub_sub/v1/model/message_transform.ex

@@ -0,0 +1,49 @@
+# Copyright 2019 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+# NOTE: This file is auto generated by the elixir code generator program.
+# Do not edit this file manually.
+
+defmodule GoogleApi.PubSub.V1.Model.MessageTransform do
+  @moduledoc """
+  All supported message transforms types.
+
+  ## Attributes
+
+  *   `enabled` (*type:* `boolean()`, *default:* `nil`) - Optional. If set to true, the transform is enabled. If false, the transform is disabled and will not be applied to messages. Defaults to `true`.
+  *   `javascriptUdf` (*type:* `GoogleApi.PubSub.V1.Model.JavaScriptUDF.t`, *default:* `nil`) - Optional. JavaScript User Defined Function. If multiple JavaScriptUDF's are specified on a resource, each must have a unique `function_name`.
+  """
+
+  use GoogleApi.Gax.ModelBase
+
+  @type t :: %__MODULE__{
+          :enabled => boolean() | nil,
+          :javascriptUdf => GoogleApi.PubSub.V1.Model.JavaScriptUDF.t() | nil
+        }
+
+  field(:enabled)
+  field(:javascriptUdf, as: GoogleApi.PubSub.V1.Model.JavaScriptUDF)
+end
+
+defimpl Poison.Decoder, for: GoogleApi.PubSub.V1.Model.MessageTransform do
+  def decode(value, options) do
+    GoogleApi.PubSub.V1.Model.MessageTransform.decode(value, options)
+  end
+end
+
+defimpl Poison.Encoder, for: GoogleApi.PubSub.V1.Model.MessageTransform do
+  def encode(value, options) do
+    GoogleApi.Gax.ModelBase.encode(value, options)
+  end
+end

clients/pub_sub/lib/google_api/pub_sub/v1/model/subscription.ex

@@ -33,6 +33,7 @@ defmodule GoogleApi.PubSub.V1.Model.Subscription do
   *   `filter` (*type:* `String.t`, *default:* `nil`) - Optional. An expression written in the Pub/Sub [filter language](https://cloud.google.com/pubsub/docs/filtering). If non-empty, then only `PubsubMessage`s whose `attributes` field matches the filter are delivered on this subscription. If empty, then no messages are filtered out.
   *   `labels` (*type:* `map()`, *default:* `nil`) - Optional. See [Creating and managing labels](https://cloud.google.com/pubsub/docs/labels).
   *   `messageRetentionDuration` (*type:* `String.t`, *default:* `nil`) - Optional. How long to retain unacknowledged messages in the subscription's backlog, from the moment a message is published. If `retain_acked_messages` is true, then this also configures the retention of acknowledged messages, and thus configures how far back in time a `Seek` can be done. Defaults to 7 days. Cannot be more than 31 days or less than 10 minutes.
+  *   `messageTransforms` (*type:* `list(GoogleApi.PubSub.V1.Model.MessageTransform.t)`, *default:* `nil`) - Optional. Transforms to be applied to messages before they are delivered to subscribers. Transforms are applied in the order specified.
   *   `name` (*type:* `String.t`, *default:* `nil`) - 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"`.
   *   `pushConfig` (*type:* `GoogleApi.PubSub.V1.Model.PushConfig.t`, *default:* `nil`) - Optional. If push delivery is used with this subscription, this field is used to configure it.
   *   `retainAckedMessages` (*type:* `boolean()`, *default:* `nil`) - Optional. Indicates whether to retain acknowledged messages. If true, then messages are not expunged from the subscription's backlog, even if they are acknowledged, until they fall out of the `message_retention_duration` window. This must be true if you would like to [`Seek` to a timestamp] (https://cloud.google.com/pubsub/docs/replay-overview#seek_to_a_time) in the past to replay previously-acknowledged messages.
@@ -58,6 +59,7 @@ defmodule GoogleApi.PubSub.V1.Model.Subscription do
           :filter => String.t() | nil,
           :labels => map() | nil,
           :messageRetentionDuration => String.t() | nil,
+          :messageTransforms => list(GoogleApi.PubSub.V1.Model.MessageTransform.t()) | nil,
           :name => String.t() | nil,
           :pushConfig => GoogleApi.PubSub.V1.Model.PushConfig.t() | nil,
           :retainAckedMessages => boolean() | nil,
@@ -79,6 +81,7 @@ defmodule GoogleApi.PubSub.V1.Model.Subscription do
   field(:filter)
   field(:labels, type: :map)
   field(:messageRetentionDuration)
+  field(:messageTransforms, as: GoogleApi.PubSub.V1.Model.MessageTransform, type: :list)
   field(:name)
   field(:pushConfig, as: GoogleApi.PubSub.V1.Model.PushConfig)
   field(:retainAckedMessages)

clients/pub_sub/lib/google_api/pub_sub/v1/model/topic.ex

@@ -26,6 +26,7 @@ defmodule GoogleApi.PubSub.V1.Model.Topic do
   *   `labels` (*type:* `map()`, *default:* `nil`) - Optional. See [Creating and managing labels] (https://cloud.google.com/pubsub/docs/labels).
   *   `messageRetentionDuration` (*type:* `String.t`, *default:* `nil`) - Optional. Indicates the minimum duration to retain a message after it is published to the topic. If this field is set, messages published to the topic in the last `message_retention_duration` are always available to subscribers. For instance, it allows any attached subscription to [seek to a timestamp](https://cloud.google.com/pubsub/docs/replay-overview#seek_to_a_time) that is up to `message_retention_duration` in the past. If this field is not set, message retention is controlled by settings on individual subscriptions. Cannot be more than 31 days or less than 10 minutes.
   *   `messageStoragePolicy` (*type:* `GoogleApi.PubSub.V1.Model.MessageStoragePolicy.t`, *default:* `nil`) - Optional. Policy constraining the set of Google Cloud Platform regions where messages published to the topic may be stored. If not present, then no constraints are in effect.
+  *   `messageTransforms` (*type:* `list(GoogleApi.PubSub.V1.Model.MessageTransform.t)`, *default:* `nil`) - Optional. Transforms to be applied to messages published to the topic. Transforms are applied in the order specified.
   *   `name` (*type:* `String.t`, *default:* `nil`) - 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 signs (`%`). It must be between 3 and 255 characters in length, and it must not start with `"goog"`.
   *   `satisfiesPzs` (*type:* `boolean()`, *default:* `nil`) - Optional. Reserved for future use. This field is set only in responses from the server; it is ignored if it is set in any requests.
   *   `schemaSettings` (*type:* `GoogleApi.PubSub.V1.Model.SchemaSettings.t`, *default:* `nil`) - Optional. Settings for validating messages published against a schema.
@@ -41,6 +42,7 @@ defmodule GoogleApi.PubSub.V1.Model.Topic do
           :labels => map() | nil,
           :messageRetentionDuration => String.t() | nil,
           :messageStoragePolicy => GoogleApi.PubSub.V1.Model.MessageStoragePolicy.t() | nil,
+          :messageTransforms => list(GoogleApi.PubSub.V1.Model.MessageTransform.t()) | nil,
           :name => String.t() | nil,
           :satisfiesPzs => boolean() | nil,
           :schemaSettings => GoogleApi.PubSub.V1.Model.SchemaSettings.t() | nil,
@@ -52,6 +54,7 @@ defmodule GoogleApi.PubSub.V1.Model.Topic do
   field(:labels, type: :map)
   field(:messageRetentionDuration)
   field(:messageStoragePolicy, as: GoogleApi.PubSub.V1.Model.MessageStoragePolicy)
+  field(:messageTransforms, as: GoogleApi.PubSub.V1.Model.MessageTransform, type: :list)
   field(:name)
   field(:satisfiesPzs)
   field(:schemaSettings, as: GoogleApi.PubSub.V1.Model.SchemaSettings)