a v=icCã@s¨dZddlZddlZddlZejZeje_ejZGdd„deƒZ ddd„Z ej Z ej ZejZGdd „d e ej¡ƒZGd d „d e ej¡ƒZGd d „d e ej¡ƒZdS)z8Constants and interfaces of the Beta API of gRPC Python.éNc@seZdZdZdd„ZdS)ÚGRPCCallOptionszñA value encapsulating gRPC-specific options passed on RPC invocation. This class and its instances have no supported interface - it exists to define the type of its instances and its instances exist to be passed to other functions. cCs||_||_||_dS)N)Údisable_compressionÚ subcall_ofÚ credentials)Úselfrrr©rúe/home/droni/.local/share/virtualenvs/DPS-5Je3_V2c/lib/python3.9/site-packages/grpc/beta/interfaces.pyÚ__init__$szGRPCCallOptions.__init__N)Ú__name__Ú __module__Ú __qualname__Ú__doc__r rrrrrsrFcCs t|d|ƒS)a†Creates a GRPCCallOptions value to be passed at RPC invocation. All parameters are optional and should always be passed by keyword. Args: disable_compression: A boolean indicating whether or not compression should be disabled for the request object of the RPC. Only valid for request-unary RPCs. credentials: A CallCredentials object to use for the invoked RPC. N)r)rrrrrÚgrpc_call_options*s rc@s,eZdZdZejdd„ƒZejdd„ƒZdS)ÚGRPCServicerContextzCExposes gRPC-specific options and behaviors to code servicing RPCs.cCs tƒ‚dS)z”Identifies the peer that invoked the RPC being serviced. Returns: A string identifying the peer that invoked the RPC being serviced. N©ÚNotImplementedError©rrrrÚpeer@szGRPCServicerContext.peercCs tƒ‚dS)zDDisables compression of the next response passed by the application.NrrrrrÚ!disable_next_response_compressionIsz5GRPCServicerContext.disable_next_response_compressionN)r r r r ÚabcÚabstractmethodrrrrrrr=s  rc@seZdZdZejdd„ƒZdS)ÚGRPCInvocationContextzBExposes gRPC-specific options and behaviors to code invoking RPCs.cCs tƒ‚dS)zCDisables compression of the next request passed by the application.NrrrrrÚ disable_next_request_compressionRsz6GRPCInvocationContext.disable_next_request_compressionN)r r r r rrrrrrrrOsrc@sHeZdZdZejdd„ƒZejdd„ƒZejdd„ƒZejdd „ƒZ d S) ÚServerzServices RPCs.cCs tƒ‚dS)aReserves a port for insecure RPC service once this Server becomes active. This method may only be called before calling this Server's start method is called. Args: address: The address for which to open a port. Returns: An integer port on which RPCs will be serviced after this link has been started. This is typically the same number as the port number contained in the passed address, but will likely be different if the port number contained in the passed address was zero. Nr)rÚaddressrrrÚadd_insecure_port[szServer.add_insecure_portcCs tƒ‚dS)aFReserves a port for secure RPC service after this Server becomes active. This method may only be called before calling this Server's start method is called. Args: address: The address for which to open a port. server_credentials: A ServerCredentials. Returns: An integer port on which RPCs will be serviced after this link has been started. This is typically the same number as the port number contained in the passed address, but will likely be different if the port number contained in the passed address was zero. Nr)rrZserver_credentialsrrrÚadd_secure_portmszServer.add_secure_portcCs tƒ‚dS)z”Starts this Server's service of RPCs. This method may only be called while the server is not serving RPCs (i.e. it is not idempotent). NrrrrrÚstart€sz Server.startcCs tƒ‚dS)a¨Stops this Server's service of RPCs. All calls to this method immediately stop service of new RPCs. When existing RPCs are aborted is controlled by the grace period parameter passed to this method. This method may be called at any time and is idempotent. Passing a smaller grace value than has been passed in a previous call will have the effect of stopping the Server sooner. Passing a larger grace value than has been passed in a previous call will not have the effect of stopping the server later. Args: grace: A duration of time in seconds to allow existing RPCs to complete before being aborted by this Server's stopping. May be zero for immediate abortion of all in-progress RPCs. Returns: A threading.Event that will be set when this Server has completely stopped. The returned event may not be set until after the full grace period (if some ongoing RPC continues for the full length of the period) of it may be set much sooner (such as if this Server had no RPCs underway at the time it was stopped or if all RPCs that it had underway completed very early in the grace period). Nr)rZgracerrrÚstop‰sz Server.stopN) r r r r rrrrrrrrrrrXs   r)FN)r rZgrpcÚsixZChannelConnectivityÚSHUTDOWNZ FATAL_FAILUREZ StatusCodeÚobjectrrZAuthMetadataContextZGRPCAuthMetadataContextZAuthMetadataPluginCallbackZGRPCAuthMetadataPluginCallbackZAuthMetadataPluginZGRPCAuthMetadataPluginÚwith_metaclassÚABCMetarrrrrrrÚs