xddlmZmZddlmZddlmZmZmZm Z ddl m Z Gdde eZ Gdd eeZ y ) )abstractmethodABCMeta)Future)ContextManagerMappingUnionAsyncContextManager) TopicPathc NeZdZdZe d deeefdedede eefdef dZ y) AsyncPublisherClientInterfacea An AsyncPublisherClientInterface 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. topicdata ordering_keyattrsreturncKtw)a Publish a message. Args: topic: The topic to publish to. Publishes to new topics may have nontrivial startup latency. data: The bytestring payload of the message ordering_key: The key to enforce ordering on, or "" for no ordering. **attrs: Additional attributes to send. Returns: An ack id, which can be decoded using MessageMetadata.decode. Raises: GoogleApiCallError: On a permanent failure. NotImplementedErrorselfr rrrs Qlib/third_party/google/cloud/pubsublite/cloudpubsub/publisher_client_interface.pypublishz%AsyncPublisherClientInterface.publishs."##s N __name__ __module__ __qualname____doc__rrr strbytesrrrr r sb  $Y^$$$ $ c" $ $$r#r ) metaclassc NeZdZdZe d deeefdedede eefddf dZ y ) PublisherClientInterfacez A PublisherClientInterface 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. r rrrrz Future[str]c t)a  Publish a message. Args: topic: The topic to publish to. Publishes to new topics may have nontrivial startup latency. data: The bytestring payload of the message ordering_key: The key to enforce ordering on, or "" for no ordering. **attrs: Additional attributes to send. Returns: A future completed with an ack id of type str, which can be decoded using MessageMetadata.decode. Raises: GoogleApiCallError: On a permanent failure. rrs rrz PublisherClientInterface.publish@s 0"##r#Nrrr"r#rr&r&8sb  $Y^$$$ $ c" $  $$r#r&N)abcrrconcurrent.futuresrtypingrrrr google.cloud.pubsublite.typesr r r&r"r#rr,s4(%FF3$$77$D $~ $r#