sSrSSKJr SSKrSSKJr SSKJr SSKJr SSK J r SSK J r SS K Jr SS K Jr SS K Jr SS KJr S r"SS\R(5rSr"SS\5rg)z)Utilities for Pub/Sub Lite subscriptions.)futuresN)Optional) cloudpubsub)types) PubsubMessage) lite_util) exceptions) gapic_util)log)queuelc\rSrSrSrSrg)SubscribeOperationException#z2Error when something went wrong while subscribing.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r7lib/googlecloudsdk/api_lib/pubsub/lite_subscriptions.pyrr#s:rrcP[R"[R"5S9$)N) credentials)rSubscriberClientr GetGapicCredentialsrrrGetDefaultSubscriberClientr's!  % %002 44rcP\rSrSrSrS SjrSrSrSrSr S \ \ 4S jr S r g) r,z4GCloud wrapper client for a Pub/Sub Lite subscriber.NcLU=(d [5Ul[R"5UlUR U5UlUVs1sHn[R"U5iM snUl [R"U[S9Ul X@l SUlgs snf)N)messages_outstandingbytes_outstanding)r_clientr Queue _messages_SubscriptionResourceToPath _subscriptionr Partition _partitionsFlowControlSettings _MAX_INT64_flow_control_settings _auto_ack _pull_future)selfsubscription_resource partitions max_messagesauto_ackclient partitions r__init__SubscriberClient.__init__/s 979DL[[]DN99:OPDDNOJy 2JOD"'";";)$#DND Ps B!cURR5 URRURURR UR URS9UlU$)N)callback#per_partition_flow_control_settingsfixed_partitions) r# __enter__ subscriber'r%putr,r)r.)r/s rr<SubscriberClient.__enter__@s]LL .. ##,0,G,G)) /+D KrcD[R"S5 URR5(d5URR 5 URR 5 URRXU5 g![ Ra N3f=f)N) timesleepr.donecancelresultrCancelledErrorr#__exit__)r/exc_type exc_value tracebacks rrHSubscriberClient.__exit__Is}JJqM    ! ! # #    "   " LL(y9 # #   s4BBBc[R"[R"UR5[R "UR 5URS9$)N)projectlocationname)rSubscriptionPathrProjectIdToProjectNumber projectsIdLocationToZoneOrRegion locationsIdsubscriptionsId)r/resources rr&,SubscriberClient._SubscriptionResourceToPathUsF  ! !2283F3FG11(2F2FG  % % ''rc URR5(aeURR5nU(a[SR US95e[ R "S5 [R"S5eg)Nz.Subscribe operation failed with error: {error})errorzNThe streaming pull future completed unexpectedly without raising an exception.z-The subscribe stream terminated unexpectedly.) r.rD exceptionrformatr debugr InternalError)r/es r_RaiseIfFailedSubscriberClient._RaiseIfFailed[sz     % % 'a ) < C C! C LN N ii()  $ $ 9 ;; rreturncUR5 URRSS9nUR(aUR 5 U$![ R a gf=f)z~Pulls and optionally acks a message from the provided subscription. Returns: A PubsubMessage pulled from the subscription. rA)timeoutN)r`r%getr-ackr Empty)r/messages rPullSubscriberClient.PullfsW  ""1"-g  n ;; s;AA%$A%)r-r#r,r%r)r.r')N)rrrrrr6r<rHr&r`rrrirrrrrr,s4< " :' ; H]+ rr)r concurrentrrBtypingrgoogle.cloud.pubsubliterrgoogle.pubsub_v1r!googlecloudsdk.command_lib.pubsubrgooglecloudsdk.corer r r six.movesr r+ErrorrrobjectrrrrrtsW 0 /)*7**#  ;*"2"2;4 GvGr