o Ph@sBddlZddlZddlmZmZmZmZmZmZGdddZ dS)N)DictIterableIteratorListOptionalTuplec@seZdZUgZeeed<ddeededdfddZ d eddfd d Z d eddfd d Z dede efddZ dedee ee effddZdedeee ee effddZdede efddZdS)HashRingnodesreplicasreturnNcCs*||_i|_g|_|D]}||q dSN)r ring sorted_keysadd_node)selfr r noder r b/var/www/html/Testing_prj/Navya-Bakers/venv/lib/python3.10/site-packages/django_redis/hash_ring.py__init__ s  zHashRing.__init__rcCs`|j|t|jD]}|d|}t|}||j|<|j |q |j dSN:) r appendranger hashlibsha256encode hexdigestrrsort)rrx_key_hashr r rrs  zHashRing.add_nodecCsP|j|t|jD]}t|d|}|j|=|j |q dSr) r removerr rrrrrr)rrrr!r r r remove_nodes zHashRing.remove_nodekeycCs||\}}|Sr) get_node_pos)rr$nir r rget_node$szHashRing.get_nodecCsdt|jdkr dSt|}t|j|}t|d|j t|j d}|j|j||fS)NrNN) lenrrrrrbisectrminr r )rr$r!idxr r rr%(s zHashRing.get_node_posccsLt|jdkr dV||\}}|j|dD] }||j|fVqdS)Nrr))r+rr%r)rr$rposkr r r iter_nodes1szHashRing.iter_nodescCs ||Sr)r()rr$r r r__call__9s zHashRing.__call__)r r )__name__ __module__ __qualname__r rstr__annotations__rintrrr#rr(rr%rr1r2r r r rrs  "& r) r,rtypingrrrrrrrr r r rs