codekingpro/portable-devtools
115k
1�
2 ��js0 � � � S r SSKrSSKrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J3r4 SS K J r \R r
\R r\R rSS5 jrS r\R$ r\R& r\R( r " S S
\5 rS rS r " S S\5 r\" SSSSSS5 r SS jrSS jr SS jr \R< r \R> r " S S\5 r \ " SSSSSSS5 r! SS jr"SS jr#g) z.Entry points into the Beta API of gRPC Python.� N)�_auth)�_client_adaptations)� _metadata)�_server_adaptations)�6interfaces)� cardinality)�facec �8 ^ � U 4S jn[ R " X!S9$ )Nc �$ >^� U4S jnT" X5 g )Nc �@ >� T" [ R " U 5 U5 g �N)r �unbeta)�
beta_metadata�error�callbacks ��_D:\code\apps\devtools\python\user_packages\Python313\site-packages\grpc/beta/implementations.py�wrapped_callback�Cmetadata_call_credentials.<locals>.plugin.<locals>.wrapped_callback' s �� � �Y�%�%�m�4�e� <� � )�contextr r �metadata_plugins ` �r �plugin�)metadata_call_credentials.<locals>.plugin& s �� � =� ��2r )�name)�grpc�metadata_call_credentials)r r r s ` r r r % s �� �3� � )� )�&� <�<r c �@ � [ [ R " U 5 5 $ )z�Construct CallCredentials from GoogleCredentials.7 8Args:9 credentials: A GoogleCredentials object from the oauth2client library.10 11Returns:12 A CallCredentials object for use in a GRPCCallOptions object.13)r r �GoogleCallCredentials)� credentialss r �google_call_credentialsr! / s � � %�U�%@�%@��%M� N�Nr c �. � \ rS rSrSrS rSS jrS rSrg) �Channel�@ z�A channel to a remote host through which RPCs may be conducted.14 15Only the "subscribe" and "unsubscribe" methods are supported for application16use. This class' instance constructor and all other attributes are17unsupported.18c � � Xl g r
��_channel)�self�channels r �__init__�Channel.__init__H s � � �
r Nc �6 � U R R XS9 g)a� Subscribes to this Channel's connectivity.19 20Args:21 callback: A callable to be invoked and passed an22 interfaces.ChannelConnectivity identifying this Channel's connectivity.23 The callable will be invoked immediately upon subscription and again for24 every change to this Channel's connectivity thereafter until it is25 unsubscribed.26 try_to_connect: A boolean indicating whether or not this Channel should27 attempt to connect if it is not already connected and ready to conduct28 RPCs.29)�try_to_connectN)r' � subscribe)r( r r- s r r. �Channel.subscribeK s � �
�
�
� � �� �Hr c �: � U R R U5 g)z�Unsubscribes a callback from this Channel's connectivity.30 31Args:32 callback: A callable previously registered with this Channel from having33 been passed to its "subscribe" method.34N)r' � unsubscribe)r( r s r r1 �Channel.unsubscribeZ s � �
�
�
�!�!�(�+r r& r
) �__name__�35__module__� __qualname__�__firstlineno__�__doc__r* r. r1 �__static_attributes__r r r r# r# @ s � �� �
I� ,r r# c �V � [ R " Uc U OSX4- 5 n[ U5 $ )a$ Creates an insecure Channel to a remote host.36 37Args:38 host: The name of the remote host to which to connect.39 port: The port of the remote host to which to connect.40 If None only the 'host' part will be used.41 42Returns:43 A Channel to the remote host through which RPCs may be conducted.44�%s:%d)r �insecure_channelr# )�host�portr) s r r; r; d s1 � � �#�#�� ��'�T�L�"8��G� �7� �r c �X � [ R " Uc U OSX4- U5 n[ U5 $ )aU Creates a secure Channel to a remote host.45 46Args:47 host: The name of the remote host to which to connect.48 port: The port of the remote host to which to connect.49 If None only the 'host' part will be used.50 channel_credentials: A ChannelCredentials.51 52Returns:53 A secure Channel to the remote host through which RPCs may be conducted.54r: )r �secure_channelr# )r< r= �channel_credentialsr) s r r? r? u s4 � � �!�!�� ��'�T�L�"8�:M��G� �7� �r c � � \ rS rSrSrS rSrg)� StubOptions� z�A value encapsulating the various options for creation of a Stub.55 56This class and its instances have no supported interface - it exists to define57the type of its instances and its instances exist to be passed to other58functions.59c �L � Xl X l X0l X@l XPl X`l g r
�r< �request_serializers�response_deserializers�metadata_transformer� thread_pool�thread_pool_size)r( r< rF rG rH rI rJ s r r* �StubOptions.__init__� s' � � � �#6� �&<�#�$8�!�&�� 0� r )r< rH rF rG rI rJ N�r3 r4 r5 r6 r7 r* r8 r r r rB rB � s � ��1r rB c �" � [ U UUUUU5 $ )a Creates a StubOptions value to be passed at stub creation.60 61All parameters are optional and should always be passed by keyword.62 63Args:64 host: A host string to set on RPC calls.65 request_serializers: A dictionary from service name-method name pair to66 request serialization behavior.67 response_deserializers: A dictionary from service name-method name pair to68 response deserialization behavior.69 metadata_transformer: A callable that given a metadata object produces70 another metadata object to be used in the underlying communication on the71 wire.72 thread_pool: A thread pool to use in stubs.73 thread_pool_size: The size of thread pool to create for use in stubs;74 ignored if thread_pool has been passed.75 76Returns:77 A StubOptions value created from the passed parameters.78)rB rE s r � stub_optionsrN � s# � �8 � �� � ���
� r c � � Uc [ OUn[ R " U R UR UR79 UR UR 5 $ )z�Creates a face.GenericStub on which RPCs can be made.80 81Args:82 channel: A Channel for use by the created stub.83 options: A StubOptions customizing the created stub.84 85Returns:86 A face.GenericStub on which RPCs can be made.87)�_EMPTY_STUB_OPTIONSr � generic_stubr' r< rH rF rG )r) �options�effective_optionss r rQ rQ � sQ � � 07��+�G�� � +� +����� � ��.�.��-�-��0�0� � r c � � Uc [ OUn[ R " U R UUUR UR88 UR UR 5 $ )a� Creates a face.DynamicStub with which RPCs can be invoked.89 90Args:91 channel: A Channel for the returned face.DynamicStub to use.92 service: The package-qualified full name of the service.93 cardinalities: A dictionary from RPC method name to cardinality.Cardinality94 value identifying the cardinality of the RPC method.95 options: An optional StubOptions value further customizing the functionality96 of the returned face.DynamicStub.97 98Returns:99 A face.DynamicStub with which RPCs can be invoked.100)rP r � dynamic_stubr' r< rH rF rG )r) �service�
cardinalitiesrR rS s r rU rU � sW � � 07��+�G�� � +� +������� � ��.�.��-�-��0�0� � r c � � \ rS rSrSrS rSrg)�
ServerOptions�� z�A value encapsulating the various options for creation of a Server.101 102This class and its instances have no supported interface - it exists to define103the type of its instances and its instances exist to be passed to other104functions.105c �X � Xl X l X0l X@l XPl X`l Xpl g r
��multi_method_implementation�request_deserializers�response_serializersrI rJ �default_timeout�maximum_timeout)r( r] r^ r_ rI rJ r` ra s r r* �ServerOptions.__init__ s/ � � ,G�(�%:�"�$8�!�&�� 0� � .� � .� r )r` ra r] r^ r_ rI rJ NrL r r r rY rY � s � ��/r rY c �$ � [ U UUUUUU5 $ )aT Creates a ServerOptions value to be passed at server creation.106 107All parameters are optional and should always be passed by keyword.108 109Args:110 multi_method_implementation: A face.MultiMethodImplementation to be called111 to service an RPC if the server has no specific method implementation for112 the name of the RPC for which service was requested.113 request_deserializers: A dictionary from service name-method name pair to114 request deserialization behavior.115 response_serializers: A dictionary from service name-method name pair to116 response serialization behavior.117 thread_pool: A thread pool to use in stubs.118 thread_pool_size: The size of thread pool to create for use in stubs;119 ignored if thread_pool has been passed.120 default_timeout: A duration in seconds to allow for RPC service when121 servicing RPCs that did not include a timeout value when invoked.122 maximum_timeout: A duration in seconds to allow for RPC service when123 servicing RPCs no matter what timeout value was passed when the RPC was124 invoked.125 126Returns:127 A StubOptions value created from the passed parameters.128)rY r\ s r �server_optionsrd s' � �B �#� � ����� � r c � � Uc [ OUn[ R " U UR UR UR129 UR UR 5 $ )aa Creates an interfaces.Server with which RPCs can be serviced.130 131Args:132 service_implementations: A dictionary from service name-method name pair to133 face.MethodImplementation.134 options: An optional ServerOptions value further customizing the135 functionality of the returned Server.136 137Returns:138 An interfaces.Server with which RPCs can be serviced.139)�_EMPTY_SERVER_OPTIONSr �serverr] r^ r_ rI rJ )�service_implementationsrR rS s r rg rg E sT � � 29� �-�g�� � %� %� ��5�5��/�/��.�.��%�%��*�*�
� r r
)NNNNNN)NNNNNNN)$r7 � threadingr r � grpc.betar r r r �grpc.framework.commonr � grpc.framework.interfaces.facer �ChannelCredentials�ssl_channel_credentials�CallCredentialsr r! � access_token_call_credentials�composite_call_credentials� composite_channel_credentials�objectr# r; r? rB rP rN rQ rU �ServerCredentials�ssl_server_credentialsrY rf rd rg r r r �<module>rv s> �� 5� � � � )� � )� � -� /� �,�,� � �6�6� ��&�&��=� O� !%� B� B� � !� <� <� � $� B� B� �!,�f� !,�H �" �$1�&� 1�2 "�$��d�D�$��E� � 140� � � ���
#�L�(�4 �*�*� � �4�4� �/�F� /�6 &�d�D�$��d�D�$�O� � !%� � �����)�Xr