
    m                    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)z5Generated client library for anthosevents version v1.    )absolute_import)base_api)anthosevents_v1_messagesc                       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 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 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" G d* d+ej&                        Z# G d, d-ej&                        Z$ G d. d/ej&                        Z% G d0 d1ej&                        Z& G d2 d3ej&                        Z' G d4 d5ej&                        Z( G d6 d7ej&                        Z) G d8 d9ej&                        Z* G d: d;ej&                        Z+ G d< d=ej&                        Z, G d> d?ej&                        Z- xZ.S )AAnthoseventsV1z=Generated client library for service anthosevents version v1.z$https://anthosevents.googleapis.com/z)https://anthosevents.mtls.googleapis.com/anthoseventsz.https://www.googleapis.com/auth/userinfo.emailv1	CLIENT_IDCLIENT_SECRETzgoogle-cloud-sdkNc                    |xs | j                   }t        t        |   |||||||||	|
|       | j	                  |       | _        | j                  |       | _        | j                  |       | _	        | j                  |       | _        | j                  |       | _        | j                  |       | _        | j!                  |       | _        | j%                  |       | _        | j)                  |       | _        | j-                  |       | _        | j1                  |       | _        | j5                  |       | _        | j9                  |       | _        | j=                  |       | _        | jA                  |       | _!        | jE                  |       | _#        | jI                  |       | _%        | jM                  |       | _'        | jQ                  |       | _)        | jU                  |       | _+        | jY                  |       | _-        | j]                  |       | _/        | ja                  |       | _1        | je                  |       | _3        | ji                  |       | _5        | jm                  |       | _7        y)z!Create a new anthosevents handle.)
credentialsget_credentialshttpmodellog_requestlog_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)8BASE_URLsuperr   __init__ ApiV1NamespacesConfigmapsServiceapi_v1_namespaces_configmapsApiV1NamespacesSecretsServiceapi_v1_namespaces_secrets%ApiV1NamespacesServiceaccountsService!api_v1_namespaces_serviceaccountsApiV1NamespacesServiceapi_v1_namespacesApiV1Serviceapi_v1
ApiServiceapiBrokersServicebrokers CustomresourcedefinitionsServicecustomresourcedefinitionsNamespacesBrokersServicenamespaces_brokers&NamespacesCloudauditlogssourcesService namespaces_cloudauditlogssources#NamespacesCloudpubsubsourcesServicenamespaces_cloudpubsubsources&NamespacesCloudschedulersourcesService namespaces_cloudschedulersources$NamespacesCloudstoragesourcesServicenamespaces_cloudstoragesourcesNamespacesTriggersServicenamespaces_triggersNamespacesService
namespacesProjectServiceaccountsServiceproject_serviceaccountsProjectServiceproject"ProjectsLocationsConfigmapsServiceprojects_locations_configmaps,ProjectsLocationsNamespacesConfigmapsService(projects_locations_namespaces_configmaps1ProjectsLocationsNamespacesServiceaccountsService-projects_locations_namespaces_serviceaccounts"ProjectsLocationsNamespacesServiceprojects_locations_namespacesProjectsLocationsSecretsServiceprojects_locations_secrets'ProjectsLocationsServiceaccountsService"projects_locations_serviceaccountsProjectsLocationsServiceprojects_locationsProjectsServiceprojectsTriggersServicetriggers)selfurlr   r   r   r   r   r   r   r   r   r   	__class__s               Slib/googlecloudsdk/generated_clients/apis/anthosevents/v1/anthosevents_v1_client.pyr   zAnthoseventsV1.__init__   s5    
C	.$('d%l)3 7+ ) - )-(M(Md(SD%%)%G%G%MD"-1-W-WX\-]D*!88>D##D)DKt$DH&&t,DL%)%J%J4%PD"";;DAD,0,W,WX\,]D))-)Q)QRV)WD&,0,W,WX\,]D)*.*S*STX*YD'#==dCD,,T2DO#'#E#Ed#KD &&t,DL)-)P)PQU)VD&484e4efj4kD19=9o9opt9uD6)-)P)PQU)VD&&*&J&J4&PD#.2.Z.Z[_.`D+";;DAD((.DM((.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
_         xZS )/AnthoseventsV1.ApiV1NamespacesConfigmapsServicez<Service class for the api_v1_namespaces_configmaps resource.r   c                 N    t         t        j                  |   |       i | _        y N)r   r   r   r   _upload_configsrN   clientrP   s     rQ   r   z8AnthoseventsV1.ApiV1NamespacesConfigmapsService.__init__J   "    N;;TKFSdrR   c                 L    | j                  d      }| j                  |||      S )a  Creates a new config map.

      Args:
        request: (AnthoseventsApiV1NamespacesConfigmapsCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ConfigMap) The response message.
      Createglobal_paramsGetMethodConfig
_RunMethodrN   requestr^   configs       rQ   r\   z6AnthoseventsV1.ApiV1NamespacesConfigmapsService.CreateO   1     ##H-f__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nz+api/v1/namespaces/{namespacesId}/configmapsPOSTz0anthosevents.api.v1.namespaces.configmaps.createparentzapi/v1/{+parent}/configmaps	configMap2AnthoseventsApiV1NamespacesConfigmapsCreateRequest	ConfigMapF	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 rR   rQ   <lambda>z8AnthoseventsV1.ApiV1NamespacesConfigmapsService.<lambda>\   s4    8#9#9?D zJ3!N&$rR   c                 L    | j                  d      }| j                  |||      S )a
  Rpc to retrieve config map.

      Args:
        request: (AnthoseventsApiV1NamespacesConfigmapsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ConfigMap) The response message.
      Getr]   r_   rb   s       rQ   r}   z3AnthoseventsV1.ApiV1NamespacesConfigmapsService.Getj   1     ##E*f__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )N:api/v1/namespaces/{namespacesId}/configmaps/{configmapsId}GETz-anthosevents.api.v1.namespaces.configmaps.getnameapi/v1/{+name} /AnthoseventsApiV1NamespacesConfigmapsGetRequestrk   Frl   rx   rz   rR   rQ   r{   z8AnthoseventsV1.ApiV1NamespacesConfigmapsService.<lambda>w   s4     6 6NAxH&K&!rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to update a ConfigMap.

      Args:
        request: (AnthoseventsApiV1NamespacesConfigmapsPatchRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ConfigMap) The response message.
      Patchr]   r_   rb   s       rQ   r   z5AnthoseventsV1.ApiV1NamespacesConfigmapsService.Patch   1     ##G,f__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   PATCHz/anthosevents.api.v1.namespaces.configmaps.patchr   r   ri   1AnthoseventsApiV1NamespacesConfigmapsPatchRequestrk   Frl   rx   rz   rR   rQ   r{   z8AnthoseventsV1.ApiV1NamespacesConfigmapsService.<lambda>   s4    ("8"8NCxH&!M&#rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to replace a ConfigMap.

      Args:
        request: (AnthoseventsApiV1NamespacesConfigmapsReplaceConfigMapRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ConfigMap) The response message.
      ReplaceConfigMapr]   r_   rb   s       rQ   r   z@AnthoseventsV1.ApiV1NamespacesConfigmapsService.ReplaceConfigMap   2     ##$67f__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   PUTz:anthosevents.api.v1.namespaces.configmaps.replaceConfigMapr   r   ri   <AnthoseventsApiV1NamespacesConfigmapsReplaceConfigMapRequestrk   Frl   rx   rz   rR   rQ   r{   z8AnthoseventsV1.ApiV1NamespacesConfigmapsService.<lambda>   s4    X-C-CNNxH&!X&.rR   rV   )__name__
