xSrSSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r S r"S S \5rg ) z"Utilities for Pub/Sub Lite topics.) cloudpubsub)types)message_transforms)topics) lite_util) gapic_util) http_encodingcP[R"[R"5S9$)N) credentials)rPublisherClientrGetGapicCredentials0lib/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 rrPublisherClient.__exit__+sLL(y9rc[R"[R"UR5[R "UR 5URS9$)N)projectlocationname)r TopicPathrProjectIdToProjectNumber projectsIdLocationToZoneOrRegion locationsIdtopicsId)rresources r_TopicResourceToPath$PublisherClient._TopicResourceToPath.sD ??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)rEmptyMessageExceptionr/rencode_attribute_event_timePUBSUB_LITE_EVENT_TIMErMessageMetadatadecoderpublishr Encoderesult ExceptionPublishOperationExceptionformat)rtopic_resourcemessage ordering_key attributes event_time topic_pathes rPublishPublisherClient.Publish4s. :  ( ( 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__rrrr/rE__static_attributes__rrrr r !s-49:  &Jrr N)rKgoogle.cloud.pubsubliterr#google.cloud.pubsublite.cloudpubsubrgooglecloudsdk.api_lib.pubsubr!googlecloudsdk.command_lib.pubsubrgooglecloudsdk.corergooglecloudsdk.core.utilr robjectr rrrrTs4 )0)B07*24 9Jf9Jr