8SrSSKJr SSKJr SSKJr SSKJr SSK Jr SSK J r SSK J r SSK J r SS KJr SS KJr SS KrS rS rSrSrSrSrSrSrSrSrSrSrSrSr Sr!"SS\RD5r#"SS\RD5r$S;Sjr%SS9r?S:r@g )>z9A library that is used to support Cloud Pub/Sub commands.) subscriptions)topics) exceptions)util)log) properties) resources)resource_projector)timesNz%Y-%m-%dT%H:%M:%S.%fZzpubsub.projects.topicszpubsub.topics.publishzpubsub.projects.snapshotszpubsub.snapshots.listzpubsub.projects.subscriptionszpubsub.subscriptions.ackzpubsub.subscriptions.listzpubsub.subscriptions.mod_ackzpubsub.subscriptions.mod_configzpubsub.subscriptions.pullzpubsub.subscriptions.seekpubsub.projects.schemasaUsing --push-auth-service-account requires specifying --push-endpoint. This command will continue to run while ignoring --push-auth-service-account, but will fail in a future version. To correct a subscription configuration, run: $ gcloud pubsub subscriptions update SUBSCRIPTION \ --push-endpoint=PUSH_ENDPOINT \ --push-auth-service-account={SERVICE_ACCOUNT_EMAIL} [...] aUsing --push-auth-token-audience requires specifying both --push-endpoint and --push-auth-service-account. This command will continue to run while ignoring --push-auth-token-audience, but will fail in a future version. To correct a subscription configuration, run: $ gcloud pubsub subscriptions update SUBSCRIPTION \ --push-endpoint={PUSH_ENDPOINT} \ --push-auth-service-account={SERVICE_ACCOUNT_EMAIL} \ --push-auth-token-audience={OPTIONAL_AUDIENCE_OVERRIDE} [...] c\rSrSrSrSrg)InvalidArgumentErrorGz$The user provides invalid arguments.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r-lib/googlecloudsdk/command_lib/pubsub/util.pyrrGs,rrc,^\rSrSrSrU4SjrSrU=r$)RequestsFailedErrorKz4Indicates that some requests to the API have failed.cf>[[U] SRUSR U5S95 g)Nz/Failed to {action} the following: [{requests}].,)actionrequests)superr__init__formatjoin)selfrr __class__s rr!RequestsFailedError.__init__Ns5 t-9@@CHHX$6 A 89rr)rrrrrr!r __classcell__)r%s@rrrKs<99rrcU(aU$U$Nr)original_messagedefault_messages rCreateFailureErrorMessager,Ts. B?Brcb[U5n[RRUSU0[S9$N projectsIdparams collection) _GetProjectr REGISTRYParseSNAPSHOTS_COLLECTION) snapshot_name project_ids r ParseSnapshotr9Zs9:&*    ! !-*6 )C-A " CCrcb[U5n[RRUSU0[S9$r.)r3r r4r5SUBSCRIPTIONS_COLLECTION)subscription_namer8s rParseSubscriptionr=as::&*    ! !"3*6 )C-E " GGrcb[U5n[RRUSU0[S9$r.)r3r r4r5TOPICS_COLLECTION) topic_namer8s r ParseTopicrAhs9:&*    ! !**6 )C-> " @@rcD[U5n[R"U5$r))r3 projects_util ParseProjectr8s rrDrDos:&*  # #J //rcvU=(d1 [RRRR SS9$)NTrequiredrVALUEScoreprojectGetrEs rr3r3ts-  Hz((--559949HHrcn[U[5(aUSnOUn[U5R5$)Nname) isinstancedictr9SelfLink)snapshotrOs rSnapshotUriFuncrTxs2$ F D D t  % % ''rcSn[U[5(a USnUSnO$[U[5(aUnO URn[ X!5R 5$)NsubscriptionId projectId)rPrQstrrOr=rR) subscriptionrLrOs rSubscriptionUriFuncrZsZ ' d## ( )D;'G,$$ D   D 4 ) 2 2 44rc[U[5(aUSnO URn[U5R 5$)NtopicId)rPrQrOrArR)topicrOs r TopicUriFuncr^s6t  D ::D D  " " $$rcURn[USS5n[USS5nUbBUbUc<[R"[R U=(d SU=(d SUS95 O-Ub*Uc'[R"[ R US95 Uc[U5(a [S5egU=(d [R"5nSnUbURRX4S9nSn[U5(a&[US S 5nURRUS 9nURRX%US 9$) z.Parses configs of push subscription from args.SERVICE_ACCOUNT_EMAILNOPTIONAL_AUDIENCE_OVERRIDE PUSH_ENDPOINT)rbr`ra)r`z>argument --push-no-wrapper: --push-endpoint must be specified.)serviceAccountEmailaudiencepush_no_wrapper_write_metadataF) writeMetadata) pushEndpoint oidcToken noWrapper) push_endpointgetattrrwarning7PUSH_AUTH_TOKEN_AUDIENCE_MISSING_REQUIRED_FLAGS_WARNINGr"2PUSH_AUTH_SERVICE_ACCOUNT_MISSING_ENDPOINT_WARNING HasNoWrapperrrSubscriptionsClientmessages OidcToken NoWrapper PushConfig)argsclientrjservice_account_emailrd oidc_token no_wrapperwrite_metadatas rParsePushConfigr{sf$$-!$(?F T7 >(4<KK?FF':?"7#'&'/ G (]-BKK:AA"7 B  D J    8]668&*&**1+FJ*$T#CUKN***HJ  # # * $ NNrc[USS5$)Npush_no_wrapperF)rk)rus rroros (% 00rcR[R"U[[RS9$)N)fmttzinfo)r FormatDateTimeSEEK_TIME_FORMATUTC)times rFormatSeekTimers   d(8 KKrc4[R"U5S-$)zFormats a duration argument to be a string with units. Args: duration (int): The duration in seconds. Returns: unicode: The formatted duration. s)six text_type)durations rFormatDurationrs x 3 &&rc U=(d [R"5n/nU(a[[[R"U55H8up4UR UR RRUUS95 M: U$)aParses attribute_dict into a list of AdditionalProperty messages. Args: attribute_dict (Optional[dict]): Dict containing key=value pairs to parse. messages (Optional[module]): Module containing pubsub proto messages. Returns: list: List of AdditionalProperty messages. )keyvalue) rGetMessagesModulesortedr iteritemsappend PubsubMessageAttributesValueAdditionalProperty)attribute_dictrq attributesrrs rParseAttributesrsu 3113(*S]]>:;   0 0 C C D < rcV[R"U5nURUS'US U$)zCreates a serializable from a Cloud Pub/Sub Topic operation for display. Args: topic: (Cloud Pub/Sub Topic) Topic to be serialized. Returns: A serialized object representing a Cloud Pub/Sub Topic operation (create, delete). r\rO)r MakeSerializablerO)r]topic_display_dicts rTopicDisplayDictrs2*::5A"'**Y rc 2SnSnUR(a3URR(aURRnSnURURUUUR[ UR 5URURS.$)a Creates a serializable from a Cloud Pub/Sub Subscription op for display. Args: subscription: (Cloud Pub/Sub Subscription) Subscription to be serialized. Returns: A serialized object representing a Cloud Pub/Sub Subscription operation (create, delete, update). pullpush)rVr]typergackDeadlineSecondsretainAckedMessagesmessageRetentionDurationenableExactlyOnceDelivery) pushConfigrgrOr]rboolrrr)rYrjsubscription_types rSubscriptionDisplayDictrs-++"--::m %))!!#(;;!,"B"BC"."G"G#/#I#I  rcJURURURS.$)zCreates a serializable from a Cloud Pub/Sub Snapshot operation for display. Args: snapshot: (Cloud Pub/Sub Snapshot) Snapshot to be serialized. Returns: A serialized object representing a Cloud Pub/Sub Snapshot operation (create, delete). ) snapshotIdr] expireTime)rOr]r)rSs rSnapshotDisplayDictrs%MM~~'' rc$[R"U5nURR(aSOSUS'[ UR 5nUR US'URUS'[UR5nURUS'U$)z3Returns a subscription dict with additional fields.PUSHPULLrrWrVr\) r rrrgr=rOr/subscriptionsIdrAr]topicsId)rYresultsubscription_ref topic_infos rListSubscriptionDisplayDictr,s  . .| <&)44AA6v&.&|'8'89(33&-==& ,,,-* ))& -rc[R"U5n[UR5nURUS'URUS'US U$)Nr]r\rO)r rrArOr)r] topic_dict topic_refs rListTopicDisplayDictr8sL!2259*$) *W#,,*Y rc[R"SU05n[U5nURUS'URUS'U$)z9Returns a topic_subscription dict with additional fields.rYrWrV)r rr=r/r)topic_subscriptionrrs r ListTopicSubscriptionDisplayDictrAsO  . .)* ,&''9:(33&-==&  -rc[R"U5n[UR5nURUS'UR US'[ UR5nURUS'URUS'U$)z/Returns a snapshot dict with additional fields.rWrr\r) r rr9rOr/ snapshotsIdrAr]rr)rSr snapshot_refrs rListSnapshotDisplayDictrLss  . .x 8&x}}-,$//&%11&()((&!,,& -rcd[RRRR SS9$)zReturns the value of the core/project config property. Config properties can be overridden with command line flags. If the --project flag was provided, this will return the value provided with the flag. TrGrIrrr GetProjectrXs*      ' ' + +T + ::rch[RRUS[0SS9R 5$)zParses a schema name using configuration properties for fallback. Args: schema: str, the schema's ID, fully-qualified URL, or relative name Returns: str: the relative name of the schema resource r/r r0)r r4r5r RelativeName)schemas rParseSchemaNameras;    ! !  - " /0<|~>rcB[RRS5 g)z1Logs a message indicating that a schema is valid.zSchema is valid.NrstatusPrintunused_response unused_argss rOutputSchemaValidatedrps**%&rcB[RRS5 g)z2Logs a message indicating that a message is valid.zMessage is valid.Nrrs rOutputMessageValidatedrus**&'rcvUVs/sHo"SPM nnUVs/sH oDU;dM UPM nnX54$s snfs snf)NAckIdr)ack_ids_and_failure_reasonsack_idsackfailed_ack_idsack_idsuccessfully_processed_ack_idss r'ParseExactlyOnceAckIdsAndFailureReasonsrzsQ,GH,GSL,G.H"$"N&Bf7!$  77 I$s 1 66c[R"U5n[URR5nU(dUeU$r))exc HttpExceptionParseExactlyOnceErrorInfopayloaddetails)errorers rHandleExactlyOnceDeliveryErrorrs7 ! 9!)):K:K L % K $$rc0/nUHnSU;d SUS;aMSU;d[US[5(dM4USR5HBup4SU;dSU;dM[R"05nX5S'XES'UR U5 MD M U$)zParses error metadata for exactly once ack/modAck failures. Args: error_metadata: error metadata as dict of format ack_id -> failure_reason. Returns: list: error metadata with only exactly once failures. reason EXACTLY_ONCEmetadataPERMANENT_FAILURETEMPORARY_FAILUREr FailureReason)rPrQitemsr rr)error_metadatarerror_mdrfailure_reasonrs rrrs!# hx>(9K#K!HZ4H$)O)O"*:"6"<"<">  .3F6D4E#44R8 w"0#**62 #? ! %$r)zInternal Error)rr))Argooglecloudsdk.api_lib.pubsubrrgooglecloudsdk.api_lib.utilrr#googlecloudsdk.command_lib.projectsrrCgooglecloudsdk.corerrr googlecloudsdk.core.resourcer googlecloudsdk.core.utilr rrr?TOPICS_PUBLISH_COLLECTIONr6SNAPSHOTS_LIST_COLLECTIONr;SUBSCRIPTIONS_ACK_COLLECTIONSUBSCRIPTIONS_LIST_COLLECTION SUBSCRIPTIONS_MOD_ACK_COLLECTION#SUBSCRIPTIONS_MOD_CONFIG_COLLECTIONSUBSCRIPTIONS_PULL_COLLECTIONSUBSCRIPTIONS_SEEK_COLLECTIONSCHEMAS_COLLECTIONrnrmErrorrrr,r9r=rArDr3rTrZr^r{rorrrrrrrrrrrrrrrrrrrrrsM @809E*#*);* +-323:9 ;#A &G# ; ;.62 ;7-:++-9***9'7C CG@0 I( 5%/Nd1L',  8"  ; >' ( 8%%r