__module____qualname____doc___NAMEr   r\   method_configr}   r   r   __classcell__rP   s   @rQ   r   rT   E   sP    F*E
8F8C8E8&""rR   r   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 ),AnthoseventsV1.ApiV1NamespacesSecretsServicez9Service class for the api_v1_namespaces_secrets resource.r   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r   r   rW   rX   s     rQ   r   z5AnthoseventsV1.ApiV1NamespacesSecretsService.__init__   "    N88$HPdrR   c                 L    | j                  d      }| j                  |||      S )a  Creates a new secret.

      Args:
        request: (AnthoseventsApiV1NamespacesSecretsCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Secret) The response message.
      r\   r]   r_   rb   s       rQ   r\   z3AnthoseventsV1.ApiV1NamespacesSecretsService.Create   re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )N(api/v1/namespaces/{namespacesId}/secretsrg   z-anthosevents.api.v1.namespaces.secrets.createrh   api/v1/{+parent}/secretssecret/AnthoseventsApiV1NamespacesSecretsCreateRequestSecretFrl   rx   rz   rR   rQ   r{   z5AnthoseventsV1.ApiV1NamespacesSecretsService.<lambda>   s4    8#9#9<A zJ0K#$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to delete a secret.

      Args:
        request: (AnthoseventsApiV1NamespacesSecretsDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      Deleter]   r_   rb   s       rQ   r   z3AnthoseventsV1.ApiV1NamespacesSecretsService.Delete   re   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )N4api/v1/namespaces/{namespacesId}/secrets/{secretsId}DELETEz-anthosevents.api.v1.namespaces.secrets.deleter   
apiVersionkindpropagationPolicyr   r   /AnthoseventsApiV1NamespacesSecretsDeleteRequestEmptyFrl   rx   rz   rR   rQ   r{   z5AnthoseventsV1.ApiV1NamespacesSecretsService.<lambda>   s4    8#9#9HAxH@&K"$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to get information about a secret.

      Args:
        request: (AnthoseventsApiV1NamespacesSecretsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Secret) The response message.
      r}   r]   r_   rb   s       rQ   r}   z0AnthoseventsV1.ApiV1NamespacesSecretsService.Get   r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   z*anthosevents.api.v1.namespaces.secrets.getr   r   r   ,AnthoseventsApiV1NamespacesSecretsGetRequestr   Frl   rx   rz   rR   rQ   r{   z5AnthoseventsV1.ApiV1NamespacesSecretsService.<lambda>  s4     6 6H>xH&H#!rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to list secrets.

      Args:
        request: (AnthoseventsApiV1NamespacesSecretsListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListSecretsResponse) The response message.
      Listr]   r_   rb   s       rQ   r   z1AnthoseventsV1.ApiV1NamespacesSecretsService.List  1     ##F+f__
'  8 8rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr   r   z+anthosevents.api.v1.namespaces.secrets.listrh   	continue_fieldSelectorincludeUninitializedlabelSelectorlimitresourceVersionwatchr   r   -AnthoseventsApiV1NamespacesSecretsListRequestListSecretsResponseFrl   rx   rz   rR   rQ   r{   z5AnthoseventsV1.ApiV1NamespacesSecretsService.<lambda>#  s7    !7!7<? zJ B0I0"rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to replace a secret. Only the spec and metadata labels and annotations are modifiable. After the Update request, Cloud Run will work to make the 'status' match the requested 'spec'. May provide metadata.resourceVersion to enforce update from last read for optimistic concurrency control.

      Args:
        request: (AnthoseventsApiV1NamespacesSecretsReplaceSecretRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Secret) The response message.
      ReplaceSecretr]   r_   rb   s       rQ   r   z:AnthoseventsV1.ApiV1NamespacesSecretsService.ReplaceSecret1  1     ##O4f__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   z4anthosevents.api.v1.namespaces.secrets.replaceSecretr   r   r   6AnthoseventsApiV1NamespacesSecretsReplaceSecretRequestr   Frl   rx   rz   rR   rQ   r{   z5AnthoseventsV1.ApiV1NamespacesSecretsService.<lambda>>  s4    (*@*@HHxH&R#+rR   rV   r   r   r   r   r   r   r\   r   r   r}   r   r   r   r   s   @rQ   r   r      s^    C'E
8F8F8C8D8#MrR   r   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 )4AnthoseventsV1.ApiV1NamespacesServiceaccountsServicezAService class for the api_v1_namespaces_serviceaccounts resource.r   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r   r   rW   rX   s     rQ   r   z=AnthoseventsV1.ApiV1NamespacesServiceaccountsService.__init__Q  s#    N@@$PQWXdrR   c                 L    | j                  d      }| j                  |||      S )a  Creates a new service account.

      Args:
        request: (AnthoseventsApiV1NamespacesServiceaccountsCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ServiceAccount) The response message.
      r\   r]   r_   rb   s       rQ   r\   z;AnthoseventsV1.ApiV1NamespacesServiceaccountsService.CreateV  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )N0api/v1/namespaces/{namespacesId}/serviceaccountsrg   z5anthosevents.api.v1.namespaces.serviceaccounts.createrh    api/v1/{+parent}/serviceaccountsserviceAccount7AnthoseventsApiV1NamespacesServiceaccountsCreateRequestServiceAccountFrl   rx   rz   rR   rQ   r{   z=AnthoseventsV1.ApiV1NamespacesServiceaccountsService.<lambda>c  s4    8#9#9DI zJ8&S+$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to retrieve service account.

      Args:
        request: (AnthoseventsApiV1NamespacesServiceaccountsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ServiceAccount) The response message.
      r}   r]   r_   rb   s       rQ   r}   z8AnthoseventsV1.ApiV1NamespacesServiceaccountsService.Getq  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )NDapi/v1/namespaces/{namespacesId}/serviceaccounts/{serviceaccountsId}r   z2anthosevents.api.v1.namespaces.serviceaccounts.getr   r   r   4AnthoseventsApiV1NamespacesServiceaccountsGetRequestr   Frl   rx   rz   rR   rQ   r{   z=AnthoseventsV1.ApiV1NamespacesServiceaccountsService.<lambda>~  s4     6 6XFxH&P+!rR   c                 L    | j                  d      }| j                  |||      S )a$  Rpc to list Service Accounts.

      Args:
        request: (AnthoseventsApiV1NamespacesServiceaccountsListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListServiceAccountsResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z9AnthoseventsV1.ApiV1NamespacesServiceaccountsService.List  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   z3anthosevents.api.v1.namespaces.serviceaccounts.listrh   r   r   5AnthoseventsApiV1NamespacesServiceaccountsListRequestListServiceAccountsResponseFrl   rx   rz   rR   rQ   r{   z=AnthoseventsV1.ApiV1NamespacesServiceaccountsService.<lambda>  s4    !7!7DG zJ8Q8"rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to update Service Account.

      Args:
        request: (AnthoseventsApiV1NamespacesServiceaccountsPatchRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ServiceAccount) The response message.
      r   r]   r_   rb   s       rQ   r   z:AnthoseventsV1.ApiV1NamespacesServiceaccountsService.Patch  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   z4anthosevents.api.v1.namespaces.serviceaccounts.patchr   r   r   6AnthoseventsApiV1NamespacesServiceaccountsPatchRequestr   Frl   rx   rz   rR   rQ   r{   z=AnthoseventsV1.ApiV1NamespacesServiceaccountsService.<lambda>  s4    ("8"8XHxH&&R+#rR   c                 L    | j                  d      }| j                  |||      S )a,  Rpc to replace a Service Account.

      Args:
        request: (AnthoseventsApiV1NamespacesServiceaccountsReplaceServiceAccountRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ServiceAccount) The response message.
      ReplaceServiceAccountr]   r_   rb   s       rQ   r   zJAnthoseventsV1.ApiV1NamespacesServiceaccountsService.ReplaceServiceAccount  2     ##$;<f__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   zDanthosevents.api.v1.namespaces.serviceaccounts.replaceServiceAccountr   r   r   FAnthoseventsApiV1NamespacesServiceaccountsReplaceServiceAccountRequestr   Frl   rx   rz   rR   rQ   r{   z=AnthoseventsV1.ApiV1NamespacesServiceaccountsService.<lambda>  s4    (2H2HXXxH&&b+3rR   rV   )r   r   r   r   r   r   r\   r   r}   r   r   r   r   r   s   @rQ   r   r   L  s_    K/E
8F8C8D8E8+''rR   r   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_        ddZd e_         xZS )%AnthoseventsV1.ApiV1NamespacesServicez1Service class for the api_v1_namespaces resource.r!   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r    r   rW   rX   s     rQ   r   z.AnthoseventsV1.ApiV1NamespacesService.__init__  s"    N114A&IdrR   c                 L    | j                  d      }| j                  |||      S )a   Creates a new namespace.

      Args:
        request: (AnthoseventsApiV1NamespacesCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Namespace) The response message.
      r\   r]   r_   rb   s       rQ   r\   z,AnthoseventsV1.ApiV1NamespacesService.Create  re   rR   c                  B    t        j                  ddg g dgddddd	
      S )
