\jdZddlmZddlZddlZddlZddlmZmZm Z ddl Z ddl Z ddl m ZeZGddeZGdd eZe j*ej,Zd ZGd d eZd ZdZdZegdfZej>Zee e efgdfZ!ee edge e dffZ"edd ddZ#dZ$ejJdkDrddl&m'Z'ddl&m(Z(ddl&m)Z)ddl&m*Z*e$dz Z$yy)zbgRPC's experimental APIs. These APIs are subject to be removed during any minor version release. ) annotationsN)CallableOptionalUnion)cygrpcceZdZdZdZy)ChannelOptionszIndicates a channel option unique to gRPC Python. This enumeration is part of an EXPERIMENTAL API. Attributes: SingleThreadedUnaryStream: Perform unary-stream RPCs on a single thread. SingleThreadedUnaryStreamN)__name__ __module__ __qualname____doc__r D/root/env/lib/python3.12/site-packages/grpc/experimental/__init__.pyr r s!<rr ceZdZdZy) UsageErrorzDRaised by the gRPC library to indicate usage not allowed by the API.Nr r r rrrrrr,sNrrctS)zeCreates a ChannelCredentials for use with an insecure channel. THIS IS AN EXPERIMENTAL API. )_insecure_channel_credentialsrrrinsecure_channel_credentialsr7s )(rceZdZdZy)ExperimentalApiWarningz&A warning that an API is experimental.Nrrrrrr?s0rrc|tvrItj|dj|dz}tj|t d|zyy)Nz8'{}' is an experimental API. It is subject to change or z5removal between minor releases. Proceed with caution.) stacklevel)_EXPERIMENTAL_APIS_USEDaddformatwarningswarnr)api_name stack_offsetmsgs r_warn_experimentalr%CsX..##H- F M M F F  c1a,>NO/rcBtjfd}|S)Nc@tjd|i|S)N)r%r )argskwargsfs r_wrapperz"experimental_api.._wrapperPs!1::q)$!&!!r) functoolswraps)r+r,s` rexperimental_apir/Os%__Q"" Orc`|sy|jsP|js"|j||jS|j||jS|js"|j||j S|j||j S)aWraps the server method handler function. The server implementation requires all server handlers being wrapped as RpcMethodHandler objects. This helper function ease the pain of writing server handler wrappers. Args: wrapper: A wrapper function that takes in a method handler behavior (the actual function) and returns a wrapped function. handler: A RpcMethodHandler object to be wrapped. Returns: A newly created RpcMethodHandler. N unary_unary unary_stream stream_unary stream_stream)request_streamingresponse_streaming_replacer2r4r6r8)wrapperhandlers rwrap_server_method_handlerr>Xs   $ $))##8K8K0L#M MWW5I5I-JKK  % %WW5I5I-JKK   ''2G2G*H  IIrPrivateKeySignOnCompletePrivateKeySignCancel)root_certificatescXtjtj|d||S)aCreates a ChannelCredentials for use with an SSL-enabled Channel with a custom signer. THIS IS AN EXPERIMENTAL API. This API will be removed in a future version and combined with `grpc.ssl_channel_credentials`. Args: private_key_sign_fn: a function with the signature of `CustomPrivateKeySign`. This function can return synchronously or asynchronously. To return synchronously, return the signed bytes. To return asynchronously, return a callable matching the `PrivateKeySignCancel` signature.This can be a no-op if no cancellation is needed. In the async case, this function must return this callable quickly, then call the passed in `PrivateKeySignOnComplete` when the async signing operation is complete to trigger gRPC to continue the handshake. root_certificates: The PEM-encoded root certificates as a byte string, or None to retrieve them from a default location chosen by gRPC runtime. certificate_chain: The PEM-encoded certificate chain as a byte string to use Returns: A ChannelCredentials for use with an SSL-enabled Channel. N)grpcChannelCredentials_cygrpcSSLChannelCredentials)private_key_sign_fnrAcertificate_chains r*ssl_channel_credentials_with_custom_signerrIs0<  " "%% t%68K  r)r rrrrIr>)r7r5r3r1)r8r6r4r2)rGz'CustomPrivateKeySign'rAzOptional[bytes]rHbytesreturnzgrpc.ChannelCredentials)+r __future__rcopyr-systypingrrrr rC grpc._cythonrrEsetrobjectr ExceptionrrDchannel_credentials_insecurerrWarningrr%r/r>r@PrivateKeySignatureAlgorithmrLr?CustomPrivateKeySignrI__all__ version_infogrpc._simple_stubsr8r6r4r2rrrr]so#  ,, *%  D)&CC#U5)+;%<$=t$CD  $"  %' '( **.!/!'! !  !!H f0//. G r