internalAddGeneratedFile( ' �q google/pubsub/v1/pubsub.protogoogle.pubsub.v1google/api/client.protogoogle/api/field_behavior.protogoogle/api/resource.protogoogle/protobuf/duration.protogoogle/protobuf/empty.proto google/protobuf/field_mask.protogoogle/protobuf/timestamp.protogoogle/pubsub/v1/schema.proto"a MessageStoragePolicy( allowed_persistence_regions
( B�A
 enforce_in_transit
(B�A
"�
SchemaSettings4 schema

( B$�A�A pubsub.googleapis.com/Schema1 encoding
(2.google.pubsub.v1.EncodingB�A
 first_revision_id
( B�A
 last_revision_id
( B�A
"� IngestionDataSourceSettingsT aws_kinesis

(28.google.pubsub.v1.IngestionDataSourceSettings.AwsKinesisB�A
H� AwsKinesisR state

(2>.google.pubsub.v1.IngestionDataSourceSettings.AwsKinesis.StateB�A stream_arn
( B�A consumer_arn
( B�A aws_role_arn
( B�A gcp_service_account
( B�A"�
State STATE_UNSPECIFIED ACTIVE
 KINESIS_PERMISSION_DENIED PUBLISH_PERMISSION_DENIED STREAM_NOT_FOUND CONSUMER_NOT_FOUNDB source"� Topic name

( B�A8 labels (2#.google.pubsub.v1.Topic.LabelsEntryB�A
K message_storage_policy
(2&.google.pubsub.v1.MessageStoragePolicyB�A
 kms_key_name
( B�A
> schema_settings
(2 .google.pubsub.v1.SchemaSettingsB�A
 satisfies_pzs
(B�A
B message_retention_duration
(2.google.protobuf.DurationB�A
1 state
(2.google.pubsub.v1.Topic.StateB�AZ ingestion_data_source_settings
(2-.google.pubsub.v1.IngestionDataSourceSettingsB�A
- LabelsEntry key

(  value
( :8
"H State STATE_UNSPECIFIED ACTIVE
 INGESTION_RESOURCE_ERROR:T�AQ pubsub.googleapis.com/Topic!projects/{project}/topics/{topic}_deleted-topic_"� PubsubMessage data

(B�A
H attributes (2/.google.pubsub.v1.PubsubMessage.AttributesEntryB�A
 message_id
( 0 publish_time
(2.google.protobuf.Timestamp ordering_key
( B�A
1 AttributesEntry key

(  value
( :8
"E GetTopicRequest2 topic

( B#�A�A pubsub.googleapis.com/Topic"w UpdateTopicRequest+ topic

(2.google.pubsub.v1.TopicB�A4 update_mask
(2.google.protobuf.FieldMaskB�A"| PublishRequest2 topic

( B#�A�A pubsub.googleapis.com/Topic6 messages (2.google.pubsub.v1.PubsubMessageB�A"+ PublishResponse message_ids
( B�A
"�
ListTopicsRequestD project

( B3�A�A- +cloudresourcemanager.googleapis.com/Project page_size
(B�A
 page_token
( B�A
"` ListTopicsResponse, topics
(2.google.pubsub.v1.TopicB�A
 next_page_token
( B�A
"�
ListTopicSubscriptionsRequest2 topic

( B#�A�A pubsub.googleapis.com/Topic page_size
(B�A
 page_token
( B�A
"�
ListTopicSubscriptionsResponseA subscriptions
( B*�A
�A$ "pubsub.googleapis.com/Subscription next_page_token
( B�A
"�
ListTopicSnapshotsRequest2 topic

( B#�A�A pubsub.googleapis.com/Topic page_size
(B�A
 page_token
( B�A
"R ListTopicSnapshotsResponse snapshots
( B�A
 next_page_token
( B�A
"H DeleteTopicRequest2 topic

( B#�A�A pubsub.googleapis.com/Topic"] DetachSubscriptionRequest@ subscription

( B*�A�A$ "pubsub.googleapis.com/Subscription" DetachSubscriptionResponse"� Subscription name

( B�A2 topic
( B#�A�A pubsub.googleapis.com/Topic6 push_config
(2.google.pubsub.v1.PushConfigB�A
> bigquery_config
(2 .google.pubsub.v1.BigQueryConfigB�A
G cloud_storage_config
(2$.google.pubsub.v1.CloudStorageConfigB�A
! ack_deadline_seconds
(B�A
" retain_acked_messages
(B�A
B message_retention_duration
(2.google.protobuf.DurationB�A
? labels (2*.google.pubsub.v1.Subscription.LabelsEntryB�A
$ enable_message_ordering
(B�A
B expiration_policy
(2".google.pubsub.v1.ExpirationPolicyB�A
 filter
( B�A
C dead_letter_policy
(2".google.pubsub.v1.DeadLetterPolicyB�A
8 retry_policy
(2.google.pubsub.v1.RetryPolicyB�A
 detached
(B�A
) enable_exactly_once_delivery
(B�A
H topic_message_retention_duration
(2.google.protobuf.DurationB�A8 state
(2$.google.pubsub.v1.Subscription.StateB�A- LabelsEntry key

(  value
( :8
"> State STATE_UNSPECIFIED ACTIVE
 RESOURCE_ERROR:X�AU "pubsub.googleapis.com/Subscription/projects/{project}/subscriptions/{subscription}" RetryPolicy7 minimum_backoff

(2.google.protobuf.DurationB�A
7 maximum_backoff
(2.google.protobuf.DurationB�A
"V DeadLetterPolicy dead_letter_topic

( B�A
" max_delivery_attempts
(B�A
"? ExpirationPolicy+ ttl

(2.google.protobuf.DurationB�A
"� PushConfig push_endpoint

( B�A
E attributes (2,.google.pubsub.v1.PushConfig.AttributesEntryB�A
A oidc_token
(2&.google.pubsub.v1.PushConfig.OidcTokenB�A
HI pubsub_wrapper
(2*.google.pubsub.v1.PushConfig.PubsubWrapperB�A
H
A no_wrapper
(2&.google.pubsub.v1.PushConfig.NoWrapperB�A
H
F OidcToken" service_account_email

( B�A
 audience
( B�A
 PubsubWrapper( NoWrapper write_metadata

(B�A
1 AttributesEntry key

(  value
( :8
B authentication_methodB wrapper"� BigQueryConfig table

( B�A
 use_topic_schema
(B�A
 write_metadata
(B�A
 drop_unknown_fields
(B�A
: state
(2&.google.pubsub.v1.BigQueryConfig.StateB�A use_table_schema
(B�A
"�
State STATE_UNSPECIFIED ACTIVE
 PERMISSION_DENIED NOT_FOUND SCHEMA_MISMATCH# IN_TRANSIT_LOCATION_RESTRICTION"� CloudStorageConfig bucket

( B�A filename_prefix
( B�A
 filename_suffix
( B�A
K text_config
(2/.google.pubsub.v1.CloudStorageConfig.TextConfigB�A
HK avro_config
(2/.google.pubsub.v1.CloudStorageConfig.AvroConfigB�A
H4 max_duration
(2.google.protobuf.DurationB�A
 max_bytes
(B�A
> state
(2*.google.pubsub.v1.CloudStorageConfig.StateB�A TextConfig) AvroConfig write_metadata

(B�A
"u State STATE_UNSPECIFIED ACTIVE
 PERMISSION_DENIED NOT_FOUND# IN_TRANSIT_LOCATION_RESTRICTIONB output_format"| ReceivedMessage ack_id

( B�A
5 message
(2.google.pubsub.v1.PubsubMessageB�A
 delivery_attempt
(B�A
"Z GetSubscriptionRequest@ subscription

( B*�A�A$ "pubsub.googleapis.com/Subscription"�
UpdateSubscriptionRequest9 subscription

(2.google.pubsub.v1.SubscriptionB�A4 update_mask
(2.google.protobuf.FieldMaskB�A"�
ListSubscriptionsRequestD project

( B3�A�A- +cloudresourcemanager.googleapis.com/Project page_size
(B�A
 page_token
( B�A
"u ListSubscriptionsResponse: subscriptions
(2.google.pubsub.v1.SubscriptionB�A
 next_page_token
( B�A
"] DeleteSubscriptionRequest@ subscription

( B*�A�A$ "pubsub.googleapis.com/Subscription"�
ModifyPushConfigRequest@ subscription

( B*�A�A$ "pubsub.googleapis.com/Subscription6 push_config
(2.google.pubsub.v1.PushConfigB�A"�
PullRequest@ subscription

( B*�A�A$ "pubsub.googleapis.com/Subscription! return_immediately
(B
�A
 max_messages
(B�A"Q PullResponseA received_messages
(2!.google.pubsub.v1.ReceivedMessageB�A
"�
ModifyAckDeadlineRequest@ subscription

( B*�A�A$ "pubsub.googleapis.com/Subscription ack_ids ( B�A! ack_deadline_seconds
(B�A"l AcknowledgeRequest@ subscription

( B*�A�A$ "pubsub.googleapis.com/Subscription ack_ids ( B�A"� StreamingPullRequest@ subscription

( B*�A�A$ "pubsub.googleapis.com/Subscription ack_ids ( B�A
$ modify_deadline_seconds (B�A
$ modify_deadline_ack_ids ( B�A
( stream_ack_deadline_seconds
(B�A client_id
( B�A
% max_outstanding_messages
(B�A
" max_outstanding_bytes
(B�A
"� StreamingPullResponseA received_messages
(2!.google.pubsub.v1.ReceivedMessageB�A
f acknowledge_confirmation
(2?.google.pubsub.v1.StreamingPullResponse.AcknowledgeConfirmationB�A
t modify_ack_deadline_confirmation
(2E.google.pubsub.v1.StreamingPullResponse.ModifyAckDeadlineConfirmationB�A
d subscription_properties
(2>.google.pubsub.v1.StreamingPullResponse.SubscriptionPropertiesB�A
�
AcknowledgeConfirmation ack_ids
( B�A
 invalid_ack_ids ( B�A
 unordered_ack_ids ( B�A
% temporary_failed_ack_ids ( B�A
z ModifyAckDeadlineConfirmation ack_ids
( B�A
 invalid_ack_ids ( B�A
% temporary_failed_ack_ids ( B�A
k SubscriptionProperties* exactly_once_delivery_enabled

(B�A
% message_ordering_enabled
(B�A
"� CreateSnapshotRequest4 name

( B&�A�A pubsub.googleapis.com/Snapshot@ subscription
( B*�A�A$ "pubsub.googleapis.com/SubscriptionH labels (23.google.pubsub.v1.CreateSnapshotRequest.LabelsEntryB�A
- LabelsEntry key

(  value
( :8
"�
UpdateSnapshotRequest1 snapshot

(2.google.pubsub.v1.SnapshotB�A4 update_mask
(2.google.protobuf.FieldMaskB�A"� Snapshot name

( B�A
2 topic
( B#�A
�A pubsub.googleapis.com/Topic4 expire_time
(2.google.protobuf.TimestampB�A
; labels (2&.google.pubsub.v1.Snapshot.LabelsEntryB�A
- LabelsEntry key

(  value
( :8
:L�AI pubsub.googleapis.com/Snapshot\'projects/{project}/snapshots/{snapshot}"N GetSnapshotRequest8 snapshot

( B&�A�A pubsub.googleapis.com/Snapshot"�
ListSnapshotsRequestD project

( B3�A�A- +cloudresourcemanager.googleapis.com/Project page_size
(B�A
 page_token
( B�A
"i ListSnapshotsResponse2 snapshots
(2.google.pubsub.v1.SnapshotB�A
 next_page_token
( B�A
"Q DeleteSnapshotRequest8 snapshot

( B&�A�A pubsub.googleapis.com/Snapshot"�
SeekRequest@ subscription

( B*�A�A$ "pubsub.googleapis.com/Subscription/ time
(2.google.protobuf.TimestampB�A
H: snapshot
( B&�A
�A pubsub.googleapis.com/SnapshotHB target" SeekResponse2� Publisherq CreateTopic.google.pubsub.v1.Topic.google.pubsub.v1.Topic"0���#/v1/{name=projects/*/topics/*}:
*�Aname�
UpdateTopic$.google.pubsub.v1.UpdateTopicRequest.google.pubsub.v1.Topic"C���)2$/v1/{topic.name=projects/*/topics/*}:
*�Atopic,update_mask�
Publish .google.pubsub.v1.PublishRequest!.google.pubsub.v1.PublishResponse"C���,"\'/v1/{topic=projects/*/topics/*}:publish:
*�Atopic,messagesw GetTopic!.google.pubsub.v1.GetTopicRequest.google.pubsub.v1.Topic"/���!/v1/{topic=projects/*/topics/*}�Atopic�
ListTopics#.google.pubsub.v1.ListTopicsRequest$.google.pubsub.v1.ListTopicsResponse"1���!/v1/{project=projects/*}/topics�Aproject�
ListTopicSubscriptions/.google.pubsub.v1.ListTopicSubscriptionsRequest0.google.pubsub.v1.ListTopicSubscriptionsResponse"=���/-/v1/{topic=projects/*/topics/*}/subscriptions�Atopic�
ListTopicSnapshots+.google.pubsub.v1.ListTopicSnapshotsRequest,.google.pubsub.v1.ListTopicSnapshotsResponse"9���+)/v1/{topic=projects/*/topics/*}/snapshots�Atopic| DeleteTopic$.google.pubsub.v1.DeleteTopicRequest.google.protobuf.Empty"/���!*/v1/{topic=projects/*/topics/*}�Atopic�
DetachSubscription+.google.pubsub.v1.DetachSubscriptionRequest,.google.pubsub.v1.DetachSubscriptionResponse"<���6"4/v1/{subscription=projects/*/subscriptions/*}:detachp�Apubsub.googleapis.com�AUhttps://www.googleapis.com/auth/cloud-platform,https://www.googleapis.com/auth/pubsub2� Subscriber�
CreateSubscription.google.pubsub.v1.Subscription.google.pubsub.v1.Subscription"^���*%/v1/{name=projects/*/subscriptions/*}:
*�A+name,topic,push_config,ack_deadline_seconds�
GetSubscription(.google.pubsub.v1.GetSubscriptionRequest.google.pubsub.v1.Subscription"D���/-/v1/{subscription=projects/*/subscriptions/*}�Asubscription�
UpdateSubscription+.google.pubsub.v1.UpdateSubscriptionRequest.google.pubsub.v1.Subscription"X���722/v1/{subscription.name=projects/*/subscriptions/*}:
*�Asubscription,update_mask�
ListSubscriptions*.google.pubsub.v1.ListSubscriptionsRequest+.google.pubsub.v1.ListSubscriptionsResponse"8���(&/v1/{project=projects/*}/subscriptions�Aproject�
DeleteSubscription+.google.pubsub.v1.DeleteSubscriptionRequest.google.protobuf.Empty"D���/*-/v1/{subscription=projects/*/subscriptions/*}�Asubscription�
ModifyAckDeadline*.google.pubsub.v1.ModifyAckDeadlineRequest.google.protobuf.Empty"v���D"?/v1/{subscription=projects/*/subscriptions/*}:modifyAckDeadline:
*�A)subscription,ack_ids,ack_deadline_seconds�
Acknowledge$.google.pubsub.v1.AcknowledgeRequest.google.protobuf.Empty"[���>"9/v1/{subscription=projects/*/subscriptions/*}:acknowledge:
*�Asubscription,ack_ids�
Pull.google.pubsub.v1.PullRequest.google.pubsub.v1.PullResponse"�
���7"2/v1/{subscription=projects/*/subscriptions/*}:pull:
*�A,subscription,return_immediately,max_messages�Asubscription,max_messagesf StreamingPull&.google.pubsub.v1.StreamingPullRequest\'.google.pubsub.v1.StreamingPullResponse"(
0
�
ModifyPushConfig).google.pubsub.v1.ModifyPushConfigRequest.google.protobuf.Empty"d���C">/v1/{subscription=projects/*/subscriptions/*}:modifyPushConfig:
*�Asubscription,push_config�
GetSnapshot$.google.pubsub.v1.GetSnapshotRequest.google.pubsub.v1.Snapshot"8���\'%/v1/{snapshot=projects/*/snapshots/*}�Asnapshot�
ListSnapshots&.google.pubsub.v1.ListSnapshotsRequest\'.google.pubsub.v1.ListSnapshotsResponse"4���$"/v1/{project=projects/*}/snapshots�Aproject�
CreateSnapshot\'.google.pubsub.v1.CreateSnapshotRequest.google.pubsub.v1.Snapshot"@���&!/v1/{name=projects/*/snapshots/*}:
*�Aname,subscription�
UpdateSnapshot\'.google.pubsub.v1.UpdateSnapshotRequest.google.pubsub.v1.Snapshot"L���/2*/v1/{snapshot.name=projects/*/snapshots/*}:
*�Asnapshot,update_mask�
DeleteSnapshot\'.google.pubsub.v1.DeleteSnapshotRequest.google.protobuf.Empty"8���\'*%/v1/{snapshot=projects/*/snapshots/*}�Asnapshot�
Seek.google.pubsub.v1.SeekRequest.google.pubsub.v1.SeekResponse"=���7"2/v1/{subscription=projects/*/subscriptions/*}:seek:
*p�Apubsub.googleapis.com�AUhttps://www.googleapis.com/auth/cloud-platform,https://www.googleapis.com/auth/pubsubB�
com.google.pubsub.v1BPubsubProtoP
Z2cloud.google.com/go/pubsub/apiv1/pubsubpb;pubsubpb�

�Google.Cloud.PubSub.V1�Google\\Cloud\\PubSub\\V1�Google::Cloud::PubSub::V1bproto3' , true); static::$is_initialized = true; } }