Nrg   z%anthosevents.api.v1.namespaces.createrh   api/v1/namespaces	namespace(AnthoseventsApiV1NamespacesCreateRequest	NamespaceF
rn   ro   rp   rq   rr   rs   rt   ru   rv   rw   rx   rz   rR   rQ   r{   z.AnthoseventsV1.ApiV1NamespacesService.<lambda>  s/    8#9#99Z)!D&$rR   c                 L    | j                  d      }| j                  |||      S )zRpc to delete a namespace.

      Args:
        request: (AnthoseventsApiV1NamespacesDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   r]   r_   rb   s       rQ   r   z,AnthoseventsV1.ApiV1NamespacesService.Delete  re   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )N api/v1/namespaces/{namespacesId}r   z%anthosevents.api.v1.namespaces.deleter   r   r   r   (AnthoseventsApiV1NamespacesDeleteRequestr   Frl   rx   rz   rR   rQ   r{   z.AnthoseventsV1.ApiV1NamespacesService.<lambda>  s4    8#9#949xH@&D"$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to get information about a namespace.

      Args:
        request: (AnthoseventsApiV1NamespacesGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Namespace) The response message.
      r}   r]   r_   rb   s       rQ   r}   z)AnthoseventsV1.ApiV1NamespacesService.Get  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   z"anthosevents.api.v1.namespaces.getr   r   r   %AnthoseventsApiV1NamespacesGetRequestr   Frl   rx   rz   rR   rQ   r{   z.AnthoseventsV1.ApiV1NamespacesService.<lambda>)  s4     6 646xH&A&!rR   c                 L    | j                  d      }| j                  |||      S )a
  Rpc to list namespaces.

      Args:
        request: (AnthoseventsApiV1NamespacesListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListNamespacesResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z*AnthoseventsV1.ApiV1NamespacesService.List7  r   rR   c                  D    t        j                  ddg g g dddddd	
      S )
Nr   z#anthosevents.api.v1.namespaces.listr   r   r   r   r   rh   r   r   r   r   &AnthoseventsApiV1NamespacesListRequestListNamespacesResponseFr   rx   rz   rR   rQ   r{   z.AnthoseventsV1.ApiV1NamespacesService.<lambda>D  s0    !7!77 L)B3"rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to update a namespace.

      Args:
        request: (AnthoseventsApiV1NamespacesPatchRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Namespace) The response message.
      r   r]   r_   rb   s       rQ   r   z+AnthoseventsV1.ApiV1NamespacesService.PatchQ  r   rR   c                  H    t        j                  ddddgdgdgdddd	d
      S )Nr   r   z$anthosevents.api.v1.namespaces.patchr   
updateMaskr   r   'AnthoseventsApiV1NamespacesPatchRequestr   Frl   rx   rz   rR   rQ   r{   z.AnthoseventsV1.ApiV1NamespacesService.<lambda>^  s6    ("8"848xH"^&!C&#rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to replace a namespace.

      Args:
        request: (AnthoseventsApiV1NamespacesReplaceNamespaceRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Namespace) The response message.
      ReplaceNamespacer]   r_   rb   s       rQ   r   z6AnthoseventsV1.ApiV1NamespacesService.ReplaceNamespacel  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   z/anthosevents.api.v1.namespaces.replaceNamespacer   r   r   2AnthoseventsApiV1NamespacesReplaceNamespaceRequestr   Frl   rx   rz   rR   rQ   r{   z.AnthoseventsV1.ApiV1NamespacesService.<lambda>y  s4    X-C-C4CxH&!N&.rR   rV   r   r   r   r   r   r   r\   r   r   r}   r   r   r   r   r   s   @rQ   r    r     sn    ;E
8F8F8C8D8E8&""rR   r    c                   &     e Zd ZdZdZ fdZ xZS )AnthoseventsV1.ApiV1Servicez&Service class for the api_v1 resource.r#   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r"   r   rW   rX   s     rQ   r   z$AnthoseventsV1.ApiV1Service.__init__  s"    N''7?drR   r   r   r   r   r   r   r   r   s   @rQ   r"   r    s    0E rR   r"   c                   &     e Zd ZdZdZ fdZ xZS )AnthoseventsV1.ApiServicez#Service class for the api resource.r%   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r$   r   rW   rX   s     rQ   r   z"AnthoseventsV1.ApiService.__init__  s"    N%%t5f=drR   r  r   s   @rQ   r$   r    s    -E rR   r$   c                   >     e Zd ZdZdZ fdZddZd e_         xZS )AnthoseventsV1.BrokersServicez'Service class for the brokers resource.r'   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r&   r   rW   rX   s     rQ   r   z&AnthoseventsV1.BrokersService.__init__  "    N))49&AdrR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to list brokers in all namespaces.

      Args:
        request: (AnthoseventsBrokersListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListBrokersResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z"AnthoseventsV1.BrokersService.List  r   rR   c                  D    t        j                  ddg g g dddddd	
      S )
Nr   zanthosevents.brokers.listr   z$apis/eventing.knative.dev/v1/brokersr   AnthoseventsBrokersListRequestListBrokersResponseFr   rx   rz   rR   rQ   r{   z&AnthoseventsV1.BrokersService.<lambda>  s0    !7!7- L<:0"rR   rV   	r   r   r   r   r   r   r   r   r   r   s   @rQ   r&   r    s"    1E
8DrR   r&   c                   V     e Zd ZdZdZ fdZddZd e_        ddZd e_         xZ	S )	/AnthoseventsV1.CustomresourcedefinitionsServicez9Service class for the customresourcedefinitions resource.r)   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r(   r   rW   rX   s     rQ   r   z8AnthoseventsV1.CustomresourcedefinitionsService.__init__  rZ   rR   c                 L    | j                  d      }| j                  |||      S )a6  Rpc to get information about a CustomResourceDefinition.

      Args:
        request: (AnthoseventsCustomresourcedefinitionsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CustomResourceDefinition) The response message.
      r}   r]   r_   rb   s       rQ   r}   z3AnthoseventsV1.CustomresourcedefinitionsService.Get  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )NzTapis/apiextensions.k8s.io/v1/customresourcedefinitions/{customresourcedefinitionsId}r   z*anthosevents.customresourcedefinitions.getr   z$apis/apiextensions.k8s.io/v1/{+name}r   /AnthoseventsCustomresourcedefinitionsGetRequestCustomResourceDefinitionFrl   rx   rz   rR   rQ   r{   z8AnthoseventsV1.CustomresourcedefinitionsService.<lambda>  s4     6 6h>xH<K5!rR   c                 L    | j                  d      }| j                  |||      S )a4  Rpc to list custom resource definitions.

      Args:
        request: (AnthoseventsCustomresourcedefinitionsListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListCustomResourceDefinitionsResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z4AnthoseventsV1.CustomresourcedefinitionsService.List  r   rR   c                  D    t        j                  ddg g g dddddd	
      S )
Nr   z+anthosevents.customresourcedefinitions.listr   z6apis/apiextensions.k8s.io/v1/customresourcedefinitionsr   0AnthoseventsCustomresourcedefinitionsListRequest%ListCustomResourceDefinitionsResponseFr   rx   rz   rR   rQ   r{   z8AnthoseventsV1.CustomresourcedefinitionsService.<lambda>  s0    !7!7? LNLB"rR   rV   
r   r   r   r   r   r   r}   r   r   r   r   s   @rQ   r(   r    s1    C'E
8C8DrR   r(   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
_         xZS )'AnthoseventsV1.NamespacesBrokersServicez2Service class for the namespaces_brokers resource.r+   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r*   r   rW   rX   s     rQ   r   z0AnthoseventsV1.NamespacesBrokersService.__init__  "    N33TCFKdrR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to create a new broker.

      Args:
        request: (AnthoseventsNamespacesBrokersCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Broker) The response message.
      r\   r]   r_   rb   s       rQ   r\   z.AnthoseventsV1.NamespacesBrokersService.Create  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )N>apis/eventing.knative.dev/v1/namespaces/{namespacesId}/brokersrg   z&anthosevents.namespaces.brokers.createrh   .apis/eventing.knative.dev/v1/{+parent}/brokersbroker*AnthoseventsNamespacesBrokersCreateRequestBrokerFrl   rx   rz   rR   rQ   r{   z0AnthoseventsV1.NamespacesBrokersService.<lambda>  s4    8#9#9R: zJFF#$rR   c                 L    | j                  d      }| j                  |||      S )zRpc to delete a broker.

      Args:
        request: (AnthoseventsNamespacesBrokersDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   r]   r_   rb   s       rQ   r   z.AnthoseventsV1.NamespacesBrokersService.Delete#  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )NJapis/eventing.knative.dev/v1/namespaces/{namespacesId}/brokers/{brokersId}r   z&anthosevents.namespaces.brokers.deleter   $apis/eventing.knative.dev/v1/{+name}r   *AnthoseventsNamespacesBrokersDeleteRequestr   Frl   rx   rz   rR   rQ   r{   z0AnthoseventsV1.NamespacesBrokersService.<lambda>0  s4    8#9#9^:xH<F"$rR   c                 L    | j                  d      }| j                  |||      S )a
  Rpc to get information about a Broker.

      Args:
        request: (AnthoseventsNamespacesBrokersGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Broker) The response message.
      r}   r]   r_   rb   s       rQ   r}   z+AnthoseventsV1.NamespacesBrokersService.Get>  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr)  r   z#anthosevents.namespaces.brokers.getr   r*  r   'AnthoseventsNamespacesBrokersGetRequestr&  Frl   rx   rz   rR   rQ   r{   z0AnthoseventsV1.NamespacesBrokersService.<lambda>K  s4     6 6^7xH<C#!rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to list brokers.

      Args:
        request: (AnthoseventsNamespacesBrokersListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListBrokersResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z,AnthoseventsV1.NamespacesBrokersService.ListY  r   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr"  r   z$anthosevents.namespaces.brokers.listrh   r   r#  r   (AnthoseventsNamespacesBrokersListRequestr  Frl   rx   rz   rR   rQ   r{   z0AnthoseventsV1.NamespacesBrokersService.<lambda>f  s7    !7!7R8 zJ BFD0"rR   rV   )r   r   r   r   r   r   r\   r   r   r}   r   r   r   s   @rQ   r*   r    sO    < E
