iddlmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZer ed d Gd d e ZdS)) annotations) TYPE_CHECKING)versionchanged)Version)parse_storage_uri)ConfigurationError) RedisStorage) RedisClientz4.3zuAdded support for using the redis client from :pypi:`valkey` if :paramref:`uri` has the ``valkey+sentinel://`` schema)versionreasonceZdZdZddgZ ededededdZdddejd fdfd Z e ddZ d d!dZ 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.sentinelNTFuristr service_name str | None use_replicasboolsentinel_kwargs$dict[str, float | str | bool] | None key_prefixwrap_exceptionsoptionsfloat | str | boolreturnNonec ^tt|j|fd|i|t|}g} |r|ni} i} |d|jx} r| | d<|d|jx} r| | d<| |j ||_ |j r|j ddn||_ |j td|drdnd |_|j|jd j}|j| fd i| | ii| ||_|j|j |_|j|j |_||_||dS) 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. rusernamepassword/Nz'service_name' not providedrrz .sentinelr)superr __init__rcopygetr r!extend locationsrpathreplacerr startswith target_server dependenciesmoduleSentinelsentinel master_forstorage slave_for storage_slaverinitialize_storage)selfrrrrrrrstorage_uri_optionssentinel_configurationsentinel_options parsed_authr r! sentinel_dep __class__s m/var/www/html/crypto-mining-system/backend/venv/lib/python3.11/site-packages/limits/storage/redis_sentinel.pyr%zRedisSentinelStorage.__init__*s< +lD!!*   !0 4;   044!#5DL?//111"57 {{:/B/KLL L8 /&.K #{{:/B/KLL L8 /&.K #%%&9&CDDD$#'   $ , ,S" 5 5 5    $$%BCC C),)A)ANXXw(D,>)I)I)IJQ - - "  ?{?.>? )((   %)M$<$base_exceptionsz$RedisSentinelStorage.base_exceptionsns> !W,,  g & - 8 8"8,3? r?readonlyr c0|r|jr|jn|jS)N)rr5r3)r7rEs r>get_connectionz#RedisSentinelStorage.get_connectionxs&.W43DWt!!4<Wr?)rrrrrrrrrrrrrrrr)rr@)F)rErrr )__name__ __module__ __qualname____doc__STORAGE_SCHEMEr DEPENDENCIESr PREFIXr%propertyrDrG __classcell__)r=s@r>rrs'(9:NQ!'%..'%.."75>> L$(!@D&- %B%B%B%B%B%B%B%H   X XXXXXXXXXr?rN) __future__rtypingrdeprecated.sphinxrpackaging.versionrlimits._storage_schemer limits.errorsrlimits.storage.redisr limits.typingr rr?r>rZs"""""" ,,,,,,%%%%%%444444,,,,,,------%%%%%%   DaXaXaXaXaX<aXaXaXaXaXr?