feat: Automated regeneration of PubSub client (#12777)

Auto-created at 2025-01-07 13:18:16 +0000 using the toys pull request generator.

clients/pub_sub/README.md

@@ -11,7 +11,7 @@ Install this package from [Hex](https://hex.pm) by adding
 
 ```elixir
 def deps do
-  [{:google_api_pub_sub, "~> 0.41"}]
+  [{:google_api_pub_sub, "~> 0.42"}]
 end
 ```
 

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 "20241212"
+  @discovery_revision "20241231"
 
   def discovery_revision(), do: @discovery_revision
 end

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

@@ -0,0 +1,58 @@
+# 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.AwsMsk do
+  @moduledoc """
+  Ingestion settings for Amazon MSK.
+
+  ## Attributes
+
+  *   `awsRoleArn` (*type:* `String.t`, *default:* `nil`) - Required. AWS role ARN to be used for Federated Identity authentication with Amazon MSK. Check the Pub/Sub docs for how to set up this role and the required permissions that need to be attached to it.
+  *   `clusterArn` (*type:* `String.t`, *default:* `nil`) - Required. The Amazon Resource Name (ARN) that uniquely identifies the cluster.
+  *   `gcpServiceAccount` (*type:* `String.t`, *default:* `nil`) - Required. The GCP service account to be used for Federated Identity authentication with Amazon MSK (via a `AssumeRoleWithWebIdentity` call for the provided role). The `aws_role_arn` must be set up with `accounts.google.com:sub` equals to this service account number.
+  *   `state` (*type:* `String.t`, *default:* `nil`) - Output only. An output-only field that indicates the state of the Amazon MSK ingestion source.
+  *   `topic` (*type:* `String.t`, *default:* `nil`) - Required. The name of the topic in the Amazon MSK cluster that Pub/Sub will import from.
+  """
+
+  use GoogleApi.Gax.ModelBase
+
+  @type t :: %__MODULE__{
+          :awsRoleArn => String.t() | nil,
+          :clusterArn => String.t() | nil,
+          :gcpServiceAccount => String.t() | nil,
+          :state => String.t() | nil,
+          :topic => String.t() | nil
+        }
+
+  field(:awsRoleArn)
+  field(:clusterArn)
+  field(:gcpServiceAccount)
+  field(:state)
+  field(:topic)
+end
+
+defimpl Poison.Decoder, for: GoogleApi.PubSub.V1.Model.AwsMsk do
+  def decode(value, options) do
+    GoogleApi.PubSub.V1.Model.AwsMsk.decode(value, options)
+  end
+end
+
+defimpl Poison.Encoder, for: GoogleApi.PubSub.V1.Model.AwsMsk do
+  def encode(value, options) do
+    GoogleApi.Gax.ModelBase.encode(value, options)
+  end
+end

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

@@ -0,0 +1,67 @@
+# 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.AzureEventHubs do
+  @moduledoc """
+  Ingestion settings for Azure Event Hubs.
+
+  ## Attributes
+
+  *   `clientId` (*type:* `String.t`, *default:* `nil`) - Optional. The client id of the Azure application that is being used to authenticate Pub/Sub.
+  *   `eventHub` (*type:* `String.t`, *default:* `nil`) - Optional. The name of the Event Hub.
+  *   `gcpServiceAccount` (*type:* `String.t`, *default:* `nil`) - Optional. The GCP service account to be used for Federated Identity authentication.
+  *   `namespace` (*type:* `String.t`, *default:* `nil`) - Optional. The name of the Event Hubs namespace.
+  *   `resourceGroup` (*type:* `String.t`, *default:* `nil`) - Optional. Name of the resource group within the azure subscription.
+  *   `state` (*type:* `String.t`, *default:* `nil`) - Output only. An output-only field that indicates the state of the Event Hubs ingestion source.
+  *   `subscriptionId` (*type:* `String.t`, *default:* `nil`) - Optional. The Azure subscription id.
+  *   `tenantId` (*type:* `String.t`, *default:* `nil`) - Optional. The tenant id of the Azure application that is being used to authenticate Pub/Sub.
+  """
+
+  use GoogleApi.Gax.ModelBase
+
+  @type t :: %__MODULE__{
+          :clientId => String.t() | nil,
+          :eventHub => String.t() | nil,
+          :gcpServiceAccount => String.t() | nil,
+          :namespace => String.t() | nil,
+          :resourceGroup => String.t() | nil,
+          :state => String.t() | nil,
+          :subscriptionId => String.t() | nil,
+          :tenantId => String.t() | nil
+        }
+
+  field(:clientId)
+  field(:eventHub)
+  field(:gcpServiceAccount)
+  field(:namespace)
+  field(:resourceGroup)
+  field(:state)
+  field(:subscriptionId)
+  field(:tenantId)
+end
+
+defimpl Poison.Decoder, for: GoogleApi.PubSub.V1.Model.AzureEventHubs do
+  def decode(value, options) do
+    GoogleApi.PubSub.V1.Model.AzureEventHubs.decode(value, options)
+  end
+end
+
+defimpl Poison.Encoder, for: GoogleApi.PubSub.V1.Model.AzureEventHubs do
+  def encode(value, options) do
+    GoogleApi.Gax.ModelBase.encode(value, options)
+  end
+end

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

@@ -0,0 +1,61 @@
+# 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.ConfluentCloud do
+  @moduledoc """
+  Ingestion settings for Confluent Cloud.
+
+  ## Attributes
+
+  *   `bootstrapServer` (*type:* `String.t`, *default:* `nil`) - Required. The address of the bootstrap server. The format is url:port.
+  *   `clusterId` (*type:* `String.t`, *default:* `nil`) - Required. The id of the cluster.
+  *   `gcpServiceAccount` (*type:* `String.t`, *default:* `nil`) - Required. The GCP service account to be used for Federated Identity authentication with `identity_pool_id`.
+  *   `identityPoolId` (*type:* `String.t`, *default:* `nil`) - Required. The id of the identity pool to be used for Federated Identity authentication with Confluent Cloud. See https://docs.confluent.io/cloud/current/security/authenticate/workload-identities/identity-providers/oauth/identity-pools.html#add-oauth-identity-pools.
+  *   `state` (*type:* `String.t`, *default:* `nil`) - Output only. An output-only field that indicates the state of the Confluent Cloud ingestion source.
+  *   `topic` (*type:* `String.t`, *default:* `nil`) - Required. The name of the topic in the Confluent Cloud cluster that Pub/Sub will import from.
+  """
+
+  use GoogleApi.Gax.ModelBase
+
+  @type t :: %__MODULE__{
+          :bootstrapServer => String.t() | nil,
+          :clusterId => String.t() | nil,
+          :gcpServiceAccount => String.t() | nil,
+          :identityPoolId => String.t() | nil,
+          :state => String.t() | nil,
+          :topic => String.t() | nil
+        }
+
+  field(:bootstrapServer)
+  field(:clusterId)
+  field(:gcpServiceAccount)
+  field(:identityPoolId)
+  field(:state)
+  field(:topic)
+end
+
+defimpl Poison.Decoder, for: GoogleApi.PubSub.V1.Model.ConfluentCloud do
+  def decode(value, options) do
+    GoogleApi.PubSub.V1.Model.ConfluentCloud.decode(value, options)
+  end
+end
+
+defimpl Poison.Encoder, for: GoogleApi.PubSub.V1.Model.ConfluentCloud do
+  def encode(value, options) do
+    GoogleApi.Gax.ModelBase.encode(value, options)
+  end
+end

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

@@ -22,20 +22,29 @@ defmodule GoogleApi.PubSub.V1.Model.IngestionDataSourceSettings do
   ## Attributes
 
   *   `awsKinesis` (*type:* `GoogleApi.PubSub.V1.Model.AwsKinesis.t`, *default:* `nil`) - Optional. Amazon Kinesis Data Streams.
+  *   `awsMsk` (*type:* `GoogleApi.PubSub.V1.Model.AwsMsk.t`, *default:* `nil`) - Optional. Amazon MSK.
+  *   `azureEventHubs` (*type:* `GoogleApi.PubSub.V1.Model.AzureEventHubs.t`, *default:* `nil`) - Optional. Azure Event Hubs.
   *   `cloudStorage` (*type:* `GoogleApi.PubSub.V1.Model.CloudStorage.t`, *default:* `nil`) - Optional. Cloud Storage.
+  *   `confluentCloud` (*type:* `GoogleApi.PubSub.V1.Model.ConfluentCloud.t`, *default:* `nil`) - Optional. Confluent Cloud.
   *   `platformLogsSettings` (*type:* `GoogleApi.PubSub.V1.Model.PlatformLogsSettings.t`, *default:* `nil`) - Optional. Platform Logs settings. If unset, no Platform Logs will be generated.
   """
 
   use GoogleApi.Gax.ModelBase
 
   @type t :: %__MODULE__{
           :awsKinesis => GoogleApi.PubSub.V1.Model.AwsKinesis.t() | nil,
+          :awsMsk => GoogleApi.PubSub.V1.Model.AwsMsk.t() | nil,
+          :azureEventHubs => GoogleApi.PubSub.V1.Model.AzureEventHubs.t() | nil,
           :cloudStorage => GoogleApi.PubSub.V1.Model.CloudStorage.t() | nil,
+          :confluentCloud => GoogleApi.PubSub.V1.Model.ConfluentCloud.t() | nil,
           :platformLogsSettings => GoogleApi.PubSub.V1.Model.PlatformLogsSettings.t() | nil
         }
 
   field(:awsKinesis, as: GoogleApi.PubSub.V1.Model.AwsKinesis)
+  field(:awsMsk, as: GoogleApi.PubSub.V1.Model.AwsMsk)
+  field(:azureEventHubs, as: GoogleApi.PubSub.V1.Model.AzureEventHubs)
   field(:cloudStorage, as: GoogleApi.PubSub.V1.Model.CloudStorage)
+  field(:confluentCloud, as: GoogleApi.PubSub.V1.Model.ConfluentCloud)
   field(:platformLogsSettings, as: GoogleApi.PubSub.V1.Model.PlatformLogsSettings)
 end
 

clients/pub_sub/mix.exs

@@ -18,7 +18,7 @@
 defmodule GoogleApi.PubSub.Mixfile do
   use Mix.Project
 
-  @version "0.41.1"
+  @version "0.42.0"
 
   def project() do
     [