jSSKJr SSKJrJrJr SSKJr SSKJ r SSK J r SSK J r SSKJrJr SSKJr SS KJr SS KJrJr SS KJr SS KJr SS KJr SSKJr SSK!J"r" S\#4Sjr$"SS\\5r%"SS\\5r&g))Future)OptionalMappingUnion)uuid4) ClientOptions) Credentials) BatchSettings)make_publishermake_async_publisher)MultiplexedAsyncPublisherClient)MultiplexedPublisherClient)PublisherClientInterfaceAsyncPublisherClientInterface)ConstructableFromServiceAccount)PublisherClientId)RequireStarted)DEFAULT_BATCHING_SETTINGS) TopicPathenable_idempotencecNU(a[[5R5$S$N)rrbytes)rs Glib/third_party/google/cloud/pubsublite/cloudpubsub/publisher_client.py_get_client_idr0s/A UW]] +KtKc \rSrSr%Sr\\S'\\S'\r SSSSSS.S \ \ S \ \ S \ S \ \S \4 SjjrSS\\\ 4S\S\ S\\ \ 4SS4 SjjrSrSrSrg)PublisherClient4z A PublisherClient publishes messages similar to Google Pub/Sub. Any publish failures are unlikely to succeed if retried. Must be used in a `with` block or have __enter__() called before use. _impl_require_startedN grpc_asyncioFper_partition_batching_settings credentials transportclient_optionsrr$r%r&r'rcr^^^^^[U5m[UUUUU4Sj5Ul[5Ulg)a0 Create a new PublisherClient. Args: per_partition_batching_settings: The settings for publish batching. Apply on a per-partition basis. credentials: If provided, the credentials to use when connecting. transport: The transport to use. Must correspond to an asyncio transport. client_options: The client options to use when connecting. If used, must explicitly set `api_endpoint`. enable_idempotence: Whether idempotence is enabled, where the server will ensure that unique messages within a single publisher session are stored only once. c  >[UTTTTTS9$N)topicr$r%r'r& client_id)r r+r,r'r%r$r&s r*PublisherClient.__init__..Ys.0O'-## rN)rrr rr!selfr$r%r&r'rr,s ```` @r__init__PublisherClient.__init__Ds3&##56 /     !/ 0rr+data ordering_keyattrsreturnz Future[str]c tURR5 URR"SXUS.UD6$N)r+r4r5r!require_startedr publishr1r+r4r5r6s rr=PublisherClient.publishds? --/zz!!  AF  rcnURR5 URR5 U$r)r! __enter__r r1s rrAPublisherClient.__enter__ps) '')  rctURRXU5 URRXU5 gr)r __exit__r!r1exc_type exc_value tracebacks rrEPublisherClient.__exit__us, H; &&xIFrr r!)__name__ __module__ __qualname____firstlineno____doc__r__annotations__rWIRE_DEFAULT_BATCHINGrrr r strrboolr2rrrrr=rArE__static_attributes__r:rrrr4s $#$$ 5DH-1'26#(1*2-)@1k* 1  1 !/ 1!1H  Y^$      c"     Grrc \rSrSr%Sr\\S'\\S'\r SSSSSS.S \ \ S \ \ S \ S \ \S \4 SjjrSS\\\ 4S\S\ S\\ \ 4S\ 4 SjjrSrSrSrg)AsyncPublisherClientzz An AsyncPublisherClient publishes messages similar to Google Pub/Sub, but must be used in an async context. Any publish failures are unlikely to succeed if retried. Must be used in an `async with` block or have __aenter__() awaited before use. r r!Nr"Fr#r$r%r&r'rcr^^^^^[U5m[UUUUU4Sj5Ul[5Ulg)a5 Create a new AsyncPublisherClient. Args: per_partition_batching_settings: The settings for publish batching. Apply on a per-partition basis. credentials: If provided, the credentials to use when connecting. transport: The transport to use. Must correspond to an asyncio transport. client_options: The client options to use when connecting. If used, must explicitly set `api_endpoint`. enable_idempotence: Whether idempotence is enabled, where the server will ensure that unique messages within a single publisher session are stored only once. c  >[UTTTTTS9$r*)r r-s rr./AsyncPublisherClient.__init__..s.0O'-## rN)rr r rr!r0s ```` @rr2AsyncPublisherClient.__init__s3&##56 4     !/ 0rr+r4r5r6r7c# URR5 URR"SXUS.UD6IShvN $N7fr9r;r>s rr=AsyncPublisherClient.publishsL --/ZZ''  AF    s=AAAc# URR5 URR5IShvN U$N7fr)r!rAr __aenter__rBs rrbAsyncPublisherClient.__aenter__s7 '')jj##%%%  &s8AAAc# URRXU5IShvN URRXU5 gN!7fr)r __aexit__r!rErFs rreAsyncPublisherClient.__aexit__s;jj""8 BBB &&xIF Cs AA"ArKrL)rNrOrPrQrRrrSrrTrrr r rUrrVr2rrrrr=rbrerWr:rrrYrYzs )($$ 5DH-1'26#(1*2-)@1k* 1  1 !/ 1!1H  Y^$      c"    GrrYN)'concurrent.futuresrtypingrrruuidrgoogle.api_core.client_optionsrgoogle.auth.credentialsr google.cloud.pubsub_v1.typesr ;google.cloud.pubsublite.cloudpubsub.internal.make_publisherr r Ogoogle.cloud.pubsublite.cloudpubsub.internal.multiplexed_async_publisher_clientr Igoogle.cloud.pubsublite.cloudpubsub.internal.multiplexed_publisher_clientr>google.cloud.pubsublite.cloudpubsub.publisher_client_interfacerrCgoogle.cloud.pubsublite.internal.constructable_from_service_accountr4google.cloud.pubsublite.internal.publisher_client_idr0google.cloud.pubsublite.internal.require_startedr4google.cloud.pubsublite.internal.wire.make_publisherrrTgoogle.cloud.pubsublite.typesrrVrrrYr:rrrvs&++8/6SK4LtLCG.0OCGLEG!#BEGr