5jSSKJr SSKJr SSKJr SSKJr SSKJ r \"SSS9\"S S S9\"S S S9"S S\ 5555r g)) 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://`` schemac^\rSrSr%SrSS/rSS0rS\S'\"S 5\"S 5S .r \ RS 4SU4S jjjr SSjr SrU=r$)RedisClusterStorage z 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 V>[U5n0nURSUR5=n(aXvS'URSUR5=n(aXS'URn X lSUlURS5(aSOSUlURURRUl U V s/sH%oRRR"U 6PM' n n 0URESU 0EUEUEn URS:Xa,URRR"S0U D6UlO+URRR "S0U D6UlUR (deUR#U5 [$[&U]R"X40UD6 gs sn f)aX :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. usernamepasswordNrr startup_nodes)rgetrr locations key_prefixstorage startswith target_server dependenciesmodule dependencycluster ClusterNoder RedisCluster ValkeyClusterinitialize_storagesuperr__init__)selfurirwrap_exceptionsoptionsstorage_uri_options parsed_authrr cluster_hostscrmerged_options __class__s [/root/lseg-credit/backend/venv/lib/python3.13/site-packages/limits/storage/redis_cluster.pyr%RedisClusterStorage.__init__7s*04 {{:/B/K/KL L8 L&. #{{:/B/K/KL L8 L&. #+55 $ ),)A)AXw++D,>,>?FFJWX-Q00<RDL||| $ lD*3K7KYs,F&c HURS5nSnURR5HknURRU5nUR U5nU[ UVs/sH"odR URS55PM$ sn5- nMm U$s snf)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*rzutf-8) prefixed_keyr get_primariesget_redis_connectionkeyssumdeletedecode)r&prefixcountprimarynoder7ks r0resetRedisClusterStorage.resetis""3'||113G<<44W=D99V$D S$G$Q++ahhw&78$GH HE4 Hs')B )rrrr) r'strrrBr(boolr)zfloat | str | boolreturnNone)rDz int | None)__name__ __module__ __qualname____firstlineno____doc__STORAGE_SCHEMEr__annotations__r DEPENDENCIESrPREFIXr%r@__static_attributes__ __classcell__)r/s@r0r r s2&'78N. 46O2I!%.L'-- % 0L 0L0L 0L & 0L  0L0Ldr N) __future__rdeprecated.sphinxrpackaging.versionrlimits._storage_schemerlimits.storage.redisrr rrQr0rWsn",%4-       CY,Y 0YrQ