$gPddlZddlZddlmZmZmZmZmZmZGddZ dS)N)DictIterableIteratorListOptionalTuplec eZdZUgZeeed<ddeededdfdZ deddfd Z deddfd Z d ede efd Z d edee ee effd Zd edeee ee effdZd ede efdZdS)HashRingnodesreplicasreturnNcd||_i|_g|_|D]}||dSN)rring sorted_keysadd_node)selfr rnodes V/var/www/html/netbox-4.1.3/venv/lib/python3.11/site-packages/django_redis/hash_ring.py__init__zHashRing.__init__ sF% $& &(  D MM$      rc`|j|t|jD]e}|d|}t j|}||j|<|j |f|j dSN:) r appendrangerhashlibsha256encode hexdigestrrsort)rrx_key_hashs rrzHashRing.add_nodes $t}%% + +A==Q==DN4;;==11;;==E#DIe    # #E * * * * rc&|j|t|jD]a}t j|d|}|j|=|j |bdSr) r removerrrr r!r"rr)rrr$r&s r remove_nodezHashRing.remove_nodes $t}%% + +ANd==Q==#7#7#9#9::DDFFE %   # #E * * * * + +rkeyc6||\}}|Sr) get_node_pos)rr*nis rget_nodezHashRing.get_node$s  %%1rcnt|jdkrdStj|}t j|j|}t|dz |j t|j zdz }|j|j||fS)NrNN) lenrrr r!r"bisectrminrr )rr*r&idxs rr,zHashRing.get_node_pos(s ty>>Q  :szz||,,6688mD,e44#'DMC OO;q@AAy)#./44rc#Kt|jdkrdV||\}}|j|dD]}||j|fVdS)Nrr1)r3rr,r)rr*rposks r iter_nodeszHashRing.iter_nodes1sz ty>>Q     %%c** c!#$$' " "ATYq\/ ! ! ! ! " "rc,||Sr)r/)rr*s r__call__zHashRing.__call__9s}}S!!!r)r r )__name__ __module__ __qualname__r rstr__annotations__rintrrr)rr/rr,rr:r<r rrr r sYE49  hsm C $      S  T     ++++++CHSM55hsmXc].J(K5555"c"huXc]HSM5Q/R&S"""""C"HSM""""""rr ) r4rtypingrrrrrrr r rrrDsy BBBBBBBBBBBBBBBB4"4"4"4"4"4"4"4"4"4"r