
                         V    S r SSKJr  SSKJr  SSKJr   " S S\R                  5      r	g)z:Generated client library for anthosevents version v1beta1.    )absolute_import)base_api)anthosevents_v1beta1_messagesc                     ^  \ rS rSrSr\rSrSrSr	S/r
SrSrS	rS
rS rSrSr     S(U 4S jjr " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S \R(                  5      r " S! S"\R(                  5      r " S# S$\R(                  5      r  " S% S&\R(                  5      r!S'r"U =r#$ ))AnthoseventsV1beta1
   zBGenerated 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                   > U=(       d    U R                   n[        [        U ]  XX4UXgUU	U
US9  U R	                  U 5      U l        U R                  U 5      U l        U R                  U 5      U l	        U R                  U 5      U l        U R                  U 5      U l        U R                  U 5      U l        U R!                  U 5      U l        U R%                  U 5      U l        U R)                  U 5      U l        U R-                  U 5      U l        U R1                  U 5      U l        U R5                  U 5      U l        U R9                  U 5      U l        g)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   AnthoseventsV1beta1.__init__   s:    
C	
t-'%)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                   J   ^  \ rS rSrSrSrU 4S jrSS jrS \l        Sr	U =r
$ )	"AnthoseventsV1beta1.BrokersService8   z'Service class for the brokers resource.r   c                 N   > [         [        R                  U ]  U5        0 U l        g N)r   r   r   r   _upload_configsr5   clientr7   s     r8   r   +AnthoseventsV1beta1.BrokersService.__init__=   s#    ..>vFdr:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc 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r5   requestrG   configs       r8   rE   'AnthoseventsV1beta1.BrokersService.ListB   /     ##F+f__
  8 8r:   c                  @    [         R                  " SS/ / / SQSSSSSS	9
$ )
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 r:   r8   <lambda>+AnthoseventsV1beta1.BrokersService.<lambda>O   s0    !7!7- LA:0"r:   r@   r?   __name__
__module____qualname____firstlineno____doc___NAMEr   rE   method_config__static_attributes____classcell__r7   s   @r8   r   r<   8   s"    1E
8Dr:   r   c                   J   ^  \ rS rSrSrSrU 4S jrSS jrS \l        Sr	U =r
$ )	4AnthoseventsV1beta1.CustomresourcedefinitionsService\   z9Service class for the customresourcedefinitions resource.r   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r   r   r@   rA   s     r8   r   =AnthoseventsV1beta1.CustomresourcedefinitionsService.__init__a   s$    @@$PQWXdr:   c                 D    U R                  S5      nU R                  X1US9$ )a  Rpc to list custom resource definitions.

Args:
  request: (AnthoseventsCustomresourcedefinitionsListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListCustomResourceDefinitionsResponse) The response message.
rE   rF   rH   rK   s       r8   rE   9AnthoseventsV1beta1.CustomresourcedefinitionsService.Listf   rO   r:   c                  @    [         R                  " SS/ / / SQSSSSSS	9
$ )
NrQ   z+anthosevents.customresourcedefinitions.listrR   z;apis/apiextensions.k8s.io/v1beta1/customresourcedefinitionsr[   0AnthoseventsCustomresourcedefinitionsListRequest%ListCustomResourceDefinitionsResponseFr^   ri   rk   r:   r8   rl   =AnthoseventsV1beta1.CustomresourcedefinitionsService.<lambda>s   s0    !7!7? LSLB"r:   rn   r?   ro   ry   s   @r8   r   r{   \   s"    C'E
8Dr:   r   c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SS jrS \l        SrU =r$ )5AnthoseventsV1beta1.NamespacesApiserversourcesService   z;Service class for the namespaces_apiserversources resource.r    c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r   r   r@   rA   s     r8   r   >AnthoseventsV1beta1.NamespacesApiserversourcesService.__init__   s$    AA4QRXYdr:   c                 D    U R                  S5      nU R                  X1US9$ )zCreates a new apiserversource.

Args:
  request: (AnthoseventsNamespacesApiserversourcesCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ApiServerSource) The response message.
