codekingpro/portable-devtools
114k
1�
2 ��je � �P � S r SSKrSSKr\R r\R \l \R r " S S\5 rS S jr \R r \R r
\R r " S S\R 5 r " S S \R 5 r " S3 S \R 5 rg)
z8Constants and interfaces of the Beta API of gRPC Python.� Nc � � \ rS rSrSrS rSrg)�GRPCCallOptions� z�A value encapsulating gRPC-specific options passed on RPC invocation.4 5This class and its instances have no supported interface - it exists to6define the type of its instances and its instances exist to be passed to7other functions.8c �( � Xl X l X0l g )N)�disable_compression�9subcall_of� credentials)�selfr r r s �ZD:\code\apps\devtools\python\user_packages\Python313\site-packages\grpc/beta/interfaces.py�__init__�GRPCCallOptions.__init__# s � �#6� �$��&�� )r r r N)�__name__�10__module__� __qualname__�__firstlineno__�__doc__r �__static_attributes__� r r r r s � ��'r r c � � [ U SU5 $ )ax Creates a GRPCCallOptions value to be passed at RPC invocation.11 12All parameters are optional and should always be passed by keyword.13 14Args:15 disable_compression: A boolean indicating whether or not compression should16 be disabled for the request object of the RPC. Only valid for17 request-unary RPCs.18 credentials: A CallCredentials object to use for the invoked RPC.19N)r )r r s r �grpc_call_optionsr ) s � � �.��k� B�Br c �` � \ rS rSrSr\R S 5 r\R S 5 rSr g)�GRPCServicerContext�< zCExposes gRPC-specific options and behaviors to code servicing RPCs.c � � [ 5 e)z�Identifies the peer that invoked the RPC being serviced.20 21Returns:22 A string identifying the peer that invoked the RPC being serviced.23��NotImplementedError�r24 s r �peer�GRPCServicerContext.peer? �
� � "�#�#r c � � [ 5 e)zDDisables compression of the next response passed by the application.r r s r �!disable_next_response_compression�5GRPCServicerContext.disable_next_response_compressionH �
� � "�#�#r r N)25r r r r r �abc�abstractmethodr r# r r r r r r < s7 � �M����$� �$� ���$� �$r r c �< � \ rS rSrSr\R S 5 rSrg)�GRPCInvocationContext�N zBExposes gRPC-specific options and behaviors to code invoking RPCs.c � � [ 5 e)zCDisables compression of the next request passed by the application.r r s r � disable_next_request_compression�6GRPCInvocationContext.disable_next_request_compressionQ r% r r N) r r r r r r& r' r, r r r r r) r) N s � �L����$� �$r r) c � � \ rS rSrSr\R S 5 r\R S 5 r\R S 5 r \R S 5 r26Sr g) �Server�W zServices RPCs.c � � [ 5 e)a� Reserves a port for insecure RPC service once this Server becomes active.27 28This method may only be called before calling this Server's start method is29called.30 31Args:32 address: The address for which to open a port.33 34Returns:35 An integer port on which RPCs will be serviced after this link has been36 started. This is typically the same number as the port number contained37 in the passed address, but will likely be different if the port number38 contained in the passed address was zero.39r )r40 �addresss r �add_insecure_port�Server.add_insecure_portZ s
� � "�#�#r c � � [ 5 e)a Reserves a port for secure RPC service after this Server becomes active.41 42This method may only be called before calling this Server's start method is43called.44 45Args:46 address: The address for which to open a port.47 server_credentials: A ServerCredentials.48 49Returns:50 An integer port on which RPCs will be serviced after this link has been51 started. This is typically the same number as the port number contained52 in the passed address, but will likely be different if the port number53 contained in the passed address was zero.54r )r55 r2 �server_credentialss r �add_secure_port�Server.add_secure_portl s
� �" "�#�#r c � � [ 5 e)z�Starts this Server's service of RPCs.56 57This method may only be called while the server is not serving RPCs (i.e. it58is not idempotent).59r r s r �start� Server.start r! r c � � [ 5 e)aX Stops this Server's service of RPCs.60 61All calls to this method immediately stop service of new RPCs. When existing62RPCs are aborted is controlled by the grace period parameter passed to this63method.64 65This method may be called at any time and is idempotent. Passing a smaller66grace value than has been passed in a previous call will have the effect of67stopping the Server sooner. Passing a larger grace value than has been68passed in a previous call will not have the effect of stopping the server69later.70 71Args:72 grace: A duration of time in seconds to allow existing RPCs to complete73 before being aborted by this Server's stopping. May be zero for74 immediate abortion of all in-progress RPCs.75 76Returns:77 A threading.Event that will be set when this Server has completely78 stopped. The returned event may not be set until after the full grace79 period (if some ongoing RPC continues for the full length of the period)80 of it may be set much sooner (such as if this Server had no RPCs underway81 at the time it was stopped or if all RPCs that it had underway completed82 very early in the grace period).83r )r84 �graces r �stop� Server.stop� s
� �6 "�#�#r r N) r r r r r r& r' r3 r7 r: r> r r r r r/ r/ W sk � �����$� �$�" ���$� �$�$ ���$� �$� ���$� �$r r/ )FN)r r& �grpc�ChannelConnectivity�SHUTDOWN�
FATAL_FAILURE�85StatusCode�objectr r �AuthMetadataContext�GRPCAuthMetadataContext�AuthMetadataPluginCallback� GRPCAuthMetadataPluginCallback�AuthMetadataPlugin�GRPCAuthMetadataPlugin�ABCr r) r/ r r r �<module>rM s� �� ?� 86� ��.�.� �$7�$@�$@� � !�
�_�_�87� '�f� '� C� �2�2� �!%�!@�!@� � �0�0� �$�#�'�'� $�$$�C�G�G� $�L$�S�W�W� L$r