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 W/var/www/html/CropPilot/venv/lib/python3.10/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. )_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)api_name stack_offsetmsgr r r_warn_experimentalCs r cstfdd}|S)Ncstjd|i|S)N)r r )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)request_streamingresponse_streaming_replacer+r-r/r1)wrapperhandlerr r rwrap_server_method_handlerXsr7PrivateKeySignOnCompletePrivateKeySignCancel)root_certificatesprivate_key_sign_fn'CustomPrivateKeySign'r:Optional[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_cygrpcSSLChannelCredentials)r;r:r>r r r*ssl_channel_credentials_with_custom_signers rF)rrrrrFr7)r0r.r,r*)r1r/r-r+)r;r<r:r=r>r?r@rA)+r __future__rcopyr'systypingrrrrrB grpc._cythonrrDsetrobjectr ExceptionrrCchannel_credentials_insecurerrWarningrr r)r7r9PrivateKeySignatureAlgorithmr?r8CustomPrivateKeySignrF__all__ version_infogrpc._simple_stubsr1r/r-r+r r r rsT       $