9iddlmZddlZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZer ed d Gd d e Zy)) annotationsN) TYPE_CHECKING)versionchanged)Version)ConfigurationError) RedisStorage) RedisClientz4.3zuAdded support for using the redis client from :pypi:`valkey` if :paramref:`uri` has the ``valkey+sentinel://`` schema)versionreasonceZdZdZddgZ ededededdZdddejd f d fd Z e dd Z ddd Z xZ S)RedisSentinelStoragez Rate limit storage with redis sentinel as backend Depends on :pypi:`redis` package (or :pypi:`valkey` if :paramref:`uri` starts with ``valkey+sentinel://``) zredis+sentinelzvalkey+sentinelz3.0z6.0)rediszredis.sentinelvalkeyzvalkey.sentinelNTFc $tt| |fd|i|tjj |}g} |r|j ni} i} |jr|j| d<|jr|j| d<|jjddz} |j| djdD]2} | jd\}}| j|t|f4||_|jr|jj!d d n||_|j" t%d |j'd rd nd |_|j*|j(dj,}|j.| fdi| | ii| ||_|j0j3|j"|_|j0j7|j"|_||_|j=|y)a :param uri: url of the form ``redis+sentinel://host:port,host:port/service_name`` If the uri scheme is ``valkey+sentinel`` the implementation used will be from :pypi:`valkey`. :param service_name: sentinel service name (if not provided in :attr:`uri`) :param use_replicas: Whether to use replicas for read only operations :param sentinel_kwargs: kwargs to pass as :attr:`sentinel_kwargs` to :class:`redis.sentinel.Sentinel` :param key_prefix: the prefix for each key created in redis :param wrap_exceptions: Whether to wrap storage exceptions in :exc:`limits.errors.StorageError` before raising it. :param options: all remaining keyword arguments are passed directly to the constructor of :class:`redis.sentinel.Sentinel` :raise ConfigurationError: when the redis library is not available or if the redis master host cannot be pinged. wrap_exceptionsusernamepassword@N,:/z'service_name' not providedrrz .sentinelsentinel_kwargs)superr__init__urllibparseurlparsecopyrrnetlocfindsplitappendint key_prefixpathreplace service_namer startswith target_server dependenciesmoduleSentinelsentinel master_forstorage slave_for storage_slave use_replicasinitialize_storage)selfurir)r4rr&roptionsparsedsentinel_configurationsentinel_options parsed_authseplochostport sentinel_dep __class__s P/var/www/html/venv/lib/python3.12/site-packages/limits/storage/redis_sentinel.pyrzRedisSentinelStorage.__init__*s< lD*  !0 4; &&s+!#5D?//1"57 ??&,ooK # ??&,ooK #mm  %)==&,,S1 =C3JD$ " ) )4T*; < =%,2KKFKK  R (\     $$%BC C),)AXw((D,>,>+?y)IJQQ - -- " ?{?.>? )((  %)MM$<$ L$(!@D&-- %D% D%!D% D% > D%  D%D%&D% D%L 6  XXrDr ) __future__r urllib.parsertypingrdeprecated.sphinxrpackaging.versionr limits.errorsrlimits.storage.redisr limits.typingr r rDrCrbsR" ,%,-%  DcX<cXcXrD