
                         V    d Z ddlmZ ddlmZ ddlmZ  G d dej                        Z	y)z;Generated client library for eventarcpublishing version v1.    )absolute_import)base_api)eventarcpublishing_v1_messagesc                   2    e Zd ZdZeZdZdZdZdgZ	dZ
dZdZd	Zd ZdZd
Z	 	 	 	 	 d fd	Z G d dej&                        Z G d dej&                        Z G d dej&                        Z G d dej&                        Z G d dej&                        Z xZS )EventarcpublishingV1zCGenerated client library for service eventarcpublishing version v1.z*https://eventarcpublishing.googleapis.com/z/https://eventarcpublishing.mtls.googleapis.com/eventarcpublishingz.https://www.googleapis.com/auth/cloud-platformv1	CLIENT_IDCLIENT_SECRETzgoogle-cloud-sdkNc                 >   |xs | j                   }t        t        |   |||||||||	|
|       | j	                  |       | _        | j                  |       | _        | j                  |       | _	        | j                  |       | _        | j                  |       | _        y)z'Create a new eventarcpublishing handle.)
credentialsget_credentialshttpmodellog_requestlog_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)BASE_URLsuperr   __init__*ProjectsLocationsChannelConnectionsService%projects_locations_channelConnections ProjectsLocationsChannelsServiceprojects_locations_channels$ProjectsLocationsMessageBusesServiceprojects_locations_messageBusesProjectsLocationsServiceprojects_locationsProjectsServiceprojects)selfurlr   r   r   r   r   r   r   r   r   r   	__class__s               _lib/googlecloudsdk/generated_clients/apis/eventarcpublishing/v1/eventarcpublishing_v1_client.pyr   zEventarcpublishingV1.__init__   s     
C	
.'d%l)3 7+ / - 261`1`ae1fD.'+'L'LT'RD$+/+T+TUY+ZD(";;DAD((.DM    c                   >     e Zd ZdZdZ fdZddZd e_         xZS )?EventarcpublishingV1.ProjectsLocationsChannelConnectionsServicezEService class for the projects_locations_channelConnections resource.r   c                 N    t         t        j                  |   |       i | _        y N)r   r   r   r   _upload_configsr$   clientr&   s     r'   r   zHEventarcpublishingV1.ProjectsLocationsChannelConnectionsService.__init__5   s$     KKT[\bcdr(   c                 L    | j                  d      }| j                  |||      S )a  Publish events to a ChannelConnection in a partner's project.

      Args:
        request: (EventarcpublishingProjectsLocationsChannelConnectionsPublishEventsRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (GoogleCloudEventarcPublishingV1PublishChannelConnectionEventsResponse) The response message.
      PublishEventsglobal_paramsGetMethodConfig
_RunMethodr$   requestr3   configs       r'   r1   zMEventarcpublishingV1.ProjectsLocationsChannelConnectionsService.PublishEvents:   1     ##O4f__
'  8 8r(   c                  F    t        j                  ddddgdgg ddddd	
      S )Nzhv1/projects/{projectsId}/locations/{locationsId}/channelConnections/{channelConnectionsId}:publishEventsPOSTzFeventarcpublishing.projects.locations.channelConnections.publishEventschannelConnectionz%v1/{+channelConnection}:publishEventsDgoogleCloudEventarcPublishingV1PublishChannelConnectionEventsRequestIEventarcpublishingProjectsLocationsChannelConnectionsPublishEventsRequestEGoogleCloudEventarcPublishingV1PublishChannelConnectionEventsResponseF	flat_pathhttp_method	method_idordered_paramspath_paramsquery_paramsrelative_pathrequest_fieldrequest_type_nameresponse_type_namesupports_downloadr   ApiMethodInfo r(   r'   <lambda>zHEventarcpublishingV1.ProjectsLocationsChannelConnectionsService.<lambda>G   s6    (*@*@|Z+,()=\eb+r(   r,   	__name__
__module____qualname____doc___NAMEr   r1   method_config__classcell__r&   s   @r'   r   r*   0   s"    O3E
8#Mr(   r   c                   >     e Zd ZdZdZ fdZddZd e_         xZS )5EventarcpublishingV1.ProjectsLocationsChannelsServicez;Service class for the projects_locations_channels resource.r   c                 N    t         t        j                  |   |       i | _        y r,   )r   r   r   r   r-   r.   s     r'   r   z>EventarcpublishingV1.ProjectsLocationsChannelsService.__init__Z   s$     AA4QRXYdr(   c                 L    | j                  d      }| j                  |||      S )aS  Publish events to a subscriber's channel.

      Args:
        request: (EventarcpublishingProjectsLocationsChannelsPublishEventsRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (GoogleCloudEventarcPublishingV1PublishEventsResponse) The response message.
      r1   r2   r4   r7   s       r'   r1   zCEventarcpublishingV1.ProjectsLocationsChannelsService.PublishEvents_   r:   r(   c                  F    t        j                  ddddgdgg ddddd	
      S )NzTv1/projects/{projectsId}/locations/{locationsId}/channels/{channelsId}:publishEventsr<   z<eventarcpublishing.projects.locations.channels.publishEventschannelzv1/{+channel}:publishEvents3googleCloudEventarcPublishingV1PublishEventsRequest?EventarcpublishingProjectsLocationsChannelsPublishEventsRequest4GoogleCloudEventarcPublishingV1PublishEventsResponseFrA   rM   rO   r(   r'   rP   z>EventarcpublishingV1.ProjectsLocationsChannelsService.<lambda>l   s4    (*@*@hP!{K3K[Q+r(   r,   rQ   rY   s   @r'   r   r[   U   s"    E)E
8#Mr(   r   c                   >     e Zd ZdZdZ fdZddZd e_         xZS )9EventarcpublishingV1.ProjectsLocationsMessageBusesServicez?Service class for the projects_locations_messageBuses resource.r   c                 N    t         t        j                  |   |       i | _        y r,   )r   r   r   r   r-   r.   s     r'   r   zBEventarcpublishingV1.ProjectsLocationsMessageBusesService.__init__   s$     EEtUV\]dr(   c                 L    | j                  d      }| j                  |||      S )aB  Publish events to a message bus.

      Args:
        request: (EventarcpublishingProjectsLocationsMessageBusesPublishRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (GoogleCloudEventarcPublishingV1PublishResponse) The response message.
      Publishr2   r4   r7   s       r'   rg   zAEventarcpublishingV1.ProjectsLocationsMessageBusesService.Publish   s1     ##I.f__
'  8 8r(   c                  F    t        j                  ddddgdgg ddddd	
      S )NzVv1/projects/{projectsId}/locations/{locationsId}/messageBuses/{messageBusesId}:publishr<   z:eventarcpublishing.projects.locations.messageBuses.publish
messageBuszv1/{+messageBus}:publish-googleCloudEventarcPublishingV1PublishRequest=EventarcpublishingProjectsLocationsMessageBusesPublishRequest.GoogleCloudEventarcPublishingV1PublishResponseFrA   rM   rO   r(   r'   rP   zBEventarcpublishingV1.ProjectsLocationsMessageBusesService.<lambda>   s4    H$:$:jN$~!N0EYK%r(   r,   )	rR   rS   rT   rU   rV   r   rg   rW   rX   rY   s   @r'   r   rd   z   s"    I-E
8Gr(   r   c                   &     e Zd ZdZdZ fdZ xZS )-EventarcpublishingV1.ProjectsLocationsServicez2Service class for the projects_locations resource.r!   c                 N    t         t        j                  |   |       i | _        y r,   )r   r   r    r   r-   r.   s     r'   r   z6EventarcpublishingV1.ProjectsLocationsService.__init__   s#     994I&Qdr(   rR   rS   rT   rU   rV   r   rX   rY   s   @r'   r    rn      s    < E r(   r    c                   &     e Zd ZdZdZ fdZ xZS )$EventarcpublishingV1.ProjectsServicez(Service class for the projects resource.r#   c                 N    t         t        j                  |   |       i | _        y r,   )r   r   r"   r   r-   r.   s     r'   r   z-EventarcpublishingV1.ProjectsService.__init__   s#     00$@Hdr(   rp   rY   s   @r'   r"   rr      s    2E r(   r"   ) NTNNFFNNNN)rR   rS   rT   rU   messagesMESSAGES_MODULEr   MTLS_BASE_URL_PACKAGE_SCOPES_VERSION
_CLIENT_ID_CLIENT_SECRET_USER_AGENT_CLIENT_CLASS_NAME_URL_VERSION_API_KEYr   r   BaseApiServicer   r   r   r    r"   rX   rY   s   @r'   r   r   
   s    K/9(C-!(=>'(*"."+-,()-6:/4<@?C	/*#83J3J #J#)@)@ #J#X-D-D #J!8!8 //  r(   r   N)
rU   
__future__r   apitools.base.pyr   ;googlecloudsdk.generated_clients.apis.eventarcpublishing.v1r   ru   BaseApiClientr   rO   r(   r'   <module>r      s'    A ' % rg811 gr(   