8F8F8C8DrR   r*   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 )5AnthoseventsV1.NamespacesCloudauditlogssourcesServicez@Service class for the namespaces_cloudauditlogssources resource.r-   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r,   r   rW   rX   s     rQ   r   z>AnthoseventsV1.NamespacesCloudauditlogssourcesService.__init__y  #    NAA4QRXYdrR   c                 L    | j                  d      }| j                  |||      S )a&  Creates a new cloudauditlogssource.

      Args:
        request: (AnthoseventsNamespacesCloudauditlogssourcesCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudAuditLogsSource) The response message.
      r\   r]   r_   rb   s       rQ   r\   z<AnthoseventsV1.NamespacesCloudauditlogssourcesService.Create~  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )NOapis/events.cloud.google.com/v1/namespaces/{namespacesId}/cloudauditlogssourcesrg   z4anthosevents.namespaces.cloudauditlogssources.createrh   ?apis/events.cloud.google.com/v1/{+parent}/cloudauditlogssourcescloudAuditLogsSource8AnthoseventsNamespacesCloudauditlogssourcesCreateRequestCloudAuditLogsSourceFrl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudauditlogssourcesService.<lambda>  4    8#9#9cH zJW,T1$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to delete a cloudauditlogssource.

      Args:
        request: (AnthoseventsNamespacesCloudauditlogssourcesDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   r]   r_   rb   s       rQ   r   z<AnthoseventsV1.NamespacesCloudauditlogssourcesService.Delete  re   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Niapis/events.cloud.google.com/v1/namespaces/{namespacesId}/cloudauditlogssources/{cloudauditlogssourcesId}r   z4anthosevents.namespaces.cloudauditlogssources.deleter   r   'apis/events.cloud.google.com/v1/{+name}r   8AnthoseventsNamespacesCloudauditlogssourcesDeleteRequestr   Frl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudauditlogssourcesService.<lambda>  4    8#9#9}HxH@?T"$rR   c                 L    | j                  d      }| j                  |||      S )a4  Rpc to get information about a cloudauditlogssource.

      Args:
        request: (AnthoseventsNamespacesCloudauditlogssourcesGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudAuditLogsSource) The response message.
      r}   r]   r_   rb   s       rQ   r}   z9AnthoseventsV1.NamespacesCloudauditlogssourcesService.Get  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr@  r   z1anthosevents.namespaces.cloudauditlogssources.getr   rA  r   5AnthoseventsNamespacesCloudauditlogssourcesGetRequestr<  Frl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudauditlogssourcesService.<lambda>  4     6 6}ExH?Q1!rR   c                 L    | j                  d      }| j                  |||      S )a0  Rpc to list cloudauditlogssources.

      Args:
        request: (AnthoseventsNamespacesCloudauditlogssourcesListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListCloudAuditLogsSourcesResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z:AnthoseventsV1.NamespacesCloudauditlogssourcesService.List  r   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr8  r   z2anthosevents.namespaces.cloudauditlogssources.listrh   r   r9  r   6AnthoseventsNamespacesCloudauditlogssourcesListRequest!ListCloudAuditLogsSourcesResponseFrl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudauditlogssourcesService.<lambda>  7    !7!7cF zJ BWR>"rR   c                 L    | j                  d      }| j                  |||      S )aI  Rpc to replace a cloudauditlogssource. Only the spec and metadata labels and annotations are modifiable. After the Update request, Cloud Run will work to make the 'status' match the requested 'spec'. May provide metadata.resourceVersion to enforce update from last read for optimistic concurrency control.

      Args:
        request: (AnthoseventsNamespacesCloudauditlogssourcesReplaceCloudAuditLogsSourceRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudAuditLogsSource) The response message.
      ReplaceCloudAuditLogsSourcer]   r_   rb   s       rQ   rN  zQAnthoseventsV1.NamespacesCloudauditlogssourcesService.ReplaceCloudAuditLogsSource  2     ##$ABf__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr@  r   zIanthosevents.namespaces.cloudauditlogssources.replaceCloudAuditLogsSourcer   rA  r:  MAnthoseventsNamespacesCloudauditlogssourcesReplaceCloudAuditLogsSourceRequestr<  Frl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudauditlogssourcesService.<lambda>  4    8N8N}]xH?,i19rR   rV   )r   r   r   r   r   r   r\   r   r   r}   r   rN  r   r   s   @rQ   r,   r3  t  _    J.E
8F8F8C8D81--rR   r,   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 )2AnthoseventsV1.NamespacesCloudpubsubsourcesServicez=Service class for the namespaces_cloudpubsubsources resource.r/   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r.   r   rW   rX   s     rQ   r   z;AnthoseventsV1.NamespacesCloudpubsubsourcesService.__init__
  s"    N>>NvVdrR   c                 L    | j                  d      }| j                  |||      S )a  Creates a new cloudpubsubsource.

      Args:
        request: (AnthoseventsNamespacesCloudpubsubsourcesCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudPubSubSource) The response message.
      r\   r]   r_   rb   s       rQ   r\   z9AnthoseventsV1.NamespacesCloudpubsubsourcesService.Create  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )NLapis/events.cloud.google.com/v1/namespaces/{namespacesId}/cloudpubsubsourcesrg   z1anthosevents.namespaces.cloudpubsubsources.createrh   <apis/events.cloud.google.com/v1/{+parent}/cloudpubsubsourcescloudPubSubSource5AnthoseventsNamespacesCloudpubsubsourcesCreateRequestCloudPubSubSourceFrl   rx   rz   rR   rQ   r{   z;AnthoseventsV1.NamespacesCloudpubsubsourcesService.<lambda>  s4    8#9#9`E zJT)Q.$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to delete a cloudpubsubsource.

      Args:
        request: (AnthoseventsNamespacesCloudpubsubsourcesDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   r]   r_   rb   s       rQ   r   z9AnthoseventsV1.NamespacesCloudpubsubsourcesService.Delete*  re   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Ncapis/events.cloud.google.com/v1/namespaces/{namespacesId}/cloudpubsubsources/{cloudpubsubsourcesId}r   z1anthosevents.namespaces.cloudpubsubsources.deleter   r   rA  r   5AnthoseventsNamespacesCloudpubsubsourcesDeleteRequestr   Frl   rx   rz   rR   rQ   r{   z;AnthoseventsV1.NamespacesCloudpubsubsourcesService.<lambda>7  s4    8#9#9wExH@?Q"$rR   c                 L    | j                  d      }| j                  |||      S )a+  Rpc to get information about a cloudpubsubsource.

      Args:
        request: (AnthoseventsNamespacesCloudpubsubsourcesGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudPubSubSource) The response message.
      r}   r]   r_   rb   s       rQ   r}   z6AnthoseventsV1.NamespacesCloudpubsubsourcesService.GetE  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr`  r   z.anthosevents.namespaces.cloudpubsubsources.getr   rA  r   2AnthoseventsNamespacesCloudpubsubsourcesGetRequestr]  Frl   rx   rz   rR   rQ   r{   z;AnthoseventsV1.NamespacesCloudpubsubsourcesService.<lambda>R  s4     6 6wBxH?N.!rR   c                 L    | j                  d      }| j                  |||      S )a'  Rpc to list cloudpubsubsources.

      Args:
        request: (AnthoseventsNamespacesCloudpubsubsourcesListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListCloudPubSubSourcesResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z7AnthoseventsV1.NamespacesCloudpubsubsourcesService.List`  r   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )NrY  r   z/anthosevents.namespaces.cloudpubsubsources.listrh   r   rZ  r   3AnthoseventsNamespacesCloudpubsubsourcesListRequestListCloudPubSubSourcesResponseFrl   rx   rz   rR   rQ   r{   z;AnthoseventsV1.NamespacesCloudpubsubsourcesService.<lambda>m  s7    !7!7`C zJ BTO;"rR   c                 L    | j                  d      }| j                  |||      S )a=  Rpc to replace a cloudpubsubsource. Only the spec and metadata labels and annotations are modifiable. After the Update request, Cloud Run will work to make the 'status' match the requested 'spec'. May provide metadata.resourceVersion to enforce update from last read for optimistic concurrency control.

      Args:
        request: (AnthoseventsNamespacesCloudpubsubsourcesReplaceCloudPubSubSourceRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudPubSubSource) The response message.
      ReplaceCloudPubSubSourcer]   r_   rb   s       rQ   rj  zKAnthoseventsV1.NamespacesCloudpubsubsourcesService.ReplaceCloudPubSubSource{  s2     ##$>?f__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr`  r   zCanthosevents.namespaces.cloudpubsubsources.replaceCloudPubSubSourcer   rA  r[  GAnthoseventsNamespacesCloudpubsubsourcesReplaceCloudPubSubSourceRequestr]  Frl   rx   rz   rR   rQ   r{   z;AnthoseventsV1.NamespacesCloudpubsubsourcesService.<lambda>  s4    X5K5KwWxH?)c.6rR   rV   )r   r   r   r   r   r   r\   r   r   r}   r   rj  r   r   s   @rQ   r.   rU    s_    G+E
