
                         V    d Z ddlmZ ddlmZ ddlmZ  G d dej                        Z	y)z:Generated client library for anthosevents version v1beta1.    )absolute_import)base_api)anthosevents_v1beta1_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  xZ!S )'AnthoseventsV1beta1zBGenerated client library for service anthosevents version v1beta1.z$https://anthosevents.googleapis.com/z)https://anthosevents.mtls.googleapis.com/anthoseventsz.https://www.googleapis.com/auth/userinfo.emailv1beta1	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                  |       | _        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)BASE_URLsuperr   __init__BrokersServicebrokers CustomresourcedefinitionsServicecustomresourcedefinitions!NamespacesApiserversourcesServicenamespaces_apiserversourcesNamespacesBrokersServicenamespaces_brokers&NamespacesCloudauditlogssourcesService namespaces_cloudauditlogssources#NamespacesCloudpubsubsourcesServicenamespaces_cloudpubsubsources&NamespacesCloudschedulersourcesService namespaces_cloudschedulersources$NamespacesCloudstoragesourcesServicenamespaces_cloudstoragesources*NamespacesCustomresourcedefinitionsService$namespaces_customresourcedefinitionsNamespacesPingsourcesServicenamespaces_pingsourcesNamespacesTriggersServicenamespaces_triggersNamespacesService
