|
@@ -46,8 +46,8 @@ class ChannelCache(TimedStorage[ChannelInfo, Tuple[Union[grpc.Channel, grpc.aio.
|
|
|
Unlike TimedStorage, ChannelCache actively evicts stale channels even if the cache is not accessed
|
|
|
Unlike grpc._simple_stubs.ChannelCache, this implementation supports aio and does not forcibly close active channels
|
|
|
"""
|
|
|
- MAXIMUM_CHANNELS = os.environ.get("GRPC_PYTHON_MANAGED_CHANNEL_MAXIMUM", 4096)
|
|
|
- EVICTION_PERIOD_SECONDS = os.environ.get("GRPC_PYTHON_MANAGED_CHANNEL_EVICTION_SECONDS", 10 * 60)
|
|
|
+ MAXIMUM_CHANNELS = int(os.environ.get("GRPC_PYTHON_MANAGED_CHANNEL_MAXIMUM", 4096))
|
|
|
+ EVICTION_PERIOD_SECONDS = float(os.environ.get("GRPC_PYTHON_MANAGED_CHANNEL_EVICTION_SECONDS", 10 * 60))
|
|
|
logger.debug(f"Eviction period = {EVICTION_PERIOD_SECONDS}s, max channels = {MAXIMUM_CHANNELS}")
|
|
|
|
|
|
_singleton: Optional[ChannelCache] = None
|