diff --git a/clients/pub_sub/README.md b/clients/pub_sub/README.md index 81e9ac8747..e9f52ce191 100644 --- a/clients/pub_sub/README.md +++ b/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 ``` diff --git a/clients/pub_sub/lib/google_api/pub_sub/v1/metadata.ex b/clients/pub_sub/lib/google_api/pub_sub/v1/metadata.ex index f6eb9d0020..5ca01229e8 100644 --- a/clients/pub_sub/lib/google_api/pub_sub/v1/metadata.ex +++ b/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 diff --git a/clients/pub_sub/lib/google_api/pub_sub/v1/model/aws_msk.ex b/clients/pub_sub/lib/google_api/pub_sub/v1/model/aws_msk.ex new file mode 100644 index 0000000000..fd38bce9df --- /dev/null +++ b/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 diff --git a/clients/pub_sub/lib/google_api/pub_sub/v1/model/azure_event_hubs.ex b/clients/pub_sub/lib/google_api/pub_sub/v1/model/azure_event_hubs.ex new file mode 100644 index 0000000000..34bb523333 --- /dev/null +++ b/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 diff --git a/clients/pub_sub/lib/google_api/pub_sub/v1/model/confluent_cloud.ex b/clients/pub_sub/lib/google_api/pub_sub/v1/model/confluent_cloud.ex new file mode 100644 index 0000000000..544f9a5e9a --- /dev/null +++ b/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 diff --git a/clients/pub_sub/lib/google_api/pub_sub/v1/model/ingestion_data_source_settings.ex b/clients/pub_sub/lib/google_api/pub_sub/v1/model/ingestion_data_source_settings.ex index f45f6f61c4..35fb93102f 100644 --- a/clients/pub_sub/lib/google_api/pub_sub/v1/model/ingestion_data_source_settings.ex +++ b/clients/pub_sub/lib/google_api/pub_sub/v1/model/ingestion_data_source_settings.ex @@ -22,7 +22,10 @@ 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. """ @@ -30,12 +33,18 @@ defmodule GoogleApi.PubSub.V1.Model.IngestionDataSourceSettings do @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 diff --git a/clients/pub_sub/mix.exs b/clients/pub_sub/mix.exs index d29075c694..a8391e3873 100644 --- a/clients/pub_sub/mix.exs +++ b/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 [