9i ddlmZddlZddlmZddlmZddlmZedded d ed d Gd deZ y)) annotationsN)versionchanged)Version) RedisStoragez3.14.0z_ Dropped support for the :pypi:`redis-py-cluster` library which has been abandoned/deprecated. )versionreasonz2.5.0aa Cluster support was provided by the :pypi:`redis-py-cluster` library which has been absorbed into the official :pypi:`redis` client. By default the :class:`redis.cluster.RedisCluster` client will be used however if the version of the package is lower than ``4.2.0`` the implementation will fallback to trying to use :class:`rediscluster.RedisCluster`. z4.3ztAdded support for using the redis client from :pypi:`valkey` if :paramref:`uri` has the ``valkey+cluster://`` schemaceZdZUdZddgZ ddiZded< eded d Ze jd f dfd Z dd Z xZ S)RedisClusterStoragez Rate limit storage with redis cluster as backend Depends on :pypi:`redis` (or :pypi:`valkey` if :paramref:`uri` starts with ``valkey+cluster://``). z redis+clusterzvalkey+clustermax_connectionsizdict[str, float | str | bool]DEFAULT_OPTIONSz4.2.0z6.0)redisvalkeyFc tjj|}i}|jr|j|d<|jr|j|d<|j j ddz}g}|j |djdD]2} | jd\} } |j| t| f4||_ d|_ |jdrdnd |_ i|j||} |j|jj |_|D cgc]%} |j"j$j&| '}} |jd k(r.|j"j$j(d d |i| |_ n-|j"j$j*d d |i| |_ |jsJ|j-|t/t0|f||fi|ycc} w) a :param uri: url of the form ``redis+cluster://[:password]@host:port,host:port`` If the uri scheme is ``valkey+cluster`` the implementation used will be from :pypi:`valkey`. :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.cluster.RedisCluster` :raise ConfigurationError: when the :pypi:`redis` library is not available or if the redis cluster cannot be reached. usernamepassword@N,:rr startup_nodes)urllibparseurlparserrnetlocfindsplitappendint key_prefixstorage startswith target_serverr dependenciesmodule dependencycluster ClusterNode RedisCluster ValkeyClusterinitialize_storagesuperr__init__)selfurir wrap_exceptionsoptionsparsed parsed_authsep cluster_hostslochostportmerged_optionscr __class__s O/var/www/html/venv/lib/python3.12/site-packages/limits/storage/redis_cluster.pyr-zRedisClusterStorage.__init__8s*&&s+57 ??&,ooK # ??&,ooK #mm  %) ==&,,S1 4C3JD$  $D !2 3 4% ),)AXwKD00KKK7K++D,>,>?FFJWXQ<00<r^sn" ,%-       C],] 0]rY