5RfSrSSKJr SSKJr SSKJr SSKJr SSKrSSKJr SSK J r SS K J r SS K J r SS K Jr SS KJr SSKrSS KJr SrSrSrSrSrSrSr"SS\ R65r"SS\ R65r"SS\ R65r"SS\ R65r"SS\ R65r Sr!S r"S!r#S"r$S#r%S$r&S%r'S&r(S'r)S(r*S)r+S*r,S+r-S,r.S-r/S.r0S/r1S0r2S1r3S2r4S3r5S4r6S5r7S6r8S7r9S8r:S9r;S:rS=r?S>r@S?rAS@rBSArCSCSBjrDg)Dz>A library that is used to support Cloud Pub/Sub Lite commands.)absolute_import)division)print_function)unicode_literalsN)apis)util) exceptions)log) properties) console_io)urlparsez projects/z locations/z reservations/ztopics/zsubscriptions/ pubsublitev1c\rSrSrSrSrg)UnexpectedResourceField+z,Error for having and unknown resource field.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r2lib/googlecloudsdk/command_lib/pubsub/lite_util.pyrr+4rrc\rSrSrSrSrg)InvalidPythonVersion/z$Error for an invalid python version.rNrrrrrr/s,rrc,^\rSrSrSrU4SjrSrU=r$)NoGrpcInstalled3z8Error that occurs when the grpc module is not installed.c,>[[U] S5 g)NzPlease ensure that the gRPC module is installed and the environment is correctly configured. Run `sudo pip3 install grpcio` and set the environment variable CLOUDSDK_PYTHON_SITEPACKAGES=1.)superr"__init__)self __class__s rr&NoGrpcInstalled.__init__6s /4) ?@rr)rrrrrr&r __classcell__)r(s@rr"r"3s@@@rr"c\rSrSrSrSrg)InvalidSeekTarget=z,Error for specifying an invalid seek target.rNrrrrr,r,=rrr,c\rSrSrSrSrg)InvalidResourcePathAz>Error for specifying an invalid fully qualified resource path.rNrrrrr/r/AsFrr/c@[R"[[5$)z*Returns the Pub/Sub Lite v1 client module.)rGetClientInstancePUBSUBLITE_API_NAMEPUBSUBLITE_API_VERSIONrrrPubsubLiteClientr5E   35K LLrc@[R"[[5$)z,Returns the Pub/Sub Lite v1 messages module.)rGetMessagesModuler3r4rrrPubsubLiteMessagesr9Jr6rcZ[R"[UR55S-$)zCConvert Duration object to total seconds for backend compatibility.s)six text_typeint total_seconds)durations rDurationToSecondsrAOs! s8112 3c 99rcLURS5nSRUSS5$)aReturns the region from a location string. Args: location: A str of the form `-` or ``, such as `us-central1-a` or `us-central1`. Any other form will cause undefined behavior. Returns: The str region. Example: `us-central1`. -N)splitjoin)locationsplitss rDeriveRegionFromLocationrITs' >># & &!* rc[U5nURRS5n[U5S:aUSS-US-$g)a6Returns the region from a endpoint string. Args: endpoint: A str of the form `https://base.url.com/`. Example `https://us-central-base.url.com/`, `https://us-central-autopush-base.url.com/`, or `https://base.url.com/`. Returns: The str region if it exists, otherwise None. rCrDrN)r netlocrElen)endpointparsed dash_splitss rDeriveRegionFromEndpointrQcsJ H & ##C(+ q>C +a. 00 rcPURS5nUSnUS-U-S-US-$)zTReturns a new endpoint string with the defined `region` prefixed to the netlocation.z://rrCrK)rE)regionurl url_parts url_schemes rCreateRegionalEndpointrWvs7ii)|* e f $s *Yq\ 99rcT[U5nU(aURUS-S5nU$)zCReturns a new endpoint string stripped of the region if one exists.rC)rQreplace)rNrSs rRemoveRegionFromEndpointr[}s* #H -&  b1H /rcSnSn[US5(aURnSnX4$[US5(aURnSnX4$[US5(aURnSnX4$[ S5e)aReturns a tuple of the resource and resource name from the `request`. Args: request: A Request object instance. Returns: A tuple of the resource string path and the resource name. Raises: UnexpectedResourceField: The `request` had a unsupported resource. rYparentname subscriptionz3The resource specified for this command is unknown!)hasattrr]r^r_r)requestresource resource_names rGetResourceInfords(- Wh~~HM   w||HM   w''##H"M    "= ??rcSSKJn [URS55S:XaURR U5$UR R U5$)Nr)typesrC)google.cloud.pubsubliterfrMrE CloudZoneparse CloudRegion) location_idrfs rLocationToZoneOrRegionrmsI+  3  A% ??  --    " "; //rc|XR[5[[5-SnURS5SnU$)z,Returns the location from a resource string.N/r)indexLOCATIONS_RESOURCE_PATHrMrE)rbrGs rDeriveLocationFromResourcerrsA nn%<=12345( ^^C  #( /rc|XR[5[[5-SnURS5SnU$)z+Returns the project from a resource string.Nror)rpPROJECTS_RESOURCE_PATHrMrE)rbprojects rDeriveProjectFromResourcervsA ^^$:;/012 3' MM# q !' .rcf[U5upXR[5Sn[XU5 U$)z;Returns an updated `request` with the resource path parsed.N)rdrindexrtsetattr)rarbrc new_resources r ParseResourcer{s3+G4(//*@ABC, ',/ .rc[U5up[[U55n[R"[ [ 5n[U5n[X45n[RRRRU5 g)zx$H I&  ) )*=*@B( &h /(,V> **5599:KLrc[R"SS5n[R"SS5nURUS9nURR U5nUR $)zBReturns the Cloud project number associated with the `project_id`.cloudresourcemanagerr) projectId)rr8r2&CloudresourcemanagerProjectsGetRequestprojectsGet projectNumber) project_idcrm_message_moduleresource_managerreqrus rProjectIdToProjectNumberrse--.DdK++,BDIAA B #  % % ) )# .'   rc [U5up[U5n[U5n[XUR U[ R "U555 U$)z;Returns an updated `request` with the Cloud project number.)rdrvrryrZr<r=)rarbrcrproject_numbers r OverrideProjectIdToProjectNumberrsN+G4((2*+J7. '   :s}}^'D EG .rcLAA[U5n[U5n[U5 U$)zCReturns an updated `request` with values for a valid Admin request.)r{rr resource_refargsras rUpdateAdminRequestrs*D ' "' ,W 5'W% .rcAA[U5nURR=RS- sl[ U5 U$)zAUpdates a CommitCursorRequest by adding 1 to the provided offset.rK)r{commitCursorRequestcursoroffsetrrs rUpdateCommitCursorRequestrs?D ' "' $$++q0+W% .rc\URcg[URR5$)z0Returns whether the topic has a reservation set.F)reservationConfigboolthroughputReservationtopics r_HasReservationr s( $  e%%;; <x$H I&''==+ '+BF $k3 --!!7 .rcAA[U5up4SRU[URR5URlU$)z?Returns an updated `request` with a resource path on the topic.z{}/{}{})rdrTOPICS_RESOURCE_PATHr_r)rrrarbrs rAddSubscriptionTopicResourcer9sJD(+((//:N070D0D0J0J L' .rcfASU;dUR(dU$[R"SSSS9 U$)z:Prompts to confirm an update to a topic's partition count. partitionszWarning: The number of partitions in a topic can be increased but not decreased. Additionally message order is not guaranteed across a topic resize. See https://cloud.google.com/pubsub/lite/docs/topics#scaling_capacity for more detailsT)messagedefault cancel_on_no)rr PromptContinuers rConfirmPartitionsUpdaterEs:T__ N    .rcRA[US5(aURS:HUlU$)Nstarting_offsetend)r`r skipBacklogrs rUpdateSkipBacklogFieldrVs+ T$%%//58G .rc@UR=(d UR$)z"Returns the raw location argument.)rGzone)rs rGetLocationValuer`s  #$))#rc[U5n[U;aU$[U5nU(d[SR U55eU$)zReturns the resource location (zone or region) extracted from arguments. Args: args: argparse.Namespace, the parsed commandline arguments. Raises: InvalidResourcePath: if the location component in a fully qualified path is invalid. zGThe location component in the specified location path is invalid: `{}`.)rrqrrr/r)rrGparsed_locations r GetLocationresJd #(H, O.x8/  Q    rc2[U5nUR[5(dEUR=(d2 [R R RR5$[U5nU(d[SRU55eU$)zReturns the project from either arguments or attributes. Args: args: argparse.Namespace, the parsed commandline arguments. Raises: InvalidResourcePath: if the project component in a fully qualified path is invalid. zFThe project component in the specified location path is invalid: `{}`.) r startswithrtrur r~core GetOrFailrvr/r)rrGparsed_projects r GetProjectr{syd #(   3 4 4 << E:,,1199CCEE,X6.  P    rcURS:Xa URRR$URRR$)z4Returns the DeliveryRequirement enum from arguments.zdeliver-after-stored)delivery_requirementDeliveryConfig"DeliveryRequirementValueValuesEnumDELIVER_AFTER_STOREDDELIVER_IMMEDIATELYrpsls rGetDeliveryRequirementrsA "88    @ @ U UU   > > R RRrcURS:Xa URRR$URRR$)z4Returns the export DesiredState enum from arguments.paused)export_desired_state ExportConfigDesiredStateValueValuesEnumPAUSEDACTIVErs rGetDesiredExportStaters@ (*    7 7 > >>   5 5 < <>++D,=,=>"@ ' AA   & &>>))$//:"< ' ==  {*  ( (S5P5P*D*DTT)KK   &  ( (S5P5P*D*DTT)KK  L NN < ==rcUR(aVURnUR[5(dSR[U[U5nUR US9UlUR(aOURnUR[5(d"SR[U[U[U5nXTl gg)z8Sets fully qualified resource paths for an ExportConfig. {}{}/{}{}rrN) export_pubsub_topicrrtrr PubSubConfig pubsubConfigexport_dead_letter_topicrqdeadLetterTopic)rrrurG export_configrs rSetExportConfigResourcesrs   $ $E   2 3 3!!"8'"6?e!$!1!1!1!>M ""  ) )E   2 3 3&&'=w'>';UDe%*! #rcURcg[X5nU(a URRRnURUS9n[ XX#U5 U$)z'Returns an ExportConfig from arguments.N desiredState)rrrrrr)rrrurG requires_seek desired_staters rGetExportConfigrsZ % '2-$$@@GGM"" ">-4gG rc[5n[U5n[U5n[R"[ U55nUR =(d URnURSR[U[U5URURUR[X5S9[!XXSU5S9UR"S9n[%U5 ['XU5 U(d [)XU5 [+5nUR,R/U5n U(a>UR1U R2[5X5S9n UR,R7U 5 U(aUR"R8(a~UR:S:XanUR=U R2SURUR?UR>R@RBS9S 9S 9n UR,REU 5n U $) aIssues a CreateSubscriptionRequest and potentially other requests. Args: resource_ref: resources.Resource, the resource reference for the resource being operated on. args: argparse.Namespace, the parsed commandline arguments. Returns: The created Pub/Sub Lite Subscription. r)deliveryRequirement)rdeliveryConfig exportConfig)r]r_subscriptionId)r^seekSubscriptionRequestactivezexport_config.desired_stater)r)r^ updateMaskr_)#r9rrr<r=rrr:PubsubliteAdminProjectsLocationsSubscriptionsCreateRequestrrtrq Subscriptionrrrrr_rrrr5&admin_projects_locations_subscriptionsCreate8PubsubliteAdminProjectsLocationsSubscriptionsSeekRequestr^rSeekrr9PubsubliteAdminProjectsLocationsSubscriptionsPatchRequestrrrPatch) rrrrGrrrcreate_requestclientresponse seek_requestupdate_requests r ExecuteCreateSubscriptionRequestrs #  ($*==!9*!EF.##6t-QQ  !7!8(D## ++"8"C,E&t.'46 $7 &&R (.^,|>B <~>  &  : : A A(OO ]]N44MPOL 1166|D~22??DD]D]aiDiRR ]]0%%))s7G7G+F+Fvv*O&PSQN <<BBH /rcAURRcU$[U5up4[U5n[ U5n[ 5n[ XXVURR5 U$)a9Sets export resource paths for an UpdateSubscriptionRequest. Args: resource_ref: resources.Resource, the resource reference for the resource being operated on. args: argparse.Namespace, the parsed commandline arguments. request: An UpdateSubscriptionRequest. Returns: The UpdateSubscriptionRequest. )r_rrdrvrrr9r)rrrarbrrurGrs rAddExportResourcesrsf &&. N(+( %h /' ' 1(#4g"//<<> .rchA[5n[X5Ul[R"S5 U$)z.Sets the target for a SeekSubscriptionRequest.zThe seek operation will complete once subscribers react to the seek. If subscribers are offline, `pubsub lite-operations describe` can be used to check the operation status later.)r9rrr warning)rrrars r SetSeekTargetr.s4#$24$='!++23 .rcAUR(aU$UR(a0SRUR[UR5UlUR (a\UR(aU=RS- slOSUlU=RSRUR 5- slU$)z/Updates the filter for a ListOperationsRequest.ztarget={}/{}{}z AND rYzdone={})filterr_rr^SUBSCRIPTIONS_RESOURCE_PATHdoners rUpdateListOperationsFilterr<s [[ N &,,W\\-H-1->->@GN YY~~ nnngn NNi&&tyy11N .rc[RRS:d<[RRS:Xa9[RRS:a[ SR U55egg)zVerifies that the python version is 3.6+. Args: cmd: The string command that requires python 3.6+. Raises: InvalidPythonVersion: if the python version is not 3.6+. rgznThe `{}` command requires python 3.6 or greater. Please update the python version to use this command.N)sys version_infomajorminorrr)cmds rRequirePython36r#Vse aC$4$4$:$:a$?$'$4$4$:$:Q$>  //5vc{ <<%?%@r)gcloud)Er __future__rrrrrgooglecloudsdk.api_lib.utilr!googlecloudsdk.command_lib.pubsubrgooglecloudsdk.corer r r googlecloudsdk.core.consoler r<six.moves.urllib.parser rtrqrrrr3r4Errorrrr"r,r/r5r9rArIrQrWr[rdrmrrrvr{rrrrrrrrrrrrrrrrrrrrrrrr#rrrr,suE&%' ,2*#*2 +%&, ."5j..5-:++-@j&&@5 ((5G***GM M : &:!>0M"   =(* "$ ,,S=>4*$ 6r6 4