
    
                        S r SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJ	r	  SSK
Jr  SS	KJr  S
SS.r\	R                  \	R                   " \	R"                  R$                  5       " S S\	R&                  5      5       5       rg)zCommand to publish channels.    )absolute_import)division)unicode_literals)channels)common_publishing)base)flags)logz{description}a           To publish an event to the channel `my-channel`
        with event id `1234`
        with event type `event-provider.event.v1.eventType`
        with event source `//event-provider/event/source`
        with event data `{ "key": "value" }`
        and  event attributes of `attribute1=value`, run:

          $ {command} my-channel --event-id=1234 --event-type=event-provider.event.v1.eventType --event-source="//event-provider/event/source" --event-data='{"key": "value"}' --event-attributes=attribute1=value
        )DESCRIPTIONEXAMPLESc                   2    \ rS rSrSr\r\S 5       rS r	Sr
g)Publish,   zPublish to an Eventarc channel.c                 \    [         R                  " USSS9  [         R                  " U5        g )NzChannel to Publish to.T)required)r	   AddChannelResourceArgAddEventPublishingArgs)clsparsers     (lib/surface/eventarc/channels/publish.pyArgsPublish.Args2   s#    	(@4P	  (    c           
         [         R                  " 5       nUR                  R                  R	                  5       nUR                  5       n[        R                  " SR                  UR                  U5      5        UR                  U[        R                  " UR                  UR                  UR                  UR                  UR                   5      5        [        R"                  R%                  S5      $ )zRun the Publish command.z+Publishing event with id: {} to channel: {}zEvent published successfully)r   ChannelClientV1CONCEPTSchannelParseNamer
   debugformatevent_idr   r   CreateCloudEvent
event_typeevent_source
event_dataevent_attributesoutPrint)selfargsclientchannel_refnames        r   RunPublish.Run7   s     %%'F--''--/KDII;BBt  NN**4==$//+/+<+<doo+/+@+@	BC 77==788r    N)__name__
__module____qualname____firstlineno____doc___DETAILED_HELPdetailed_helpclassmethodr   r/   __static_attributes__r1   r   r   r   r   ,   s#     ( -) )9r   r   N)r6   
__future__r   r   r   googlecloudsdk.api_lib.eventarcr   r   googlecloudsdk.callioper   #googlecloudsdk.command_lib.eventarcr	   googlecloudsdk.corer
   r7   HiddenReleaseTracksReleaseTrackGACommandr   r1   r   r   <module>rE      su    # &  ' 4 = ( 5 # 				" D%%(()9dll 9 * 9r   