o = j@s`dZddlmZddlZddlZddlZddlmZmZm Z ddl Z ddl Z ddl m ZeZGdddeZGdd d eZe eZd d ZGd d d eZddZddZddZegdfZejZee e efgdfZ!ee edge e dffZ"eddd(dd Z#d!Z$ej%d"krdd#l&m'Z'dd$l&m(Z(dd%l&m)Z)dd&l&m*Z*e$d'7Z$dSdS))zbgRPC's experimental APIs. These APIs are subject to be removed during any minor version release. ) annotationsN)CallableOptionalUnion)cygrpcc@seZdZdZdZdS)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__rr r dC:\Users\psant\Downloads\Anu Raj Backend\school\venv\Lib\site-packages\grpc/experimental/__init__.pyr src@eZdZdZdS) UsageErrorzDRaised by the gRPC library to indicate usage not allowed by the API.Nr r r r r r r rr,rcCstS)zeCreates a ChannelCredentials for use with an insecure channel. THIS IS AN EXPERIMENTAL API. N)_insecure_channel_credentialsr r r rinsecure_channel_credentials7src@r)ExperimentalApiWarningz&A warning that an API is experimental.Nrr r r rr?rrcCs<|tvrt|d|d}tj|td|ddSdS)Nz8'{}' is an experimental API. It is subject to change or z5removal between minor releases. Proceed with caution.) stacklevel)_EXPERIMENTAL_APIS_USEDaddformatwarningswarnr)Zapi_nameZ stack_offsetmsgr r r_warn_experimentalCs rcstfdd}|S)Ncstjd|i|S)N)rr )argskwargsfr r_wrapperPs z"experimental_api.._wrapper) functoolswraps)r#r$r r"rexperimental_apiOsr'cCsb|sdS|js|js|j||jdS|j||jdS|js(|j||jdS|j||jdS)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)Zrequest_streamingZresponse_streaming_replacer)r+r-r/)wrapperhandlerr r rwrap_server_method_handlerXsr3PrivateKeySignOnCompletePrivateKeySignCancel)root_certificatesprivate_key_sign_fn'CustomPrivateKeySign'r6Optional[bytes]certificate_chainbytesreturngrpc.ChannelCredentialscCstt|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_cygrpcZSSLChannelCredentials)r7r6r:r r r*ssl_channel_credentials_with_custom_signers rA)rrrrrAr3)r.r,r*r()r/r-r+r))r7r8r6r9r:r;r<r=)+r __future__rcopyr%systypingrrrrr>Z grpc._cythonrr@setrobjectr Exceptionrr?Zchannel_credentials_insecurerrWarningrrr'r3r5ZPrivateKeySignatureAlgorithmr;r4ZCustomPrivateKeySignrA__all__ version_infoZgrpc._simple_stubsr/r-r+r)r r r rsT       $