iddlmZddlmZddlmZddlmZddlm Z edded d ed d Gd de Z dS)) annotations)versionchanged)Version)parse_storage_uri) 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 j d fdfd Z ddZ 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)redisvalkeyFuristr key_prefixwrap_exceptionsbooloptionsfloat | str | boolreturnNonec t|}i}|d|jx}r||d<|d|jx}r||d<|j} |_d_|drdnd_j jj _ fd| D} ij d| i||} jdkrj j jdi| _nj j jdi| _jsJ|t#t$j||fi|dS) 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. usernamepasswordNrrc8g|]}jjj|S) dependencycluster ClusterNode).0cselfs l/var/www/html/crypto-mining-system/backend/venv/lib/python3.11/site-packages/limits/storage/redis_cluster.py z0RedisClusterStorage.__init__..Ys)XXXQ<0?FXXXX-XXX  "  .       ( (?4?2?QQ.QQDLL@4?2@RR>RRDL|| $$$*lD!!*3KK7KKKKKr& int | Nonec|d}d}|jD]O}|j||}|t fd|Dz }P|S)a Redis Clusters are sharded and deleting across shards can't be done atomically. Because of this, this reset loops over all keys that are prefixed with :paramref:`RedisClusterStorage.prefix` and calls delete on them one at a time. .. warning:: This operation was not tested with extremely large data sets. On a large production based system, care should be taken with its usage as it could be slow on very large data sets*rc`g|]*}|d+S)zutf-8)deletedecode)r!knodes r$r%z-RedisClusterStorage.reset..zs1GGGQ$++ahhw&7&788GGGr&) prefixed_keyr* get_primariesget_redis_connectionkeyssum)r#prefixcountprimaryrDr@s @r$resetzRedisClusterStorage.resetis""3''|1133 I IG<44W==D99V$$D SGGGG$GGGHH HEE r&) rrrrrrrrrr)rr9)__name__ __module__ __qualname____doc__STORAGE_SCHEMEr __annotations__r DEPENDENCIESrPREFIXr3rI __classcell__)r8s@r$r r s2&'78N. 46OI!!'%..L'- % 0L0L0L0L0L0L0Ldr&r N) __future__rdeprecated.sphinxrpackaging.versionrlimits._storage_schemerlimits.storage.redisrr rr&r$rXs"""""",,,,,,%%%%%%444444------         CYYYYY,YY  0YYYr&