8F8F8C8D8.**rR   r.   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 )5AnthoseventsV1.NamespacesCloudschedulersourcesServicez@Service class for the namespaces_cloudschedulersources resource.r1   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r0   r   rW   rX   s     rQ   r   z>AnthoseventsV1.NamespacesCloudschedulersourcesService.__init__  r5  rR   c                 L    | j                  d      }| j                  |||      S )a&  Creates a new cloudschedulersource.

      Args:
        request: (AnthoseventsNamespacesCloudschedulersourcesCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudSchedulerSource) The response message.
      r\   r]   r_   rb   s       rQ   r\   z<AnthoseventsV1.NamespacesCloudschedulersourcesService.Create  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )NOapis/events.cloud.google.com/v1/namespaces/{namespacesId}/cloudschedulersourcesrg   z4anthosevents.namespaces.cloudschedulersources.createrh   ?apis/events.cloud.google.com/v1/{+parent}/cloudschedulersourcescloudSchedulerSource8AnthoseventsNamespacesCloudschedulersourcesCreateRequestCloudSchedulerSourceFrl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudschedulersourcesService.<lambda>  r=  rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to delete a cloudschedulersource.

      Args:
        request: (AnthoseventsNamespacesCloudschedulersourcesDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   r]   r_   rb   s       rQ   r   z<AnthoseventsV1.NamespacesCloudschedulersourcesService.Delete  re   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Niapis/events.cloud.google.com/v1/namespaces/{namespacesId}/cloudschedulersources/{cloudschedulersourcesId}r   z4anthosevents.namespaces.cloudschedulersources.deleter   r   rA  r   8AnthoseventsNamespacesCloudschedulersourcesDeleteRequestr   Frl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudschedulersourcesService.<lambda>  rC  rR   c                 L    | j                  d      }| j                  |||      S )a4  Rpc to get information about a cloudschedulersource.

      Args:
        request: (AnthoseventsNamespacesCloudschedulersourcesGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudSchedulerSource) The response message.
      r}   r]   r_   rb   s       rQ   r}   z9AnthoseventsV1.NamespacesCloudschedulersourcesService.Get  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nry  r   z1anthosevents.namespaces.cloudschedulersources.getr   rA  r   5AnthoseventsNamespacesCloudschedulersourcesGetRequestrv  Frl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudschedulersourcesService.<lambda>  rG  rR   c                 L    | j                  d      }| j                  |||      S )a0  Rpc to list cloudschedulersources.

      Args:
        request: (AnthoseventsNamespacesCloudschedulersourcesListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListCloudSchedulerSourcesResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z:AnthoseventsV1.NamespacesCloudschedulersourcesService.List  r   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nrr  r   z2anthosevents.namespaces.cloudschedulersources.listrh   r   rs  r   6AnthoseventsNamespacesCloudschedulersourcesListRequest!ListCloudSchedulerSourcesResponseFrl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudschedulersourcesService.<lambda>  rL  rR   c                 L    | j                  d      }| j                  |||      S )aI  Rpc to replace a cloudschedulersource. Only the spec and metadata labels and annotations are modifiable. After the Update request, Cloud Run will work to make the 'status' match the requested 'spec'. May provide metadata.resourceVersion to enforce update from last read for optimistic concurrency control.

      Args:
        request: (AnthoseventsNamespacesCloudschedulersourcesReplaceCloudSchedulerSourceRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudSchedulerSource) The response message.
      ReplaceCloudSchedulerSourcer]   r_   rb   s       rQ   r  zQAnthoseventsV1.NamespacesCloudschedulersourcesService.ReplaceCloudSchedulerSource  rO  rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nry  r   zIanthosevents.namespaces.cloudschedulersources.replaceCloudSchedulerSourcer   rA  rt  MAnthoseventsNamespacesCloudschedulersourcesReplaceCloudSchedulerSourceRequestrv  Frl   rx   rz   rR   rQ   r{   z>AnthoseventsV1.NamespacesCloudschedulersourcesService.<lambda>  rR  rR   rV   )r   r   r   r   r   r   r\   r   r   r}   r   r  r   r   s   @rQ   r0   rn    rS  rR   r0   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 )3AnthoseventsV1.NamespacesCloudstoragesourcesServicez>Service class for the namespaces_cloudstoragesources resource.r3   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r2   r   rW   rX   s     rQ   r   z<AnthoseventsV1.NamespacesCloudstoragesourcesService.__init__,  s#    N??OPVWdrR   c                 L    | j                  d      }| j                  |||      S )a   Creates a new cloudstoragesource.

      Args:
        request: (AnthoseventsNamespacesCloudstoragesourcesCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudStorageSource) The response message.
      r\   r]   r_   rb   s       rQ   r\   z:AnthoseventsV1.NamespacesCloudstoragesourcesService.Create1  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )NMapis/events.cloud.google.com/v1/namespaces/{namespacesId}/cloudstoragesourcesrg   z2anthosevents.namespaces.cloudstoragesources.createrh   =apis/events.cloud.google.com/v1/{+parent}/cloudstoragesourcescloudStorageSource6AnthoseventsNamespacesCloudstoragesourcesCreateRequestCloudStorageSourceFrl   rx   rz   rR   rQ   r{   z<AnthoseventsV1.NamespacesCloudstoragesourcesService.<lambda>>  s4    8#9#9aF zJU*R/$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to delete a cloudstoragesource.

      Args:
        request: (AnthoseventsNamespacesCloudstoragesourcesDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   r]   r_   rb   s       rQ   r   z:AnthoseventsV1.NamespacesCloudstoragesourcesService.DeleteL  re   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Neapis/events.cloud.google.com/v1/namespaces/{namespacesId}/cloudstoragesources/{cloudstoragesourcesId}r   z2anthosevents.namespaces.cloudstoragesources.deleter   r   rA  r   6AnthoseventsNamespacesCloudstoragesourcesDeleteRequestr   Frl   rx   rz   rR   rQ   r{   z<AnthoseventsV1.NamespacesCloudstoragesourcesService.<lambda>Y  s4    8#9#9yFxH@?R"$rR   c                 L    | j                  d      }| j                  |||      S )a.  Rpc to get information about a cloudstoragesource.

      Args:
        request: (AnthoseventsNamespacesCloudstoragesourcesGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudStorageSource) The response message.
      r}   r]   r_   rb   s       rQ   r}   z7AnthoseventsV1.NamespacesCloudstoragesourcesService.Getg  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  r   z/anthosevents.namespaces.cloudstoragesources.getr   rA  r   3AnthoseventsNamespacesCloudstoragesourcesGetRequestr  Frl   rx   rz   rR   rQ   r{   z<AnthoseventsV1.NamespacesCloudstoragesourcesService.<lambda>t  s4     6 6yCxH?O/!rR   c                 L    | j                  d      }| j                  |||      S )a*  Rpc to list cloudstoragesources.

      Args:
        request: (AnthoseventsNamespacesCloudstoragesourcesListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListCloudStorageSourcesResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z8AnthoseventsV1.NamespacesCloudstoragesourcesService.List  r   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr  r   z0anthosevents.namespaces.cloudstoragesources.listrh   r   r  r   4AnthoseventsNamespacesCloudstoragesourcesListRequestListCloudStorageSourcesResponseFrl   rx   rz   rR   rQ   r{   z<AnthoseventsV1.NamespacesCloudstoragesourcesService.<lambda>  s7    !7!7aD zJ BUP<"rR   c                 L    | j                  d      }| j                  |||      S )aA  Rpc to replace a cloudstoragesource. Only the spec and metadata labels and annotations are modifiable. After the Update request, Cloud Run will work to make the 'status' match the requested 'spec'. May provide metadata.resourceVersion to enforce update from last read for optimistic concurrency control.

      Args:
        request: (AnthoseventsNamespacesCloudstoragesourcesReplaceCloudStorageSourceRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CloudStorageSource) The response message.
      ReplaceCloudStorageSourcer]   r_   rb   s       rQ   r  zMAnthoseventsV1.NamespacesCloudstoragesourcesService.ReplaceCloudStorageSource  s2     ##$?@f__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  r   zEanthosevents.namespaces.cloudstoragesources.replaceCloudStorageSourcer   rA  r  IAnthoseventsNamespacesCloudstoragesourcesReplaceCloudStorageSourceRequestr  Frl   rx   rz   rR   rQ   r{   z<AnthoseventsV1.NamespacesCloudstoragesourcesService.<lambda>  s4    h6L6LyYxH?*e/7rR   rV   )r   r   r   r   r   r   r\   r   r   r}   r   r  r   r   s   @rQ   r2   r  '  s_    H,E
8F8F8C8D8/++rR   r2   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 )(AnthoseventsV1.NamespacesTriggersServicez3Service class for the namespaces_triggers resource.r5   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r4   r   rW   rX   s     rQ   r   z1AnthoseventsV1.NamespacesTriggersService.__init__  s"    N44dDVLdrR   c                 L    | j                  d      }| j                  |||      S )zCreates a new trigger.

      Args:
        request: (AnthoseventsNamespacesTriggersCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Trigger) The response message.
      r\   r]   r_   rb   s       rQ   r\   z/AnthoseventsV1.NamespacesTriggersService.Create  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )N?apis/eventing.knative.dev/v1/namespaces/{namespacesId}/triggersrg   z'anthosevents.namespaces.triggers.createrh   /apis/eventing.knative.dev/v1/{+parent}/triggerstrigger+AnthoseventsNamespacesTriggersCreateRequestTriggerFrl   rx   rz   rR   rQ   r{   z1AnthoseventsV1.NamespacesTriggersService.<lambda>  s4    8#9#9S; zJGG$$rR   c                 L    | j                  d      }| j                  |||      S )zRpc to delete a trigger.

      Args:
        request: (AnthoseventsNamespacesTriggersDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   r]   r_   rb   s       rQ   r   z/AnthoseventsV1.NamespacesTriggersService.Delete  re   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )NLapis/eventing.knative.dev/v1/namespaces/{namespacesId}/triggers/{triggersId}r   z'anthosevents.namespaces.triggers.deleter   r   r*  r   +AnthoseventsNamespacesTriggersDeleteRequestr   Frl   rx   rz   rR   rQ   r{   z1AnthoseventsV1.NamespacesTriggersService.<lambda>  s4    8#9#9`;xH@<G"$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to get information about a trigger.

      Args:
        request: (AnthoseventsNamespacesTriggersGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Trigger) The response message.
      r}   r]   r_   rb   s       rQ   r}   z,AnthoseventsV1.NamespacesTriggersService.Get  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  r   z$anthosevents.namespaces.triggers.getr   r*  r   (AnthoseventsNamespacesTriggersGetRequestr  Frl   rx   rz   rR   rQ   r{   z1AnthoseventsV1.NamespacesTriggersService.<lambda>  s4     6 6`8xH<D$!rR   c                 L    | j                  d      }| j                  |||      S )a	  Rpc to list triggers.

      Args:
        request: (AnthoseventsNamespacesTriggersListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListTriggersResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z-AnthoseventsV1.NamespacesTriggersService.List  r   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr  r   z%anthosevents.namespaces.triggers.listrh   )r   r   r   r   pageSizer   r   r  r   )AnthoseventsNamespacesTriggersListRequestListTriggersResponseFrl   rx   rz   rR   rQ   r{   z1AnthoseventsV1.NamespacesTriggersService.<lambda>   s7    !7!7S9 zJ EGE1"rR   c                 L    | j                  d      }| j                  |||      S )a   Rpc to replace a trigger. Only the spec and metadata labels and annotations are modifiable. After the Update request, Events for Cloud Run will work to make the 'status' match the requested 'spec'. May provide metadata.resourceVersion to enforce update from last read for optimistic concurrency control.

      Args:
        request: (AnthoseventsNamespacesTriggersReplaceTriggerRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Trigger) The response message.
      ReplaceTriggerr]   r_   rb   s       rQ   r  z7AnthoseventsV1.NamespacesTriggersService.ReplaceTrigger.  s2     ##$45f__
'  8 8rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  r   z/anthosevents.namespaces.triggers.replaceTriggerr   r*  r  3AnthoseventsNamespacesTriggersReplaceTriggerRequestr  Frl   rx   rz   rR   rQ   r{   z1AnthoseventsV1.NamespacesTriggersService.<lambda>;  s4    8+A+A`CxH<O$,rR   rV   )r   r   r   r   r   r   r\   r   r   r}   r   r  r   r   s   @rQ   r4   r    s^    =!E
8F8F8C8D8$N  rR   r4   c                   &     e Zd ZdZdZ fdZ xZS ) AnthoseventsV1.NamespacesServicez*Service class for the namespaces resource.r7   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r6   r   rW   rX   s     rQ   r   z)AnthoseventsV1.NamespacesService.__init__N  s"    N,,d<VDdrR   r  r   s   @rQ   r6   r  I  s    4E rR   r6   c                   >     e Zd ZdZdZ fdZddZd e_         xZS ),AnthoseventsV1.ProjectServiceaccountsServicez7Service class for the project_serviceaccounts resource.r9   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r8   r   rW   rX   s     rQ   r   z5AnthoseventsV1.ProjectServiceaccountsService.__init__X  r   rR   c                 L    | j                  d      }| j                  |||      S )a  Creates a new service account.

      Args:
        request: (AnthoseventsProjectServiceaccountsCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ServiceAccount) The response message.
      r\   r]   r_   rb   s       rQ   r\   z3AnthoseventsV1.ProjectServiceaccountsService.Create]  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nz&v1/project/{projectId}/serviceaccountsrg   z+anthosevents.project.serviceaccounts.createrh   v1/{+parent}/serviceaccountsr   /AnthoseventsProjectServiceaccountsCreateRequestr   Frl   rx   rz   rR   rQ   r{   z5AnthoseventsV1.ProjectServiceaccountsService.<lambda>j  s4    8#9#9:? zJ4&K+$rR   rV   )	r   r   r   r   r   r   r\   r   r   r   s   @rQ   r8   r  S  s"    A%E
8FrR   r8   c                   &     e Zd ZdZdZ fdZ xZS )AnthoseventsV1.ProjectServicez'Service class for the project resource.r;   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r:   r   rW   rX   s     rQ   r   z&AnthoseventsV1.ProjectService.__init__}  r
  rR   r  r   s   @rQ   r:   r  x  s    1E rR   r:   c                   V     e Zd ZdZdZ fdZddZd e_        ddZd e_         xZ	S )	1AnthoseventsV1.ProjectsLocationsConfigmapsServicez=Service class for the projects_locations_configmaps resource.r=   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r<   r   rW   rX   s     rQ   r   z:AnthoseventsV1.ProjectsLocationsConfigmapsService.__init__  "    N==tMfUdrR   c                 L    | j                  d      }| j                  |||      S )a  Creates a new config map.

      Args:
        request: (AnthoseventsProjectsLocationsConfigmapsCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ConfigMap) The response message.
      r\   r]   r_   rb   s       rQ   r\   z8AnthoseventsV1.ProjectsLocationsConfigmapsService.Create  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nz;v1/projects/{projectsId}/locations/{locationsId}/configmapsrg   z1anthosevents.projects.locations.configmaps.createrh   zv1/{+parent}/configmapsri   4AnthoseventsProjectsLocationsConfigmapsCreateRequestrk   Frl   rx   rz   rR   rQ   r{   z:AnthoseventsV1.ProjectsLocationsConfigmapsService.<lambda>  4    8#9#9OE zJ/!P&$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to retrieve config map.

      Args:
        request: (AnthoseventsProjectsLocationsConfigmapsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ConfigMap) The response message.
      r}   r]   r_   rb   s       rQ   r}   z5AnthoseventsV1.ProjectsLocationsConfigmapsService.Get  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )NzJv1/projects/{projectsId}/locations/{locationsId}/configmaps/{configmapsId}r   z.anthosevents.projects.locations.configmaps.getr   
