feat: Annotate some resource fields with their corresponding API types

feat: Add AwsKinesisFailureReason.ApiViolationReason
feat: Add tags to Subscription, Topic, and CreateSnapshotRequest messages for use in CreateSubscription, CreateTopic, and CreateSnapshot requests respectively
docs: A comment for field `received_messages` in message `.google.pubsub.v1.StreamingPullResponse` is changed

PiperOrigin-RevId: 820071518

Source-Link: googleapis/googleapis@e938992

Source-Link: googleapis/googleapis-gen@825a3ca
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiODI1YTNjYWEyNGYwYmYxNzBmMWM1NmVhNWYyY2Y3MzRmOGY5ZmM1MSJ9

Author: gcf-owl-bot[bot]

owl-bot-staging/v1/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
@@ -712,12 +723,21 @@ message IngestionFailureEvent {
       // 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];
@@ -849,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];
@@ -881,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<string, string> 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
@@ -1054,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
@@ -1348,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:
@@ -1514,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<string, string> 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.
@@ -1555,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.
@@ -2183,7 +2239,7 @@ 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];
 
@@ -2234,6 +2290,16 @@ message CreateSnapshotRequest {
   // Optional. See [Creating and managing
   // labels](https://cloud.google.com/pubsub/docs/labels).
   map<string, string> 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<string, string> tags = 4 [
+    (google.api.field_behavior) = INPUT_ONLY,
+    (google.api.field_behavior) = IMMUTABLE,
+    (google.api.field_behavior) = OPTIONAL
+  ];
 }
 
 // Request for the UpdateSnapshot method.