h)ddlZddlZddlZddlmZmZddlmZmZddl m Z ddl m Z m Z mZddlmZmZGdde Zej&Zgd Zgd Zd Zd Zd ZdZGddeZGddeZy)N)ABCabstractmethod) OrderedDict defaultdict)Enum)ListSequenceUnion)KeyT ResponseTceZdZdZdZdZy)EvictionPolicylrulfurandomN)__name__ __module__ __qualname__LRULFURANDOMW/var/www/html/retail-simulation-api/retail/lib/python3.12/site-packages/redis/_cache.pyrr s C C Frr)9zBF.CARDzBF.DEBUGz BF.EXISTSzBF.INFOz BF.MEXISTSz BF.SCANDUMPz CF.COMPACTzCF.COUNTzCF.DEBUGz CF.EXISTSzCF.INFOz CF.MEXISTSz CF.SCANDUMPzCMS.INFOz CMS.QUERYDUMP EXPIRETIMEz FT.AGGREGATEz FT.ALIASADDz FT.ALIASDELzFT.ALIASUPDATEz FT.CURSORz FT.EXPLAINz FT.EXPLAINCLIzFT.GETzFT.INFOzFT.MGETz FT.PROFILEz FT.SEARCHz FT.SPELLCHECKz FT.SUGGETz FT.SUGLENz FT.SYNDUMPz FT.TAGVALSzFT._ALIASADDIFNXzFT._ALIASDELIFX HRANDFIELDz JSON.DEBUG PEXPIRETIMEPFCOUNTPTTL SRANDMEMBERzTDIGEST.BYRANKzTDIGEST.BYREVRANKz TDIGEST.CDFz TDIGEST.INFOz TDIGEST.MAXz TDIGEST.MINzTDIGEST.QUANTILEz TDIGEST.RANKzTDIGEST.REVRANKzTDIGEST.TRIMMED_MEANz TOPK.INFOz TOPK.LISTz TOPK.QUERYTOUCHTTL)JBITCOUNT BITFIELD_ROBITPOSEXISTSGEODISTGEOHASHGEOPOSGEORADIUSBYMEMBER_RO GEORADIUS_RO GEOSEARCHGETGETBITGETRANGEHEXISTSHGETHGETALLHKEYSHLENHMGETHSTRLENHVALSz JSON.ARRINDEXz JSON.ARRLENzJSON.GETz JSON.MGETz JSON.OBJKEYSz JSON.OBJLENz JSON.RESPz JSON.STRLENz JSON.TYPELCSLINDEXLLENLPOSLRANGEMGETSCARDSDIFFSINTER SINTERCARD SISMEMBERSMEMBERS SMISMEMBERSORT_ROSTRLENSUBSTRSUNIONzTS.GETzTS.INFOzTS.RANGEz TS.REVRANGETYPEXLENXPENDINGXRANGEXREAD XREVRANGEZCARDZCOUNTZDIFFZINTER ZINTERCARD ZLEXCOUNTZMSCOREZRANGE ZRANGEBYLEX ZRANGEBYSCOREZRANK ZREVRANGEZREVRANGEBYLEXZREVRANGEBYSCOREZREVRANKZSCOREZUNIONresponsekeysctime access_countceZdZdZedeeeefdede e fdZ edeeeefdefdZ edeeeeffdZ ed e eeeeffd Zed Zed e fd Zy) AbstractCachez An abstract base class for client caching implementations. If you want to implement your own cache you must support these methods. commandrakeys_in_commandcyNrselfrgrarhs rsetzAbstractCache.sets rreturncyrjrrlrgs rgetzAbstractCache.get rcyrjrrps rdelete_commandzAbstractCache.delete_commandrrrcommandscyrjr)rlrus rdelete_commandszAbstractCache.delete_commandsrrrcyrjrrls rflushzAbstractCache.flushrrrkeycyrjr)rlr{s rinvalidate_keyzAbstractCache.invalidate_keyrrrN)rrr__doc__rr strr r rr rmrqrtrwrzr}rrrrfrfs  sHSM)*  d    5hsm!34    eC#,>&?   U3 3E-F(G     $  rrfcTeZdZdZddefdededefdZdee e e fd e d e e fd Zdee e e fd e fd Zdee e e ffdZde ee e e ffdZdZdee e e fd efdZdee e e ffdZdZde e dee e e ffdZde e dee e e ffdZde fdZy) _LocalCachea A caching mechanism for storing redis commands and their responses. Args: max_size (int): The maximum number of commands to be stored in the cache. ttl (int): The time-to-live for each command in seconds. eviction_policy (EvictionPolicy): The eviction policy to use for removing commands when the cache is full. Attributes: max_size (int): The maximum number of commands to be stored in the cache. ttl (int): The time-to-live for each command in seconds. eviction_policy (EvictionPolicy): The eviction policy used for cache management. cache (OrderedDict): The ordered dictionary to store commands and their metadata. key_commands_map (defaultdict): A mapping of keys to the set of commands that use each key. commands_ttl_list (list): A list to keep track of the commands in the order they were added. # noqa i'rmax_sizettleviction_policyc||_||_||_t|_t t |_g|_yrj) rrrrcacherrmkey_commands_mapcommands_ttl_list)rlrrrs r__init__z_LocalCache.__init__s8 ! . ] +C 0!#rrgrarhc4t|j|jk\r|jt|t |t tjtdi|j|<|j|||jj|y)a3 Set a redis command and its response in the cache. Args: command (Union[str, Sequence[str]]): The redis command. response (ResponseT): The response associated with the command. keys_in_command (List[KeyT]): The list of keys used in the command. rN) lenrr_evict _RESPONSE_KEYS_CTIMEtime monotonic _ACCESS_COUNT_update_key_commands_maprappendrks rrmz_LocalCache.setsr tzz?dmm + KKM x ? DNN$ 1   7 %%ow? %%g.rrnc||jvrY|j|r|j|y|j|t j |j|dSy)a  Get the response for a redis command from the cache. Args: command (Union[str, Sequence[str]]): The redis command. Returns: ResponseT: The response associated with the command, or None if the command is not in the cache. # noqa Nra)r _is_expiredrt_update_accesscopydeepcopyrps rrqz_LocalCache.gets_ djj (##G,    (==G!4Z!@A A !rc||jvrY|j|jd}|j|||jj ||j|=yy)z Delete a redis command and its metadata from the cache. Args: command (Union[str, Sequence[str]]): The redis command to be deleted. rbN)rrq_del_key_commands_maprremove)rlrgrhs rrtz_LocalCache.delete_commands^ djj "jj155f=O  & & @  " " ) )' 2 7# !rruc4|D]}|j|y)z Delete multiple commands and their metadata from the cache. Args: commands (List[Union[str, Sequence[str]]]): The list of commands to be deleted. N)rt)rlrurgs rrwz_LocalCache.delete_commandss G    ( rcz|jj|jjg|_y)zAClear the entire cache, removing all redis commands and metadata.N)rclearrrrys rrzz_LocalCache.flush(s,  ##%!#rc|jdk(rytj|j|dz |jkDS)z Check if a redis command has expired based on its time-to-live. Args: command (Union[str, Sequence[str]]): The redis command. Returns: bool: True if the command has expired, False otherwise. rFrc)rrrrrps rrz_LocalCache._is_expired.s; 88q=~~$**W"5g">>IIrc|jtjk(r|jj |y|jtj k(r[|jj |ij dddz|j|d<|jj |y|jtjk(ryy)z Update the access information for a redis command based on the eviction policy. Args: command (Union[str, Sequence[str]]): The redis command. rdrN)rrrr move_to_endrrqrrps rrz_LocalCache._update_access<s   >#5#5 5 JJ " "7 +  ! !^%7%7 7 w+//BQF JJw  / JJ " "7 +  ! !^%:%: : ;rcxjjdrjjdyjtj k(rj jdyjtjk(r6tj fd}j j|yjtjk(rRtjtj j}j j|yy)zBEvict a redis command from the cache based on the eviction policy.rF)lastcBj|jddS)Nrdr)rrq)krls rz$_LocalCache._evict..Us$**Q-*;*;NA*Nr)r{N)rrrtrrrrpopitemrminpoprrchoicelistrb)rlmin_access_commandrandom_commands` rrz_LocalCache._evictMs   D2215 6    6 6q 9 :  ! !^%7%7 7 JJ  E  *  ! !^%7%7 7!$ N"  JJNN- .  ! !^%:%: :#]]4 0A+BCN JJNN> *;rrbcN|D] }|j|j|"y)z Update the key_commands_map with command that uses the keys. Args: keys (List[KeyT]): The list of keys used in the command. command (Union[str, Sequence[str]]): The redis command. N)raddrlrbrgr{s rrz$_LocalCache._update_key_commands_map\s'C  ! !# & * *7 3rcN|D] }|j|j|"y)z Remove a redis command from the key_commands_map. Args: keys (List[KeyT]): The list of keys used in the redis command. command (Union[str, Sequence[str]]): The redis command. N)rrrs rrz!_LocalCache._del_key_commands_mapis'C  ! !# & - -g 6rr{c||jvryt|j|}|D]}|j|y)z Invalidate (delete) all redis commands associated with a specific key. Args: key (KeyT): The key to be invalidated. N)rrrt)rlr{rurgs rr}z_LocalCache.invalidate_keyvsB d++ + --c23G    ( rN)rrrr~DEFAULT_EVICTION_POLICYintrrr rr r rr rmrqrtrwrzboolrrrrrr}rrrrrse&*A $ $ $( $/sHSM)*//d /2B5hsm!34BB" $eC#,>&? $ )U3 3E-F(G )$ J5hsm);#< J JeC#,>&?" + 4J 4).sHSM/A)B 4 7J 7).sHSM/A)B 7 )$ )rr)rrrabcrr collectionsrrenumrtypingrr r redis.typingr r rrrDEFAULT_DENY_LISTDEFAULT_ALLOW_LISTrrrrrfrrrrrs~ #0(((T ),,:xKZ    ! C! Hz)-z)r