SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r SS K J r SS K Jr "S S \ R5rSS jrSSSjjrSSjrSSjrSSjrg)z1Helper Classes for using gapic clients in gcloud.)absolute_import) annotations)division)unicode_literals)external_account) exceptions)requests)creds)storec\rSrSrSrSrg)MissingStoredCredentialsErrorz?Indicates stored credentials do not exist or are not available.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r%lib/googlecloudsdk/core/gapic_util.pyr r sGrr c^^[R"USS9m[R"T5(d [ S5eU(a[R "T5TlTRmUU4SjnUTlT$)aReturns a credential object for use by gapic client libraries. Currently, we set _quota_project on the credentials, unlike for http requests, which add quota project through request wrapping to implement go/gcloud-quota-model-v2. Additionally, we wrap the refresh method and plug in our own google.auth.transport.Request object that uses our transport. Args: enable_resource_quota: bool, By default, we are going to tell APIs to use the quota of the project being operated on. For some APIs we want to use gcloud's quota, so you can explicitly disable that behavior by passing False here. allow_account_impersonation: bool, True to allow use of impersonated service account credentials for calls made with this client. If False, the active user credentials will always be used. Returns: A google auth credentials.Credentials object. Raises: MissingStoredCredentialsError: If a google-auth credential cannot be loaded. T)allow_account_impersonationuse_google_authzUnable to load credentialsc>A[T[R5(aTR(agT"[R "55$)N) isinstancegoogle_auth_external_account Credentialsvalidr GoogleAuthRequest)request credentialsoriginal_refreshs rWrappedRefresh+GetGapicCredentials..WrappedRefreshJsA$00226A6G6G  H668 99r)r LoadIfEnabledr IsGoogleAuthCredentialsr GetQuotaProject_quota_project_idrefresh)enable_resource_quotarr$r"r#s @@rGetGapicCredentialsr,!ss6##"=+  & &{ 3 3 '(D EE$)$9$9+$FK! !((:'+ rNc.SSKJn URXX#S9$)aInitializes a BidiRpc instances. Args: client: GAPIC Wrapper client to use. start_rpc (grpc.StreamStreamMultiCallable): The gRPC method used to start the RPC. initial_request: The initial request to yield. This is useful if an initial request is needed to start the stream. metadata: The metadata headers to use for the RPC. It is a list of tuples. The first string in the tuple is the header name and the second is the header value. Returns: A bidiRPC instance. rgapic_util_internal)initial_requestmetadata)googlecloudsdk.corer/BidiRpc)client start_rpcr0r1r/s r MakeBidiRpcr6Xs$,6  $ $  % rcURS5nU(a URO URnU(aU"U5nU"U"XQS9S9$)aInstantiates a gapic REST client with gcloud defaults and configuration. Args: client_class: a gapic client class. credentials: google.auth.credentials.Credentials, the credentials to use. address_override_func: function, function to call to override the client host. It takes a single argument which is the original host. mtls_enabled: bool, True if mTLS is enabled for this client. _ Returns: A gapic API client. rest)hostr" transport)get_transport_classDEFAULT_MTLS_ENDPOINTDEFAULT_ENDPOINT) client_classr"address_override_func mtls_enabledtransport_classaddresss rMakeRestClientrDusM !44VL . .LDaDa'#G,G WF HHrc @SSKJn U"URUUUUUUUS9S9$)aInstantiates a gapic API client with gcloud defaults and configuration. grpc cannot be packaged like our other Python dependencies, due to platform differences and must be installed by the user. googlecloudsdk.core.gapic depends on grpc and must be imported lazily here so that this module can be imported safely anywhere. Args: client_class: a gapic client class. credentials: google.auth.credentials.Credentials, the credentials to use. address_override_func: function, function to call to override the client host. It takes a single argument which is the original host. mtls_enabled: bool, True if mTLS is enabled for this client. attempt_direct_path: bool, True if we want to attempt direct path gRPC where possible redact_request_body_reason: str, the reason why the request body must be redacted if --log-http is used. If None, the body is not redacted. custom_interceptors: list[grpc interceptor], a list of custom interceptors to add to the channel. Returns: A gapic API client. rr.)custom_interceptorsr:)r2r/ MakeTransport)r?r"r@rAattempt_direct_pathredact_request_body_reasonrFr/s r MakeClientrJs=B6 #11      $12  rc @SSKJn U"URUUUUU5S9$)aInstantiates a gapic API client with gcloud defaults and configuration. grpc cannot be packaged like our other Python dependencies, due to platform differences and must be installed by the user. googlecloudsdk.core.gapic depends on grpc and must be imported lazily here so that this module can be imported safely anywhere. Args: client_class: a gapic client class. credentials: google.auth.credentials.Credentials, the credentials to use. address_override_func: function, function to call to override the client host. It takes a single argument which is the original host. mtls_enabled: bool, True if mTLS is enabled for this client. attempt_direct_path: bool, True if we want to attempt direct path gRPC where possible Returns: A gapic API client. rr.r:)r2r/MakeAsyncTransport)r?r"r@rArHr/s rMakeAsyncClientrMs166 #66       r)TT)NN)r1zlist[tuple[str, str]] | None)NF)NFFNN)NFF)r __future__rrrr google.authrrr2rr googlecloudsdk.core.credentialsr r Errorr r,r6rDrJrMrrrrRs8&"'H*(11HJ$4$4H/3484t-1 + >*. %H6#-f %r