SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SS K J r SS KJr SS KJr S r"S S\5rg)z"Utilities for Pub/Sub Lite topics.)absolute_import)division)unicode_literals) cloudpubsub)types)message_transforms)topics) lite_util) gapic_util) http_encodingcP[R"[R"5S9$)N) credentials)rPublisherClientr GetGapicCredentials0lib/googlecloudsdk/api_lib/pubsub/lite_topics.pyGetDefaultPublisherClientrs!  $ $002 44rcF\rSrSrSrS SjrSrSrSrS Sjr S r g) r$z,Wrapper client for a Pub/Sub Lite publisher.Nc4U=(d [5UlgN)r_client)selfclients r__init__PublisherClient.__init__'s868DLrc:URR5 U$r)r __enter__)rs rrPublisherClient.__enter__*sLL Krc<URRXU5 gr)r__exit__)rexc_type exc_value tracebacks rr"PublisherClient.__exit__.sLL(y9rc[R"[R"UR5[R "UR 5URS9$)N)projectlocationname)r TopicPathr ProjectIdToProjectNumber projectsIdLocationToZoneOrRegion locationsIdtopicsId)rresources r_TopicResourceToPath$PublisherClient._TopicResourceToPath1sD ??2283F3FG11(2F2FG     rcU(dU(d[R"S5eURU5nU=(d 0nU(a'[R"U5U[R '[ RRURR"U[R"U5U40UD6R55$![a(n[R"SR!US95eSnAff=f)a4Publishes a message to the specified Pub/Sub Lite topic. Args: topic_resource: The pubsub.lite_topic resource to publish to. message: The string message to publish. ordering_key: The key for ordering delivery to subscribers. attributes: A dict of attributes to attach to the message. event_time: A user-specified event timestamp. Raises: EmptyMessageException: if the message is empty. PublishOperationException: if the publish operation is not successful. Returns: The messageId of the published message, containing the Partition and Offset. zdYou cannot send an empty message. You must specify either a MESSAGE, one or more ATTRIBUTE, or both.z,Publish operation failed with error: {error})errorN)r EmptyMessageExceptionr2rencode_attribute_event_timePUBSUB_LITE_EVENT_TIMErMessageMetadatadecoderpublishr Encoderesult ExceptionPublishOperationExceptionformat)rtopic_resourcemessage ordering_key attributes event_time topic_pathes rPublishPublisherClient.Publish7s. :  ( ( 5 66**>:J!rJ  8 8 D#::;J  " " ) ) ,,  z=+?+?+H+ ;/9 ;;A68EE J  , , 8 ? ?a ? H JJJs0AC D#C;;D)rr)NNNN) __name__ __module__ __qualname____firstlineno____doc__rrr"r2rH__static_attributes__rrrrr$s-49:  &JrrN)rN __future__rrrgoogle.cloud.pubsubliterr#google.cloud.pubsublite.cloudpubsubrgooglecloudsdk.api_lib.pubsubr !googlecloudsdk.command_lib.pubsubr googlecloudsdk.corer googlecloudsdk.core.utilr robjectrrrrrXs; )&'/)B07*24 9Jf9Jr