From aebf1b7375ba4d05bfe6ea62306230bc38dffd95 Mon Sep 17 00:00:00 2001 From: "gcf-owl-bot[bot]" <78513119+gcf-owl-bot[bot]@users.noreply.github.com> Date: Wed, 18 Feb 2026 17:14:07 -0500 Subject: [PATCH 1/3] chore(nodejs): remove wheel 0.45.1 (#2133) Source-Link: https://github.com/googleapis/synthtool/commit/b1b05f794f4bf050b0ffe9d5303d7427932d5d93 Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-nodejs:latest@sha256:cd5bfcc3d183c1974bca4227785fd397452149bce3785b45a2f735a793ae6241 Co-authored-by: Owl Bot --- .github/.OwlBot.lock.yaml | 6 +++--- .github/CODEOWNERS | 2 +- .github/sync-repo-settings.yaml | 6 +----- 3 files changed, 5 insertions(+), 9 deletions(-) diff --git a/.github/.OwlBot.lock.yaml b/.github/.OwlBot.lock.yaml index 24f126d88..1a90daec6 100644 --- a/.github/.OwlBot.lock.yaml +++ b/.github/.OwlBot.lock.yaml @@ -1,4 +1,4 @@ -# Copyright 2025 Google LLC +# Copyright 2026 Google LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. @@ -13,5 +13,5 @@ # limitations under the License. docker: image: gcr.io/cloud-devrel-public-resources/owlbot-nodejs:latest - digest: sha256:1c50961ec998cd24968d5b2628e8d88a36b612ea881e71bfd171c93cc9d08b9e -# created: 2025-12-02T19:51:56.208302619Z + digest: sha256:cd5bfcc3d183c1974bca4227785fd397452149bce3785b45a2f735a793ae6241 +# created: 2026-02-12T17:44:25.68637179Z diff --git a/.github/CODEOWNERS b/.github/CODEOWNERS index 4a6519253..6b8f272e2 100644 --- a/.github/CODEOWNERS +++ b/.github/CODEOWNERS @@ -6,4 +6,4 @@ # Unless specified, the jsteam is the default owner for nodejs repositories. -* @googleapis/api-pubsub @googleapis/jsteam \ No newline at end of file +* @googleapis/api-pubsub @googleapis/cloud-sdk-nodejs-team \ No newline at end of file diff --git a/.github/sync-repo-settings.yaml b/.github/sync-repo-settings.yaml index a013376d1..9e91ffc8a 100644 --- a/.github/sync-repo-settings.yaml +++ b/.github/sync-repo-settings.yaml @@ -15,9 +15,5 @@ branchProtectionRules: - windows - OwlBot Post Processor permissionRules: - - team: yoshi-admins - permission: admin - - team: jsteam-admins - permission: admin - - team: jsteam + - team: cloud-sdk-nodejs-team permission: push From 2f1e8d198ffbc14795f9f0d0a88095d69ac437a3 Mon Sep 17 00:00:00 2001 From: feywind <57276408+feywind@users.noreply.github.com> Date: Thu, 19 Feb 2026 14:36:41 -0500 Subject: [PATCH 2/3] feat: manual proto pushing (#2134) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * feat: manual proto pushing * feat: manually push protos * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot --- protos/google/cloud/common_resources.proto | 52 -- protos/google/pubsub/v1/pubsub.proto | 118 +++- protos/protos.d.ts | 161 +++++- protos/protos.js | 624 ++++++++++++++++++++- protos/protos.json | 114 +++- 5 files changed, 978 insertions(+), 91 deletions(-) delete mode 100644 protos/google/cloud/common_resources.proto diff --git a/protos/google/cloud/common_resources.proto b/protos/google/cloud/common_resources.proto deleted file mode 100644 index 56c9f800d..000000000 --- a/protos/google/cloud/common_resources.proto +++ /dev/null @@ -1,52 +0,0 @@ -// 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. - -// This file contains stub messages for common resources in GCP. -// It is not intended to be directly generated, and is instead used by -// other tooling to be able to match common resource patterns. -syntax = "proto3"; - -package google.cloud; - -import "google/api/resource.proto"; - - -option (google.api.resource_definition) = { - type: "cloudresourcemanager.googleapis.com/Project" - pattern: "projects/{project}" -}; - - -option (google.api.resource_definition) = { - type: "cloudresourcemanager.googleapis.com/Organization" - pattern: "organizations/{organization}" -}; - - -option (google.api.resource_definition) = { - type: "cloudresourcemanager.googleapis.com/Folder" - pattern: "folders/{folder}" -}; - - -option (google.api.resource_definition) = { - type: "cloudbilling.googleapis.com/BillingAccount" - pattern: "billingAccounts/{billing_account}" -}; - -option (google.api.resource_definition) = { - type: "locations.googleapis.com/Location" - pattern: "projects/{project}/locations/{location}" -}; - diff --git a/protos/google/pubsub/v1/pubsub.proto b/protos/google/pubsub/v1/pubsub.proto index 2792133a4..b542351d9 100644 --- a/protos/google/pubsub/v1/pubsub.proto +++ b/protos/google/pubsub/v1/pubsub.proto @@ -33,6 +33,14 @@ option java_outer_classname = "PubsubProto"; option java_package = "com.google.pubsub.v1"; option php_namespace = "Google\\Cloud\\PubSub\\V1"; option ruby_package = "Google::Cloud::PubSub::V1"; +option (google.api.resource_definition) = { + type: "cloudkms.googleapis.com/CryptoKey" + pattern: "projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{crypto_key}" +}; +option (google.api.resource_definition) = { + type: "analyticshub.googleapis.com/Listing" + pattern: "projects/{project}/locations/{location}/dataExchanges/{data_exchange}/listings/{listing}" +}; // The service that an application uses to manipulate topics, and to send // messages to a topic. @@ -415,7 +423,10 @@ message IngestionDataSourceSettings { // Required. The name of the topic in the Amazon MSK cluster that Pub/Sub // will import from. - string topic = 3 [(google.api.field_behavior) = REQUIRED]; + string topic = 3 [ + (google.api.field_behavior) = REQUIRED, + (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" } + ]; // 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 @@ -553,6 +564,10 @@ message IngestionFailureEvent { // validation violation. message SchemaViolationReason {} + // Set when a Pub/Sub message fails to get published due to a message + // transformation error. + message MessageTransformationFailureReason {} + // Failure when ingesting from a Cloud Storage source. message CloudStorageFailure { // Optional. Name of the Cloud Storage bucket used for ingestion. @@ -580,6 +595,11 @@ message IngestionFailureEvent { // Optional. The Pub/Sub message failed schema validation. SchemaViolationReason schema_violation_reason = 7 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. Failure encountered when applying a message transformation to + // the Pub/Sub message. + MessageTransformationFailureReason message_transformation_failure_reason = + 8 [(google.api.field_behavior) = OPTIONAL]; } } @@ -608,6 +628,11 @@ message IngestionFailureEvent { // Optional. The Pub/Sub message failed schema validation. SchemaViolationReason schema_violation_reason = 6 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. Failure encountered when applying a message transformation to + // the Pub/Sub message. + MessageTransformationFailureReason message_transformation_failure_reason = + 7 [(google.api.field_behavior) = OPTIONAL]; } } @@ -636,6 +661,11 @@ message IngestionFailureEvent { // Optional. The Pub/Sub message failed schema validation. SchemaViolationReason schema_violation_reason = 6 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. Failure encountered when applying a message transformation to + // the Pub/Sub message. + MessageTransformationFailureReason message_transformation_failure_reason = + 7 [(google.api.field_behavior) = OPTIONAL]; } } @@ -664,6 +694,11 @@ message IngestionFailureEvent { // Optional. The Pub/Sub message failed schema validation. SchemaViolationReason schema_violation_reason = 6 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. Failure encountered when applying a message transformation to + // the Pub/Sub message. + MessageTransformationFailureReason message_transformation_failure_reason = + 7 [(google.api.field_behavior) = OPTIONAL]; } } @@ -683,12 +718,26 @@ message IngestionFailureEvent { // Optional. The Pub/Sub message failed schema validation. SchemaViolationReason schema_violation_reason = 4 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. Failure encountered when applying a message transformation to + // the Pub/Sub message. + MessageTransformationFailureReason message_transformation_failure_reason = + 5 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. The message failed to be published due to an API violation. + // This is only set when the size of the data field of the Kinesis record + // is zero. + ApiViolationReason api_violation_reason = 6 + [(google.api.field_behavior) = OPTIONAL]; } } // Required. Name of the import topic. Format is: // projects/{project_name}/topics/{topic_name}. - string topic = 1 [(google.api.field_behavior) = REQUIRED]; + string topic = 1 [ + (google.api.field_behavior) = REQUIRED, + (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" } + ]; // Required. Error details explaining why ingestion to Pub/Sub has failed. string error_message = 2 [(google.api.field_behavior) = REQUIRED]; @@ -820,7 +869,12 @@ message Topic { // protect access to messages published on this topic. // // The expected format is `projects/*/locations/*/keyRings/*/cryptoKeys/*`. - string kms_key_name = 5 [(google.api.field_behavior) = OPTIONAL]; + string kms_key_name = 5 [ + (google.api.field_behavior) = OPTIONAL, + (google.api.resource_reference) = { + type: "cloudkms.googleapis.com/CryptoKey" + } + ]; // Optional. Settings for validating messages published against a schema. SchemaSettings schema_settings = 6 [(google.api.field_behavior) = OPTIONAL]; @@ -852,6 +906,16 @@ message Topic { // Transforms are applied in the order specified. repeated MessageTransform message_transforms = 13 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. Input only. Immutable. Tag keys/values directly bound to this + // resource. For example: + // "123/environment": "production", + // "123/costCenter": "marketing" + map tags = 14 [ + (google.api.field_behavior) = INPUT_ONLY, + (google.api.field_behavior) = IMMUTABLE, + (google.api.field_behavior) = OPTIONAL + ]; } // A message that is published by publishers and consumed by subscribers. The @@ -1025,7 +1089,10 @@ message ListTopicSnapshotsRequest { // Response for the `ListTopicSnapshots` method. message ListTopicSnapshotsResponse { // Optional. The names of the snapshots that match the request. - repeated string snapshots = 1 [(google.api.field_behavior) = OPTIONAL]; + repeated string snapshots = 1 [ + (google.api.field_behavior) = OPTIONAL, + (google.api.resource_reference) = { type: "pubsub.googleapis.com/Snapshot" } + ]; // Optional. If not empty, indicates that there may be more snapshots that // match the request; this value should be passed in a new @@ -1319,7 +1386,12 @@ message Subscription { // Optional. The name of the associated Analytics Hub listing resource. // Pattern: // "projects/{project}/locations/{location}/dataExchanges/{data_exchange}/listings/{listing}" - string listing = 1 [(google.api.field_behavior) = OPTIONAL]; + string listing = 1 [ + (google.api.field_behavior) = OPTIONAL, + (google.api.resource_reference) = { + type: "analyticshub.googleapis.com/Listing" + } + ]; // Optional. The name of the associated Analytics Hub subscription resource. // Pattern: @@ -1485,6 +1557,16 @@ message Subscription { // subscribers. Transforms are applied in the order specified. repeated MessageTransform message_transforms = 25 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. Input only. Immutable. Tag keys/values directly bound to this + // resource. For example: + // "123/environment": "production", + // "123/costCenter": "marketing" + map tags = 26 [ + (google.api.field_behavior) = INPUT_ONLY, + (google.api.field_behavior) = IMMUTABLE, + (google.api.field_behavior) = OPTIONAL + ]; } // A policy that specifies how Pub/Sub retries message delivery. @@ -1526,7 +1608,10 @@ message DeadLetterPolicy { // The operation will fail if the topic does not exist. // Users should ensure that there is a subscription attached to this topic // since messages published to a topic with no subscriptions are lost. - string dead_letter_topic = 1 [(google.api.field_behavior) = OPTIONAL]; + string dead_letter_topic = 1 [ + (google.api.field_behavior) = OPTIONAL, + (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" } + ]; // Optional. The maximum number of delivery attempts for any message. The // value must be between 5 and 100. @@ -2095,6 +2180,11 @@ message StreamingPullRequest { // set on a subsequent request, the stream will be aborted with status // `INVALID_ARGUMENT`. int64 max_outstanding_bytes = 8 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. The protocol version used by the client. This property can only + // be set on the initial StreamingPullRequest. If it is set on a subsequent + // request, the stream will be aborted with status `INVALID_ARGUMENT`. + int64 protocol_version = 10 [(google.api.field_behavior) = OPTIONAL]; } // Response for the `StreamingPull` method. This response is used to stream @@ -2149,17 +2239,17 @@ message StreamingPullResponse { bool message_ordering_enabled = 2 [(google.api.field_behavior) = OPTIONAL]; } - // Optional. Received Pub/Sub messages. This will not be empty. + // Optional. Received Pub/Sub messages. repeated ReceivedMessage received_messages = 1 [(google.api.field_behavior) = OPTIONAL]; // Optional. This field will only be set if `enable_exactly_once_delivery` is - // set to `true`. + // set to `true` and is not guaranteed to be populated. AcknowledgeConfirmation acknowledge_confirmation = 5 [(google.api.field_behavior) = OPTIONAL]; // Optional. This field will only be set if `enable_exactly_once_delivery` is - // set to `true`. + // set to `true` and is not guaranteed to be populated. ModifyAckDeadlineConfirmation modify_ack_deadline_confirmation = 3 [(google.api.field_behavior) = OPTIONAL]; @@ -2200,6 +2290,16 @@ message CreateSnapshotRequest { // Optional. See [Creating and managing // labels](https://cloud.google.com/pubsub/docs/labels). map labels = 3 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. Input only. Immutable. Tag keys/values directly bound to this + // resource. For example: + // "123/environment": "production", + // "123/costCenter": "marketing" + map tags = 4 [ + (google.api.field_behavior) = INPUT_ONLY, + (google.api.field_behavior) = IMMUTABLE, + (google.api.field_behavior) = OPTIONAL + ]; } // Request for the UpdateSnapshot method. diff --git a/protos/protos.d.ts b/protos/protos.d.ts index e198396e1..6f6201d1f 100644 --- a/protos/protos.d.ts +++ b/protos/protos.d.ts @@ -2099,6 +2099,97 @@ export namespace google { public static getTypeUrl(typeUrlPrefix?: string): string; } + /** Properties of a MessageTransformationFailureReason. */ + interface IMessageTransformationFailureReason { + } + + /** Represents a MessageTransformationFailureReason. */ + class MessageTransformationFailureReason implements IMessageTransformationFailureReason { + + /** + * Constructs a new MessageTransformationFailureReason. + * @param [properties] Properties to set + */ + constructor(properties?: google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason); + + /** + * Creates a new MessageTransformationFailureReason instance using the specified properties. + * @param [properties] Properties to set + * @returns MessageTransformationFailureReason instance + */ + public static create(properties?: google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason): google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason; + + /** + * Encodes the specified MessageTransformationFailureReason message. Does not implicitly {@link google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.verify|verify} messages. + * @param message MessageTransformationFailureReason message or plain object to encode + * @param [writer] Writer to encode to + * @returns Writer + */ + public static encode(message: google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason, writer?: $protobuf.Writer): $protobuf.Writer; + + /** + * Encodes the specified MessageTransformationFailureReason message, length delimited. Does not implicitly {@link google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.verify|verify} messages. + * @param message MessageTransformationFailureReason message or plain object to encode + * @param [writer] Writer to encode to + * @returns Writer + */ + public static encodeDelimited(message: google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason, writer?: $protobuf.Writer): $protobuf.Writer; + + /** + * Decodes a MessageTransformationFailureReason message from the specified reader or buffer. + * @param reader Reader or buffer to decode from + * @param [length] Message length if known beforehand + * @returns MessageTransformationFailureReason + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason; + + /** + * Decodes a MessageTransformationFailureReason message from the specified reader or buffer, length delimited. + * @param reader Reader or buffer to decode from + * @returns MessageTransformationFailureReason + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason; + + /** + * Verifies a MessageTransformationFailureReason message. + * @param message Plain object to verify + * @returns `null` if valid, otherwise the reason why it is not + */ + public static verify(message: { [k: string]: any }): (string|null); + + /** + * Creates a MessageTransformationFailureReason message from a plain object. Also converts values to their respective internal types. + * @param object Plain object + * @returns MessageTransformationFailureReason + */ + public static fromObject(object: { [k: string]: any }): google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason; + + /** + * Creates a plain object from a MessageTransformationFailureReason message. Also converts values to other types if specified. + * @param message MessageTransformationFailureReason + * @param [options] Conversion options + * @returns Plain object + */ + public static toObject(message: google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason, options?: $protobuf.IConversionOptions): { [k: string]: any }; + + /** + * Converts this MessageTransformationFailureReason to JSON. + * @returns JSON object + */ + public toJSON(): { [k: string]: any }; + + /** + * Gets the default type url for MessageTransformationFailureReason + * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com") + * @returns The default type url + */ + public static getTypeUrl(typeUrlPrefix?: string): string; + } + /** Properties of a CloudStorageFailure. */ interface ICloudStorageFailure { @@ -2119,6 +2210,9 @@ export namespace google { /** CloudStorageFailure schemaViolationReason */ schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + + /** CloudStorageFailure messageTransformationFailureReason */ + messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); } /** Represents a CloudStorageFailure. */ @@ -2148,8 +2242,11 @@ export namespace google { /** CloudStorageFailure schemaViolationReason. */ public schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + /** CloudStorageFailure messageTransformationFailureReason. */ + public messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); + /** CloudStorageFailure reason. */ - public reason?: ("avroFailureReason"|"apiViolationReason"|"schemaViolationReason"); + public reason?: ("avroFailureReason"|"apiViolationReason"|"schemaViolationReason"|"messageTransformationFailureReason"); /** * Creates a new CloudStorageFailure instance using the specified properties. @@ -2249,6 +2346,9 @@ export namespace google { /** AwsMskFailureReason schemaViolationReason */ schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + + /** AwsMskFailureReason messageTransformationFailureReason */ + messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); } /** Represents an AwsMskFailureReason. */ @@ -2278,8 +2378,11 @@ export namespace google { /** AwsMskFailureReason schemaViolationReason. */ public schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + /** AwsMskFailureReason messageTransformationFailureReason. */ + public messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); + /** AwsMskFailureReason reason. */ - public reason?: ("apiViolationReason"|"schemaViolationReason"); + public reason?: ("apiViolationReason"|"schemaViolationReason"|"messageTransformationFailureReason"); /** * Creates a new AwsMskFailureReason instance using the specified properties. @@ -2379,6 +2482,9 @@ export namespace google { /** AzureEventHubsFailureReason schemaViolationReason */ schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + + /** AzureEventHubsFailureReason messageTransformationFailureReason */ + messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); } /** Represents an AzureEventHubsFailureReason. */ @@ -2408,8 +2514,11 @@ export namespace google { /** AzureEventHubsFailureReason schemaViolationReason. */ public schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + /** AzureEventHubsFailureReason messageTransformationFailureReason. */ + public messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); + /** AzureEventHubsFailureReason reason. */ - public reason?: ("apiViolationReason"|"schemaViolationReason"); + public reason?: ("apiViolationReason"|"schemaViolationReason"|"messageTransformationFailureReason"); /** * Creates a new AzureEventHubsFailureReason instance using the specified properties. @@ -2509,6 +2618,9 @@ export namespace google { /** ConfluentCloudFailureReason schemaViolationReason */ schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + + /** ConfluentCloudFailureReason messageTransformationFailureReason */ + messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); } /** Represents a ConfluentCloudFailureReason. */ @@ -2538,8 +2650,11 @@ export namespace google { /** ConfluentCloudFailureReason schemaViolationReason. */ public schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + /** ConfluentCloudFailureReason messageTransformationFailureReason. */ + public messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); + /** ConfluentCloudFailureReason reason. */ - public reason?: ("apiViolationReason"|"schemaViolationReason"); + public reason?: ("apiViolationReason"|"schemaViolationReason"|"messageTransformationFailureReason"); /** * Creates a new ConfluentCloudFailureReason instance using the specified properties. @@ -2633,6 +2748,12 @@ export namespace google { /** AwsKinesisFailureReason schemaViolationReason */ schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + + /** AwsKinesisFailureReason messageTransformationFailureReason */ + messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); + + /** AwsKinesisFailureReason apiViolationReason */ + apiViolationReason?: (google.pubsub.v1.IngestionFailureEvent.IApiViolationReason|null); } /** Represents an AwsKinesisFailureReason. */ @@ -2656,8 +2777,14 @@ export namespace google { /** AwsKinesisFailureReason schemaViolationReason. */ public schemaViolationReason?: (google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null); + /** AwsKinesisFailureReason messageTransformationFailureReason. */ + public messageTransformationFailureReason?: (google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null); + + /** AwsKinesisFailureReason apiViolationReason. */ + public apiViolationReason?: (google.pubsub.v1.IngestionFailureEvent.IApiViolationReason|null); + /** AwsKinesisFailureReason reason. */ - public reason?: "schemaViolationReason"; + public reason?: ("schemaViolationReason"|"messageTransformationFailureReason"|"apiViolationReason"); /** * Creates a new AwsKinesisFailureReason instance using the specified properties. @@ -2985,6 +3112,9 @@ export namespace google { /** Topic messageTransforms */ messageTransforms?: (google.pubsub.v1.IMessageTransform[]|null); + + /** Topic tags */ + tags?: ({ [k: string]: string }|null); } /** Represents a Topic. */ @@ -3026,6 +3156,9 @@ export namespace google { /** Topic messageTransforms. */ public messageTransforms: google.pubsub.v1.IMessageTransform[]; + /** Topic tags. */ + public tags: { [k: string]: string }; + /** * Creates a new Topic instance using the specified properties. * @param [properties] Properties to set @@ -4978,6 +5111,9 @@ export namespace google { /** Subscription messageTransforms */ messageTransforms?: (google.pubsub.v1.IMessageTransform[]|null); + + /** Subscription tags */ + tags?: ({ [k: string]: string }|null); } /** Represents a Subscription. */ @@ -5049,6 +5185,9 @@ export namespace google { /** Subscription messageTransforms. */ public messageTransforms: google.pubsub.v1.IMessageTransform[]; + /** Subscription tags. */ + public tags: { [k: string]: string }; + /** * Creates a new Subscription instance using the specified properties. * @param [properties] Properties to set @@ -7642,6 +7781,9 @@ export namespace google { /** StreamingPullRequest maxOutstandingBytes */ maxOutstandingBytes?: (number|Long|string|null); + + /** StreamingPullRequest protocolVersion */ + protocolVersion?: (number|Long|string|null); } /** Represents a StreamingPullRequest. */ @@ -7677,6 +7819,9 @@ export namespace google { /** StreamingPullRequest maxOutstandingBytes. */ public maxOutstandingBytes: (number|Long|string); + /** StreamingPullRequest protocolVersion. */ + public protocolVersion: (number|Long|string); + /** * Creates a new StreamingPullRequest instance using the specified properties. * @param [properties] Properties to set @@ -8211,6 +8356,9 @@ export namespace google { /** CreateSnapshotRequest labels */ labels?: ({ [k: string]: string }|null); + + /** CreateSnapshotRequest tags */ + tags?: ({ [k: string]: string }|null); } /** Represents a CreateSnapshotRequest. */ @@ -8231,6 +8379,9 @@ export namespace google { /** CreateSnapshotRequest labels. */ public labels: { [k: string]: string }; + /** CreateSnapshotRequest tags. */ + public tags: { [k: string]: string }; + /** * Creates a new CreateSnapshotRequest instance using the specified properties. * @param [properties] Properties to set diff --git a/protos/protos.js b/protos/protos.js index a3fdcc20c..319bc7995 100644 --- a/protos/protos.js +++ b/protos/protos.js @@ -5122,6 +5122,183 @@ return SchemaViolationReason; })(); + IngestionFailureEvent.MessageTransformationFailureReason = (function() { + + /** + * Properties of a MessageTransformationFailureReason. + * @memberof google.pubsub.v1.IngestionFailureEvent + * @interface IMessageTransformationFailureReason + */ + + /** + * Constructs a new MessageTransformationFailureReason. + * @memberof google.pubsub.v1.IngestionFailureEvent + * @classdesc Represents a MessageTransformationFailureReason. + * @implements IMessageTransformationFailureReason + * @constructor + * @param {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason=} [properties] Properties to set + */ + function MessageTransformationFailureReason(properties) { + if (properties) + for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i) + if (properties[keys[i]] != null) + this[keys[i]] = properties[keys[i]]; + } + + /** + * Creates a new MessageTransformationFailureReason instance using the specified properties. + * @function create + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @static + * @param {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason=} [properties] Properties to set + * @returns {google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason} MessageTransformationFailureReason instance + */ + MessageTransformationFailureReason.create = function create(properties) { + return new MessageTransformationFailureReason(properties); + }; + + /** + * Encodes the specified MessageTransformationFailureReason message. Does not implicitly {@link google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.verify|verify} messages. + * @function encode + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @static + * @param {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason} message MessageTransformationFailureReason message or plain object to encode + * @param {$protobuf.Writer} [writer] Writer to encode to + * @returns {$protobuf.Writer} Writer + */ + MessageTransformationFailureReason.encode = function encode(message, writer) { + if (!writer) + writer = $Writer.create(); + return writer; + }; + + /** + * Encodes the specified MessageTransformationFailureReason message, length delimited. Does not implicitly {@link google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.verify|verify} messages. + * @function encodeDelimited + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @static + * @param {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason} message MessageTransformationFailureReason message or plain object to encode + * @param {$protobuf.Writer} [writer] Writer to encode to + * @returns {$protobuf.Writer} Writer + */ + MessageTransformationFailureReason.encodeDelimited = function encodeDelimited(message, writer) { + return this.encode(message, writer).ldelim(); + }; + + /** + * Decodes a MessageTransformationFailureReason message from the specified reader or buffer. + * @function decode + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @static + * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from + * @param {number} [length] Message length if known beforehand + * @returns {google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason} MessageTransformationFailureReason + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + MessageTransformationFailureReason.decode = function decode(reader, length, error) { + if (!(reader instanceof $Reader)) + reader = $Reader.create(reader); + var end = length === undefined ? reader.len : reader.pos + length, message = new $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason(); + while (reader.pos < end) { + var tag = reader.uint32(); + if (tag === error) + break; + switch (tag >>> 3) { + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }; + + /** + * Decodes a MessageTransformationFailureReason message from the specified reader or buffer, length delimited. + * @function decodeDelimited + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @static + * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from + * @returns {google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason} MessageTransformationFailureReason + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + MessageTransformationFailureReason.decodeDelimited = function decodeDelimited(reader) { + if (!(reader instanceof $Reader)) + reader = new $Reader(reader); + return this.decode(reader, reader.uint32()); + }; + + /** + * Verifies a MessageTransformationFailureReason message. + * @function verify + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @static + * @param {Object.} message Plain object to verify + * @returns {string|null} `null` if valid, otherwise the reason why it is not + */ + MessageTransformationFailureReason.verify = function verify(message) { + if (typeof message !== "object" || message === null) + return "object expected"; + return null; + }; + + /** + * Creates a MessageTransformationFailureReason message from a plain object. Also converts values to their respective internal types. + * @function fromObject + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @static + * @param {Object.} object Plain object + * @returns {google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason} MessageTransformationFailureReason + */ + MessageTransformationFailureReason.fromObject = function fromObject(object) { + if (object instanceof $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason) + return object; + return new $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason(); + }; + + /** + * Creates a plain object from a MessageTransformationFailureReason message. Also converts values to other types if specified. + * @function toObject + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @static + * @param {google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason} message MessageTransformationFailureReason + * @param {$protobuf.IConversionOptions} [options] Conversion options + * @returns {Object.} Plain object + */ + MessageTransformationFailureReason.toObject = function toObject() { + return {}; + }; + + /** + * Converts this MessageTransformationFailureReason to JSON. + * @function toJSON + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @instance + * @returns {Object.} JSON object + */ + MessageTransformationFailureReason.prototype.toJSON = function toJSON() { + return this.constructor.toObject(this, $protobuf.util.toJSONOptions); + }; + + /** + * Gets the default type url for MessageTransformationFailureReason + * @function getTypeUrl + * @memberof google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason + * @static + * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com") + * @returns {string} The default type url + */ + MessageTransformationFailureReason.getTypeUrl = function getTypeUrl(typeUrlPrefix) { + if (typeUrlPrefix === undefined) { + typeUrlPrefix = "type.googleapis.com"; + } + return typeUrlPrefix + "/google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason"; + }; + + return MessageTransformationFailureReason; + })(); + IngestionFailureEvent.CloudStorageFailure = (function() { /** @@ -5134,6 +5311,7 @@ * @property {google.pubsub.v1.IngestionFailureEvent.IAvroFailureReason|null} [avroFailureReason] CloudStorageFailure avroFailureReason * @property {google.pubsub.v1.IngestionFailureEvent.IApiViolationReason|null} [apiViolationReason] CloudStorageFailure apiViolationReason * @property {google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null} [schemaViolationReason] CloudStorageFailure schemaViolationReason + * @property {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null} [messageTransformationFailureReason] CloudStorageFailure messageTransformationFailureReason */ /** @@ -5199,17 +5377,25 @@ */ CloudStorageFailure.prototype.schemaViolationReason = null; + /** + * CloudStorageFailure messageTransformationFailureReason. + * @member {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null|undefined} messageTransformationFailureReason + * @memberof google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure + * @instance + */ + CloudStorageFailure.prototype.messageTransformationFailureReason = null; + // OneOf field names bound to virtual getters and setters var $oneOfFields; /** * CloudStorageFailure reason. - * @member {"avroFailureReason"|"apiViolationReason"|"schemaViolationReason"|undefined} reason + * @member {"avroFailureReason"|"apiViolationReason"|"schemaViolationReason"|"messageTransformationFailureReason"|undefined} reason * @memberof google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure * @instance */ Object.defineProperty(CloudStorageFailure.prototype, "reason", { - get: $util.oneOfGetter($oneOfFields = ["avroFailureReason", "apiViolationReason", "schemaViolationReason"]), + get: $util.oneOfGetter($oneOfFields = ["avroFailureReason", "apiViolationReason", "schemaViolationReason", "messageTransformationFailureReason"]), set: $util.oneOfSetter($oneOfFields) }); @@ -5249,6 +5435,8 @@ $root.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason.encode(message.apiViolationReason, writer.uint32(/* id 6, wireType 2 =*/50).fork()).ldelim(); if (message.schemaViolationReason != null && Object.hasOwnProperty.call(message, "schemaViolationReason")) $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.encode(message.schemaViolationReason, writer.uint32(/* id 7, wireType 2 =*/58).fork()).ldelim(); + if (message.messageTransformationFailureReason != null && Object.hasOwnProperty.call(message, "messageTransformationFailureReason")) + $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.encode(message.messageTransformationFailureReason, writer.uint32(/* id 8, wireType 2 =*/66).fork()).ldelim(); return writer; }; @@ -5309,6 +5497,10 @@ message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.decode(reader, reader.uint32()); break; } + case 8: { + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.decode(reader, reader.uint32()); + break; + } default: reader.skipType(tag & 7); break; @@ -5382,6 +5574,16 @@ return "schemaViolationReason." + error; } } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + if (properties.reason === 1) + return "reason: multiple values"; + properties.reason = 1; + { + var error = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.verify(message.messageTransformationFailureReason); + if (error) + return "messageTransformationFailureReason." + error; + } + } return null; }; @@ -5425,6 +5627,11 @@ throw TypeError(".google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure.schemaViolationReason: object expected"); message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.fromObject(object.schemaViolationReason); } + if (object.messageTransformationFailureReason != null) { + if (typeof object.messageTransformationFailureReason !== "object") + throw TypeError(".google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure.messageTransformationFailureReason: object expected"); + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.fromObject(object.messageTransformationFailureReason); + } return message; }; @@ -5474,6 +5681,11 @@ if (options.oneofs) object.reason = "schemaViolationReason"; } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + object.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.toObject(message.messageTransformationFailureReason, options); + if (options.oneofs) + object.reason = "messageTransformationFailureReason"; + } return object; }; @@ -5518,6 +5730,7 @@ * @property {number|Long|null} [offset] AwsMskFailureReason offset * @property {google.pubsub.v1.IngestionFailureEvent.IApiViolationReason|null} [apiViolationReason] AwsMskFailureReason apiViolationReason * @property {google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null} [schemaViolationReason] AwsMskFailureReason schemaViolationReason + * @property {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null} [messageTransformationFailureReason] AwsMskFailureReason messageTransformationFailureReason */ /** @@ -5583,17 +5796,25 @@ */ AwsMskFailureReason.prototype.schemaViolationReason = null; + /** + * AwsMskFailureReason messageTransformationFailureReason. + * @member {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null|undefined} messageTransformationFailureReason + * @memberof google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason + * @instance + */ + AwsMskFailureReason.prototype.messageTransformationFailureReason = null; + // OneOf field names bound to virtual getters and setters var $oneOfFields; /** * AwsMskFailureReason reason. - * @member {"apiViolationReason"|"schemaViolationReason"|undefined} reason + * @member {"apiViolationReason"|"schemaViolationReason"|"messageTransformationFailureReason"|undefined} reason * @memberof google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason * @instance */ Object.defineProperty(AwsMskFailureReason.prototype, "reason", { - get: $util.oneOfGetter($oneOfFields = ["apiViolationReason", "schemaViolationReason"]), + get: $util.oneOfGetter($oneOfFields = ["apiViolationReason", "schemaViolationReason", "messageTransformationFailureReason"]), set: $util.oneOfSetter($oneOfFields) }); @@ -5633,6 +5854,8 @@ $root.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason.encode(message.apiViolationReason, writer.uint32(/* id 5, wireType 2 =*/42).fork()).ldelim(); if (message.schemaViolationReason != null && Object.hasOwnProperty.call(message, "schemaViolationReason")) $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.encode(message.schemaViolationReason, writer.uint32(/* id 6, wireType 2 =*/50).fork()).ldelim(); + if (message.messageTransformationFailureReason != null && Object.hasOwnProperty.call(message, "messageTransformationFailureReason")) + $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.encode(message.messageTransformationFailureReason, writer.uint32(/* id 7, wireType 2 =*/58).fork()).ldelim(); return writer; }; @@ -5693,6 +5916,10 @@ message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.decode(reader, reader.uint32()); break; } + case 7: { + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.decode(reader, reader.uint32()); + break; + } default: reader.skipType(tag & 7); break; @@ -5759,6 +5986,16 @@ return "schemaViolationReason." + error; } } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + if (properties.reason === 1) + return "reason: multiple values"; + properties.reason = 1; + { + var error = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.verify(message.messageTransformationFailureReason); + if (error) + return "messageTransformationFailureReason." + error; + } + } return null; }; @@ -5806,6 +6043,11 @@ throw TypeError(".google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason.schemaViolationReason: object expected"); message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.fromObject(object.schemaViolationReason); } + if (object.messageTransformationFailureReason != null) { + if (typeof object.messageTransformationFailureReason !== "object") + throw TypeError(".google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason.messageTransformationFailureReason: object expected"); + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.fromObject(object.messageTransformationFailureReason); + } return message; }; @@ -5860,6 +6102,11 @@ if (options.oneofs) object.reason = "schemaViolationReason"; } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + object.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.toObject(message.messageTransformationFailureReason, options); + if (options.oneofs) + object.reason = "messageTransformationFailureReason"; + } return object; }; @@ -5904,6 +6151,7 @@ * @property {number|Long|null} [offset] AzureEventHubsFailureReason offset * @property {google.pubsub.v1.IngestionFailureEvent.IApiViolationReason|null} [apiViolationReason] AzureEventHubsFailureReason apiViolationReason * @property {google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null} [schemaViolationReason] AzureEventHubsFailureReason schemaViolationReason + * @property {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null} [messageTransformationFailureReason] AzureEventHubsFailureReason messageTransformationFailureReason */ /** @@ -5969,17 +6217,25 @@ */ AzureEventHubsFailureReason.prototype.schemaViolationReason = null; + /** + * AzureEventHubsFailureReason messageTransformationFailureReason. + * @member {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null|undefined} messageTransformationFailureReason + * @memberof google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason + * @instance + */ + AzureEventHubsFailureReason.prototype.messageTransformationFailureReason = null; + // OneOf field names bound to virtual getters and setters var $oneOfFields; /** * AzureEventHubsFailureReason reason. - * @member {"apiViolationReason"|"schemaViolationReason"|undefined} reason + * @member {"apiViolationReason"|"schemaViolationReason"|"messageTransformationFailureReason"|undefined} reason * @memberof google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason * @instance */ Object.defineProperty(AzureEventHubsFailureReason.prototype, "reason", { - get: $util.oneOfGetter($oneOfFields = ["apiViolationReason", "schemaViolationReason"]), + get: $util.oneOfGetter($oneOfFields = ["apiViolationReason", "schemaViolationReason", "messageTransformationFailureReason"]), set: $util.oneOfSetter($oneOfFields) }); @@ -6019,6 +6275,8 @@ $root.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason.encode(message.apiViolationReason, writer.uint32(/* id 5, wireType 2 =*/42).fork()).ldelim(); if (message.schemaViolationReason != null && Object.hasOwnProperty.call(message, "schemaViolationReason")) $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.encode(message.schemaViolationReason, writer.uint32(/* id 6, wireType 2 =*/50).fork()).ldelim(); + if (message.messageTransformationFailureReason != null && Object.hasOwnProperty.call(message, "messageTransformationFailureReason")) + $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.encode(message.messageTransformationFailureReason, writer.uint32(/* id 7, wireType 2 =*/58).fork()).ldelim(); return writer; }; @@ -6079,6 +6337,10 @@ message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.decode(reader, reader.uint32()); break; } + case 7: { + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.decode(reader, reader.uint32()); + break; + } default: reader.skipType(tag & 7); break; @@ -6145,6 +6407,16 @@ return "schemaViolationReason." + error; } } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + if (properties.reason === 1) + return "reason: multiple values"; + properties.reason = 1; + { + var error = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.verify(message.messageTransformationFailureReason); + if (error) + return "messageTransformationFailureReason." + error; + } + } return null; }; @@ -6192,6 +6464,11 @@ throw TypeError(".google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason.schemaViolationReason: object expected"); message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.fromObject(object.schemaViolationReason); } + if (object.messageTransformationFailureReason != null) { + if (typeof object.messageTransformationFailureReason !== "object") + throw TypeError(".google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason.messageTransformationFailureReason: object expected"); + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.fromObject(object.messageTransformationFailureReason); + } return message; }; @@ -6246,6 +6523,11 @@ if (options.oneofs) object.reason = "schemaViolationReason"; } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + object.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.toObject(message.messageTransformationFailureReason, options); + if (options.oneofs) + object.reason = "messageTransformationFailureReason"; + } return object; }; @@ -6290,6 +6572,7 @@ * @property {number|Long|null} [offset] ConfluentCloudFailureReason offset * @property {google.pubsub.v1.IngestionFailureEvent.IApiViolationReason|null} [apiViolationReason] ConfluentCloudFailureReason apiViolationReason * @property {google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null} [schemaViolationReason] ConfluentCloudFailureReason schemaViolationReason + * @property {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null} [messageTransformationFailureReason] ConfluentCloudFailureReason messageTransformationFailureReason */ /** @@ -6355,17 +6638,25 @@ */ ConfluentCloudFailureReason.prototype.schemaViolationReason = null; + /** + * ConfluentCloudFailureReason messageTransformationFailureReason. + * @member {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null|undefined} messageTransformationFailureReason + * @memberof google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason + * @instance + */ + ConfluentCloudFailureReason.prototype.messageTransformationFailureReason = null; + // OneOf field names bound to virtual getters and setters var $oneOfFields; /** * ConfluentCloudFailureReason reason. - * @member {"apiViolationReason"|"schemaViolationReason"|undefined} reason + * @member {"apiViolationReason"|"schemaViolationReason"|"messageTransformationFailureReason"|undefined} reason * @memberof google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason * @instance */ Object.defineProperty(ConfluentCloudFailureReason.prototype, "reason", { - get: $util.oneOfGetter($oneOfFields = ["apiViolationReason", "schemaViolationReason"]), + get: $util.oneOfGetter($oneOfFields = ["apiViolationReason", "schemaViolationReason", "messageTransformationFailureReason"]), set: $util.oneOfSetter($oneOfFields) }); @@ -6405,6 +6696,8 @@ $root.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason.encode(message.apiViolationReason, writer.uint32(/* id 5, wireType 2 =*/42).fork()).ldelim(); if (message.schemaViolationReason != null && Object.hasOwnProperty.call(message, "schemaViolationReason")) $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.encode(message.schemaViolationReason, writer.uint32(/* id 6, wireType 2 =*/50).fork()).ldelim(); + if (message.messageTransformationFailureReason != null && Object.hasOwnProperty.call(message, "messageTransformationFailureReason")) + $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.encode(message.messageTransformationFailureReason, writer.uint32(/* id 7, wireType 2 =*/58).fork()).ldelim(); return writer; }; @@ -6465,6 +6758,10 @@ message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.decode(reader, reader.uint32()); break; } + case 7: { + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.decode(reader, reader.uint32()); + break; + } default: reader.skipType(tag & 7); break; @@ -6531,6 +6828,16 @@ return "schemaViolationReason." + error; } } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + if (properties.reason === 1) + return "reason: multiple values"; + properties.reason = 1; + { + var error = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.verify(message.messageTransformationFailureReason); + if (error) + return "messageTransformationFailureReason." + error; + } + } return null; }; @@ -6578,6 +6885,11 @@ throw TypeError(".google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason.schemaViolationReason: object expected"); message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.fromObject(object.schemaViolationReason); } + if (object.messageTransformationFailureReason != null) { + if (typeof object.messageTransformationFailureReason !== "object") + throw TypeError(".google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason.messageTransformationFailureReason: object expected"); + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.fromObject(object.messageTransformationFailureReason); + } return message; }; @@ -6632,6 +6944,11 @@ if (options.oneofs) object.reason = "schemaViolationReason"; } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + object.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.toObject(message.messageTransformationFailureReason, options); + if (options.oneofs) + object.reason = "messageTransformationFailureReason"; + } return object; }; @@ -6674,6 +6991,8 @@ * @property {string|null} [partitionKey] AwsKinesisFailureReason partitionKey * @property {string|null} [sequenceNumber] AwsKinesisFailureReason sequenceNumber * @property {google.pubsub.v1.IngestionFailureEvent.ISchemaViolationReason|null} [schemaViolationReason] AwsKinesisFailureReason schemaViolationReason + * @property {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null} [messageTransformationFailureReason] AwsKinesisFailureReason messageTransformationFailureReason + * @property {google.pubsub.v1.IngestionFailureEvent.IApiViolationReason|null} [apiViolationReason] AwsKinesisFailureReason apiViolationReason */ /** @@ -6723,17 +7042,33 @@ */ AwsKinesisFailureReason.prototype.schemaViolationReason = null; + /** + * AwsKinesisFailureReason messageTransformationFailureReason. + * @member {google.pubsub.v1.IngestionFailureEvent.IMessageTransformationFailureReason|null|undefined} messageTransformationFailureReason + * @memberof google.pubsub.v1.IngestionFailureEvent.AwsKinesisFailureReason + * @instance + */ + AwsKinesisFailureReason.prototype.messageTransformationFailureReason = null; + + /** + * AwsKinesisFailureReason apiViolationReason. + * @member {google.pubsub.v1.IngestionFailureEvent.IApiViolationReason|null|undefined} apiViolationReason + * @memberof google.pubsub.v1.IngestionFailureEvent.AwsKinesisFailureReason + * @instance + */ + AwsKinesisFailureReason.prototype.apiViolationReason = null; + // OneOf field names bound to virtual getters and setters var $oneOfFields; /** * AwsKinesisFailureReason reason. - * @member {"schemaViolationReason"|undefined} reason + * @member {"schemaViolationReason"|"messageTransformationFailureReason"|"apiViolationReason"|undefined} reason * @memberof google.pubsub.v1.IngestionFailureEvent.AwsKinesisFailureReason * @instance */ Object.defineProperty(AwsKinesisFailureReason.prototype, "reason", { - get: $util.oneOfGetter($oneOfFields = ["schemaViolationReason"]), + get: $util.oneOfGetter($oneOfFields = ["schemaViolationReason", "messageTransformationFailureReason", "apiViolationReason"]), set: $util.oneOfSetter($oneOfFields) }); @@ -6769,6 +7104,10 @@ writer.uint32(/* id 3, wireType 2 =*/26).string(message.sequenceNumber); if (message.schemaViolationReason != null && Object.hasOwnProperty.call(message, "schemaViolationReason")) $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.encode(message.schemaViolationReason, writer.uint32(/* id 4, wireType 2 =*/34).fork()).ldelim(); + if (message.messageTransformationFailureReason != null && Object.hasOwnProperty.call(message, "messageTransformationFailureReason")) + $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.encode(message.messageTransformationFailureReason, writer.uint32(/* id 5, wireType 2 =*/42).fork()).ldelim(); + if (message.apiViolationReason != null && Object.hasOwnProperty.call(message, "apiViolationReason")) + $root.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason.encode(message.apiViolationReason, writer.uint32(/* id 6, wireType 2 =*/50).fork()).ldelim(); return writer; }; @@ -6821,6 +7160,14 @@ message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.decode(reader, reader.uint32()); break; } + case 5: { + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.decode(reader, reader.uint32()); + break; + } + case 6: { + message.apiViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason.decode(reader, reader.uint32()); + break; + } default: reader.skipType(tag & 7); break; @@ -6874,6 +7221,26 @@ return "schemaViolationReason." + error; } } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + if (properties.reason === 1) + return "reason: multiple values"; + properties.reason = 1; + { + var error = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.verify(message.messageTransformationFailureReason); + if (error) + return "messageTransformationFailureReason." + error; + } + } + if (message.apiViolationReason != null && message.hasOwnProperty("apiViolationReason")) { + if (properties.reason === 1) + return "reason: multiple values"; + properties.reason = 1; + { + var error = $root.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason.verify(message.apiViolationReason); + if (error) + return "apiViolationReason." + error; + } + } return null; }; @@ -6900,6 +7267,16 @@ throw TypeError(".google.pubsub.v1.IngestionFailureEvent.AwsKinesisFailureReason.schemaViolationReason: object expected"); message.schemaViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.SchemaViolationReason.fromObject(object.schemaViolationReason); } + if (object.messageTransformationFailureReason != null) { + if (typeof object.messageTransformationFailureReason !== "object") + throw TypeError(".google.pubsub.v1.IngestionFailureEvent.AwsKinesisFailureReason.messageTransformationFailureReason: object expected"); + message.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.fromObject(object.messageTransformationFailureReason); + } + if (object.apiViolationReason != null) { + if (typeof object.apiViolationReason !== "object") + throw TypeError(".google.pubsub.v1.IngestionFailureEvent.AwsKinesisFailureReason.apiViolationReason: object expected"); + message.apiViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason.fromObject(object.apiViolationReason); + } return message; }; @@ -6932,6 +7309,16 @@ if (options.oneofs) object.reason = "schemaViolationReason"; } + if (message.messageTransformationFailureReason != null && message.hasOwnProperty("messageTransformationFailureReason")) { + object.messageTransformationFailureReason = $root.google.pubsub.v1.IngestionFailureEvent.MessageTransformationFailureReason.toObject(message.messageTransformationFailureReason, options); + if (options.oneofs) + object.reason = "messageTransformationFailureReason"; + } + if (message.apiViolationReason != null && message.hasOwnProperty("apiViolationReason")) { + object.apiViolationReason = $root.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason.toObject(message.apiViolationReason, options); + if (options.oneofs) + object.reason = "apiViolationReason"; + } return object; }; @@ -7489,6 +7876,7 @@ * @property {google.pubsub.v1.Topic.State|null} [state] Topic state * @property {google.pubsub.v1.IIngestionDataSourceSettings|null} [ingestionDataSourceSettings] Topic ingestionDataSourceSettings * @property {Array.|null} [messageTransforms] Topic messageTransforms + * @property {Object.|null} [tags] Topic tags */ /** @@ -7502,6 +7890,7 @@ function Topic(properties) { this.labels = {}; this.messageTransforms = []; + this.tags = {}; if (properties) for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i) if (properties[keys[i]] != null) @@ -7588,6 +7977,14 @@ */ Topic.prototype.messageTransforms = $util.emptyArray; + /** + * Topic tags. + * @member {Object.} tags + * @memberof google.pubsub.v1.Topic + * @instance + */ + Topic.prototype.tags = $util.emptyObject; + /** * Creates a new Topic instance using the specified properties. * @function create @@ -7634,6 +8031,9 @@ if (message.messageTransforms != null && message.messageTransforms.length) for (var i = 0; i < message.messageTransforms.length; ++i) $root.google.pubsub.v1.MessageTransform.encode(message.messageTransforms[i], writer.uint32(/* id 13, wireType 2 =*/106).fork()).ldelim(); + if (message.tags != null && Object.hasOwnProperty.call(message, "tags")) + for (var keys = Object.keys(message.tags), i = 0; i < keys.length; ++i) + writer.uint32(/* id 14, wireType 2 =*/114).fork().uint32(/* id 1, wireType 2 =*/10).string(keys[i]).uint32(/* id 2, wireType 2 =*/18).string(message.tags[keys[i]]).ldelim(); return writer; }; @@ -7731,6 +8131,29 @@ message.messageTransforms.push($root.google.pubsub.v1.MessageTransform.decode(reader, reader.uint32())); break; } + case 14: { + if (message.tags === $util.emptyObject) + message.tags = {}; + var end2 = reader.uint32() + reader.pos; + key = ""; + value = ""; + while (reader.pos < end2) { + var tag2 = reader.uint32(); + switch (tag2 >>> 3) { + case 1: + key = reader.string(); + break; + case 2: + value = reader.string(); + break; + default: + reader.skipType(tag2 & 7); + break; + } + } + message.tags[key] = value; + break; + } default: reader.skipType(tag & 7); break; @@ -7821,6 +8244,14 @@ return "messageTransforms." + error; } } + if (message.tags != null && message.hasOwnProperty("tags")) { + if (!$util.isObject(message.tags)) + return "tags: object expected"; + var key = Object.keys(message.tags); + for (var i = 0; i < key.length; ++i) + if (!$util.isString(message.tags[key[i]])) + return "tags: string{k:string} expected"; + } return null; }; @@ -7899,6 +8330,13 @@ message.messageTransforms[i] = $root.google.pubsub.v1.MessageTransform.fromObject(object.messageTransforms[i]); } } + if (object.tags) { + if (typeof object.tags !== "object") + throw TypeError(".google.pubsub.v1.Topic.tags: object expected"); + message.tags = {}; + for (var keys = Object.keys(object.tags), i = 0; i < keys.length; ++i) + message.tags[keys[i]] = String(object.tags[keys[i]]); + } return message; }; @@ -7917,8 +8355,10 @@ var object = {}; if (options.arrays || options.defaults) object.messageTransforms = []; - if (options.objects || options.defaults) + if (options.objects || options.defaults) { object.labels = {}; + object.tags = {}; + } if (options.defaults) { object.name = ""; object.messageStoragePolicy = null; @@ -7956,6 +8396,11 @@ for (var j = 0; j < message.messageTransforms.length; ++j) object.messageTransforms[j] = $root.google.pubsub.v1.MessageTransform.toObject(message.messageTransforms[j], options); } + if (message.tags && (keys2 = Object.keys(message.tags)).length) { + object.tags = {}; + for (var j = 0; j < keys2.length; ++j) + object.tags[keys2[j]] = message.tags[keys2[j]]; + } return object; }; @@ -11939,6 +12384,7 @@ * @property {google.pubsub.v1.Subscription.State|null} [state] Subscription state * @property {google.pubsub.v1.Subscription.IAnalyticsHubSubscriptionInfo|null} [analyticsHubSubscriptionInfo] Subscription analyticsHubSubscriptionInfo * @property {Array.|null} [messageTransforms] Subscription messageTransforms + * @property {Object.|null} [tags] Subscription tags */ /** @@ -11952,6 +12398,7 @@ function Subscription(properties) { this.labels = {}; this.messageTransforms = []; + this.tags = {}; if (properties) for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i) if (properties[keys[i]] != null) @@ -12118,6 +12565,14 @@ */ Subscription.prototype.messageTransforms = $util.emptyArray; + /** + * Subscription tags. + * @member {Object.} tags + * @memberof google.pubsub.v1.Subscription + * @instance + */ + Subscription.prototype.tags = $util.emptyObject; + /** * Creates a new Subscription instance using the specified properties. * @function create @@ -12184,6 +12639,9 @@ if (message.messageTransforms != null && message.messageTransforms.length) for (var i = 0; i < message.messageTransforms.length; ++i) $root.google.pubsub.v1.MessageTransform.encode(message.messageTransforms[i], writer.uint32(/* id 25, wireType 2 =*/202).fork()).ldelim(); + if (message.tags != null && Object.hasOwnProperty.call(message, "tags")) + for (var keys = Object.keys(message.tags), i = 0; i < keys.length; ++i) + writer.uint32(/* id 26, wireType 2 =*/210).fork().uint32(/* id 1, wireType 2 =*/10).string(keys[i]).uint32(/* id 2, wireType 2 =*/18).string(message.tags[keys[i]]).ldelim(); return writer; }; @@ -12321,6 +12779,29 @@ message.messageTransforms.push($root.google.pubsub.v1.MessageTransform.decode(reader, reader.uint32())); break; } + case 26: { + if (message.tags === $util.emptyObject) + message.tags = {}; + var end2 = reader.uint32() + reader.pos; + key = ""; + value = ""; + while (reader.pos < end2) { + var tag2 = reader.uint32(); + switch (tag2 >>> 3) { + case 1: + key = reader.string(); + break; + case 2: + value = reader.string(); + break; + default: + reader.skipType(tag2 & 7); + break; + } + } + message.tags[key] = value; + break; + } default: reader.skipType(tag & 7); break; @@ -12451,6 +12932,14 @@ return "messageTransforms." + error; } } + if (message.tags != null && message.hasOwnProperty("tags")) { + if (!$util.isObject(message.tags)) + return "tags: object expected"; + var key = Object.keys(message.tags); + for (var i = 0; i < key.length; ++i) + if (!$util.isString(message.tags[key[i]])) + return "tags: string{k:string} expected"; + } return null; }; @@ -12564,6 +13053,13 @@ message.messageTransforms[i] = $root.google.pubsub.v1.MessageTransform.fromObject(object.messageTransforms[i]); } } + if (object.tags) { + if (typeof object.tags !== "object") + throw TypeError(".google.pubsub.v1.Subscription.tags: object expected"); + message.tags = {}; + for (var keys = Object.keys(object.tags), i = 0; i < keys.length; ++i) + message.tags[keys[i]] = String(object.tags[keys[i]]); + } return message; }; @@ -12582,8 +13078,10 @@ var object = {}; if (options.arrays || options.defaults) object.messageTransforms = []; - if (options.objects || options.defaults) + if (options.objects || options.defaults) { object.labels = {}; + object.tags = {}; + } if (options.defaults) { object.name = ""; object.topic = ""; @@ -12651,6 +13149,11 @@ for (var j = 0; j < message.messageTransforms.length; ++j) object.messageTransforms[j] = $root.google.pubsub.v1.MessageTransform.toObject(message.messageTransforms[j], options); } + if (message.tags && (keys2 = Object.keys(message.tags)).length) { + object.tags = {}; + for (var j = 0; j < keys2.length; ++j) + object.tags[keys2[j]] = message.tags[keys2[j]]; + } return object; }; @@ -18634,6 +19137,7 @@ * @property {string|null} [clientId] StreamingPullRequest clientId * @property {number|Long|null} [maxOutstandingMessages] StreamingPullRequest maxOutstandingMessages * @property {number|Long|null} [maxOutstandingBytes] StreamingPullRequest maxOutstandingBytes + * @property {number|Long|null} [protocolVersion] StreamingPullRequest protocolVersion */ /** @@ -18718,6 +19222,14 @@ */ StreamingPullRequest.prototype.maxOutstandingBytes = $util.Long ? $util.Long.fromBits(0,0,false) : 0; + /** + * StreamingPullRequest protocolVersion. + * @member {number|Long} protocolVersion + * @memberof google.pubsub.v1.StreamingPullRequest + * @instance + */ + StreamingPullRequest.prototype.protocolVersion = $util.Long ? $util.Long.fromBits(0,0,false) : 0; + /** * Creates a new StreamingPullRequest instance using the specified properties. * @function create @@ -18764,6 +19276,8 @@ writer.uint32(/* id 7, wireType 0 =*/56).int64(message.maxOutstandingMessages); if (message.maxOutstandingBytes != null && Object.hasOwnProperty.call(message, "maxOutstandingBytes")) writer.uint32(/* id 8, wireType 0 =*/64).int64(message.maxOutstandingBytes); + if (message.protocolVersion != null && Object.hasOwnProperty.call(message, "protocolVersion")) + writer.uint32(/* id 10, wireType 0 =*/80).int64(message.protocolVersion); return writer; }; @@ -18843,6 +19357,10 @@ message.maxOutstandingBytes = reader.int64(); break; } + case 10: { + message.protocolVersion = reader.int64(); + break; + } default: reader.skipType(tag & 7); break; @@ -18914,6 +19432,9 @@ if (message.maxOutstandingBytes != null && message.hasOwnProperty("maxOutstandingBytes")) if (!$util.isInteger(message.maxOutstandingBytes) && !(message.maxOutstandingBytes && $util.isInteger(message.maxOutstandingBytes.low) && $util.isInteger(message.maxOutstandingBytes.high))) return "maxOutstandingBytes: integer|Long expected"; + if (message.protocolVersion != null && message.hasOwnProperty("protocolVersion")) + if (!$util.isInteger(message.protocolVersion) && !(message.protocolVersion && $util.isInteger(message.protocolVersion.low) && $util.isInteger(message.protocolVersion.high))) + return "protocolVersion: integer|Long expected"; return null; }; @@ -18974,6 +19495,15 @@ message.maxOutstandingBytes = object.maxOutstandingBytes; else if (typeof object.maxOutstandingBytes === "object") message.maxOutstandingBytes = new $util.LongBits(object.maxOutstandingBytes.low >>> 0, object.maxOutstandingBytes.high >>> 0).toNumber(); + if (object.protocolVersion != null) + if ($util.Long) + (message.protocolVersion = $util.Long.fromValue(object.protocolVersion)).unsigned = false; + else if (typeof object.protocolVersion === "string") + message.protocolVersion = parseInt(object.protocolVersion, 10); + else if (typeof object.protocolVersion === "number") + message.protocolVersion = object.protocolVersion; + else if (typeof object.protocolVersion === "object") + message.protocolVersion = new $util.LongBits(object.protocolVersion.low >>> 0, object.protocolVersion.high >>> 0).toNumber(); return message; }; @@ -19009,6 +19539,11 @@ object.maxOutstandingBytes = options.longs === String ? long.toString() : options.longs === Number ? long.toNumber() : long; } else object.maxOutstandingBytes = options.longs === String ? "0" : 0; + if ($util.Long) { + var long = new $util.Long(0, 0, false); + object.protocolVersion = options.longs === String ? long.toString() : options.longs === Number ? long.toNumber() : long; + } else + object.protocolVersion = options.longs === String ? "0" : 0; } if (message.subscription != null && message.hasOwnProperty("subscription")) object.subscription = message.subscription; @@ -19041,6 +19576,11 @@ object.maxOutstandingBytes = options.longs === String ? String(message.maxOutstandingBytes) : message.maxOutstandingBytes; else object.maxOutstandingBytes = options.longs === String ? $util.Long.prototype.toString.call(message.maxOutstandingBytes) : options.longs === Number ? new $util.LongBits(message.maxOutstandingBytes.low >>> 0, message.maxOutstandingBytes.high >>> 0).toNumber() : message.maxOutstandingBytes; + if (message.protocolVersion != null && message.hasOwnProperty("protocolVersion")) + if (typeof message.protocolVersion === "number") + object.protocolVersion = options.longs === String ? String(message.protocolVersion) : message.protocolVersion; + else + object.protocolVersion = options.longs === String ? $util.Long.prototype.toString.call(message.protocolVersion) : options.longs === Number ? new $util.LongBits(message.protocolVersion.low >>> 0, message.protocolVersion.high >>> 0).toNumber() : message.protocolVersion; return object; }; @@ -20262,6 +20802,7 @@ * @property {string|null} [name] CreateSnapshotRequest name * @property {string|null} [subscription] CreateSnapshotRequest subscription * @property {Object.|null} [labels] CreateSnapshotRequest labels + * @property {Object.|null} [tags] CreateSnapshotRequest tags */ /** @@ -20274,6 +20815,7 @@ */ function CreateSnapshotRequest(properties) { this.labels = {}; + this.tags = {}; if (properties) for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i) if (properties[keys[i]] != null) @@ -20304,6 +20846,14 @@ */ CreateSnapshotRequest.prototype.labels = $util.emptyObject; + /** + * CreateSnapshotRequest tags. + * @member {Object.} tags + * @memberof google.pubsub.v1.CreateSnapshotRequest + * @instance + */ + CreateSnapshotRequest.prototype.tags = $util.emptyObject; + /** * Creates a new CreateSnapshotRequest instance using the specified properties. * @function create @@ -20335,6 +20885,9 @@ if (message.labels != null && Object.hasOwnProperty.call(message, "labels")) for (var keys = Object.keys(message.labels), i = 0; i < keys.length; ++i) writer.uint32(/* id 3, wireType 2 =*/26).fork().uint32(/* id 1, wireType 2 =*/10).string(keys[i]).uint32(/* id 2, wireType 2 =*/18).string(message.labels[keys[i]]).ldelim(); + if (message.tags != null && Object.hasOwnProperty.call(message, "tags")) + for (var keys = Object.keys(message.tags), i = 0; i < keys.length; ++i) + writer.uint32(/* id 4, wireType 2 =*/34).fork().uint32(/* id 1, wireType 2 =*/10).string(keys[i]).uint32(/* id 2, wireType 2 =*/18).string(message.tags[keys[i]]).ldelim(); return writer; }; @@ -20402,6 +20955,29 @@ message.labels[key] = value; break; } + case 4: { + if (message.tags === $util.emptyObject) + message.tags = {}; + var end2 = reader.uint32() + reader.pos; + key = ""; + value = ""; + while (reader.pos < end2) { + var tag2 = reader.uint32(); + switch (tag2 >>> 3) { + case 1: + key = reader.string(); + break; + case 2: + value = reader.string(); + break; + default: + reader.skipType(tag2 & 7); + break; + } + } + message.tags[key] = value; + break; + } default: reader.skipType(tag & 7); break; @@ -20451,6 +21027,14 @@ if (!$util.isString(message.labels[key[i]])) return "labels: string{k:string} expected"; } + if (message.tags != null && message.hasOwnProperty("tags")) { + if (!$util.isObject(message.tags)) + return "tags: object expected"; + var key = Object.keys(message.tags); + for (var i = 0; i < key.length; ++i) + if (!$util.isString(message.tags[key[i]])) + return "tags: string{k:string} expected"; + } return null; }; @@ -20477,6 +21061,13 @@ for (var keys = Object.keys(object.labels), i = 0; i < keys.length; ++i) message.labels[keys[i]] = String(object.labels[keys[i]]); } + if (object.tags) { + if (typeof object.tags !== "object") + throw TypeError(".google.pubsub.v1.CreateSnapshotRequest.tags: object expected"); + message.tags = {}; + for (var keys = Object.keys(object.tags), i = 0; i < keys.length; ++i) + message.tags[keys[i]] = String(object.tags[keys[i]]); + } return message; }; @@ -20493,8 +21084,10 @@ if (!options) options = {}; var object = {}; - if (options.objects || options.defaults) + if (options.objects || options.defaults) { object.labels = {}; + object.tags = {}; + } if (options.defaults) { object.name = ""; object.subscription = ""; @@ -20509,6 +21102,11 @@ for (var j = 0; j < keys2.length; ++j) object.labels[keys2[j]] = message.labels[keys2[j]]; } + if (message.tags && (keys2 = Object.keys(message.tags)).length) { + object.tags = {}; + for (var j = 0; j < keys2.length; ++j) + object.tags[keys2[j]] = message.tags[keys2[j]]; + } return object; }; diff --git a/protos/protos.json b/protos/protos.json index 696cfafed..ff48d61d4 100644 --- a/protos/protos.json +++ b/protos/protos.json @@ -12,7 +12,9 @@ "java_outer_classname": "SchemaProto", "java_package": "com.google.pubsub.v1", "php_namespace": "Google\\Cloud\\PubSub\\V1", - "ruby_package": "Google::Cloud::PubSub::V1" + "ruby_package": "Google::Cloud::PubSub::V1", + "(google.api.resource_definition).type": "analyticshub.googleapis.com/Listing", + "(google.api.resource_definition).pattern": "projects/{project}/locations/{location}/dataExchanges/{data_exchange}/listings/{listing}" }, "nested": { "Publisher": { @@ -540,7 +542,8 @@ "type": "string", "id": 3, "options": { - "(google.api.field_behavior)": "REQUIRED" + "(google.api.field_behavior)": "REQUIRED", + "(google.api.resource_reference).type": "pubsub.googleapis.com/Topic" } }, "awsRoleArn": { @@ -672,7 +675,8 @@ "type": "string", "id": 1, "options": { - "(google.api.field_behavior)": "REQUIRED" + "(google.api.field_behavior)": "REQUIRED", + "(google.api.resource_reference).type": "pubsub.googleapis.com/Topic" } }, "errorMessage": { @@ -728,13 +732,17 @@ "SchemaViolationReason": { "fields": {} }, + "MessageTransformationFailureReason": { + "fields": {} + }, "CloudStorageFailure": { "oneofs": { "reason": { "oneof": [ "avroFailureReason", "apiViolationReason", - "schemaViolationReason" + "schemaViolationReason", + "messageTransformationFailureReason" ] } }, @@ -780,6 +788,13 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "messageTransformationFailureReason": { + "type": "MessageTransformationFailureReason", + "id": 8, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } } }, @@ -788,7 +803,8 @@ "reason": { "oneof": [ "apiViolationReason", - "schemaViolationReason" + "schemaViolationReason", + "messageTransformationFailureReason" ] } }, @@ -834,6 +850,13 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "messageTransformationFailureReason": { + "type": "MessageTransformationFailureReason", + "id": 7, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } } }, @@ -842,7 +865,8 @@ "reason": { "oneof": [ "apiViolationReason", - "schemaViolationReason" + "schemaViolationReason", + "messageTransformationFailureReason" ] } }, @@ -888,6 +912,13 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "messageTransformationFailureReason": { + "type": "MessageTransformationFailureReason", + "id": 7, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } } }, @@ -896,7 +927,8 @@ "reason": { "oneof": [ "apiViolationReason", - "schemaViolationReason" + "schemaViolationReason", + "messageTransformationFailureReason" ] } }, @@ -942,6 +974,13 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "messageTransformationFailureReason": { + "type": "MessageTransformationFailureReason", + "id": 7, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } } }, @@ -949,7 +988,9 @@ "oneofs": { "reason": { "oneof": [ - "schemaViolationReason" + "schemaViolationReason", + "messageTransformationFailureReason", + "apiViolationReason" ] } }, @@ -981,6 +1022,20 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "messageTransformationFailureReason": { + "type": "MessageTransformationFailureReason", + "id": 5, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } + }, + "apiViolationReason": { + "type": "ApiViolationReason", + "id": 6, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } } } @@ -1071,7 +1126,8 @@ "type": "string", "id": 5, "options": { - "(google.api.field_behavior)": "OPTIONAL" + "(google.api.field_behavior)": "OPTIONAL", + "(google.api.resource_reference).type": "cloudkms.googleapis.com/CryptoKey" } }, "schemaSettings": { @@ -1116,6 +1172,14 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "tags": { + "keyType": "string", + "type": "string", + "id": 14, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } }, "nested": { @@ -1348,7 +1412,8 @@ "type": "string", "id": 1, "options": { - "(google.api.field_behavior)": "OPTIONAL" + "(google.api.field_behavior)": "OPTIONAL", + "(google.api.resource_reference).type": "pubsub.googleapis.com/Snapshot" } }, "nextPageToken": { @@ -1838,6 +1903,14 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "tags": { + "keyType": "string", + "type": "string", + "id": 26, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } }, "nested": { @@ -1854,7 +1927,8 @@ "type": "string", "id": 1, "options": { - "(google.api.field_behavior)": "OPTIONAL" + "(google.api.field_behavior)": "OPTIONAL", + "(google.api.resource_reference).type": "analyticshub.googleapis.com/Listing" } }, "subscription": { @@ -1892,7 +1966,8 @@ "type": "string", "id": 1, "options": { - "(google.api.field_behavior)": "OPTIONAL" + "(google.api.field_behavior)": "OPTIONAL", + "(google.api.resource_reference).type": "pubsub.googleapis.com/Topic" } }, "maxDeliveryAttempts": { @@ -2467,6 +2542,13 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "protocolVersion": { + "type": "int64", + "id": 10, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } } }, @@ -2612,6 +2694,14 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "tags": { + "keyType": "string", + "type": "string", + "id": 4, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } } }, From 775cc886500038f729048cc3b26b9bf18c81846d Mon Sep 17 00:00:00 2001 From: "release-please[bot]" <55107282+release-please[bot]@users.noreply.github.com> Date: Thu, 19 Feb 2026 15:49:20 -0500 Subject: [PATCH 3/3] chore(main): release 5.3.0 (#2136) Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com> --- CHANGELOG.md | 7 +++++++ package.json | 2 +- samples/package.json | 2 +- 3 files changed, 9 insertions(+), 2 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index c9326eef6..55636e531 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -4,6 +4,13 @@ [1]: https://www.npmjs.com/package/@google-cloud/pubsub?activeTab=versions +## [5.3.0](https://github.com/googleapis/nodejs-pubsub/compare/v5.2.4...v5.3.0) (2026-02-19) + + +### Features + +* Manual proto pushing ([#2134](https://github.com/googleapis/nodejs-pubsub/issues/2134)) ([2f1e8d1](https://github.com/googleapis/nodejs-pubsub/commit/2f1e8d198ffbc14795f9f0d0a88095d69ac437a3)) + ## [5.2.4](https://github.com/googleapis/nodejs-pubsub/compare/v5.2.3...v5.2.4) (2026-02-11) diff --git a/package.json b/package.json index fe7cfbf01..a911af2ca 100644 --- a/package.json +++ b/package.json @@ -1,7 +1,7 @@ { "name": "@google-cloud/pubsub", "description": "Cloud Pub/Sub Client Library for Node.js", - "version": "5.2.4", + "version": "5.3.0", "license": "Apache-2.0", "author": "Google Inc.", "engines": { diff --git a/samples/package.json b/samples/package.json index 8b5b954b8..4d32774e8 100644 --- a/samples/package.json +++ b/samples/package.json @@ -25,7 +25,7 @@ }, "dependencies": { "@google-cloud/opentelemetry-cloud-trace-exporter": "^2.0.0", - "@google-cloud/pubsub": "^5.2.4", + "@google-cloud/pubsub": "^5.3.0", "@google-cloud/storage": "^7.11.1", "@opentelemetry/api": "^1.6.0", "@opentelemetry/resources": "^1.17.0",