jddlmZddlmZmZmZddlmZddlm Z ddl m Z ddl m Z ddlmZmZddlmZdd lmZdd lmZmZdd lmZdd lmZdd lmZddlmZ ddl!m"Z"de#fdZ$GddeeZ%GddeeZ&y))Future)OptionalMappingUnion)uuid4) ClientOptions) Credentials) BatchSettings)make_publishermake_async_publisher)MultiplexedAsyncPublisherClient)MultiplexedPublisherClient)PublisherClientInterfaceAsyncPublisherClientInterface)ConstructableFromServiceAccount)PublisherClientId)RequireStarted)DEFAULT_BATCHING_SETTINGS) TopicPathenable_idempotencecD|rttjSdSN)rrbytes)rs Glib/third_party/google/cloud/pubsublite/cloudpubsub/publisher_client.py_get_client_idr0s/A UW]] +KtKc eZdZUdZeed<eed<eZ ddddddde e d e e d e d e e d ef d Z ddeee fdede dee e fddf dZdZdZy)PublisherClientz 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&rcpt|tfd|_t|_y)ap 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&t|SN)topicr#r$r&r% client_id)r r*r+r&r$r#r%s rz*PublisherClient.__init__..Ys.0O'-## rN)rrrrr selfr#r$r%r&rr+s ```` @r__init__zPublisherClient.__init__Ds.&##56 /    !/ 0rr*data ordering_keyattrsreturnz Future[str]c v|jj|jjd|||d|SN)r*r1r2r require_startedrpublishr/r*r1r2r3s rr:zPublisherClient.publishdsC --/!tzz!! d AF  rcn|jj|jj|Sr)r __enter__rr/s rr=zPublisherClient.__enter__ps) '')  rcx|jj||||jj|||yr)r__exit__r r/exc_type exc_value tracebacks rr@zPublisherClient.__exit__us0 Hi; &&xIFr)__name__ __module__ __qualname____doc__r__annotations__rWIRE_DEFAULT_BATCHINGrrr r strrboolr0rrrrr:r=r@r7rrrr4s $#$$ 5DH-1'26#(1*2-)@1k* 1  1 !/ 1!1H  Y^$      c"     Grrc eZdZUdZeed<eed<eZ ddddddde e d e e d e d e e d ef d Z ddeee fdede dee e fde f dZdZdZy)AsyncPublisherClienta 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. rr Nr!Fr"r#r$r%r&rcpt|tfd|_t|_y)au 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&t|Sr))r r,s rr-z/AsyncPublisherClient.__init__..s.0O'-## rN)rr rrr r.s ```` @rr0zAsyncPublisherClient.__init__s.&##56 4    !/ 0rr*r1r2r3r4cK|jj|jjd|||d|d{S7wr6r8r;s rr:zAsyncPublisherClient.publishsQ --/'TZZ'' d AF    s>AAAcK|jj|jjd{|S7wr)r r=r __aenter__r>s rrUzAsyncPublisherClient.__aenter__s8 '')jj##%%%  &s8AAAcK|jj|||d{|jj|||y7"wr)r __aexit__r r@rAs rrWzAsyncPublisherClient.__aexit__s@jj""8Y BBB &&xIF Cs!AA#ArE)rGrHrIrJrrKrrLrrr r rMrrNr0rrrrr:rUrWr7rrrPrPzs )($$ 5DH-1'26#(1*2-)@1k* 1  1 !/ 1!1H  Y^$      c"    GrrPN)'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_publisherrrLgoogle.cloud.pubsublite.typesrrNrrrPr7rrrgs&++8/6SK4LtLCG.0OCGLEG!#BEGr