XjdZddlmZddlZddlZddlZddlmZmZm Z ddl Z ddl Z ddl m ZeZGddeZGdd eZe jejZd ZGd d eZd ZdZdZegdfZejZee e efgdfZ!ee edge e dffZ"eddd#dZ#dZ$ej%dkrddl&m'Z'ddl&m(Z(dd l&m)Z)dd!l&m*Z*e$d"z Z$dSdS)$zbgRPC's experimental APIs. These APIs are subject to be removed during any minor version release. ) annotationsN)CallableOptionalUnion)cygrpcceZdZdZdZdS)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 W/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/grpc/experimental/__init__.pyr r s"!<rr ceZdZdZdS) UsageErrorzDRaised by the gRPC library to indicate usage not allowed by the API.Nr r r rrrrrr,sNNNNrrctS)zeCreates a ChannelCredentials for use with an insecure channel. THIS IS AN EXPERIMENTAL API. )_insecure_channel_credentialsrrrinsecure_channel_credentialsr7s )(rceZdZdZdS)ExperimentalApiWarningz&A warning that an API is experimental.Nrrrrrr?s0000rrc|tvrSt|d|dz}tj|t d|zdSdS)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%Csv...##H--- F M M  F F  c1a,>NOOOOOO/.rcFtjfd}|S)Nc>tjd|i|S)N)r%r )argskwargsfs r_wrapperz"experimental_api.._wrapperPs*1:q)))q$!&!!!r) functoolswraps)r+r,s` rexperimental_apir/Os8_Q""""" OrcT|sdS|jsO|js$|||jS|||jS|js$|||jS|||jS)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 t  $L) N##8K0L0L#MM MWWW5I-J-JKKK  %LWWW5I-J-JKKK   '''2G*H*H  I IIrPrivateKeySignOnCompletePrivateKeySignCancel)root_certificatesprivate_key_sign_fn'CustomPrivateKeySign'rAOptional[bytes]certificate_chainbytesreturngrpc.ChannelCredentialscTtjtj|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)rBrArEs r*ssl_channel_credentials_with_custom_signerrNs4<  "% t%68K    r)r rrrrNr>)r7r5r3r1)r8r6r4r2)rBrCrArDrErFrGrH)+r __future__rcopyr-systypingrrrr rJ grpc._cythonrrLsetrobjectr ExceptionrrKchannel_credentials_insecurerrWarningrr%r/r>r@PrivateKeySignatureAlgorithmrFr?CustomPrivateKeySignrN__all__ version_infogrpc._simple_stubsr8r6r4r2rrrr`s#"""""  ,,,,,,,,,, ******#%% < < < <  D)&C#U5)+;%<$=t$CD  $"  %' '( **.!!!!!!H f000000////////////...... GGG r