
                         V    S r SSKJr  SSKJr  SSKJr   " S S\R                  5      r	g)z;Generated client library for eventarcpublishing version v1.    )absolute_import)base_api)eventarcpublishing_v1_messagesc                   >  ^  \ rS rSrSr\rSrSrSr	S/r
SrSrS	rS
rS rSrSr     SU 4S jjr " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      rSrU =r$ )EventarcpublishingV1
   zCGenerated 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                 <  > U=(       d    U R                   n[        [        U ]  XX4UXgUU	U
US9  U R	                  U 5      U l        U R                  U 5      U l        U R                  U 5      U l	        U R                  U 5      U l        U R                  U 5      U l        g)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   EventarcpublishingV1.__init__   s     
C	
.'%)3 7+ / - 261`1`ae1fD.'+'L'LT'RD$+/+T+TUY+ZD(";;DAD((.DM    c                   J   ^  \ rS rSrSrSrU 4S jrSS jrS \l        Sr	U =r
$ )	?EventarcpublishingV1.ProjectsLocationsChannelConnectionsService0   zEService class for the projects_locations_channelConnections resource.r   c                 N   > [         [        R                  U ]  U5        0 U l        g N)r   r   r   r   _upload_configsr%   clientr'   s     r(   r   HEventarcpublishingV1.ProjectsLocationsChannelConnectionsService.__init__5   s$     KKT[\bcdr*   c                 D    U R                  S5      nU R                  X1US9$ )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%   requestr7   configs       r(   r5   MEventarcpublishingV1.ProjectsLocationsChannelConnectionsService.PublishEvents:   /     ##O4f__
  8 8r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )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>HEventarcpublishingV1.ProjectsLocationsChannelConnectionsService.<lambda>G   s6    (*@*@|Z+,()=\eb+r*   r0   r/   __name__
__module____qualname____firstlineno____doc___NAMEr   r5   method_config__static_attributes____classcell__r'   s   @r(   r   r,   0   s"    O3E
8#Mr*   r   c                   J   ^  \ rS rSrSrSrU 4S jrSS jrS \l        Sr	U =r
$ )	5EventarcpublishingV1.ProjectsLocationsChannelsServiceU   z;Service class for the projects_locations_channels resource.r   c                 N   > [         [        R                  U ]  U5        0 U l        g r/   )r   r   r   r   r0   r1   s     r(   r   >EventarcpublishingV1.ProjectsLocationsChannelsService.__init__Z   s$     AA4QRXYdr*   c                 D    U R                  S5      nU R                  X1US9$ )a/  Publish events to a subscriber's channel.

Args:
  request: (EventarcpublishingProjectsLocationsChannelsPublishEventsRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (GoogleCloudEventarcPublishingV1PublishEventsResponse) The response message.
r5   r6   r8   r;   s       r(   r5   CEventarcpublishingV1.ProjectsLocationsChannelsService.PublishEvents_   r?   r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NzTv1/projects/{projectsId}/locations/{locationsId}/channels/{channelsId}:publishEventsrA   z<eventarcpublishing.projects.locations.channels.publishEventschannelzv1/{+channel}:publishEvents3googleCloudEventarcPublishingV1PublishEventsRequest?EventarcpublishingProjectsLocationsChannelsPublishEventsRequest4GoogleCloudEventarcPublishingV1PublishEventsResponseFrF   rR   rT   r*   r(   rU   >EventarcpublishingV1.ProjectsLocationsChannelsService.<lambda>l   s4    (*@*@hP!{K3K[Q+r*   rW   r/   rX   rb   s   @r(   r   rd   U   s"    E)E
8#Mr*   r   c                   J   ^  \ rS rSrSrSrU 4S jrSS jrS \l        Sr	U =r
$ )	9EventarcpublishingV1.ProjectsLocationsMessageBusesServicez   z?Service class for the projects_locations_messageBuses resource.r    c                 N   > [         [        R                  U ]  U5        0 U l        g r/   )r   r   r   r   r0   r1   s     r(   r   BEventarcpublishingV1.ProjectsLocationsMessageBusesService.__init__   s$     EEtUV\]dr*   c                 D    U R                  S5      nU R                  X1US9$ )a  Publish events to a message bus.

Args:
  request: (EventarcpublishingProjectsLocationsMessageBusesPublishRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (GoogleCloudEventarcPublishingV1PublishResponse) The response message.
Publishr6   r8   r;   s       r(   rv   AEventarcpublishingV1.ProjectsLocationsMessageBusesService.Publish   s/     ##I.f__
  8 8r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NzVv1/projects/{projectsId}/locations/{locationsId}/messageBuses/{messageBusesId}:publishrA   z:eventarcpublishing.projects.locations.messageBuses.publish
messageBuszv1/{+messageBus}:publish-googleCloudEventarcPublishingV1PublishRequest=EventarcpublishingProjectsLocationsMessageBusesPublishRequest.GoogleCloudEventarcPublishingV1PublishResponseFrF   rR   rT   r*   r(   rU   BEventarcpublishingV1.ProjectsLocationsMessageBusesService.<lambda>   s4    H$:$:jN$~!N0EYK%r*   rW   r/   )rY   rZ   r[   r\   r]   r^   r   rv   r_   r`   ra   rb   s   @r(   r   rq   z   s"    I-E
8Gr*   r   c                   0   ^  \ rS rSrSrSrU 4S jrSrU =r$ )-EventarcpublishingV1.ProjectsLocationsService   z2Service class for the projects_locations resource.r"   c                 N   > [         [        R                  U ]  U5        0 U l        g r/   )r   r   r!   r   r0   r1   s     r(   r   6EventarcpublishingV1.ProjectsLocationsService.__init__   s#     994I&Qdr*   rW   	rY   rZ   r[   r\   r]   r^   r   r`   ra   rb   s   @r(   r!   r      s    < E r*   r!   c                   0   ^  \ rS rSrSrSrU 4S jrSrU =r$ )$EventarcpublishingV1.ProjectsService   z(Service class for the projects resource.r$   c                 N   > [         [        R                  U ]  U5        0 U l        g r/   )r   r   r#   r   r0   r1   s     r(   r   -EventarcpublishingV1.ProjectsService.__init__   s#     00$@Hdr*   rW   r   rb   s   @r(   r#   r      s    2E r*   r#   )r$   r"   r   r   r    ) NTNNFFNNNN)rY   rZ   r[   r\   r]   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#   r`   ra   rb   s   @r(   r   r   
   s    K/9(C-!(=>'(*"."+-,()-6:/4<@?C	/*#83J3J #J#)@)@ #J#X-D-D #J!8!8 //  r*   r   N)
r]   
__future__r   apitools.base.pyr   ;googlecloudsdk.generated_clients.apis.eventarcpublishing.v1r   r   BaseApiClientr   rT   r*   r(   <module>r      s'    A ' % rg811 gr*   