8SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SSKJ r SS KJr SS KJr SS KJr SS KJr SS KJr SSKrSrSrSrSrSrSrSrSrSrSr Sr!Sr"Sr#Sr$Sr%"SS\ RL5r'"S S!\ RL5r(S>S"jr)S?S#jr*S?S$jr+S?S%jr,S@S&jr-S'r.S(r/S)r0S*r1S@S+jr2S,r3S-r4S.r5S@S/jr6S0r7S1r8S2r9S3r:S4r;S5rS8r?S9r@S:rAS;rBS<rCS=rDg)Az9A library that is used to support Cloud Pub/Sub commands.)absolute_import)division)unicode_literals) 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)InvalidArgumentErrorJz$The user provides invalid arguments.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r-lib/googlecloudsdk/command_lib/pubsub/util.pyrrJs,rrc,^\rSrSrSrU4SjrSrU=r$)RequestsFailedErrorNz4Indicates that some requests to the API have failed.cf>[[U] SRUSR U5S95 g)Nz/Failed to {action} the following: [{requests}].,)actionrequests)superr__init__formatjoin)selfr"r! __class__s rr$RequestsFailedError.__init__Qs5 t-9@@CHHX$6 A 89rr)rrrrrr$r __classcell__)r(s@rrrNs<99rrcU(aU$U$Nr)original_messagedefault_messages rCreateFailureErrorMessager/Ws. B?Brcb[U5n[RRUSU0[S9$N projectsIdparams collection) _GetProjectr REGISTRYParseSNAPSHOTS_COLLECTION) snapshot_name project_ids r ParseSnapshotr<]s9:&*    ! !-*6 )C-A " CCrcb[U5n[RRUSU0[S9$r1)r6r r7r8SUBSCRIPTIONS_COLLECTION)subscription_namer;s rParseSubscriptionr@ds::&*    ! !"3*6 )C-E " GGrcb[U5n[RRUSU0[S9$r1)r6r r7r8TOPICS_COLLECTION) topic_namer;s r ParseTopicrDks9:&*    ! !**6 )C-> " @@rcD[U5n[R"U5$r,)r6 projects_util ParseProjectr;s rrGrGrs:&*  # #J //rcvU=(d1 [RRRR SS9$)NTrequiredr VALUEScoreprojectGetrHs rr6r6ws-  Hz((--559949HHrcn[U[5(aUSnOUn[U5R5$)Nname) isinstancedictr<SelfLink)snapshotrRs rSnapshotUriFuncrW{s2$ F D D t  % % ''rcSn[U[5(a USnUSnO$[U[5(aUnO URn[ X!5R 5$)NsubscriptionId projectId)rSrTstrrRr@rU) subscriptionrOrRs rSubscriptionUriFuncr]sZ ' d## ( )D;'G,$$ D   D 4 ) 2 2 44rc[U[5(aUSnO URn[U5R 5$)NtopicId)rSrTrRrDrU)topicrRs r TopicUriFuncras6t  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)rercrd)rcz>argument --push-no-wrapper: --push-endpoint must be specified.)serviceAccountEmailaudiencepush_no_wrapper_write_metadataF) writeMetadata) pushEndpoint oidcToken noWrapper) push_endpointgetattrr warning7PUSH_AUTH_TOKEN_AUDIENCE_MISSING_REQUIRED_FLAGS_WARNINGr%2PUSH_AUTH_SERVICE_ACCOUNT_MISSING_ENDPOINT_WARNING HasNoWrapperrrSubscriptionsClientmessages OidcToken NoWrapper PushConfig)argsclientrmservice_account_emailrg 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)rn)rxs rrrrrs (% 00rcR[R"U[[RS9$)N)fmttzinfo)rFormatDateTimeSEEK_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_dictrt 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_rR)r MakeSerializablerR)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)rYr`typerjackDeadlineSecondsretainAckedMessagesmessageRetentionDurationenableExactlyOnceDelivery) pushConfigrjrRr`rboolrrr)r\rmsubscription_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)rRr`r)rVs rSnapshotDisplayDictrs%MM~~'' rc$[R"U5nURR(aSOSUS'[ UR 5nUR US'URUS'[UR5nURUS'U$)z3Returns a subscription dict with additional fields.PUSHPULLrrZrYr_) r rrrjr@rRr2subscriptionsIdrDr`topicsId)r\resultsubscription_ref topic_infos rListSubscriptionDisplayDictr/s  . .| <&)44AA6v&.&|'8'89(33&-==& ,,,-* ))& -rc[R"U5n[UR5nURUS'URUS'US U$)Nr`r_rR)r rrDrRr)r` topic_dict topic_refs rListTopicDisplayDictr;sL!2259*$) *W#,,*Y rc[R"SU05n[U5nURUS'URUS'U$)z9Returns a topic_subscription dict with additional fields.r\rZrY)r rr@r2r)topic_subscriptionrrs r ListTopicSubscriptionDisplayDictrDsO  . .)* ,&''9:(33&-==&  -rc[R"U5n[UR5nURUS'UR US'[ UR5nURUS'URUS'U$)z/Returns a snapshot dict with additional fields.rZrr_r) r rr<rRr2 snapshotsIdrDr`rr)rVr snapshot_refrs rListSnapshotDisplayDictrOss  . .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. TrJrLrrr GetProjectr[s*      ' ' + +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 r2rr3)r r7r8r RelativeName)schemas rParseSchemaNamerds;    ! !  - " /0<|~>rcB[RRS5 g)z1Logs a message indicating that a schema is valid.zSchema is valid.Nr statusPrintunused_response unused_argss rOutputSchemaValidatedrss**%&rcB[RRS5 g)z2Logs a message indicating that a message is valid.zMessage is valid.Nrrs rOutputMessageValidatedrxs**&'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'ParseExactlyOnceAckIdsAndFailureReasonsr}sQ,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)rSrTitemsr rr)error_metadatarerror_mdrfailure_reasonrs rrrs!# hx>(9K#K!HZ4H$)O)O"*:"6"<"<">  .3F6D4E#44R8 w"0#**62 #? ! %$r)zInternal Error)rr,)Er __future__rrrgooglecloudsdk.api_lib.pubsubrrgooglecloudsdk.api_lib.utilrr#googlecloudsdk.command_lib.projectsr rFgooglecloudsdk.corer r r googlecloudsdk.core.resourcer googlecloudsdk.core.utilrrrrBTOPICS_PUBLISH_COLLECTIONr9SNAPSHOTS_LIST_COLLECTIONr>SUBSCRIPTIONS_ACK_COLLECTIONSUBSCRIPTIONS_LIST_COLLECTION SUBSCRIPTIONS_MOD_ACK_COLLECTION#SUBSCRIPTIONS_MOD_CONFIG_COLLECTIONSUBSCRIPTIONS_PULL_COLLECTIONSUBSCRIPTIONS_SEEK_COLLECTIONSCHEMAS_COLLECTIONrqrpErrorrrr/r<r@rDrGr6rWr]rar~rrrrrrrrrrrrrrrrrrrrrrrsT @&'709E*#*);* +-323:9 ;#A &G# ; ;.62 ;7-:++-9***9'7C CG@0 I( 5%/Nd1L',  8"  ; >' ( 8%%r