v1/{+name}r   1AnthoseventsProjectsLocationsConfigmapsGetRequestrk   Frl   rx   rz   rR   rQ   r{   z:AnthoseventsV1.ProjectsLocationsConfigmapsService.<lambda>  4     6 6^BxH"M&!rR   rV   )
r   r   r   r   r   r   r\   r   r}   r   r   s   @rQ   r<   r    s1    G+E
8F8CrR   r<   c                   V     e Zd ZdZdZ fdZddZd e_        ddZd e_         xZ	S )	;AnthoseventsV1.ProjectsLocationsNamespacesConfigmapsServicezHService class for the projects_locations_namespaces_configmaps resource.r?   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r>   r   rW   rX   s     rQ   r   zDAnthoseventsV1.ProjectsLocationsNamespacesConfigmapsService.__init__  s#    NGGWX^_drR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to update a ConfigMap.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesConfigmapsPatchRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ConfigMap) The response message.
      r   r]   r_   rb   s       rQ   r   zAAnthoseventsV1.ProjectsLocationsNamespacesConfigmapsService.Patch  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Ndv1/projects/{projectsId}/locations/{locationsId}/namespaces/{namespacesId}/configmaps/{configmapsId}r   z;anthosevents.projects.locations.namespaces.configmaps.patchr   r  ri   =AnthoseventsProjectsLocationsNamespacesConfigmapsPatchRequestrk   Frl   rx   rz   rR   rQ   r{   zDAnthoseventsV1.ProjectsLocationsNamespacesConfigmapsService.<lambda>  s4    ("8"8xOxH"!Y&#rR   c                 L    | j                  d      }| j                  |||      S )a#  Rpc to replace a ConfigMap.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesConfigmapsReplaceConfigMapRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ConfigMap) The response message.
      r   r]   r_   rb   s       rQ   r   zLAnthoseventsV1.ProjectsLocationsNamespacesConfigmapsService.ReplaceConfigMap  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  r   zFanthosevents.projects.locations.namespaces.configmaps.replaceConfigMapr   r  ri   HAnthoseventsProjectsLocationsNamespacesConfigmapsReplaceConfigMapRequestrk   Frl   rx   rz   rR   rQ   r{   zDAnthoseventsV1.ProjectsLocationsNamespacesConfigmapsService.<lambda>  s4    X-C-CxZxH"!d&.rR   rV   )
r   r   r   r   r   r   r   r   r   r   r   s   @rQ   r>   r    s2    R6E
8E8&""rR   r>   c                   V     e Zd ZdZdZ fdZddZd e_        ddZd e_         xZ	S )	@AnthoseventsV1.ProjectsLocationsNamespacesServiceaccountsServicezMService class for the projects_locations_namespaces_serviceaccounts resource.rA   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   r@   r   rW   rX   s     rQ   r   zIAnthoseventsV1.ProjectsLocationsNamespacesServiceaccountsService.__init__  s#    NLLd\]cddrR   c                 L    | j                  d      }| j                  |||      S )a%  Rpc to update Service Account.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesServiceaccountsPatchRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ServiceAccount) The response message.
      r   r]   r_   rb   s       rQ   r   zFAnthoseventsV1.ProjectsLocationsNamespacesServiceaccountsService.Patch  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nnv1/projects/{projectsId}/locations/{locationsId}/namespaces/{namespacesId}/serviceaccounts/{serviceaccountsId}r   z@anthosevents.projects.locations.namespaces.serviceaccounts.patchr   r  r   BAnthoseventsProjectsLocationsNamespacesServiceaccountsPatchRequestr   Frl   rx   rz   rR   rQ   r{   zIAnthoseventsV1.ProjectsLocationsNamespacesServiceaccountsService.<lambda>  s7    ("8"8 CTxH"&^+#rR   c                 L    | j                  d      }| j                  |||      S )a8  Rpc to replace a Service Account.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesServiceaccountsReplaceServiceAccountRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ServiceAccount) The response message.
      r   r]   r_   rb   s       rQ   r   zVAnthoseventsV1.ProjectsLocationsNamespacesServiceaccountsService.ReplaceServiceAccount'  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  r   zPanthosevents.projects.locations.namespaces.serviceaccounts.replaceServiceAccountr   r  r   RAnthoseventsProjectsLocationsNamespacesServiceaccountsReplaceServiceAccountRequestr   Frl   rx   rz   rR   rQ   r{   zIAnthoseventsV1.ProjectsLocationsNamespacesServiceaccountsService.<lambda>4  s7    (2H2H CdxH"&n+3rR   rV   )
r   r   r   r   r   r   r   r   r   r   r   s   @rQ   r@   r    s2    W;E
8E8+''rR   r@   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_        ddZd e_         xZS )1AnthoseventsV1.ProjectsLocationsNamespacesServicez=Service class for the projects_locations_namespaces resource.rC   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   rB   r   rW   rX   s     rQ   r   z:AnthoseventsV1.ProjectsLocationsNamespacesService.__init__G  r  rR   c                 L    | j                  d      }| j                  |||      S )a  Creates a new namespace.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Namespace) The response message.
      r\   r]   r_   rb   s       rQ   r\   z8AnthoseventsV1.ProjectsLocationsNamespacesService.CreateL  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )N;v1/projects/{projectsId}/locations/{locationsId}/namespacesrg   z1anthosevents.projects.locations.namespaces.createrh   v1/{+parent}/namespacesr   4AnthoseventsProjectsLocationsNamespacesCreateRequestr   Frl   rx   rz   rR   rQ   r{   z:AnthoseventsV1.ProjectsLocationsNamespacesService.<lambda>Y  r  rR   c                 L    | j                  d      }| j                  |||      S )a
  Rpc to delete a namespace.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   r]   r_   rb   s       rQ   r   z8AnthoseventsV1.ProjectsLocationsNamespacesService.Deleteg  re   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )NJv1/projects/{projectsId}/locations/{locationsId}/namespaces/{namespacesId}r   z1anthosevents.projects.locations.namespaces.deleter   r   r  r   4AnthoseventsProjectsLocationsNamespacesDeleteRequestr   Frl   rx   rz   rR   rQ   r{   z:AnthoseventsV1.ProjectsLocationsNamespacesService.<lambda>t  s4    8#9#9^ExH@"P"$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to get information about a namespace.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Namespace) The response message.
      r}   r]   r_   rb   s       rQ   r}   z5AnthoseventsV1.ProjectsLocationsNamespacesService.Get  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  r   z.anthosevents.projects.locations.namespaces.getr   r  r   1AnthoseventsProjectsLocationsNamespacesGetRequestr   Frl   rx   rz   rR   rQ   r{   z:AnthoseventsV1.ProjectsLocationsNamespacesService.<lambda>  r  rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to list namespaces.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListNamespacesResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z6AnthoseventsV1.ProjectsLocationsNamespacesService.List  r   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr  r   z/anthosevents.projects.locations.namespaces.listrh   r   r  r   2AnthoseventsProjectsLocationsNamespacesListRequestr   Frl   rx   rz   rR   rQ   r{   z:AnthoseventsV1.ProjectsLocationsNamespacesService.<lambda>  s7    !7!7OC zJ B/N3"rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to update a namespace.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesPatchRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Namespace) The response message.
      r   r]   r_   rb   s       rQ   r   z7AnthoseventsV1.ProjectsLocationsNamespacesService.Patch  r   rR   c                  H    t        j                  ddddgdgdgdddd	d
      S )Nr  r   z0anthosevents.projects.locations.namespaces.patchr   r   r  r   3AnthoseventsProjectsLocationsNamespacesPatchRequestr   Frl   rx   rz   rR   rQ   r{   z:AnthoseventsV1.ProjectsLocationsNamespacesService.<lambda>  s6    ("8"8^DxH"^"!O&#rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to replace a namespace.

      Args:
        request: (AnthoseventsProjectsLocationsNamespacesReplaceNamespaceRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Namespace) The response message.
      r   r]   r_   rb   s       rQ   r   zBAnthoseventsV1.ProjectsLocationsNamespacesService.ReplaceNamespace  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  r   z;anthosevents.projects.locations.namespaces.replaceNamespacer   r  r   >AnthoseventsProjectsLocationsNamespacesReplaceNamespaceRequestr   Frl   rx   rz   rR   rQ   r{   z:AnthoseventsV1.ProjectsLocationsNamespacesService.<lambda>  s4    X-C-C^OxH"!Z&.rR   rV   r   r   s   @rQ   rB   r  B  sn    G+E
8F8F8C8D8E8&""rR   rB   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 ).AnthoseventsV1.ProjectsLocationsSecretsServicez:Service class for the projects_locations_secrets resource.rE   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   rD   r   rW   rX   s     rQ   r   z7AnthoseventsV1.ProjectsLocationsSecretsService.__init__  s"    N::DJ6RdrR   c                 L    | j                  d      }| j                  |||      S )a  Creates a new secret.

      Args:
        request: (AnthoseventsProjectsLocationsSecretsCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Secret) The response message.
      r\   r]   r_   rb   s       rQ   r\   z5AnthoseventsV1.ProjectsLocationsSecretsService.Create  re   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )N8v1/projects/{projectsId}/locations/{locationsId}/secretsrg   z.anthosevents.projects.locations.secrets.createrh   v1/{+parent}/secretsr   1AnthoseventsProjectsLocationsSecretsCreateRequestr   Frl   rx   rz   rR   rQ   r{   z7AnthoseventsV1.ProjectsLocationsSecretsService.<lambda>  s4    8#9#9LB zJ,M#$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to delete a secret.

      Args:
        request: (AnthoseventsProjectsLocationsSecretsDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   r]   r_   rb   s       rQ   r   z5AnthoseventsV1.ProjectsLocationsSecretsService.Delete  re   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )NDv1/projects/{projectsId}/locations/{locationsId}/secrets/{secretsId}r   z.anthosevents.projects.locations.secrets.deleter   r   r  r   1AnthoseventsProjectsLocationsSecretsDeleteRequestr   Frl   rx   rz   rR   rQ   r{   z7AnthoseventsV1.ProjectsLocationsSecretsService.<lambda>   s4    8#9#9XBxH@"M"$rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to get information about a secret.

      Args:
        request: (AnthoseventsProjectsLocationsSecretsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Secret) The response message.
      r}   r]   r_   rb   s       rQ   r}   z2AnthoseventsV1.ProjectsLocationsSecretsService.Get.  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr	  r   z+anthosevents.projects.locations.secrets.getr   r  r   .AnthoseventsProjectsLocationsSecretsGetRequestr   Frl   rx   rz   rR   rQ   r{   z7AnthoseventsV1.ProjectsLocationsSecretsService.<lambda>;  s4     6 6X?xH"J#!rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to list secrets.

      Args:
        request: (AnthoseventsProjectsLocationsSecretsListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListSecretsResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z3AnthoseventsV1.ProjectsLocationsSecretsService.ListI  r   rR   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr  r   z,anthosevents.projects.locations.secrets.listrh   r   r  r   /AnthoseventsProjectsLocationsSecretsListRequestr   Frl   rx   rz   rR   rQ   r{   z7AnthoseventsV1.ProjectsLocationsSecretsService.<lambda>V  s7    !7!7L@ zJ B,K0"rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to replace a secret. Only the spec and metadata labels and annotations are modifiable. After the Update request, Cloud Run will work to make the 'status' match the requested 'spec'. May provide metadata.resourceVersion to enforce update from last read for optimistic concurrency control.

      Args:
        request: (AnthoseventsProjectsLocationsSecretsReplaceSecretRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Secret) The response message.
      r   r]   r_   rb   s       rQ   r   z<AnthoseventsV1.ProjectsLocationsSecretsService.ReplaceSecretd  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr	  r   z5anthosevents.projects.locations.secrets.replaceSecretr   r  r   8AnthoseventsProjectsLocationsSecretsReplaceSecretRequestr   Frl   rx   rz   rR   rQ   r{   z7AnthoseventsV1.ProjectsLocationsSecretsService.<lambda>q  s4    (*@*@XIxH"T#+rR   rV   r   r   s   @rQ   rD   r     s^    D(E
8F8F8C8D8#MrR   rD   c                   V     e Zd ZdZdZ fdZddZd e_        ddZd e_         xZ	S )	6AnthoseventsV1.ProjectsLocationsServiceaccountsServicezBService class for the projects_locations_serviceaccounts resource.rG   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   rF   r   rW   rX   s     rQ   r   z?AnthoseventsV1.ProjectsLocationsServiceaccountsService.__init__  s#    NBBDRSYZdrR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to retrieve service account.

      Args:
        request: (AnthoseventsProjectsLocationsServiceaccountsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ServiceAccount) The response message.
      r}   r]   r_   rb   s       rQ   r}   z:AnthoseventsV1.ProjectsLocationsServiceaccountsService.Get  r~   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )NzTv1/projects/{projectsId}/locations/{locationsId}/serviceaccounts/{serviceaccountsId}r   z3anthosevents.projects.locations.serviceaccounts.getr   r  r   6AnthoseventsProjectsLocationsServiceaccountsGetRequestr   Frl   rx   rz   rR   rQ   r{   z?AnthoseventsV1.ProjectsLocationsServiceaccountsService.<lambda>  s4     6 6hGxH"R+!rR   c                 L    | j                  d      }| j                  |||      S )a&  Rpc to list Service Accounts.

      Args:
        request: (AnthoseventsProjectsLocationsServiceaccountsListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListServiceAccountsResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z;AnthoseventsV1.ProjectsLocationsServiceaccountsService.List  r   rR   c                  F    t        j                  ddddgdgg ddddd	
      S )Nz@v1/projects/{projectsId}/locations/{locationsId}/serviceaccountsr   z4anthosevents.projects.locations.serviceaccounts.listrh   r  r   7AnthoseventsProjectsLocationsServiceaccountsListRequestr   Frl   rx   rz   rR   rQ   r{   z?AnthoseventsV1.ProjectsLocationsServiceaccountsService.<lambda>  s4    !7!7TH zJ4S8"rR   rV   r  r   s   @rQ   rF   r    s1    L0E
8C8DrR   rF   c                   &     e Zd ZdZdZ fdZ xZS )'AnthoseventsV1.ProjectsLocationsServicez2Service class for the projects_locations resource.rI   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   rH   r   rW   rX   s     rQ   r   z0AnthoseventsV1.ProjectsLocationsService.__init__  r  rR   r  r   s   @rQ   rH   r    s    < E rR   rH   c                   &     e Zd ZdZdZ fdZ xZS )AnthoseventsV1.ProjectsServicez(Service class for the projects resource.rK   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   rJ   r   rW   rX   s     rQ   r   z'AnthoseventsV1.ProjectsService.__init__  "    N**D:6BdrR   r  r   s   @rQ   rJ   r!    s    2E rR   rJ   c                   >     e Zd ZdZdZ fdZddZd e_         xZS )AnthoseventsV1.TriggersServicez(Service class for the triggers resource.rM   c                 N    t         t        j                  |   |       i | _        y rV   )r   r   rL   r   rW   rX   s     rQ   r   z'AnthoseventsV1.TriggersService.__init__  r#  rR   c                 L    | j                  d      }| j                  |||      S )a  Rpc to list triggers in all namespaces.

      Args:
        request: (AnthoseventsTriggersListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListTriggersResponse) The response message.
      r   r]   r_   rb   s       rQ   r   z#AnthoseventsV1.TriggersService.List  r   rR   c                  D    t        j                  ddg g g dddddd	
      S )
