SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS K J r SS K J r SS KJr SS KJr SS KrSrSrSrSrSrSrSrSrSrSrSrSrS\S\4Sjr Sr!S>Sjr"S?Sjr#S r$S!r%S"r&S@S#jr'S@S$jr(S?S%jr)S&r*S'r+S(r,S)r-S*r.S+r/S,r0SAS-jr1S?S.jr2S?S/jr3S?S0jr4S1r5S2r6S3r7S?S4jr8S5r9S6r:S7r;S8rS;r?S<r@SBS=jrAg )Cz:A library containing flags used by Cloud Pub/Sub commands.)absolute_import)division)unicode_literals) subscriptions)actions) arg_parsers) exceptions) resource_args)util)log) propertiesNdzBPositional argument `{0}` is deprecated. Please use `{1}` instead.zValid values are strings of the form INTEGER[UNIT], where UNIT is one of "s", "m", "h", and "d" for seconds, minutes, hours, and days, respectively. If the unit is omitted, seconds is assumed.z"Message Ordering is not available.z#Message Filtering is not available.z%Dead-Letter Topics are not available.zRetry Policy is not available.z'Exactly-Once Delivery is not available.zSchema is not available.zIngestion is not available.z0BigQuery Export Subscriptions are not available.z5Cloud Storage Export Subscriptions are not available. config_name is_updatec*U(a SUSUSUS3$g)zGThe help text to tell users all fields must be specified during update.z When updating z flags, all z1 flags must be specified. Otherwise, any omitted z% flags revert to their default value.)rrs .lib/googlecloudsdk/command_lib/pubsub/flags.pyMustSpecifyAllHelpTextrHs1 [Mk]C11< >   cSUS3$)Nz Use --no-z to disable this flag.r) flag_names rNegativeBooleanFlagHelpTextrSs YK5 66rc |UR"SU-4S[R"US-[U5-U50UD6 g)N--help ) add_argumentrUniverseHelpTextr)parserr help_text universe_helpkwargss rAddBooleanFlagr$WsJ Y  ' ' c/7 B B    rc "SRU5nUnU(aJURSS9nURSSU[R"SS[ RSS5S 9S 9 URSSU(+[ R"5US 9 g ) z+Adds parsing and help text for ack_id flag.acOne or more ACK_IDs to {} An ACK_ID is a [string that is returned to subscribers](https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#google.pubsub.v1.ReceivedMessage). along with the message. The ACK_ID is different from the [message ID](https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#google.pubsub.v1.PubsubMessage).Trequiredack_id*ACK_IDcgNFr_s rAddAckIdFlag..t5r --ack-ids show_messagewarn)nargsraction)metavarr'typerN)formatadd_mutually_exclusive_grouprrDeprecationActionDEPRECATION_FORMAT_STRrArgList)r r7add_deprecatedr!groups r AddAckIdFlagrAbsq F6N  %  / / / >E  (( ('..xE  !!     rcUR(a*[R"[R SS55 UR=(d UR n[ U[5(dU/nU$)aGets the list of ack_ids from args. This is only necessary because we are deprecating the positional `ack_id`. Putting the positional and a flag in an argument group, will group flag under positional args. This would be confusing. DeprecationAction can't be used here because in order to make the positional argument optional, we have to use `nargs='*'`. Since this means zero or more, the DeprecationAction warn message is always triggered. This function does not exist in util.py in order to group the explanation for why this exists with the deprecated flags. Once the positional is removed, this function can be removed. Args: args (argparse.Namespace): Parsed arguments Returns: list[str]: List of ack ids. r*r2)r(r warningr=r:ack_ids isinstancelist)argsrDs rParseAckIdsArgsrHsP, [[KK&--h DE KK '4<<' GT " "iG .rc$URSSS9 g)N policy_filez%JSON or YAML file with the IAM policyrrr s rAddIamPolicyFileFlagrNsArcURSS9nURS[RRSS9 URSSS9 URS S S9 g ) z.Adds flags for the seek command to the parser.Tr&z--timeaN The time to seek to. Messages in the subscription that were published before this time are marked as acknowledged, and messages retained in the subscription that were published after this time are marked as unacknowledged. See $ gcloud topic datetimes for information on time formats.r9rz --snapshotz\The name of the snapshot. The snapshot's topic must be the same as that of the subscription.rKz--snapshot-projectz The name of the project the snapshot belongs to (if seeking to a snapshot). If not set, it defaults to the currently selected cloud project.N)r;rrDatetimeParse)r seek_to_groups r AddSeekFlagsrTsz55t5D-    % % K  )  rc @U(a*URS[SS[R"SSS9S9 [ USSS S S 9 U(aU(aUR S S S9nU(a&URSS S[R"SSSS9S9 U(a[ USSS SS 9 gg)z7Adds the main set of message pulling flags to a parser.z--max-messageszNThe maximum number of messages that Cloud Pub/Sub can return in this response.z8`{flag_name}` is deprecated. Please use --limit instead.)r5)r9defaultrr7zauto-ack store_trueFz>Automatically ACK every message pulled from this subscription.r rr7rWr!TzPull timeout behavior.mutexrz--waitz^Wait (for a bounded amount of time) for new messages from the subscription, if there are none.zc`{flag_name}` is deprecated. This flag is non-operational, as the wait behavior is now the default.)r5r7)rWrr7zreturn-immediatelya5If this flag is set, the system responds immediately with any messages readily available in memory buffers. If no messages are available in the buffers, returns an empty list of messages as response, even if having messages in the backlog. Do not set this flag as it adversely impacts the performance of pull.N)rintrr<r$ add_group)r r?add_waitadd_return_immediatelys r AddPullFlagsr`s   (( K     J (   D/G  HF   /(( 9   & E rc\UnU(dURSS[SU5-SS9nURSUSS9 URSSS S S 9 URS SS SS 9 U(aUR5n[ USSSS9 UnURSSSS9n[ USSSSS9 [ USSSSS9 g)z0Adds flags for push subscriptions to the parser.Fz@Push Config Options. Configuration for a push delivery endpoint. PushConfigr[rr'z--push-endpointzsA URL to use as the endpoint for this subscription. This will also automatically set the subscription type to PUSH.r'rz--push-auth-service-accountSERVICE_ACCOUNT_EMAILzjService account email used as the identity for the generated Open ID Connect token for authenticated push.)r'destrz--push-auth-token-audienceOPTIONAL_AUDIENCE_OVERRIDEzAudience used in the generated Open ID Connect token for authenticated push. If not specified, it will be set to the push-endpoint.zclear-push-no-wrapper-configrXz9If set, clear the NoWrapper config from the subscription.r rr7r!zNoWrapper Config Options.zpush-no-wrapperzBWhen set, the message data is delivered directly as the HTTP body.T)r rr!r7r'zpush-no-wrapper-write-metadatazWhen true, writes the Pub/Sub message metadata to `x-goog-pubsub-:` headers of the HTTP request. Writes the Pub/Sub message attributes to `:` headers of the HTTP request.N)r]rrr;r$)r r'ris_modify_push_config_request current_groupmutual_exclusive_groupdefinition_groups rAddPushConfigFlagsrms$ - &$$ O y 9: %M B # " : " '   *GGI%0Q  +M",,  &-  ! N  0   rc0URS[USS9 g)Nz--ack-deadlinez}The number of seconds the system will wait for a subscriber to acknowledge receiving a message before re-attempting delivery.)r9r'r)rr\)r r's rAddAckDeadlineFlagroOs$  K rcU(a [nSnO[R"SSS9nSnU=(d [R"5n[USSSS S 9 UR S US R U[ 5S 9 g)zEAdds flags subscription's message retention properties to the parser.zlSpecify "default" to use the default value of 7 days. The minimum is 10 minutes, and the maximum is 31 days.10m31d lower_bound upper_boundzSThe default value is 7 days, the minimum is 10 minutes, and the maximum is 31 days.zretain-acked-messagesrXNa Whether or not to retain acknowledged messages. If true, messages are not expunged from the subscription's backlog until they fall out of the --message-retention-duration window. Acknowledged messages are not retained by default. rY--message-retention-durationa How long to retain unacknowledged messages in the subscription's backlog, from the moment a message is published. If --retain-acked-messages is true, this also configures the retention of acknowledged messages. {} {}rP)-ParseSubscriptionRetentionDurationWithDefaultrDurationr$rr:DURATION_HELP_STR)r rretention_parserretention_default_helps r$AddSubscriptionMessageRetentionFlagsr|[sD 3 #++u 2 &?)=)=)? ' I  $  FGMf "3G rcFURSSSS9 URSSS9 g) z3Adds --topic and --topic-project flags to a parser.z--topicTzzThe name of the topic from which this subscription is receiving messages. Each subscription is attached to a single topic.rdz--topic-projectzwThe name of the project the provided topic belongs to. If not set, it defaults to the currently selected cloud project.rKNrLrMs r!AddSubscriptionTopicResourceFlagsr~s? G   Mrc UnU(a$UR5n[USSSS[S9 UnUR[R "S[ SU5-[S9S 9nURS S S S 9 UR5n[USSSSS9 [USSSSS9 [USSSSS9 [USSSSS9 URSSSS9 g)z%Adds BigQuery config flags to parser.zclear-bigquery-configrXNz8If set, clear the BigQuery config from the subscription.r rr7rWr!r"aBigQuery Config Options. The Cloud Pub/Sub service account associated with the enclosing subscription's parent project (i.e., service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have permission to write to this BigQuery table.BigQueryConfigrWr"rKz--bigquery-tableTzuA BigQuery table of the form {project}:{dataset_name}.{table_name} to which to write messages for this subscription.rdzuse-topic-schemazWhether or not to use the schema for the subscription's topic (if it exists) when writing messages to BigQuery. If --drop-unknown-fields is not set, then the BigQuery schema must contain all fields that are present in the topic schema.rYzuse-table-schemazRWhether or not to use the BigQuery table schema when writing messages to BigQuery.zwrite-metadataahWhether or not to write message metadata including message ID, publish timestamp, ordering key, and attributes to BigQuery. The subscription name, message_id, and publish_time fields are put in their own columns while all other message properties other than data (for example, an ordering_key, if present) are written to a JSON object in the attributes column.zdrop-unknown-fieldszIf either --use-topic-schema or --use-table-schema is set, whether or not to ignore fields in the message that do not appear in the BigQuery table schema.z --bigquery-service-account-emailzThe service account email to use when writing to BigQuery. If unspecified, uses the Pub/Sub service agent (https://cloud.google.com/iam/docs/service-account-types#service-agents).rWr)r;r$$BIGQUERY_EXPORT_NOT_SUPPORTED_IN_TPCadd_argument_grouprrrr)r rrjrkbigquery_config_group/bigquery_schema_config_mutually_exclusive_groups rAddBigQueryConfigFlagsrs> -*GGI%)P: +M'::  ' 'B ##3Y ? @ =  ; $$ ? %88:2 <"  .  <"  #  "  3  "%  $ $$( W %rc UnS[SU5-nU(a)UR5n[USSSS[S9 UnUS- nUR [ R "U[S 9S 9nURS S S S9 URSSSS9 URSSSS9 URSSSS9 URS[ R"SSS/SQS9SSS9 URS[ R"SS S!S"9S#R[5S$9 URS%[ R"S&S'9SS(S9 URS)[ R"S*S+S+S,S-/S.9S,S/S0S19 [US2SSS3S49 [US5SSS6S49 URS7SS8S9 g)9z*Adds Cloud Storage config flags to parser.aICloud Storage Config Options. The Cloud Pub/Sub service account associated with the enclosing subscription's parent project (i.e., service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have permission to write to this Cloud Storage bucket and to read this bucket's metadata.CloudStorageConfigzclear-cloud-storage-configrXNz=If set, clear the Cloud Storage config from the subscription.rz Note that an update to the Cloud Storage config will replace it with a new config containing only the flags that are passed in the `update` CLI.rrKz--cloud-storage-bucketTzHA Cloud Storage bucket to which to write messages for this subscription.rdz--cloud-storage-file-prefixz&The prefix for Cloud Storage filename.rz--cloud-storage-file-suffixz&The suffix for Cloud Storage filename.z$--cloud-storage-file-datetime-formatzThe custom datetime format string for Cloud Storage filename. See the [datetime format guidance](https://cloud.google.com/pubsub/docs/create-cloudstorage-subscription#file_names).z--cloud-storage-max-bytes1000B10GBKB)BrKiBMBMiBGBGiB)rtru default_unitsuggested_binary_size_scalesz The maximum bytes that can be written to a Cloud Storage file before a new file is created. The value must be between 1000B and 10GB. If the unit is omitted, KB is assumed.r9rWrz--cloud-storage-max-duration1mrqs)rtrurzThe maximum duration that can elapse before a new Cloud Storage file is created. The value must be between 1m and 10m. {}rPz--cloud-storage-max-messagesi)rtzThe maximum number of messages that can be written to a Cloud Storage file before a new file is created. The value must be greater than or equal to 1000.z--cloud-storage-output-formatc4[U5R5$Nstrlowerxs rr/,AddCloudStorageConfigFlags..aQrrVtextavro element_type min_length max_lengthchoices OUTPUT_FORMATzThe output format for data written to Cloud Storage. Values: text (messages will be written as raw text, separated by a newline) or avro (messages will be written as an Avro binary).)r9rWr8rzcloud-storage-write-metadataaWhether or not to write the subscription name, message_id, publish_time, attributes, and ordering_key as additional fields in the output. The subscription name, message_id, and publish_time fields are put in their own fields while all other message properties other than data (for example, an ordering_key, if present) are added as entries in the attributes map. This has an effect only for subscriptions with --cloud-storage-output-format=avro.rYzcloud-storage-use-topic-schemazWhether or not to use the schema for the subscription's topic (if it exists) when writing messages to Cloud Storage. This has an effect only for subscriptions with --cloud-storage-output-format=avro.z%--cloud-storage-service-account-emailzThe service account email to use when writing to Cloud Storage. If unspecified, uses the Pub/Sub service agent (https://cloud.google.com/iam/docs/service-account-types#service-agents).)rr;r$)CLOUD_STORAGE_EXPORT_NOT_SUPPORTED_IN_TPCrrrr BinarySizerxr:ry BoundedIntr>)r rrjcloud_storage_config_group_helprkcloud_storage_config_groups rAddCloudStorageConfigFlagsrsW-%# &<I& %!*GGI%.U? +M#(88# -??  ' '1A  @  ))  *))# 3* ))# 3* )), j *))!  ! !(  :%*.))$   C  ()*))$  ! !d 3 , * ))%   /6"    @*  '.  1   '0  1 ))- W *rc  UnU(aURSS9n[USSSSSS9 UnURSS[S U5-S 9n[R "S S S SS9n[R "XE/5 URSS SS9 g)z*Adds Pubsub export config flags to parser.T)hiddenzclear-pubsub-export-configrXNz=If set, clear the Pubsub Export config from the subscription.)r rr7rWrr!a#Cloud Pub/Sub Export Config Options. The Cloud Pub/Sub service account associated with the enclosing subscription's parent project (i.e., service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have permission to publish to the destination Cloud Pub/Sub topic.PubsubExportConfig)rrzto publish messages to.zpubsub-export-topicFr positionalr'z--pubsub-export-topic-regionanThe Google Cloud region to which messages are published. For example, us-east1. Do not specify more than one region. If the region you specified is different from the region to which messages were published, egress fees are incurred. If the region is not specified, Pub/Sub uses the same region to which the messages were originally published on a best-effort basis.rd)r;r$rrr CreateTopicResourceArgAddResourceArgsr)r rrjrkpubsub_export_config_grouppubsub_export_topics rAddPubsubExportConfigFlagsrs-*GGH%. K +M,??  Q 3Y?  @ @ &<<%   "7))$ : * rcU[R:XaU$[R"[R "SSS9"U55$)Nrqrrrs)rDEFAULT_MESSAGE_RETENTION_VALUEr FormatDurationrrxvalues rrwrws= m;;; L  u%@G rcU[R:XaU$[R"[R "5"U55$r)rNEVER_EXPIRATION_PERIOD_VALUEr rrrxrs r&ParseExpirationPeriodWithNeverSentinelrs4 m999 L  [113E: ;;rc [U5 [UUS9 UR5n[X15 [ X15 U(a [ X15 [ X5 U(d[USSSS[S9 U(d,URS[[R"S[S 9S 9 UnU(a6UR5n[US SS[R"S [S 9S 9 UnUR[R"S[!SU5-[S 9S9n["R$"SSSSS9n["R&"Xg/5 URS[R("SS5SSS9 URS[*SR-[.5S 9 UnU(a6UR5n[USSS[R"S[0S 9S 9 UnUR[R"S[!SU5-[0S 9S9nURS [R2"S!S"S#9S$R-[.5S 9 URS%[R2"S!S"S#9S&R-[.5S 9 [US'SSS([4S9 g))aAdds the flags for creating or updating a subscription. Args: parser: The argparse parser. is_update: Whether or not this is for the update operation (vs. create). enable_push_to_cps: Whether or not to enable Pubsub Export config flags support. )rzenable-message-orderingrXNzWhether to receive messages with the same ordering key in order. If set, messages with the same ordering key are sent to subscribers in the order that Pub/Sub receives them.r--message-filterzExpression to filter messages. If set, Pub/Sub only delivers the messages that match the filter. The expression must be a non-empty string in the [Pub/Sub filtering language](https://cloud.google.com/pubsub/docs/filtering).rrPzclear-dead-letter-policyz;If set, clear the dead letter policy from the subscription.rYaLDead Letter Queue Options. The Cloud Pub/Sub service account associated with the enclosing subscription's parent project (i.e., service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have permission to Publish() to this topic and Acknowledge() messages on this subscription.DeadLetterPolicyrKz#to publish dead letter messages to.zdead-letter-topicFrz--max-delivery-attemptsrzMaximum number of delivery attempts for any message. The value must be between 5 and 100. Defaults to 5. `--dead-letter-topic` must also be specified.rz--expiration-periodzThe subscription will expire if it is inactive for the given period. {} This flag additionally accepts the special value "never" to indicate that the subscription will never expire.zclear-retry-policyz5If set, clear the retry policy from the subscription.z|Retry Policy Options. Retry policy specifies how Cloud Pub/Sub retries message delivery for this subscription. RetryPolicyz--min-retry-delay0s600srszThe minimum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 10 seconds. {}z--max-retry-delayzThe maximum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 600 seconds. {}zenable-exactly-once-deliverya Whether or not to enable exactly-once delivery on the subscription. If true, Pub/Sub provides the following guarantees for the delivery of a message with a given value of `message_id` on this subscription: The message sent to a subscriber is guaranteed not to be resent before the message's acknowledgment deadline expires. An acknowledged message will not be resent to a subscriber.)rormr;rrrr|r$%MESSAGE_ORDERING_NOT_SUPPORTED_IN_TPCrrrr&MESSAGE_FILTERING_NOT_SUPPORTED_IN_TPC'DEAD_LETTER_TOPICS_NOT_SUPPORTED_IN_TPCrrr rrrrr:ry!RETRY_POLICY_NOT_SUPPORTED_IN_TPCrx!EXACTLY_ONCE_NOT_SUPPORTED_IN_TPC) r renable_push_to_cps mutex_grouprjrkset_dead_letter_policy_groupdead_letter_topicset_retry_policy_groups rAddSubscriptionSettingsFlagsrsV  335+0[4{6&v9 +8<      ) )FA   -*GGI%,..UA +M!.!A!A  ' '- ##5y A B @ "B "$::+#  "$7++  ! !!S ) % ,  1 ??Ev @ -*GGI%&..O; +M(;;  ' 'A "=) <=:  <%%   Df E  12 &%%   Df E  12 & . F6 rcpSnU(a<URSSSU[R"SS[R SS5S9S 9 URSUS 9 URS [ R "[S 9S R [5S9 URS[ R"S[S9S 9 g)zAdds the flags for building a PubSub message to the parser. Args: parser: The argparse parser. add_deprecated: Whether or not to add the deprecated flags. z The body of the message to publish to the given topic name. Information on message formatting and size limits can be found at: https://cloud.google.com/pubsub/docs/publisher#publish message_body?N MESSAGE_BODYcgr,rr-s rr/(AddPublishMessageFlags..r1r --messager3)r6rWrr7rK --attributerzsComma-separated list of attributes. Each ATTRIBUTE has the form name="value". You can specify up to {0} attributes.rPz--ordering-keyzThe key for ordering delivery to subscribers. All messages with the same ordering key are sent to subscribers in the order that Pub/Sub receives them.r) rrr<r=r:rArgDictMAX_ATTRIBUTESrr)r r?message_help_texts rAddPublishMessageFlagsrps@  (( ('..~{K   k(9:   . 9 @@FA     ' '$>  rc UnU(a$UR5n[USSSS[S9 UnUR[R "S[ SU5-[S9S 9nS n[R"US S S S 9n[R"XF/5 URS[R"SSSSS/S9SSS S9 URSSS S9 URSSS S9 g)zAdds the flags for filling the SchemaSettings message. Args: parser: The argparse parser. is_update: (bool) If true, add another group with clear-schema-settings as a mutually exclusive argument. zclear-schema-settingsrXNz1If set, clear the Schema Settings from the topic.rztSchema settings. The schema that messages published to this topic must conform to and the expected message encoding.SchemaSettingsrrKz6that messages published to this topic must conform to.FT)rpluralr'z--message-encodingc4[U5R5$rrrs rr/(AddSchemaSettingsFlags..rrrVjsonbinaryrENCODINGz6The encoding of messages validated against the schema.)r9r8rr'z--first-revision-idzEThe id of the oldest revision allowed for the specified schema.rr'z--last-revision-idzIThe id of the most recent revision allowed for the specified schema) r;r$SCHEMA_NOT_SUPPORTED_IN_TPCrrrrr CreateSchemaResourceArgrrr>)r rrjrkset_schema_settings_groupschema_help_textschemas rAddSchemaSettingsFlagsrs3-*GGI%)I1 +M+>>  ' 'I ##3Y ? @ 4  ? N  0 05 & 98D((   /8$    G) (( 4 ) (( 3 )rc UnU(a#URSS9n[USSSS[S9 UnUR[R "S[ S U5-[S 9S9nUR5nUR[R "S [ S U5-[S 9S9nURS SSSS9 URSSSSS9 URSSSSS9 URSSSSS9 UR[R "S[ SU5-[S 9SS9nURSSSSS9 URS[R"SSS/S QS!9SS"S#SS$9 URS%SS&SS9 URS'SS(SS9 URS)SS*SS9 URS+SS,SS9 UR[R "S-[ S.U5-[S 9S9nURS/SS0SS9 URS1SS2SS9 URS3SS4SS9 URS5SS6SS9 URS7SS8SS9 URS9SS:SS9 URS;SSU5-[S 9S9n U RS?SS@SS9 U RSASSBSS9 U RSCSSDSS9 U RSESSFSS9 UR[R "SG[ SHU5-[S 9S9n U RSISSJSS9 U RSKSSLSS9 U RSMSSNSS9 U RSOSSPSS9 U RSQSSRSS9 g)SzAdds the flags for Datasource Ingestion. Args: parser: The argparse parser is_update: (bool) If true, add a wrapper group with clear-ingestion-data-source-settings as a mutually exclusive argument. zPSpecify either --clear-ingestion-data-source-settings or a new ingestion source.rKz$clear-ingestion-data-source-settingsrXNz@If set, clear the Ingestion Data Source Settings from the topic.rzOFollowing flags are for specifying the data source settings for an import topicIngestionDataSourceSettingsrzcFlags that specify settings for an import topic from Amazon Web Services (AWS) Kinesis Data StreamszAWSKinesis Sourcez--kinesis-ingestion-stream-arnz2Kinesis data stream ARN from which to ingest data.T)rWrr'z --kinesis-ingestion-consumer-arnzNKinesis data streams consumer Amazon Resource Name (ARN) to use for ingestion.z--kinesis-ingestion-role-arnzKAWS role ARN to be used for Federated Identity authentication with Kinesis.z#--kinesis-ingestion-service-accountz[Google Cloud service account to be used for Federated Identity authentication with Kinesis.zBFlags that specify settings for an import topic from Cloud StoragezCloudStorage SourceF)r sort_argsz --cloud-storage-ingestion-bucketz/Cloud Storage bucket from which to ingest data.z&--cloud-storage-ingestion-input-formatc4[U5R5$rrrs rr/-AddIngestionDatasourceFlags..LrrrV)rr pubsub_avror INPUT_FORMATz/Format of the data in the Cloud Storage bucket.)r9rWr8rr'z(--cloud-storage-ingestion-text-delimiterz?Delimiter to use with text format when partitioning the object.z4--cloud-storage-ingestion-minimum-object-create-timezVOnly Cloud Storage objects with a larger or equal creation timestamp will be ingested.z$--cloud-storage-ingestion-match-globzoGlob pattern used to match Cloud Storage objects that will be ingested. If unset, all objects will be ingested.z--ingestion-log-severityz"Log severity to use for ingestion.zEFlags that specify settings for an import topic from Azure Event HubszAzureEventHubs Sourcez+--azure-event-hubs-ingestion-resource-groupzBAzure Event Hubs resource group from within an Azure subscription.z&--azure-event-hubs-ingestion-namespacez5Azure Event Hubs namespace from which to ingest data.z&--azure-event-hubs-ingestion-event-hubz*Azure event hub from which to ingest data.z&--azure-event-hubs-ingestion-client-idz0Azure Event Hubs client ID to use for ingestion.z&--azure-event-hubs-ingestion-tenant-idz0Azure Event Hubs tenant ID to use for ingestion.z,--azure-event-hubs-ingestion-subscription-idz6Azure Event Hubs subscription ID to use for ingestion.z,--azure-event-hubs-ingestion-service-accountzdGoogle Cloud service account to be used for Federated Identity authentication with Azure Event Hubs.zwFlags that specify settings for an import topic from Amazon Web Services (AWS) Managed Streaming for Apache Kafka (MSK)zAWS MSK Sourcez--aws-msk-ingestion-cluster-arnz-ARN that uniquely identifies the MSK cluster.z--aws-msk-ingestion-topicz4Name of the MSK topic that Pub/Sub will import from.z --aws-msk-ingestion-aws-role-arnzGAWS role ARN to be used for Federated Identity authentication with MSK.z#--aws-msk-ingestion-service-accountzWGoogle Cloud service account to be used for Federated Identity authentication with MSK.zDFlags that specify settings for an import topic from Confluent CloudzConfluentCloud Sourcez,--confluent-cloud-ingestion-bootstrap-serverz9Confluent Cloud bootstrap server. The format is url:port.z&--confluent-cloud-ingestion-cluster-idzConfluent Cloud cluster ID.z!--confluent-cloud-ingestion-topicz@Name of the Confluent Cloud topic that Pub/Sub will import from.z,--confluent-cloud-ingestion-identity-pool-idzWIdentity pool ID to be used for Federated Identity authentication with Confluent Cloud.z+--confluent-cloud-ingestion-service-accountzcGoogle Cloud service account to be used for Federated Identity authentication with Confluent Cloud.) r;r$INGESTION_NOT_SUPPORTED_IN_TPCrrrrrr>) r rrjclear_settings_groupingestion_source_settings_groupingestion_data_source_groupaws_kinesis_groupcloud_storage_groupazure_event_hubs_group aws_msk_groupconfluent_cloud_groups rAddIngestionDatasourceFlagsrs-(EE !F #8 N4 )M$1$D$D  ' '% ##@) L M 7  %E %!&BBD2DD  ' '5 ##6 B C 7  E   & ? !   ( !  $ !  + *!4FF  ' ' ##8) D E 7  G ""( < # "".   /1    <# ""0 L # ""< )#"", ?#"..  / /7II  ' ' ##:I F G 7  J %%3 O & %%. B & %%. 7 & %%. = & %%. = & %%4 C & %%4 3&.@@  ' 'M ##3Y ? @ 7  A -' :  ! A  ( + &6HH  ' '! ##:I F G 7  I $$4 F % $$. ( % $$) M % $$4 2%$$3 2%rcURSSSS9nURS[SS9 URS[R"5SS9 URS [S SS 9 g ) zOAdds the flags for the Schema Definition. Args: parser: The argparse parser TzSchema definitionrcz --definitionz!The new definition of the schema.rPz--definition-filez*File containing the new schema definition.z--typezThe type of the schema.r9rr'N)r]rrr FileContents)r rls rAddCommitSchemaFlagsrs %% *T&3%H   # # % 7   S84rcUnU(aUR5n[USSSSS9 UnURS[R"SSS 9S R [ 5S 9 g) zAdd flags for the topic message retention property to the parser. Args: parser: The argparse parser. is_update: Whether the operation is for updating message retention. z clear-message-retention-durationrXNz)r rrj help_messagerecompute_msp_groupexplicit_msp_groups r!AddTopicMessageStoragePolicyFlagsr =s-3Y? @, '11:2$$, - %(M .A A %77l7L!!0     " !!3  J "rc|UnU(aUR5n[USSSS9 UnURS[SS9 g) zAdd flags for the Message Transforms. Args: parser: The argparse parser. is_update: Whether the operation is for updating message transforms. zclear-message-transformsrXz,If set, clears the message transforms field.rh--message-transforms-file8Path to YAML or JSON file containing message transforms.rPN)r;r$rr)r rrjrs rAddMessageTransformsFlagsrtsQ-557K,@   M!  Erc0URS[SSS9 g)zRAdd flags for message transform validation. Args: parser: The argparse parser. z--message-transform-filez9Path to YAML or JSON file containing a message transform.TrN)rrrMs r AddValidateMessageTransformFlagsrs#    F rcURSSS9nURSSS9 URS[R"[S9S S R [5S 9 UR SS 9nURS [SS9 Sn[R"USSS9n[R"USSS9n[R"X$U/5 g)zPAdd flags for testing message transforms. Args: parser: The argparse parser. z/Message to test the message transforms against.Trrz4Message body to test the message transforms against.rKrr ATTRIBUTEzComma-separated list of attributes to attach to the message. Each ATTRIBUTE has the form name="value". You can specify up to {0} attributes.)r9r8rr&rrrPzIfrom which the message transforms are taken to be applied to the message.F)rr')r'rN) rrrrrr:r;rr rCreateSubscriptionResourceArgr)r message_grouprr!topic subscriptions rAddTestMessageTransformFlagsrs ++ ; OO "KK&--nkJK   *dll*rcpURb)UR(d[R"SS5egg)zRaises an exception if filter string is empty. Args: args (argparse.Namespace): Parsed arguments Raises: InvalidArgumentException: if filter string is empty. NrzgFilter string must be non-empty. If you do not want a filter, do not set the --message-filter argument.)message_filterr InvalidArgumentExceptionrs rValidateFilterStringr#s< $T-@-@  - - 6 .A$rcxUR(a)UR(d[R"SS5egg)zRaises an exception if args has invalid dead letter arguments. Args: args (argparse.Namespace): Parsed arguments Raises: RequiredArgumentException: if max_delivery_attempts is set without dead_letter_topic being present. DEAD_LETTER_TOPICz--dead-letter-topicN)max_delivery_attemptsrr RequiredArgumentExceptionrs rValidateDeadLetterPolicyr(s6 (>(>  . .2 )?rc UR5HKup4[XS5(dM[R"US[R USS5-S-U-5e g)NFrr.-% is not available in universe_domain )itemsgetattrr r"rreplace)rGuniverse_domain feature_mapr exception_strs r_RaiseExceptionIfContainsr2se"-"3"3"5it&&  / /   KK 3 , - 3 4   #6rc[R"5(ag[R"5n[R"[ R U5US-U-5e)zRaises an exception if it's not in default universe. Args: command: Parsed command Raises: InvalidArgumentException: if the command is disabled in current universe. Nr+)r IsDefaultUniverseGetUniverseDomainr r"rupper)commandr/s rValidateIsDefaultUniverser8sQ!!## 002/++ ii 77/I rcpSnURSS[R"5[RUS9 g)z#Adds the --tags flag to the parser.zList of tags KEY=VALUE pairs to bind. Each item must be expressed as `=`. Example: `123/environment=production,123/costCenter=marketing`z--tagsz KEY=VALUE)r8r9r7rN)rrr UpdateAction)r r!s r AddTagsFlagr;!s@G       % %  rc [XS5nU(dgU"[[R"U55VVs/sHupEUR XES9PM snnS9$s snnf)zMakes the tags message object.N)keyr)additionalProperties)r-sortedsix iteritemsAdditionalProperty)rG tags_message tags_arg_nametagsr=rs rGetTagsMessagerF1sa d +$  #3==#677jc  ) )c ) ?7 sA r)F)FFF)FF)rE)B__doc__ __future__rrrgooglecloudsdk.api_lib.pubsubrgooglecloudsdk.callioperrr !googlecloudsdk.command_lib.pubsubr r googlecloudsdk.corer r r@rr=ryrrrrrrrrrrboolrrr$rArHrNrTr`rmror|r~rrrrwrrrrrrrr rrrrr#r(r2r8r;rFrrrrNsv A&'7+/.;2#* I @)M%)N&+(%E!$M!8!>6%<*    7>< <JO;~LQL^ 'T&_DXv.b<Yx,^;@eP ,D4n0 'DT+<"  $  r