(ph"`"SrSSKrSSKrSSKrSSKrSSKrSSKJrJrJ r J r J r J r J r JrJrJr SSKrSSKJr \"S5r\"S5r\ \\\4r\\\\ \R0\ \R24r\R6"\5rSr\\R>;a6\R@"\!"\R>\5S9r"\RGS \"5 O\R@"S S 9r"S r$\$\R>;a(\%"\R>\$5r&\RGS \&5 OSr&Sr'\'\R>;a(\!"\R>\'5r(\RGS\(5 OSr(S\S\ \\\4S\ \R0S\ \R2S\RR4 Sjr*"SS5r+\SSSSSSSS\(SS4 S\S\S\S\ \ \/\,4S\ \ \,/\4S\ \\\4S\ \R0S \-S!\ \R\S\ \R2S"\ \-S#\ \!S$\ \ \\\\\,44S%\ \-S\4S&jj5r/\SSSSSSSS\(SS4 S\S\S\S\ \ \/\,4S\ \ \,/\4S\ \\\4S\ \R0S \-S!\ \R\S\ \R2S"\ \-S#\ \!S$\ \ \\\\\,44S%\ \-S\ \4S'jj5r0\SSSSSSSS\(SS4 S(\ \S\S\S\ \ \/\,4S\ \ \,/\4S\ \\\4S\ \R0S \-S!\ \R\S\ \R2S"\ \-S#\ \!S$\ \ \\\\\,44S%\ \-S\4S)jj5r1\SSSSSSSS\(SS4 S(\ \S\S\S\ \ \/\,4S\ \ \,/\4S\ \\\4S\ \R0S \-S!\ \R\S\ \R2S"\ \-S#\ \!S$\ \ \\\\\,44S%\ \-S\ \4S*jj5r2g)+zlen_MAXIMUM_CHANNELSnextiterkeysrHitemsdatetimenow total_seconds)rBrG eviction_timerTtime_to_evictions r#r5ChannelCache._perform_evictionss>##,,002#..77 ++0020099:=NNtL$;$;$D$D$I$I$KLMC ++99#>/3\44==CCEF/+C+!#++//1C$+$//==cB $#"-:,?+N+N+P( %//44=M4N/$##sE%F</F<< G rrrinsecurermethod_registered_methodrcU(aU(a [S5eU(a[RR5nO-Uc*[R S5 [R "5nXX54nUR URRUS5n Sn U bxU Sn U(aU RU5n URRU5 U [RR5[-4URU'X4sSSS5 $[XX55n U(aU RU5n U [RR5[-4URU'[!UR5S:Xd[!UR5[":aUR$R'5 X4sSSS5 $!,(df  g=f)aGet a channel from cache or creates a new channel. This method also takes care of register method for channel, which means we'll register a new call handle if we're calling a non-registered method for an existing channel. Returns: A tuple with two items. The first item is the channel, second item is the call handle if the method is registered, None if it's not registered. zkThe insecure option is mutually exclusive with the channel_credentials option. Please use one or the other.Nz&Defaulting to SSL channel credentials.r) ValueErrorr! experimentalinsecure_channel_credentialsrr ssl_channel_credentialsr)r-r@_get_registered_call_handlerDrSrT_EVICTION_PERIODr$rMrNr+notify) r8rrrrYrrZr[rB channel_data call_handlerFs r# get_channelChannelCache.get_channels( +"  !!>>@ ! ( MMB C"&">">"@  3A ZZ==,,S$7LK'&q/&")"E"Ef"MK !!#&%%))+.>>& c"+Z *%8&")"E"Ef"MK%%))+.>>& c"  &!+4==)->>OO**,+=ZZs=BG B*G  GczUR [UR5sSSS5 $!,(df  g=fr<)r)rMr-r7s r#_test_only_channel_count%ChannelCache._test_only_channel_counts ZZt}}%ZZs, :)r.r-)#__name__ __module__ __qualname____firstlineno__r=r3RLockr)__annotations__ Conditionr+Eventr,rCacheKeyr r!ChannelrSr4r9 staticmethodr@rHr5strr rChannelCredentialsbool Compressionintrgrj__static_attributes__r?r%r#r'r'^sUJ&__.E9??.&/&9&9u&EJ ##E'0'8OY__88U4<<1B1B#BCCDD&&&&''OO6@,@,%S/*@,&d&=&=> @,  @, d../ @,@,!@, t||Xc]* +@,D&#&r%r'r?FrequestrZrequest_serializerresponse_deserializerrYcall_credentialswait_for_readyrKmetadatar[c [R5RUUUUU UU 5upURX#XO5nU bU OSn U"UU U UU S9$)a* Invokes a unary-unary RPC without an explicitly specified channel. THIS IS AN EXPERIMENTAL API. This is backed by a per-process cache of channels. Channels are evicted from the cache after a fixed period by a background. Channels will also be evicted if more than a configured maximum accumulate. The default eviction period is 10 minutes. One may set the environment variable "GRPC_PYTHON_MANAGED_CHANNEL_EVICTION_SECONDS" to configure this. The default maximum number of channels is 256. One may set the environment variable "GRPC_PYTHON_MANAGED_CHANNEL_MAXIMUM" to configure this. Args: request: An iterator that yields request values for the RPC. target: The server address. method: The name of the RPC method. request_serializer: Optional :term:`serializer` for serializing the request message. Request goes unserialized in case None is passed. response_deserializer: Optional :term:`deserializer` for deserializing the response message. Response goes undeserialized in case None is passed. options: An optional list of key-value pairs (:term:`channel_arguments` in gRPC Core runtime) to configure the channel. channel_credentials: A credential applied to the whole channel, e.g. the return value of grpc.ssl_channel_credentials() or grpc.insecure_channel_credentials(). insecure: If True, specifies channel_credentials as :term:`grpc.insecure_channel_credentials()`. This option is mutually exclusive with the `channel_credentials` option. call_credentials: A call credential applied to each call individually, e.g. the output of grpc.metadata_call_credentials() or grpc.access_token_call_credentials(). compression: An optional value indicating the compression method to be used over the lifetime of the channel, e.g. grpc.Compression.Gzip. wait_for_ready: An optional flag indicating whether the RPC should fail immediately if the connection is not ready at the time the RPC is invoked, or if it should wait until the connection to the server becomes ready. When using this option, the user will likely also want to set a timeout. Defaults to True. timeout: An optional duration of time in seconds to allow for the RPC, after which an exception will be raised. If timeout is unspecified, defaults to a timeout controlled by the GRPC_PYTHON_DEFAULT_TIMEOUT_SECONDS environment variable. If that is unset, defaults to 60 seconds. Supply a value of None to indicate that no timeout should be enforced. metadata: Optional metadata to send to the server. Returns: The response to the RPC. TrrrrK)r'r@rg unary_unaryr}rrZr~rrrrYrrrrKrr[rF method_handle multicallables r#rrsxL*--/;;G''$9M(6'A^tN %$  r%c [R5RUUUUU UU 5upURX#XO5nU bU OSn U"UU U UU S9$)a Invokes a unary-stream RPC without an explicitly specified channel. THIS IS AN EXPERIMENTAL API. This is backed by a per-process cache of channels. Channels are evicted from the cache after a fixed period by a background. Channels will also be evicted if more than a configured maximum accumulate. The default eviction period is 10 minutes. One may set the environment variable "GRPC_PYTHON_MANAGED_CHANNEL_EVICTION_SECONDS" to configure this. The default maximum number of channels is 256. One may set the environment variable "GRPC_PYTHON_MANAGED_CHANNEL_MAXIMUM" to configure this. Args: request: An iterator that yields request values for the RPC. target: The server address. method: The name of the RPC method. request_serializer: Optional :term:`serializer` for serializing the request message. Request goes unserialized in case None is passed. response_deserializer: Optional :term:`deserializer` for deserializing the response message. Response goes undeserialized in case None is passed. options: An optional list of key-value pairs (:term:`channel_arguments` in gRPC Core runtime) to configure the channel. channel_credentials: A credential applied to the whole channel, e.g. the return value of grpc.ssl_channel_credentials(). insecure: If True, specifies channel_credentials as :term:`grpc.insecure_channel_credentials()`. This option is mutually exclusive with the `channel_credentials` option. call_credentials: A call credential applied to each call individually, e.g. the output of grpc.metadata_call_credentials() or grpc.access_token_call_credentials(). compression: An optional value indicating the compression method to be used over the lifetime of the channel, e.g. grpc.Compression.Gzip. wait_for_ready: An optional flag indicating whether the RPC should fail immediately if the connection is not ready at the time the RPC is invoked, or if it should wait until the connection to the server becomes ready. When using this option, the user will likely also want to set a timeout. Defaults to True. timeout: An optional duration of time in seconds to allow for the RPC, after which an exception will be raised. If timeout is unspecified, defaults to a timeout controlled by the GRPC_PYTHON_DEFAULT_TIMEOUT_SECONDS environment variable. If that is unset, defaults to 60 seconds. Supply a value of None to indicate that no timeout should be enforced. metadata: Optional metadata to send to the server. Returns: An iterator of responses. Tr)r'r@rg unary_streamrs r#rr>sxJ*--/;;G(($9M(6'A^tN %$  r%request_iteratorc [R5RUUUUU UU 5upURX#XO5nU bU OSn U"UU U UU S9$)a Invokes a stream-unary RPC without an explicitly specified channel. THIS IS AN EXPERIMENTAL API. This is backed by a per-process cache of channels. Channels are evicted from the cache after a fixed period by a background. Channels will also be evicted if more than a configured maximum accumulate. The default eviction period is 10 minutes. One may set the environment variable "GRPC_PYTHON_MANAGED_CHANNEL_EVICTION_SECONDS" to configure this. The default maximum number of channels is 256. One may set the environment variable "GRPC_PYTHON_MANAGED_CHANNEL_MAXIMUM" to configure this. Args: request_iterator: An iterator that yields request values for the RPC. target: The server address. method: The name of the RPC method. request_serializer: Optional :term:`serializer` for serializing the request message. Request goes unserialized in case None is passed. response_deserializer: Optional :term:`deserializer` for deserializing the response message. Response goes undeserialized in case None is passed. options: An optional list of key-value pairs (:term:`channel_arguments` in gRPC Core runtime) to configure the channel. channel_credentials: A credential applied to the whole channel, e.g. the return value of grpc.ssl_channel_credentials(). call_credentials: A call credential applied to each call individually, e.g. the output of grpc.metadata_call_credentials() or grpc.access_token_call_credentials(). insecure: If True, specifies channel_credentials as :term:`grpc.insecure_channel_credentials()`. This option is mutually exclusive with the `channel_credentials` option. compression: An optional value indicating the compression method to be used over the lifetime of the channel, e.g. grpc.Compression.Gzip. wait_for_ready: An optional flag indicating whether the RPC should fail immediately if the connection is not ready at the time the RPC is invoked, or if it should wait until the connection to the server becomes ready. When using this option, the user will likely also want to set a timeout. Defaults to True. timeout: An optional duration of time in seconds to allow for the RPC, after which an exception will be raised. If timeout is unspecified, defaults to a timeout controlled by the GRPC_PYTHON_DEFAULT_TIMEOUT_SECONDS environment variable. If that is unset, defaults to 60 seconds. Supply a value of None to indicate that no timeout should be enforced. metadata: Optional metadata to send to the server. Returns: The response to the RPC. Tr)r'r@rg stream_unaryrrrZr~rrrrYrrrrKrr[rFrrs r#rrsxJ*--/;;G(($9M(6'A^tN %$  r%c [R5RUUUUU UU 5upURX#XO5nU bU OSn U"UU U UU S9$)a Invokes a stream-stream RPC without an explicitly specified channel. THIS IS AN EXPERIMENTAL API. This is backed by a per-process cache of channels. Channels are evicted from the cache after a fixed period by a background. Channels will also be evicted if more than a configured maximum accumulate. The default eviction period is 10 minutes. One may set the environment variable "GRPC_PYTHON_MANAGED_CHANNEL_EVICTION_SECONDS" to configure this. The default maximum number of channels is 256. One may set the environment variable "GRPC_PYTHON_MANAGED_CHANNEL_MAXIMUM" to configure this. Args: request_iterator: An iterator that yields request values for the RPC. target: The server address. method: The name of the RPC method. request_serializer: Optional :term:`serializer` for serializing the request message. Request goes unserialized in case None is passed. response_deserializer: Optional :term:`deserializer` for deserializing the response message. Response goes undeserialized in case None is passed. options: An optional list of key-value pairs (:term:`channel_arguments` in gRPC Core runtime) to configure the channel. channel_credentials: A credential applied to the whole channel, e.g. the return value of grpc.ssl_channel_credentials(). call_credentials: A call credential applied to each call individually, e.g. the output of grpc.metadata_call_credentials() or grpc.access_token_call_credentials(). insecure: If True, specifies channel_credentials as :term:`grpc.insecure_channel_credentials()`. This option is mutually exclusive with the `channel_credentials` option. compression: An optional value indicating the compression method to be used over the lifetime of the channel, e.g. grpc.Compression.Gzip. wait_for_ready: An optional flag indicating whether the RPC should fail immediately if the connection is not ready at the time the RPC is invoked, or if it should wait until the connection to the server becomes ready. When using this option, the user will likely also want to set a timeout. Defaults to True. timeout: An optional duration of time in seconds to allow for the RPC, after which an exception will be raised. If timeout is unspecified, defaults to a timeout controlled by the GRPC_PYTHON_DEFAULT_TIMEOUT_SECONDS environment variable. If that is unset, defaults to 60 seconds. Supply a value of None to indicate that no timeout should be enforced. metadata: Optional metadata to send to the server. Returns: An iterator of responses. Tr)r'r@rg stream_streamrs r#rrsxJ*--/;;G))$9M(6'A^tN %$  r%)3__doc__r1rSloggingosr3typingrrrrrrr r r r r!grpc.experimentalr rrrw OptionsTyperxrzrt getLoggerrlr_EVICTION_PERIOD_KEYenviron timedeltafloatrcr _MAXIMUM_CHANNELS_KEYr{rN_DEFAULT_TIMEOUT_KEY_DEFAULT_TIMEOUTrur$r'bytesryCallCredentialsrrrrr?r%r#rs:C     .m$ ~& uS#X'  T $ $% T       H %E2::%))bjj!567 MM79I ))"5=BJJ&BJJ'<=> MM: MM9;KL  eCHo &"$"9"9:$**+   \\ $A&A&H <@>B/1=A7;.2%)/BF).W W W W!3%,!78 W $HeWc\$:; W eFFN+ , W"$"9"9:WWt334W$**+WTNWe_Wxc5e+<&< =>?W!WWWt <@>B/1=A7;.2%)/BF).V V V V!3%,!78 V $HeWc\$:; V eFFN+ , V"$"9"9:VVt334V$**+VTNVe_Vxc5e+<&< =>?V!VlVVr <@>B/1=A7;.2%)/BF).V{+V V V!3%,!78 V $HeWc\$:; V eFFN+ , V"$"9"9:VVt334V$**+VTNVe_Vxc5e+<&< =>?V!VVVr <@>B/1=A7;.2%)/BF).V{+V V V!3%,!78 V $HeWc\$:; V eFFN+ , V"$"9"9:VVt334V$**+VTNVe_Vxc5e+<&< =>?V!VlVVr%