Nr   zanthosevents.triggers.list)r   r   r   r   r  rh   r   r   z%apis/eventing.knative.dev/v1/triggersr   AnthoseventsTriggersListRequestr  Fr   rx   rz   rR   rQ   r{   z'AnthoseventsV1.TriggersService.<lambda>  s0    !7!7. O=;1"rR   rV   r  r   s   @rQ   rL   r%    s"    2E
8DrR   rL   )r   NTNNFFNNNN)/r   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$   r&   r(   r*   r,   r.   r0   r2   r4   r6   r8   r:   r<   r>   r@   rB   rD   rF   rH   rJ   rL   r   r   s   @rQ   r   r   
   s_   E/3(=-(=>'(*"."+',()-6:/4<@?C	(/Tt)@)@ tlOh&=&= ObOh.E.E Obhx66 hTX,, 8** "x.. "H=)@)@ =~t!8!8 tlOx/F/F ObOH,C,C ObOx/F/F ObOX-D-D ObO("9"9 Ob(11 #h&=&= #Jx.. >8+B+B >@>X5L5L >@>(:Q:Q >@j8+B+B jXO(?(? Ob>0G0G >@!8!8 // "// " "rR   r   N)
r   
__future__r   apitools.base.pyr   5googlecloudsdk.generated_clients.apis.anthosevents.v1r   r*  BaseApiClientr   rz   rR   rQ   <module>r;     s'    ; ' % fk#X++ k#rR   