
    O                     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)z7Generated client library for eventflow version v1beta2.    )absolute_import)base_api)eventflow_v1beta2_messagesc                        e Zd ZdZeZdZdZdZd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 xZS )EventflowV1beta2z?Generated client library for service eventflow version v1beta2.z!https://eventflow.googleapis.com/z&https://eventflow.mtls.googleapis.com/	eventflowz.https://www.googleapis.com/auth/cloud-platformz(https://www.googleapis.com/auth/firebasev1beta2	CLIENT_IDCLIENT_SECRETzgoogle-cloud-sdkNc                     |xs | j                   }t        t        |   |||||||||	|
|       | j	                  |       | _        | j                  |       | _        y)zCreate a new eventflow handle.)
credentialsget_credentialshttpmodellog_requestlog_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)BASE_URLsuperr   __init__ProjectsFlowsServiceprojects_flowsProjectsServiceprojects)selfurlr   r   r   r   r   r   r   r   r   r   	__class__s               Wlib/googlecloudsdk/generated_clients/apis/eventflow/v1beta2/eventflow_v1beta2_client.pyr   zEventflowV1beta2.__init__   sl     
C	
D*'d%l)3 7+ + - 33D9D((.DM    c                        e Zd ZdZdZ fdZddZd e_        ddZd e_        ddZ	d	 e	_        dd
Z
d e
_        ddZd e_         xZS )%EventflowV1beta2.ProjectsFlowsServicez.Service class for the projects_flows resource.r   c                 N    t         t        j                  |   |       i | _        y N)r   r   r   r   _upload_configsr   clientr    s     r!   r   z.EventflowV1beta2.ProjectsFlowsService.__init__2   s#    114A&Idr"   c                 L    | j                  d      }| j                  |||      S )a  Creates a flow, and returns the new Flow.

      Args:
        request: (EventflowProjectsFlowsCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Flow) The response message.
      Createglobal_paramsGetMethodConfig
_RunMethodr   requestr-   configs       r!   r+   z,EventflowV1beta2.ProjectsFlowsService.Create7   1     ##H-f__
'  8 8r"   c                  F    t        j                  ddddgdgg ddddd	
      S )N#v1beta2/projects/{projectsId}/flowsPOSTzeventflow.projects.flows.create	namespacez#v1beta2/projects/{+namespace}/flowsflow#EventflowProjectsFlowsCreateRequestFlowF	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>z.EventflowV1beta2.ProjectsFlowsService.<lambda>D   s4    8#9#973#} M;?!$r"   c                 L    | j                  d      }| j                  |||      S )a  Deletes a flow. Returns NOT_FOUND if the item does not exist.

      Args:
        request: (EventflowProjectsFlowsDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      Deleter,   r.   r1   s       r!   rM   z,EventflowV1beta2.ProjectsFlowsService.DeleteR   r4   r"   c                  F    t        j                  ddddgdgg ddddd	
      S )N-v1beta2/projects/{projectsId}/flows/{flowsId}DELETEzeventflow.projects.flows.deletenamev1beta2/{+name} #EventflowProjectsFlowsDeleteRequestEmptyFr<   rH   rJ   r"   r!   rK   z.EventflowV1beta2.ProjectsFlowsService.<lambda>_   s4    8#9#9A3xH'?"$r"   c                 L    | j                  d      }| j                  |||      S )a  Gets a flow. Returns NOT_FOUND if the flow does not exist.

      Args:
        request: (EventflowProjectsFlowsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Flow) The response message.
      Getr,   r.   r1   s       r!   rW   z)EventflowV1beta2.ProjectsFlowsService.Getm   s1     ##E*f__
'  8 8r"   c                  F    t        j                  ddddgdgg ddddd	
      S )NrO   GETzeventflow.projects.flows.getrQ   rR   rS    EventflowProjectsFlowsGetRequestr;   Fr<   rH   rJ   r"   r!   rK   z.EventflowV1beta2.ProjectsFlowsService.<lambda>z   s4     6 6A0xH'<!!r"   c                 L    | j                  d      }| j                  |||      S )zLists flows.

      Args:
        request: (EventflowProjectsFlowsListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListFlowsResponse) The response message.
      Listr,   r.   r1   s       r!   r\   z*EventflowV1beta2.ProjectsFlowsService.List   s1     ##F+f__
'  8 8r"   c                  J    t        j                  ddddgdgddgddd	d
d      S )Nr6   rY   zeventflow.projects.flows.listparentpageSize	pageTokenzv1beta2/{+parent}/flowsrS   !EventflowProjectsFlowsListRequestListFlowsResponseFr<   rH   rJ   r"   r!   rK   z.EventflowV1beta2.ProjectsFlowsService.<lambda>   s9    !7!771 zJ +./=."r"   c                 L    | j                  d      }| j                  |||      S )a  Updates a flow, returning the updated flow. Empty fields (proto3 default values) mean don't change those fields. The call returns INVALID_ARGUMENT status if the spec.name, spec.namespace, or spec.trigger.event_type is change. trigger.event_type is changed.

      Args:
        request: (EventflowProjectsFlowsUpdateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Flow) The response message.
      Updater,   r.   r1   s       r!   rd   z,EventflowV1beta2.ProjectsFlowsService.Update   r4   r"   c                  J    t        j                  dddddgddgg dddd	d
      S )NrO   PUTzeventflow.projects.flows.updater8   rQ   z+v1beta2/projects/{+namespace}/flows/{+name}r9   #EventflowProjectsFlowsUpdateRequestr;   Fr<   rH   rJ   r"   r!   rK   z.EventflowV1beta2.ProjectsFlowsService.<lambda>   s:    8#9#9A3#V,[)C?!$r"   r&   )__name__
__module____qualname____doc___NAMEr   r+   method_configrM   rW   r\   rd   __classcell__r    s   @r!   r   r$   -   s^    8E
8F8F8C8D8Fr"   r   c                   &     e Zd ZdZdZ fdZ xZS ) EventflowV1beta2.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)EventflowV1beta2.ProjectsService.__init__   s#    ,,d<VDdr"   )rh   ri   rj   rk   rl   r   rn   ro   s   @r!   r   rq      s    2E r"   r   )rS   NTNNFFNNNN)rh   ri   rj   rk   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   rn   ro   s   @r!   r   r   
   s    G/0(:-(=?ij'(*"."+),()-6:/4<@?C	/$OX44 Ob//  r"   r   N)
rk   
__future__r   apitools.base.pyr   7googlecloudsdk.generated_clients.apis.eventflow.v1beta2r   rs   BaseApiClientr   rJ   r"   r!   <module>r      s'    = ' % j|x-- |r"   