CreaterF   rH   rK   s       r8   r   <AnthoseventsV1beta1.NamespacesApiserversourcesService.Create   /     ##H-f__
  8 8r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NKapis/sources.knative.dev/v1beta1/namespaces/{namespacesId}/apiserversourcesPOSTz/anthosevents.namespaces.apiserversources.createrX   ;apis/sources.knative.dev/v1beta1/{+parent}/apiserversourcesapiServerSource3AnthoseventsNamespacesApiserversourcesCreateRequestApiServerSourceF	flat_pathr_   r`   ra   rb   rc   rd   re   rf   rg   rh   ri   rk   r:   r8   rl   >AnthoseventsV1beta1.NamespacesApiserversourcesService.<lambda>   s4    8#9#9_C zJS'O,$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to delete a apiserversource.

Args:
  request: (AnthoseventsNamespacesApiserversourcesDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Empty) The response message.
DeleterF   rH   rK   s       r8   r   <AnthoseventsV1beta1.NamespacesApiserversourcesService.Delete   r   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )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}r[   3AnthoseventsNamespacesApiserversourcesDeleteRequestEmptyFr   ri   rk   r:   r8   rl   r      s4    8#9#9tCxH@@O"$r:   c                 D    U R                  S5      nU R                  X1US9$ )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.
GetrF   rH   rK   s       r8   r   9AnthoseventsV1beta1.NamespacesApiserversourcesService.Get   /     ##E*f__
  8 8r:   c                  D    [         R                  " SSSS/S/S/SSSS	S
S9$ )Nr   rQ   z,anthosevents.namespaces.apiserversources.getr   regionr   r[   0AnthoseventsNamespacesApiserversourcesGetRequestr   Fr   ri   rk   r:   r8   rl   r      s6     6 6t@xHZ@L,!r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to list apiserversources.

Args:
  request: (AnthoseventsNamespacesApiserversourcesListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListApiServerSourcesResponse) The response message.
rE   rF   rH   rK   s       r8   rE   :AnthoseventsV1beta1.NamespacesApiserversourcesService.List   rO   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nr   rQ   z-anthosevents.namespaces.apiserversources.listrX   rS   rT   rU   rV   rW   rY   rZ   r   r[   1AnthoseventsNamespacesApiserversourcesListRequestListApiServerSourcesResponseFr   ri   rk   r:   r8   rl   r      s7    !7!7_A zJ BSM9"r:   c                 D    U R                  S5      nU R                  X1US9$ )a  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.
ReplaceApiServerSourcerF   rH   rK   s       r8   r   LAnthoseventsV1beta1.NamespacesApiserversourcesService.ReplaceApiServerSource   s0     ##$<=f__
  8 8r:   c                  D    [         R                  " SSSS/S/S/SSSS	S
S9$ )Nr   PUTz?anthosevents.namespaces.apiserversources.replaceApiServerSourcer   r   r   r   CAnthoseventsNamespacesApiserversourcesReplaceApiServerSourceRequestr   Fr   ri   rk   r:   r8   rl   r     s6    83I3ItSxHZ@'_,4r:   rn   r?   )rp   rq   rr   rs   rt   ru   r   r   rv   r   r   rE   r   rw   rx   ry   s   @r8   r   r      s_    E)E
8F8F8C8D8,((r:   r   c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SrU =r$ ),AnthoseventsV1beta1.NamespacesBrokersServicei  z2Service class for the namespaces_brokers resource.r"   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r!   r   r@   rA   s     r8   r   5AnthoseventsV1beta1.NamespacesBrokersService.__init__  s#    88$HPdr:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to create a new broker.

Args:
  request: (AnthoseventsNamespacesBrokersCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Broker) The response message.
r   rF   rH   rK   s       r8   r   3AnthoseventsV1beta1.NamespacesBrokersService.Create  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NCapis/eventing.knative.dev/v1beta1/namespaces/{namespacesId}/brokersr   z&anthosevents.namespaces.brokers.createrX   3apis/eventing.knative.dev/v1beta1/{+parent}/brokersbroker*AnthoseventsNamespacesBrokersCreateRequestBrokerFr   ri   rk   r:   r8   rl   5AnthoseventsV1beta1.NamespacesBrokersService.<lambda>(  s4    8#9#9W: zJKF#$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to delete a broker.

Args:
  request: (AnthoseventsNamespacesBrokersDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Empty) The response message.
r   rF   rH   rK   s       r8   r   3AnthoseventsV1beta1.NamespacesBrokersService.Delete6  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NOapis/eventing.knative.dev/v1beta1/namespaces/{namespacesId}/brokers/{brokersId}r   z&anthosevents.namespaces.brokers.deleter   )apis/eventing.knative.dev/v1beta1/{+name}r[   *AnthoseventsNamespacesBrokersDeleteRequestr   Fr   ri   rk   r:   r8   rl   r   C  s4    8#9#9c:xHAF"$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to get information about a Broker.

Args:
  request: (AnthoseventsNamespacesBrokersGetRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Broker) The response message.
r   rF   rH   rK   s       r8   r   0AnthoseventsV1beta1.NamespacesBrokersService.GetQ  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr   rQ   z#anthosevents.namespaces.brokers.getr   r   r[   'AnthoseventsNamespacesBrokersGetRequestr   Fr   ri   rk   r:   r8   rl   r   ^  s4     6 6c7xHAC#!r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to list brokers.

Args:
  request: (AnthoseventsNamespacesBrokersListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListBrokersResponse) The response message.
rE   rF   rH   rK   s       r8   rE   1AnthoseventsV1beta1.NamespacesBrokersService.Listl  rO   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nr   rQ   z$anthosevents.namespaces.brokers.listrX   r   r   r[   (AnthoseventsNamespacesBrokersListRequestr]   Fr   ri   rk   r:   r8   rl   r   y  s7    !7!7W8 zJ BKD0"r:   rn   r?   )rp   rq   rr   rs   rt   ru   r   r   rv   r   r   rE   rw   rx   ry   s   @r8   r!   r     sO    < E
8F8F8C8Dr:   r!   c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SS jrS \l        SrU =r$ ):AnthoseventsV1beta1.NamespacesCloudauditlogssourcesServicei  z@Service class for the namespaces_cloudauditlogssources resource.r$   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r#   r   r@   rA   s     r8   r   CAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.__init__  $    FFVW]^dr:   c                 D    U R                  S5      nU R                  X1US9$ )a  Creates a new cloudauditlogssource.

Args:
  request: (AnthoseventsNamespacesCloudauditlogssourcesCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (CloudAuditLogsSource) The response message.
r   rF   rH   rK   s       r8   r   AAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.Create  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NTapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudauditlogssourcesr   z4anthosevents.namespaces.cloudauditlogssources.createrX   Dapis/events.cloud.google.com/v1beta1/{+parent}/cloudauditlogssourcescloudAuditLogsSource8AnthoseventsNamespacesCloudauditlogssourcesCreateRequestCloudAuditLogsSourceFr   ri   rk   r:   r8   rl   CAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.<lambda>  4    8#9#9hH zJ\,T1$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to delete a cloudauditlogssource.

Args:
  request: (AnthoseventsNamespacesCloudauditlogssourcesDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Empty) The response message.
r   rF   rH   rK   s       r8   r   AAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.Delete  r   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nnapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudauditlogssources/{cloudauditlogssourcesId}r   z4anthosevents.namespaces.cloudauditlogssources.deleter   r   ,apis/events.cloud.google.com/v1beta1/{+name}r[   8AnthoseventsNamespacesCloudauditlogssourcesDeleteRequestr   Fr   ri   rk   r:   r8   rl   r     7    8#9#9 CHxH@DT"$r:   c                 D    U R                  S5      nU R                  X1US9$ )a  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   rF   rH   rK   s       r8   r   >AnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.Get  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr   rQ   z1anthosevents.namespaces.cloudauditlogssources.getr   r   r[   5AnthoseventsNamespacesCloudauditlogssourcesGetRequestr   Fr   ri   rk   r:   r8   rl   r     7     6 6 CExHDQ1!r:   c                 D    U R                  S5      nU R                  X1US9$ )a  Rpc to list cloudauditlogssources.

Args:
  request: (AnthoseventsNamespacesCloudauditlogssourcesListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListCloudAuditLogsSourcesResponse) The response message.
rE   rF   rH   rK   s       r8   rE   ?AnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.List  rO   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nr   rQ   z2anthosevents.namespaces.cloudauditlogssources.listrX   r   r   r[   6AnthoseventsNamespacesCloudauditlogssourcesListRequest!ListCloudAuditLogsSourcesResponseFr   ri   rk   r:   r8   rl   r     7    !7!7hF zJ B\R>"r:   c                 D    U R                  S5      nU R                  X1US9$ )a%  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.
ReplaceCloudAuditLogsSourcerF   rH   rK   s       r8   r   VAnthoseventsV1beta1.NamespacesCloudauditlogssourcesService.ReplaceCloudAuditLogsSource  0     ##$ABf__
  8 8r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr   r   zIanthosevents.namespaces.cloudauditlogssources.replaceCloudAuditLogsSourcer   r   r   MAnthoseventsNamespacesCloudauditlogssourcesReplaceCloudAuditLogsSourceRequestr   Fr   ri   rk   r:   r8   rl   r   
  7    8N8N C]xHD,i19r:   rn   r?   )rp   rq   rr   rs   rt   ru   r   r   rv   r   r   rE   r   rw   rx   ry   s   @r8   r#   r     _    J.E
8F8F8C8D81--r:   r#   c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SS jrS \l        SrU =r$ )7AnthoseventsV1beta1.NamespacesCloudpubsubsourcesServicei  z=Service class for the namespaces_cloudpubsubsources resource.r&   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r%   r   r@   rA   s     r8   r   @AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.__init__  s$    CCTSTZ[dr:   c                 D    U R                  S5      nU R                  X1US9$ )zCreates a new cloudpubsubsource.

Args:
  request: (AnthoseventsNamespacesCloudpubsubsourcesCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (CloudPubSubSource) The response message.
r   rF   rH   rK   s       r8   r   >AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.Create"  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NQapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudpubsubsourcesr   z1anthosevents.namespaces.cloudpubsubsources.createrX   Aapis/events.cloud.google.com/v1beta1/{+parent}/cloudpubsubsourcescloudPubSubSource5AnthoseventsNamespacesCloudpubsubsourcesCreateRequestCloudPubSubSourceFr   ri   rk   r:   r8   rl   @AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.<lambda>/  s4    8#9#9eE zJY)Q.$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to delete a cloudpubsubsource.

Args:
  request: (AnthoseventsNamespacesCloudpubsubsourcesDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Empty) The response message.
r   rF   rH   rK   s       r8   r   >AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.Delete=  r   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nhapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudpubsubsources/{cloudpubsubsourcesId}r   z1anthosevents.namespaces.cloudpubsubsources.deleter   r   r   r[   5AnthoseventsNamespacesCloudpubsubsourcesDeleteRequestr   Fr   ri   rk   r:   r8   rl   r	  J  s4    8#9#9|ExH@DQ"$r:   c                 D    U R                  S5      nU R                  X1US9$ )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   rF   rH   rK   s       r8   r   ;AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.GetX  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr  rQ   z.anthosevents.namespaces.cloudpubsubsources.getr   r   r[   2AnthoseventsNamespacesCloudpubsubsourcesGetRequestr  Fr   ri   rk   r:   r8   rl   r	  e  s4     6 6|BxHDN.!r:   c                 D    U R                  S5      nU R                  X1US9$ )a  Rpc to list cloudpubsubsources.

Args:
  request: (AnthoseventsNamespacesCloudpubsubsourcesListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListCloudPubSubSourcesResponse) The response message.
rE   rF   rH   rK   s       r8   rE   <AnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.Lists  rO   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nr  rQ   z/anthosevents.namespaces.cloudpubsubsources.listrX   r   r  r[   3AnthoseventsNamespacesCloudpubsubsourcesListRequestListCloudPubSubSourcesResponseFr   ri   rk   r:   r8   rl   r	    s7    !7!7eC zJ BYO;"r:   c                 D    U R                  S5      nU R                  X1US9$ )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.
ReplaceCloudPubSubSourcerF   rH   rK   s       r8   r  PAnthoseventsV1beta1.NamespacesCloudpubsubsourcesService.ReplaceCloudPubSubSource  s0     ##$>?f__
  8 8r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr  r   zCanthosevents.namespaces.cloudpubsubsources.replaceCloudPubSubSourcer   r   r  GAnthoseventsNamespacesCloudpubsubsourcesReplaceCloudPubSubSourceRequestr  Fr   ri   rk   r:   r8   rl   r	    s4    X5K5K|WxHD)c.6r:   rn   r?   )rp   rq   rr   rs   rt   ru   r   r   rv   r   r   rE   r  rw   rx   ry   s   @r8   r%   r     s_    G+E
8F8F8C8D8.**r:   r%   c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SS jrS \l        SrU =r$ ):AnthoseventsV1beta1.NamespacesCloudschedulersourcesServicei  z@Service class for the namespaces_cloudschedulersources resource.r(   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r'   r   r@   rA   s     r8   r   CAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.__init__  r   r:   c                 D    U R                  S5      nU R                  X1US9$ )a  Creates a new cloudschedulersource.

Args:
  request: (AnthoseventsNamespacesCloudschedulersourcesCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (CloudSchedulerSource) The response message.
r   rF   rH   rK   s       r8   r   AAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.Create  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NTapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudschedulersourcesr   z4anthosevents.namespaces.cloudschedulersources.createrX   Dapis/events.cloud.google.com/v1beta1/{+parent}/cloudschedulersourcescloudSchedulerSource8AnthoseventsNamespacesCloudschedulersourcesCreateRequestCloudSchedulerSourceFr   ri   rk   r:   r8   rl   CAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.<lambda>  r   r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to delete a cloudschedulersource.

Args:
  request: (AnthoseventsNamespacesCloudschedulersourcesDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Empty) The response message.
r   rF   rH   rK   s       r8   r   AAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.Delete  r   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nnapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudschedulersources/{cloudschedulersourcesId}r   z4anthosevents.namespaces.cloudschedulersources.deleter   r   r   r[   8AnthoseventsNamespacesCloudschedulersourcesDeleteRequestr   Fr   ri   rk   r:   r8   rl   r)    r   r:   c                 D    U R                  S5      nU R                  X1US9$ )a  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   rF   rH   rK   s       r8   r   >AnthoseventsV1beta1.NamespacesCloudschedulersourcesService.Get  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr-  rQ   z1anthosevents.namespaces.cloudschedulersources.getr   r   r[   5AnthoseventsNamespacesCloudschedulersourcesGetRequestr(  Fr   ri   rk   r:   r8   rl   r)    r   r:   c                 D    U R                  S5      nU R                  X1US9$ )a  Rpc to list cloudschedulersources.

Args:
  request: (AnthoseventsNamespacesCloudschedulersourcesListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListCloudSchedulerSourcesResponse) The response message.
rE   rF   rH   rK   s       r8   rE   ?AnthoseventsV1beta1.NamespacesCloudschedulersourcesService.List  rO   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nr$  rQ   z2anthosevents.namespaces.cloudschedulersources.listrX   r   r%  r[   6AnthoseventsNamespacesCloudschedulersourcesListRequest!ListCloudSchedulerSourcesResponseFr   ri   rk   r:   r8   rl   r)    r   r:   c                 D    U R                  S5      nU R                  X1US9$ )a%  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.
ReplaceCloudSchedulerSourcerF   rH   rK   s       r8   r9  VAnthoseventsV1beta1.NamespacesCloudschedulersourcesService.ReplaceCloudSchedulerSource  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr-  r   zIanthosevents.namespaces.cloudschedulersources.replaceCloudSchedulerSourcer   r   r&  MAnthoseventsNamespacesCloudschedulersourcesReplaceCloudSchedulerSourceRequestr(  Fr   ri   rk   r:   r8   rl   r)  ,  r   r:   rn   r?   )rp   rq   rr   rs   rt   ru   r   r   rv   r   r   rE   r9  rw   rx   ry   s   @r8   r'   r    r   r:   r'   c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SS jrS \l        SrU =r$ )8AnthoseventsV1beta1.NamespacesCloudstoragesourcesServicei:  z>Service class for the namespaces_cloudstoragesources resource.r*   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r)   r   r@   rA   s     r8   r   AAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.__init__?  s$    DDdTU[\dr:   c                 D    U R                  S5      nU R                  X1US9$ )zCreates a new cloudstoragesource.

Args:
  request: (AnthoseventsNamespacesCloudstoragesourcesCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (CloudStorageSource) The response message.
r   rF   rH   rK   s       r8   r   ?AnthoseventsV1beta1.NamespacesCloudstoragesourcesService.CreateD  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NRapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudstoragesourcesr   z2anthosevents.namespaces.cloudstoragesources.createrX   Bapis/events.cloud.google.com/v1beta1/{+parent}/cloudstoragesourcescloudStorageSource6AnthoseventsNamespacesCloudstoragesourcesCreateRequestCloudStorageSourceFr   ri   rk   r:   r8   rl   AAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.<lambda>Q  s4    8#9#9fF zJZ*R/$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to delete a cloudstoragesource.

Args:
  request: (AnthoseventsNamespacesCloudstoragesourcesDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Empty) The response message.
r   rF   rH   rK   s       r8   r   ?AnthoseventsV1beta1.NamespacesCloudstoragesourcesService.Delete_  r   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Njapis/events.cloud.google.com/v1beta1/namespaces/{namespacesId}/cloudstoragesources/{cloudstoragesourcesId}r   z2anthosevents.namespaces.cloudstoragesources.deleter   r   r   r[   6AnthoseventsNamespacesCloudstoragesourcesDeleteRequestr   Fr   ri   rk   r:   r8   rl   rI  l  s4    8#9#9~FxH@DR"$r:   c                 D    U R                  S5      nU R                  X1US9$ )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   rF   rH   rK   s       r8   r   <AnthoseventsV1beta1.NamespacesCloudstoragesourcesService.Getz  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NrM  rQ   z/anthosevents.namespaces.cloudstoragesources.getr   r   r[   3AnthoseventsNamespacesCloudstoragesourcesGetRequestrH  Fr   ri   rk   r:   r8   rl   rI    s4     6 6~CxHDO/!r:   c                 D    U R                  S5      nU R                  X1US9$ )a  Rpc to list cloudstoragesources.

Args:
  request: (AnthoseventsNamespacesCloudstoragesourcesListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListCloudStorageSourcesResponse) The response message.
rE   rF   rH   rK   s       r8   rE   =AnthoseventsV1beta1.NamespacesCloudstoragesourcesService.List  rO   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )NrD  rQ   z0anthosevents.namespaces.cloudstoragesources.listrX   r   rE  r[   4AnthoseventsNamespacesCloudstoragesourcesListRequestListCloudStorageSourcesResponseFr   ri   rk   r:   r8   rl   rI    s7    !7!7fD zJ BZP<"r:   c                 D    U R                  S5      nU R                  X1US9$ )a  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.
ReplaceCloudStorageSourcerF   rH   rK   s       r8   rY  RAnthoseventsV1beta1.NamespacesCloudstoragesourcesService.ReplaceCloudStorageSource  s0     ##$?@f__
  8 8r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NrM  r   zEanthosevents.namespaces.cloudstoragesources.replaceCloudStorageSourcer   r   rF  IAnthoseventsNamespacesCloudstoragesourcesReplaceCloudStorageSourceRequestrH  Fr   ri   rk   r:   r8   rl   rI    s4    h6L6L~YxHD*e/7r:   rn   r?   )rp   rq   rr   rs   rt   ru   r   r   rv   r   r   rE   rY  rw   rx   ry   s   @r8   r)   r>  :  s_    H,E
8F8F8C8D8/++r:   r)   c                   J   ^  \ rS rSrSrSrU 4S jrSS jrS \l        Sr	U =r
$ )	>AnthoseventsV1beta1.NamespacesCustomresourcedefinitionsServicei  zDService class for the namespaces_customresourcedefinitions resource.r,   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r+   r   r@   rA   s     r8   r   GAnthoseventsV1beta1.NamespacesCustomresourcedefinitionsService.__init__  s$    JJDZ[abdr:   c                 D    U R                  S5      nU R                  X1US9$ )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   rF   rH   rK   s       r8   r   BAnthoseventsV1beta1.NamespacesCustomresourcedefinitionsService.Get  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nzsapis/apiextensions.k8s.io/v1beta1/namespaces/{namespacesId}/customresourcedefinitions/{customresourcedefinitionsId}rQ   z5anthosevents.namespaces.customresourcedefinitions.getr   z)apis/apiextensions.k8s.io/v1beta1/{+name}r[   9AnthoseventsNamespacesCustomresourcedefinitionsGetRequestCustomResourceDefinitionFr   ri   rk   r:   r8   rl   GAnthoseventsV1beta1.NamespacesCustomresourcedefinitionsService.<lambda>  s7     6 6 HIxHAU5!r:   rn   r?   )rp   rq   rr   rs   rt   ru   r   r   rv   rw   rx   ry   s   @r8   r+   r^    s"    N2E
8Cr:   r+   c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SS jrS \l        SrU =r$ )0AnthoseventsV1beta1.NamespacesPingsourcesServicei  z6Service class for the namespaces_pingsources resource.r.   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r-   r   r@   rA   s     r8   r   9AnthoseventsV1beta1.NamespacesPingsourcesService.__init__  s#    <<dLVTdr:   c                 D    U R                  S5      nU R                  X1US9$ )zCreates a new pingsource.

Args:
  request: (AnthoseventsNamespacesPingsourcesCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (PingSource) The response message.
r   rF   rH   rK   s       r8   r   7AnthoseventsV1beta1.NamespacesPingsourcesService.Create  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NFapis/sources.knative.dev/v1beta1/namespaces/{namespacesId}/pingsourcesr   z*anthosevents.namespaces.pingsources.createrX   6apis/sources.knative.dev/v1beta1/{+parent}/pingsources
pingSource.AnthoseventsNamespacesPingsourcesCreateRequest
PingSourceFr   ri   rk   r:   r8   rl   9AnthoseventsV1beta1.NamespacesPingsourcesService.<lambda>  s4    8#9#9Z> zJN"J'$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to delete a pingsource.

Args:
  request: (AnthoseventsNamespacesPingsourcesDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Empty) The response message.
r   rF   rH   rK   s       r8   r   7AnthoseventsV1beta1.NamespacesPingsourcesService.Delete  r   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )NVapis/sources.knative.dev/v1beta1/namespaces/{namespacesId}/pingsources/{pingsourcesId}r   z*anthosevents.namespaces.pingsources.deleter   r   r   r[   .AnthoseventsNamespacesPingsourcesDeleteRequestr   Fr   ri   rk   r:   r8   rl   rs  "  s4    8#9#9j>xH@@J"$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to get information about a pingsource.

Args:
  request: (AnthoseventsNamespacesPingsourcesGetRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (PingSource) The response message.
r   rF   rH   rK   s       r8   r   4AnthoseventsV1beta1.NamespacesPingsourcesService.Get0  r   r:   c                  D    [         R                  " SSSS/S/S/SSSS	S
S9$ )Nrw  rQ   z'anthosevents.namespaces.pingsources.getr   r   r   r[   +AnthoseventsNamespacesPingsourcesGetRequestrr  Fr   ri   rk   r:   r8   rl   rs  =  s6     6 6j;xHZ@G'!r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to list pingsources.

Args:
  request: (AnthoseventsNamespacesPingsourcesListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListPingSourcesResponse) The response message.
rE   rF   rH   rK   s       r8   rE   5AnthoseventsV1beta1.NamespacesPingsourcesService.ListK  rO   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nrn  rQ   z(anthosevents.namespaces.pingsources.listrX   r   ro  r[   ,AnthoseventsNamespacesPingsourcesListRequestListPingSourcesResponseFr   ri   rk   r:   r8   rl   rs  X  s7    !7!7Z< zJ BNH4"r:   c                 D    U R                  S5      nU R                  X1US9$ )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.
ReplacePingSourcerF   rH   rK   s       r8   r  BAnthoseventsV1beta1.NamespacesPingsourcesService.ReplacePingSourcef  s0     ##$78f__
  8 8r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nrw  r   z5anthosevents.namespaces.pingsources.replacePingSourcer   r   rp  9AnthoseventsNamespacesPingsourcesReplacePingSourceRequestrr  Fr   ri   rk   r:   r8   rl   rs  s  s4    h.D.DjIxH@"U'/r:   rn   r?   )rp   rq   rr   rs   rt   ru   r   r   rv   r   r   rE   r  rw   rx   ry   s   @r8   r-   rh    s_    @$E
8F8F8C8D8'##r:   r-   c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SS jrS \l        SrU =r$ )-AnthoseventsV1beta1.NamespacesTriggersServicei  z3Service class for the namespaces_triggers resource.r0   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r/   r   r@   rA   s     r8   r   6AnthoseventsV1beta1.NamespacesTriggersService.__init__  s#    994I&Qdr:   c                 D    U R                  S5      nU R                  X1US9$ )zCreates a new trigger.

Args:
  request: (AnthoseventsNamespacesTriggersCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Trigger) The response message.
r   rF   rH   rK   s       r8   r   4AnthoseventsV1beta1.NamespacesTriggersService.Create  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NDapis/eventing.knative.dev/v1beta1/namespaces/{namespacesId}/triggersr   z'anthosevents.namespaces.triggers.createrX   4apis/eventing.knative.dev/v1beta1/{+parent}/triggerstrigger+AnthoseventsNamespacesTriggersCreateRequestTriggerFr   ri   rk   r:   r8   rl   6AnthoseventsV1beta1.NamespacesTriggersService.<lambda>  s4    8#9#9X; zJLG$$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to delete a trigger.

Args:
  request: (AnthoseventsNamespacesTriggersDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Empty) The response message.
r   rF   rH   rK   s       r8   r   4AnthoseventsV1beta1.NamespacesTriggersService.Delete  r   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )NQapis/eventing.knative.dev/v1beta1/namespaces/{namespacesId}/triggers/{triggersId}r   z'anthosevents.namespaces.triggers.deleter   r   r   r[   +AnthoseventsNamespacesTriggersDeleteRequestr   Fr   ri   rk   r:   r8   rl   r    s4    8#9#9e;xH@AG"$r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to get information about a trigger.

Args:
  request: (AnthoseventsNamespacesTriggersGetRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Trigger) The response message.
r   rF   rH   rK   s       r8   r   1AnthoseventsV1beta1.NamespacesTriggersService.Get  r   r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr  rQ   z$anthosevents.namespaces.triggers.getr   r   r[   (AnthoseventsNamespacesTriggersGetRequestr  Fr   ri   rk   r:   r8   rl   r    s4     6 6e8xHAD$!r:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to list triggers.

Args:
  request: (AnthoseventsNamespacesTriggersListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListTriggersResponse) The response message.
rE   rF   rH   rK   s       r8   rE   2AnthoseventsV1beta1.NamespacesTriggersService.List  rO   r:   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nr  rQ   z%anthosevents.namespaces.triggers.listrX   r   r  r[   )AnthoseventsNamespacesTriggersListRequestListTriggersResponseFr   ri   rk   r:   r8   rl   r    s7    !7!7X9 zJ BLE1"r:   c                 D    U R                  S5      nU R                  X1US9$ )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.
ReplaceTriggerrF   rH   rK   s       r8   r  <AnthoseventsV1beta1.NamespacesTriggersService.ReplaceTrigger  s0     ##$45f__
  8 8r:   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr  r   z/anthosevents.namespaces.triggers.replaceTriggerr   r   r  3AnthoseventsNamespacesTriggersReplaceTriggerRequestr  Fr   ri   rk   r:   r8   rl   r    s4    8+A+AeCxHAO$,r:   rn   r?   )rp   rq   rr   rs   rt   ru   r   r   rv   r   r   rE   r  rw   rx   ry   s   @r8   r/   r    s^    =!E
8F8F8C8D8$N  r:   r/   c                   0   ^  \ rS rSrSrSrU 4S jrSrU =r$ )%AnthoseventsV1beta1.NamespacesServicei  z*Service class for the namespaces resource.r2   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r1   r   r@   rA   s     r8   r   .AnthoseventsV1beta1.NamespacesService.__init__  s#    114A&Idr:   rn   )	rp   rq   rr   rs   rt   ru   r   rw   rx   ry   s   @r8   r1   r    s    4E r:   r1   c                   J   ^  \ rS rSrSrSrU 4S jrSS jrS \l        Sr	U =r
$ )	#AnthoseventsV1beta1.TriggersServicei  z(Service class for the triggers resource.r4   c                 N   > [         [        R                  U ]  U5        0 U l        g r?   )r   r   r3   r   r@   rA   s     r8   r   ,AnthoseventsV1beta1.TriggersService.__init__!  s#    //?Gdr:   c                 D    U R                  S5      nU R                  X1US9$ )zRpc to list triggers in all namespaces.

Args:
  request: (AnthoseventsTriggersListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListTriggersResponse) The response message.
rE   rF   rH   rK   s       r8   rE   (AnthoseventsV1beta1.TriggersService.List&  rO   r:   c                  @    [         R                  " SS/ / / SQSSSSSS	9
$ )
NrQ   zanthosevents.triggers.listrR   z*apis/eventing.knative.dev/v1beta1/triggersr[   AnthoseventsTriggersListRequestr  Fr^   ri   rk   r:   r8   rl   ,AnthoseventsV1beta1.TriggersService.<lambda>3  s0    !7!7. LB;1"r:   rn   r?   ro   ry   s   @r8   r3   r    s"    2E
8Dr:   r3   )r   r   r2   r    r"   r$   r&   r(   r*   r,   r.   r0   r4   )r[   NTNNFFNNNN)$rp   rq   rr   rs   rt   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/   r1   r3   rw   rx   ry   s   @r8   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 "// " "r:   r   N)
rt   
__future__r   apitools.base.pyr   :googlecloudsdk.generated_clients.apis.anthosevents.v1beta1r   r  BaseApiClientr   rk   r:   r8   <module>r     s'    @ ' % pt(00 tr:   