namespacesTriggersServicetriggers)selfurlr   r   r   r   r   r   r   r   r   r   	__class__s               ]lib/googlecloudsdk/generated_clients/apis/anthosevents/v1beta1/anthosevents_v1beta1_client.pyr   zAnthoseventsV1beta1.__init__   s@    
C	
t-'d%l)3 7+ . - &&t,DL%)%J%J4%PD"'+'M'Md'SD$";;DAD,0,W,WX\,]D))-)Q)QRV)WD&,0,W,WX\,]D)*.*S*STX*YD'040_0_`d0eD-"&"C"CD"ID#==dCD,,T2DO((.DM    c                   >     e Zd ZdZdZ fdZddZd e_         xZS )"AnthoseventsV1beta1.BrokersServicez'Service class for the brokers resource.r   c                 N    t         t        j                  |   |       i | _        y N)r   r   r   r   _upload_configsr4   clientr6   s     r7   r   z+AnthoseventsV1beta1.BrokersService.__init__=   s#    ..>vFdr8   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.
      Listglobal_paramsGetMethodConfig
_RunMethodr4   requestrC   configs       r7   rA   z'AnthoseventsV1beta1.BrokersService.ListB   1     ##F+f__
'  8 8r8   c                  D    t        j                  ddg g g dddddd	
      S )
NGETzanthosevents.brokers.list	continue_fieldSelectorincludeUninitializedlabelSelectorlimitparentresourceVersionwatchz)apis/eventing.knative.dev/v1beta1/brokers AnthoseventsBrokersListRequestListBrokersResponseF
http_method	method_idordered_paramspath_paramsquery_paramsrelative_pathrequest_fieldrequest_type_nameresponse_type_namesupports_downloadr   ApiMethodInfo r8   r7   <lambda>z+AnthoseventsV1beta1.BrokersService.<lambda>O   s0    !7!7- LA:0"r8   r<   	__name__
__module____qualname____doc___NAMEr   rA   method_config__classcell__r6   s   @r7   r   r:   8   s"    1E
8Dr8   r   c                   >     e Zd ZdZdZ fdZddZd e_         xZS )4AnthoseventsV1beta1.CustomresourcedefinitionsServicez9Service class for the customresourcedefinitions resource.r   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r   r   r=   r>   s     r7   r   z=AnthoseventsV1beta1.CustomresourcedefinitionsService.__init__a   s$    @@$PQWXdr8   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.
      rA   rB   rD   rG   s       r7   rA   z9AnthoseventsV1beta1.CustomresourcedefinitionsService.Listf   rJ   r8   c                  D    t        j                  ddg g g dddddd	
      S )
NrL   z+anthosevents.customresourcedefinitions.listrM   z;apis/apiextensions.k8s.io/v1beta1/customresourcedefinitionsrV   0AnthoseventsCustomresourcedefinitionsListRequest%ListCustomResourceDefinitionsResponseFrY   rd   rf   r8   r7   rg   z=AnthoseventsV1beta1.CustomresourcedefinitionsService.<lambda>s   s0    !7!7? LSLB"r8   r<   rh   rp   s   @r7   r   rr   \   s"    C'E
8Dr8   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 )5AnthoseventsV1beta1.NamespacesApiserversourcesServicez;Service class for the namespaces_apiserversources resource.r   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r   r   r=   r>   s     r7   r   z>AnthoseventsV1beta1.NamespacesApiserversourcesService.__init__   s$    AA4QRXYdr8   c                 L    | j                  d      }| j                  |||      S )a  Creates a new apiserversource.

      Args:
        request: (AnthoseventsNamespacesApiserversourcesCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ApiServerSource) The response message.
      CreaterB   rD   rG   s       r7   r|   z<AnthoseventsV1beta1.NamespacesApiserversourcesService.Create   1     ##H-f__
'  8 8r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NKapis/sources.knative.dev/v1beta1/namespaces/{namespacesId}/apiserversourcesPOSTz/anthosevents.namespaces.apiserversources.createrS   ;apis/sources.knative.dev/v1beta1/{+parent}/apiserversourcesapiServerSource3AnthoseventsNamespacesApiserversourcesCreateRequestApiServerSourceF	flat_pathrZ   r[   r\   r]   r^   r_   r`   ra   rb   rc   rd   rf   r8   r7   rg   z>AnthoseventsV1beta1.NamespacesApiserversourcesService.<lambda>   s4    8#9#9_C zJS'O,$r8   c                 L    | j                  d      }| j                  |||      S )a  Rpc to delete a apiserversource.

      Args:
        request: (AnthoseventsNamespacesApiserversourcesDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      DeleterB   rD   rG   s       r7   r   z<AnthoseventsV1beta1.NamespacesApiserversourcesService.Delete   r}   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )N`apis/sources.knative.dev/v1beta1/namespaces/{namespacesId}/apiserversources/{apiserversourcesId}DELETEz/anthosevents.namespaces.apiserversources.deletename
apiVersionkindpropagationPolicy(apis/sources.knative.dev/v1beta1/{+name}rV   3AnthoseventsNamespacesApiserversourcesDeleteRequestEmptyFr   rd   rf   r8   r7   rg   z>AnthoseventsV1beta1.NamespacesApiserversourcesService.<lambda>   s4    8#9#9tCxH@@O"$r8   c                 L    | j                  d      }| j                  |||      S )a%  Rpc to get information about a apiserversource.

      Args:
        request: (AnthoseventsNamespacesApiserversourcesGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ApiServerSource) The response message.
      GetrB   rD   rG   s       r7   r   z9AnthoseventsV1beta1.NamespacesApiserversourcesService.Get   1     ##E*f__
'  8 8r8   c                  H    t        j                  ddddgdgdgdddd	d
      S )Nr   rL   z,anthosevents.namespaces.apiserversources.getr   regionr   rV   0AnthoseventsNamespacesApiserversourcesGetRequestr   Fr   rd   rf   r8   r7   rg   z>AnthoseventsV1beta1.NamespacesApiserversourcesService.<lambda>   s6     6 6t@xHZ@L,!r8   c                 L    | j                  d      }| j                  |||      S )a!  Rpc to list apiserversources.

      Args:
        request: (AnthoseventsNamespacesApiserversourcesListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListApiServerSourcesResponse) The response message.
      rA   rB   rD   rG   s       r7   rA   z:AnthoseventsV1beta1.NamespacesApiserversourcesService.List   rJ   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr   rL   z-anthosevents.namespaces.apiserversources.listrS   rN   rO   rP   rQ   rR   rT   rU   r   rV   1AnthoseventsNamespacesApiserversourcesListRequestListApiServerSourcesResponseFr   rd   rf   r8   r7   rg   z>AnthoseventsV1beta1.NamespacesApiserversourcesService.<lambda>   s7    !7!7_A zJ BSM9"r8   c                 L    | j                  d      }| j                  |||      S )a5  Rpc to replace a apiserversource. 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: (AnthoseventsNamespacesApiserversourcesReplaceApiServerSourceRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ApiServerSource) The response message.
      ReplaceApiServerSourcerB   rD   rG   s       r7   r   zLAnthoseventsV1beta1.NamespacesApiserversourcesService.ReplaceApiServerSource   s2     ##$<=f__
'  8 8r8   c                  H    t        j                  ddddgdgdgdddd	d
      S )Nr   PUTz?anthosevents.namespaces.apiserversources.replaceApiServerSourcer   r   r   r   CAnthoseventsNamespacesApiserversourcesReplaceApiServerSourceRequestr   Fr   rd   rf   r8   r7   rg   z>AnthoseventsV1beta1.NamespacesApiserversourcesService.<lambda>  s6    83I3ItSxHZ@'_,4r8   r<   )ri   rj   rk   rl   rm   r   r|   rn   r   r   rA   r   ro   rp   s   @r7   r   ry      s_    E)E
8F8F8C8D8,((r8   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 ),AnthoseventsV1beta1.NamespacesBrokersServicez2Service class for the namespaces_brokers resource.r!   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r    r   r=   r>   s     r7   r   z5AnthoseventsV1beta1.NamespacesBrokersService.__init__  s#    88$HPdr8   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|   rB   rD   rG   s       r7   r|   z3AnthoseventsV1beta1.NamespacesBrokersService.Create  r}   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NCapis/eventing.knative.dev/v1beta1/namespaces/{namespacesId}/brokersr   z&anthosevents.namespaces.brokers.createrS   3apis/eventing.knative.dev/v1beta1/{+parent}/brokersbroker*AnthoseventsNamespacesBrokersCreateRequestBrokerFr   rd   rf   r8   r7   rg   z5AnthoseventsV1beta1.NamespacesBrokersService.<lambda>(  s4    8#9#9W: zJKF#$r8   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   rB   rD   rG   s       r7   r   z3AnthoseventsV1beta1.NamespacesBrokersService.Delete6  r}   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NOapis/eventing.knative.dev/v1beta1/namespaces/{namespacesId}/brokers/{brokersId}r   z&anthosevents.namespaces.brokers.deleter   )apis/eventing.knative.dev/v1beta1/{+name}rV   *AnthoseventsNamespacesBrokersDeleteRequestr   Fr   rd   rf   r8   r7   rg   z5AnthoseventsV1beta1.NamespacesBrokersService.<lambda>C  s4    8#9#9c:xHAF"$r8   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   rB   rD   rG   s       r7   r   z0AnthoseventsV1beta1.NamespacesBrokersService.GetQ  r   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   rL   z#anthosevents.namespaces.brokers.getr   r   rV   'AnthoseventsNamespacesBrokersGetRequestr   Fr   rd   rf   r8   r7   rg   z5AnthoseventsV1beta1.NamespacesBrokersService.<lambda>^  s4     6 6c7xHAC#!r8   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.
      rA   rB   rD   rG   s       r7   rA   z1AnthoseventsV1beta1.NamespacesBrokersService.Listl  rJ   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr   rL   z$anthosevents.namespaces.brokers.listrS   r   r   rV   (AnthoseventsNamespacesBrokersListRequestrX   Fr   rd   rf   r8   r7   rg   z5AnthoseventsV1beta1.NamespacesBrokersService.<lambda>y  s7    !7!7W8 zJ BKD0"r8   r<   )ri   rj   rk   rl   rm   r   r|   rn   r   r   rA   ro   rp   s   @r7   r    r     sO    < E
8F8F8C8Dr8   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 ):AnthoseventsV1beta1.NamespacesCloudauditlogssourcesServicez@Service class for the namespaces_cloudauditlogssources resource.r#   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r"   r   r=   r>   s     r7   r   zCAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.__init__  $    FFVW]^dr8   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|   rB   rD   rG   s       r7   r|   zAAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.Create  r}   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NTapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudauditlogssourcesr   z4anthosevents.namespaces.cloudauditlogssources.createrS   Dapis/events.cloud.google.com/v1beta1/{+parent}/cloudauditlogssourcescloudAuditLogsSource8AnthoseventsNamespacesCloudauditlogssourcesCreateRequestCloudAuditLogsSourceFr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.<lambda>  4    8#9#9hH zJ\,T1$r8   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   rB   rD   rG   s       r7   r   zAAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.Delete  r}   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nnapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudauditlogssources/{cloudauditlogssourcesId}r   z4anthosevents.namespaces.cloudauditlogssources.deleter   r   ,apis/events.cloud.google.com/v1beta1/{+name}rV   8AnthoseventsNamespacesCloudauditlogssourcesDeleteRequestr   Fr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.<lambda>  7    8#9#9 CHxH@DT"$r8   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   rB   rD   rG   s       r7   r   z>AnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.Get  r   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   rL   z1anthosevents.namespaces.cloudauditlogssources.getr   r   rV   5AnthoseventsNamespacesCloudauditlogssourcesGetRequestr   Fr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.<lambda>  7     6 6 CExHDQ1!r8   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.
      rA   rB   rD   rG   s       r7   rA   z?AnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.List  rJ   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr   rL   z2anthosevents.namespaces.cloudauditlogssources.listrS   r   r   rV   6AnthoseventsNamespacesCloudauditlogssourcesListRequest!ListCloudAuditLogsSourcesResponseFr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.<lambda>  7    !7!7hF zJ B\R>"r8   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.
      ReplaceCloudAuditLogsSourcerB   rD   rG   s       r7   r   zVAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.ReplaceCloudAuditLogsSource  2     ##$ABf__
'  8 8r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   zIanthosevents.namespaces.cloudauditlogssources.replaceCloudAuditLogsSourcer   r   r   MAnthoseventsNamespacesCloudauditlogssourcesReplaceCloudAuditLogsSourceRequestr   Fr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.<lambda>
  7    8N8N C]xHD,i19r8   r<   )ri   rj   rk   rl   rm   r   r|   rn   r   r   rA   r   ro   rp   s   @r7   r"   r     _    J.E
8F8F8C8D81--r8   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 )7AnthoseventsV1beta1.NamespacesCloudpubsubsourcesServicez=Service class for the namespaces_cloudpubsubsources resource.r%   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r$   r   r=   r>   s     r7   r   z@AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.__init__  s$    CCTSTZ[dr8   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|   rB   rD   rG   s       r7   r|   z>AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.Create"  r}   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NQapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudpubsubsourcesr   z1anthosevents.namespaces.cloudpubsubsources.createrS   Aapis/events.cloud.google.com/v1beta1/{+parent}/cloudpubsubsourcescloudPubSubSource5AnthoseventsNamespacesCloudpubsubsourcesCreateRequestCloudPubSubSourceFr   rd   rf   r8   r7   rg   z@AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.<lambda>/  s4    8#9#9eE zJY)Q.$r8   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   rB   rD   rG   s       r7   r   z>AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.Delete=  r}   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nhapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudpubsubsources/{cloudpubsubsourcesId}r   z1anthosevents.namespaces.cloudpubsubsources.deleter   r   r   rV   5AnthoseventsNamespacesCloudpubsubsourcesDeleteRequestr   Fr   rd   rf   r8   r7   rg   z@AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.<lambda>J  s4    8#9#9|ExH@DQ"$r8   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   rB   rD   rG   s       r7   r   z;AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.GetX  r   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   rL   z.anthosevents.namespaces.cloudpubsubsources.getr   r   rV   2AnthoseventsNamespacesCloudpubsubsourcesGetRequestr   Fr   rd   rf   r8   r7   rg   z@AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.<lambda>e  s4     6 6|BxHDN.!r8   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.
      rA   rB   rD   rG   s       r7   rA   z<AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.Lists  rJ   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr   rL   z/anthosevents.namespaces.cloudpubsubsources.listrS   r   r   rV   3AnthoseventsNamespacesCloudpubsubsourcesListRequestListCloudPubSubSourcesResponseFr   rd   rf   r8   r7   rg   z@AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.<lambda>  s7    !7!7eC zJ BYO;"r8   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.
      ReplaceCloudPubSubSourcerB   rD   rG   s       r7   r   zPAnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.ReplaceCloudPubSubSource  s2     ##$>?f__
'  8 8r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   zCanthosevents.namespaces.cloudpubsubsources.replaceCloudPubSubSourcer   r   r   GAnthoseventsNamespacesCloudpubsubsourcesReplaceCloudPubSubSourceRequestr   Fr   rd   rf   r8   r7   rg   z@AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.<lambda>  s4    X5K5K|WxHD)c.6r8   r<   )ri   rj   rk   rl   rm   r   r|   rn   r   r   rA   r   ro   rp   s   @r7   r$   r     s_    G+E
8F8F8C8D8.**r8   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 ):AnthoseventsV1beta1.NamespacesCloudschedulersourcesServicez@Service class for the namespaces_cloudschedulersources resource.r'   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r&   r   r=   r>   s     r7   r   zCAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.__init__  r   r8   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|   rB   rD   rG   s       r7   r|   zAAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.Create  r}   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NTapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudschedulersourcesr   z4anthosevents.namespaces.cloudschedulersources.createrS   Dapis/events.cloud.google.com/v1beta1/{+parent}/cloudschedulersourcescloudSchedulerSource8AnthoseventsNamespacesCloudschedulersourcesCreateRequestCloudSchedulerSourceFr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.<lambda>  r   r8   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   rB   rD   rG   s       r7   r   zAAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.Delete  r}   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nnapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudschedulersources/{cloudschedulersourcesId}r   z4anthosevents.namespaces.cloudschedulersources.deleter   r   r   rV   8AnthoseventsNamespacesCloudschedulersourcesDeleteRequestr   Fr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.<lambda>  r   r8   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   rB   rD   rG   s       r7   r   z>AnthoseventsV1beta1.NamespacesCloudschedulersourcesService.Get  r   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   rL   z1anthosevents.namespaces.cloudschedulersources.getr   r   rV   5AnthoseventsNamespacesCloudschedulersourcesGetRequestr   Fr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.<lambda>  r   r8   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.
      rA   rB   rD   rG   s       r7   rA   z?AnthoseventsV1beta1.NamespacesCloudschedulersourcesService.List  rJ   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr   rL   z2anthosevents.namespaces.cloudschedulersources.listrS   r   r   rV   6AnthoseventsNamespacesCloudschedulersourcesListRequest!ListCloudSchedulerSourcesResponseFr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.<lambda>  r   r8   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.
      ReplaceCloudSchedulerSourcerB   rD   rG   s       r7   r
  zVAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.ReplaceCloudSchedulerSource  r   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r   zIanthosevents.namespaces.cloudschedulersources.replaceCloudSchedulerSourcer   r   r   MAnthoseventsNamespacesCloudschedulersourcesReplaceCloudSchedulerSourceRequestr   Fr   rd   rf   r8   r7   rg   zCAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.<lambda>,  r   r8   r<   )ri   rj   rk   rl   rm   r   r|   rn   r   r   rA   r
  ro   rp   s   @r7   r&   r     r   r8   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 )8AnthoseventsV1beta1.NamespacesCloudstoragesourcesServicez>Service class for the namespaces_cloudstoragesources resource.r)   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r(   r   r=   r>   s     r7   r   zAAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.__init__?  s$    DDdTU[\dr8   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|   rB   rD   rG   s       r7   r|   z?AnthoseventsV1beta1.NamespacesCloudstoragesourcesService.CreateD  r}   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NRapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudstoragesourcesr   z2anthosevents.namespaces.cloudstoragesources.createrS   Bapis/events.cloud.google.com/v1beta1/{+parent}/cloudstoragesourcescloudStorageSource6AnthoseventsNamespacesCloudstoragesourcesCreateRequestCloudStorageSourceFr   rd   rf   r8   r7   rg   zAAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.<lambda>Q  s4    8#9#9fF zJZ*R/$r8   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   rB   rD   rG   s       r7   r   z?AnthoseventsV1beta1.NamespacesCloudstoragesourcesService.Delete_  r}   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Njapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudstoragesources/{cloudstoragesourcesId}r   z2anthosevents.namespaces.cloudstoragesources.deleter   r   r   rV   6AnthoseventsNamespacesCloudstoragesourcesDeleteRequestr   Fr   rd   rf   r8   r7   rg   zAAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.<lambda>l  s4    8#9#9~FxH@DR"$r8   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   rB   rD   rG   s       r7   r   z<AnthoseventsV1beta1.NamespacesCloudstoragesourcesService.Getz  r   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  rL   z/anthosevents.namespaces.cloudstoragesources.getr   r   rV   3AnthoseventsNamespacesCloudstoragesourcesGetRequestr  Fr   rd   rf   r8   r7   rg   zAAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.<lambda>  s4     6 6~CxHDO/!r8   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.
      rA   rB   rD   rG   s       r7   rA   z=AnthoseventsV1beta1.NamespacesCloudstoragesourcesService.List  rJ   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr  rL   z0anthosevents.namespaces.cloudstoragesources.listrS   r   r  rV   4AnthoseventsNamespacesCloudstoragesourcesListRequestListCloudStorageSourcesResponseFr   rd   rf   r8   r7   rg   zAAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.<lambda>  s7    !7!7fD zJ BZP<"r8   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.
      ReplaceCloudStorageSourcerB   rD   rG   s       r7   r#  zRAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.ReplaceCloudStorageSource  s2     ##$?@f__
'  8 8r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr  r   zEanthosevents.namespaces.cloudstoragesources.replaceCloudStorageSourcer   r   r  IAnthoseventsNamespacesCloudstoragesourcesReplaceCloudStorageSourceRequestr  Fr   rd   rf   r8   r7   rg   zAAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.<lambda>  s4    h6L6L~YxHD*e/7r8   r<   )ri   rj   rk   rl   rm   r   r|   rn   r   r   rA   r#  ro   rp   s   @r7   r(   r  :  s_    H,E
8F8F8C8D8/++r8   r(   c                   >     e Zd ZdZdZ fdZddZd e_         xZS )>AnthoseventsV1beta1.NamespacesCustomresourcedefinitionsServicezDService class for the namespaces_customresourcedefinitions resource.r+   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r*   r   r=   r>   s     r7   r   zGAnthoseventsV1beta1.NamespacesCustomresourcedefinitionsService.__init__  s$    JJDZ[abdr8   c                 L    | j                  d      }| j                  |||      S )a@  Rpc to get information about a CustomResourceDefinition.

      Args:
        request: (AnthoseventsNamespacesCustomresourcedefinitionsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (CustomResourceDefinition) The response message.
      r   rB   rD   rG   s       r7   r   zBAnthoseventsV1beta1.NamespacesCustomresourcedefinitionsService.Get  r   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nzsapis/apiextensions.k8s.io/v1beta1/namespaces/{namespacesId}/customresourcedefinitions/{customresourcedefinitionsId}rL   z5anthosevents.namespaces.customresourcedefinitions.getr   z)apis/apiextensions.k8s.io/v1beta1/{+name}rV   9AnthoseventsNamespacesCustomresourcedefinitionsGetRequestCustomResourceDefinitionFr   rd   rf   r8   r7   rg   zGAnthoseventsV1beta1.NamespacesCustomresourcedefinitionsService.<lambda>  s7     6 6 HIxHAU5!r8   r<   )	ri   rj   rk   rl   rm   r   r   rn   ro   rp   s   @r7   r*   r'    s"    N2E
8Cr8   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 )0AnthoseventsV1beta1.NamespacesPingsourcesServicez6Service class for the namespaces_pingsources resource.r-   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r,   r   r=   r>   s     r7   r   z9AnthoseventsV1beta1.NamespacesPingsourcesService.__init__  s#    <<dLVTdr8   c                 L    | j                  d      }| j                  |||      S )a  Creates a new pingsource.

      Args:
        request: (AnthoseventsNamespacesPingsourcesCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (PingSource) The response message.
      r|   rB   rD   rG   s       r7   r|   z7AnthoseventsV1beta1.NamespacesPingsourcesService.Create  r}   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NFapis/sources.knative.dev/v1beta1/namespaces/{namespacesId}/pingsourcesr   z*anthosevents.namespaces.pingsources.createrS   6apis/sources.knative.dev/v1beta1/{+parent}/pingsources
pingSource.AnthoseventsNamespacesPingsourcesCreateRequest
PingSourceFr   rd   rf   r8   r7   rg   z9AnthoseventsV1beta1.NamespacesPingsourcesService.<lambda>  s4    8#9#9Z> zJN"J'$r8   c                 L    | j                  d      }| j                  |||      S )a  Rpc to delete a pingsource.

      Args:
        request: (AnthoseventsNamespacesPingsourcesDeleteRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Empty) The response message.
      r   rB   rD   rG   s       r7   r   z7AnthoseventsV1beta1.NamespacesPingsourcesService.Delete  r}   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )NVapis/sources.knative.dev/v1beta1/namespaces/{namespacesId}/pingsources/{pingsourcesId}r   z*anthosevents.namespaces.pingsources.deleter   r   r   rV   .AnthoseventsNamespacesPingsourcesDeleteRequestr   Fr   rd   rf   r8   r7   rg   z9AnthoseventsV1beta1.NamespacesPingsourcesService.<lambda>"  s4    8#9#9j>xH@@J"$r8   c                 L    | j                  d      }| j                  |||      S )a  Rpc to get information about a pingsource.

      Args:
        request: (AnthoseventsNamespacesPingsourcesGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (PingSource) The response message.
      r   rB   rD   rG   s       r7   r   z4AnthoseventsV1beta1.NamespacesPingsourcesService.Get0  r   r8   c                  H    t        j                  ddddgdgdgdddd	d
      S )Nr9  rL   z'anthosevents.namespaces.pingsources.getr   r   r   rV   +AnthoseventsNamespacesPingsourcesGetRequestr6  Fr   rd   rf   r8   r7   rg   z9AnthoseventsV1beta1.NamespacesPingsourcesService.<lambda>=  s6     6 6j;xHZ@G'!r8   c                 L    | j                  d      }| j                  |||      S )a  Rpc to list pingsources.

      Args:
        request: (AnthoseventsNamespacesPingsourcesListRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (ListPingSourcesResponse) The response message.
      rA   rB   rD   rG   s       r7   rA   z5AnthoseventsV1beta1.NamespacesPingsourcesService.ListK  rJ   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr2  rL   z(anthosevents.namespaces.pingsources.listrS   r   r3  rV   ,AnthoseventsNamespacesPingsourcesListRequestListPingSourcesResponseFr   rd   rf   r8   r7   rg   z9AnthoseventsV1beta1.NamespacesPingsourcesService.<lambda>X  s7    !7!7Z< zJ BNH4"r8   c                 L    | j                  d      }| j                  |||      S )a!  Rpc to replace a pingsource. 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: (AnthoseventsNamespacesPingsourcesReplacePingSourceRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (PingSource) The response message.
      ReplacePingSourcerB   rD   rG   s       r7   rC  zBAnthoseventsV1beta1.NamespacesPingsourcesService.ReplacePingSourcef  s2     ##$78f__
'  8 8r8   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr9  r   z5anthosevents.namespaces.pingsources.replacePingSourcer   r   r4  9AnthoseventsNamespacesPingsourcesReplacePingSourceRequestr6  Fr   rd   rf   r8   r7   rg   z9AnthoseventsV1beta1.NamespacesPingsourcesService.<lambda>s  s4    h.D.DjIxH@"U'/r8   r<   )ri   rj   rk   rl   rm   r   r|   rn   r   r   rA   rC  ro   rp   s   @r7   r,   r.    s_    @$E
8F8F8C8D8'##r8   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 )-AnthoseventsV1beta1.NamespacesTriggersServicez3Service class for the namespaces_triggers resource.r/   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r.   r   r=   r>   s     r7   r   z6AnthoseventsV1beta1.NamespacesTriggersService.__init__  s#    994I&Qdr8   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|   rB   rD   rG   s       r7   r|   z4AnthoseventsV1beta1.NamespacesTriggersService.Create  r}   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NDapis/eventing.knative.dev/v1beta1/namespaces/{namespacesId}/triggersr   z'anthosevents.namespaces.triggers.createrS   4apis/eventing.knative.dev/v1beta1/{+parent}/triggerstrigger+AnthoseventsNamespacesTriggersCreateRequestTriggerFr   rd   rf   r8   r7   rg   z6AnthoseventsV1beta1.NamespacesTriggersService.<lambda>  s4    8#9#9X; zJLG$$r8   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   rB   rD   rG   s       r7   r   z4AnthoseventsV1beta1.NamespacesTriggersService.Delete  r}   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )NQapis/eventing.knative.dev/v1beta1/namespaces/{namespacesId}/triggers/{triggersId}r   z'anthosevents.namespaces.triggers.deleter   r   r   rV   +AnthoseventsNamespacesTriggersDeleteRequestr   Fr   rd   rf   r8   r7   rg   z6AnthoseventsV1beta1.NamespacesTriggersService.<lambda>  s4    8#9#9e;xH@AG"$r8   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   rB   rD   rG   s       r7   r   z1AnthoseventsV1beta1.NamespacesTriggersService.Get  r   r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NrR  rL   z$anthosevents.namespaces.triggers.getr   r   rV   (AnthoseventsNamespacesTriggersGetRequestrO  Fr   rd   rf   r8   r7   rg   z6AnthoseventsV1beta1.NamespacesTriggersService.<lambda>  s4     6 6e8xHAD$!r8   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.
      rA   rB   rD   rG   s       r7   rA   z2AnthoseventsV1beta1.NamespacesTriggersService.List  rJ   r8   c                  J    t        j                  ddddgdgg ddddd	d
      S )NrK  rL   z%anthosevents.namespaces.triggers.listrS   r   rL  rV   )AnthoseventsNamespacesTriggersListRequestListTriggersResponseFr   rd   rf   r8   r7   rg   z6AnthoseventsV1beta1.NamespacesTriggersService.<lambda>  s7    !7!7X9 zJ BLE1"r8   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.
      ReplaceTriggerrB   rD   rG   s       r7   r\  z<AnthoseventsV1beta1.NamespacesTriggersService.ReplaceTrigger  s2     ##$45f__
'  8 8r8   c                  F    t        j                  ddddgdgg ddddd	
      S )NrR  r   z/anthosevents.namespaces.triggers.replaceTriggerr   r   rM  3AnthoseventsNamespacesTriggersReplaceTriggerRequestrO  Fr   rd   rf   r8   r7   rg   z6AnthoseventsV1beta1.NamespacesTriggersService.<lambda>  s4    8+A+AeCxHAO$,r8   r<   )ri   rj   rk   rl   rm   r   r|   rn   r   r   rA   r\  ro   rp   s   @r7   r.   rG    s^    =!E
8F8F8C8D8$N  r8   r.   c                   &     e Zd ZdZdZ fdZ xZS )%AnthoseventsV1beta1.NamespacesServicez*Service class for the namespaces resource.r1   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r0   r   r=   r>   s     r7   r   z.AnthoseventsV1beta1.NamespacesService.__init__  s#    114A&Idr8   )ri   rj   rk   rl   rm   r   ro   rp   s   @r7   r0   r`    s    4E r8   r0   c                   >     e Zd ZdZdZ fdZddZd e_         xZS )#AnthoseventsV1beta1.TriggersServicez(Service class for the triggers resource.r3   c                 N    t         t        j                  |   |       i | _        y r<   )r   r   r2   r   r=   r>   s     r7   r   z,AnthoseventsV1beta1.TriggersService.__init__!  s#    //?Gdr8   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.
      rA   rB   rD   rG   s       r7   rA   z(AnthoseventsV1beta1.TriggersService.List&  rJ   r8   c                  D    t        j                  ddg g g dddddd	
      S )
NrL   zanthosevents.triggers.listrM   z*apis/eventing.knative.dev/v1beta1/triggersrV   AnthoseventsTriggersListRequestrZ  FrY   rd   rf   r8   r7   rg   z,AnthoseventsV1beta1.TriggersService.<lambda>3  s0    !7!7. LB;1"r8   r<   rh   rp   s   @r7   r2   rc    s"    2E
8Dr8   r2   )rV   NTNNFFNNNN)"ri   rj   rk   rl   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   ro   rp   s   @r7   r   r   
   sd   J/3(=-(=>'(*"."+,,()-6:/4<@?C	/:"x.. "H")@)@ "HO(*A*A Ob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#83J3J #JOX%<%< ObO("9"9 Ob(11 "// " "r8   r   N)
rl   
__future__r   apitools.base.pyr   :googlecloudsdk.generated_clients.apis.anthosevents.v1beta1r   rh  BaseApiClientr   rf   r8   r7   <module>ry     s'    @ ' % pt(00 tr8   