+hSTddlmZddlmZddlmZmZdZdZdZ dZ dZ d Z d Z d Zd Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"d Z#d!Z$d"Z%d#Z&d$Z'd%Z(d&Z)d'Z*d(Z+d)Z,d*Z-d+Z.d,Z/d-Z0d.Z1d/Z2d0Z3d1Z4d2Z5d3Z6d4Z7Gd5d6Z8Gd7d8Z9Gd9d:Z:Gd;d<Z;Gd=d>Z`_. )append_expansionappend_no_scaleexecute_command BF_RESERVE)selfkey errorRatecapacity expansionnoScaleparamss M/var/www/html/venv/lib/python3.12/site-packages/redis/commands/bf/commands.pycreatezBFCommands.create?sHy(+ fi0 VW-#t##J888c0|jt||S)z Add to a Bloom Filter `key` an `item`. For more information see `BF.ADD `_. )r BF_ADDrritems raddzBFCommands.addM ##FC66rc2|jt|g|S)z Add to a Bloom Filter `key` multiple `items`. For more information see `BF.MADD `_. )r BF_MADDrritemss rmaddzBFCommands.maddTs $t##GS9599rc|g}|j|||j|||j|||j|||j |||j |||j tg|S)as Add to a Bloom Filter `key` multiple `items`. If `nocreate` remain `None` and `key` does not exist, a new Bloom Filter `key` will be created with desired probability of false positives `errorRate` and expected entries to be inserted as `size`. For more information see `BF.INSERT `_. )append_capacity append_errorr append_no_creater append_itemsr BF_INSERT) rrr!rerrornoCreaterrrs rinsertzBFCommands.insert[s$ VX. &%( fi0 fh/ VW- &%(#t##I777rc0|jt||S)z Check whether an `item` exists in Bloom Filter `key`. For more information see `BF.EXISTS `_. )r BF_EXISTSrs rexistszBFCommands.existsw ##IsD99rc2|jt|g|S)z Check whether `items` exist in Bloom Filter `key`. For more information see `BF.MEXISTS `_. )r BF_MEXISTSr s rmexistszBFCommands.mexists~ $t##J`_. z6This command cannot be used when hiredis is available.)rrrr BF_SCANDUMP)rriterroptionss rscandumpzBFCommands.scandumpsH VW Wt " #t##KD&DGDDrc2|jt|||S)ai Restore a filter previously saved using SCANDUMP. See the SCANDUMP command for example usage. This command will overwrite any bloom filter stored under key. Ensure that the bloom filter will not be modified between invocations. For more information see `BF.LOADCHUNK `_. )r BF_LOADCHUNKrrr6datas r loadchunkzBFCommands.loadchunks##L#tTBBrc.|jt|S)z Return capacity, size, number of filters, number of items inserted, and expansion rate. For more information see `BF.INFO `_. )r BF_INFOrrs rinfozBFCommands.infos ##GS11rc.|jt|S)a* Returns the cardinality of a Bloom filter - number of items that were added to a Bloom filter and detected as unique (items that caused at least one bit to be set in at least one sub-filter). For more information see `BF.CARD `_. )r BF_CARDr@s rcardzBFCommands.card ##GS11rNN)NNNNN)__name__ __module__ __qualname____doc__rreserverr"r+r.r2r8r=rArDrrrr<sQ  9G7:88:=E" C22rrcdeZdZdZ ddZeZdZdZddZddZ dZ d Z d Z d Z d Zd ZdZy) CFCommandszCuckoo Filter commands.Nc||g}|j|||j|||j|||jtg|S)z Create a new Cuckoo Filter `key` an initial `capacity` items. For more information see `CF.RESERVE `_. )r append_bucket_sizeappend_max_iterationsr CF_RESERVE)rrrr bucket_sizemax_iterationsrs rrzCFCommands.createsUx fi0  4 ""6>:#t##J888rc0|jt||S)z Add an `item` to a Cuckoo Filter `key`. For more information see `CF.ADD `_. )r CF_ADDrs rrzCFCommands.addrrc0|jt||S)z Add an `item` to a Cuckoo Filter `key` only if item does not yet exist. Command might be slower that `add`. For more information see `CF.ADDNX `_. )r CF_ADDNXrs raddnxzCFCommands.addnxs ##Hc488rc|g}|j|||j|||j|||jtg|S)a Add multiple `items` to a Cuckoo Filter `key`, allowing the filter to be created with a custom `capacity` if it does not yet exist. `items` must be provided as a list. For more information see `CF.INSERT `_. )r$r&r'r CF_INSERTrrr!rnocreaters rr+zCFCommands.insertsS VX. fh/ &%(#t##I777rc|g}|j|||j|||j|||jtg|S)a@ Add multiple `items` to a Cuckoo Filter `key` only if they do not exist yet, allowing the filter to be created with a custom `capacity` if it does not yet exist. `items` must be provided as a list. For more information see `CF.INSERTNX `_. )r$r&r'r CF_INSERTNXr\s rinsertnxzCFCommands.insertnxsS VX. fh/ &%(#t##K9&99rc0|jt||S)z Check whether an `item` exists in Cuckoo Filter `key`. For more information see `CF.EXISTS `_. )r CF_EXISTSrs rr.zCFCommands.existsr/rc2|jt|g|S)z Check whether an `items` exist in Cuckoo Filter `key`. For more information see `CF.MEXISTS `_. )r CF_MEXISTSr s rr2zCFCommands.mexistsr3rc0|jt||S)zz Delete `item` from `key`. For more information see `CF.DEL `_. )r CF_DELrs rdeletezCFCommands.deleterrc0|jt||S)z Return the number of times an `item` may be in the `key`. For more information see `CF.COUNT `_. )r CF_COUNTrs rcountzCFCommands.counts ##Hc488rc0|jt||S)a Begin an incremental save of the Cuckoo filter `key`. This is useful for large Cuckoo filters which cannot fit into the normal SAVE and RESTORE model. The first time this command is called, the value of `iter` should be 0. This command will return successive (iter, data) pairs until (0, NULL) to indicate completion. For more information see `CF.SCANDUMP `_. )r CF_SCANDUMP)rrr6s rr8zCFCommands.scandumps##Kd;;rc2|jt|||S)ac Restore a filter previously saved using SCANDUMP. See the SCANDUMP command for example usage. This command will overwrite any Cuckoo filter stored under key. Ensure that the Cuckoo filter will not be modified between invocations. For more information see `CF.LOADCHUNK `_. )r CF_LOADCHUNKr;s rr=zCFCommands.loadchunks##L#tTBBrc.|jt|S)z Return size, number of buckets, number of filter, number of items inserted, number of items deleted, bucket size, expansion rate, and max iteration. For more information see `CF.INFO `_. )r CF_INFOr@s rrAzCFCommands.inforEr)NNNrF)rGrHrIrJrrKrrYr+r`r.r2rgrjr8r=rArLrrrNrNsP!OS 9G79 8 ::=79 <C2rrNcVeZdZdZdZdZdZdZeddd Z d d Z d Z y ) TOPKCommandszTOP-k Filter commands.c6|jt|||||S)z Create a new Top-K Filter `key` with desired probability of false positives `errorRate` expected entries to be inserted as `size`. For more information see `TOPK.RESERVE `_. )r TOPK_RESERVE)rrkwidthdepthdecays rrKzTOPKCommands.reserve+s ##L#q%NNrc2|jt|g|S)z Add one `item` or more to a Top-K Filter `key`. For more information see `TOPK.ADD `_. )r TOPK_ADDr s rrzTOPKCommands.add3s $t##Hc:E::rc\|g}|j||||jtg|S)a Add/increase `items` to a Top-K Sketch `key` by ''increments''. Both `items` and `increments` are lists. For more information see `TOPK.INCRBY `_. Example: >>> topkincrby('A', ['foo'], [1]) )append_items_and_incrementsr TOPK_INCRBYrrr! incrementsrs rincrbyzTOPKCommands.incrby:s5 (( C#t##K9&99rc2|jt|g|S)z Check whether one `item` or more is a Top-K item at `key`. For more information see `TOPK.QUERY `_. )r TOPK_QUERYr s rqueryzTOPKCommands.queryHr3rz4.4.0z!deprecated since redisbloom 2.4.0)versionreasonc2|jt|g|S)z Return count for one `item` or more from `key`. For more information see `TOPK.COUNT `_. )r TOPK_COUNTr s rrjzTOPKCommands.countOs $t##J`_. WITHCOUNT)appendr TOPK_LIST)rr withcountrs rlistzTOPKCommands.listWs2  MM+ &#t##I777rc.|jt|S)z Return k, width, depth and decay values of `key`. For more information see `TOPK.INFO `_. )r TOPK_INFOr@s rrAzTOPKCommands.infocs ##Is33rN)F) rGrHrIrJrKrrrrrjrrArLrrrrrr(sA O; :=1TU=V= 84rrrcjeZdZddZdZdZddddZdZd Zd Z d Z d Z d Z dZ dZdZdZy)TDigestCommandsc2|jt|d|S)z Allocate the memory and initialize the t-digest. For more information see `TDIGEST.CREATE `_. COMPRESSION)r TDIGEST_CREATE)rr compressions rrzTDigestCommands.createls ##NC TTrc.|jt|S)z Reset the sketch `key` to zero - empty out the sketch and re-initialize it. For more information see `TDIGEST.RESET `_. )r TDIGEST_RESETr@s rresetzTDigestCommands.resetss ##M377rc2|jt|g|S)z Adds one or more observations to a t-digest sketch `key`. For more information see `TDIGEST.ADD `_. )r TDIGEST_ADD)rrvaluess rrzTDigestCommands.addzs $t##K>v>>rNF)roverridec||g|}||jd|g|r|jd|jtg|S)a Merges all of the values from `keys` to 'destination-key' sketch. It is mandatory to provide the `num_keys` before passing the input keys and the other (optional) arguments. If `destination_key` already exists its values are merged with the input keys. If you wish to override the destination key contents use the `OVERRIDE` parameter. For more information see `TDIGEST.MERGE `_. rOVERRIDE)extendrr TDIGEST_MERGE)rdestination_keynum_keysrrkeysrs rmergezTDigestCommands.mergesQ"83d3  " MM=+6 7  MM* %#t##M;F;;rc.|jt|S)z Return minimum value from the sketch `key`. Will return DBL_MAX if the sketch is empty. For more information see `TDIGEST.MIN `_. )r TDIGEST_MINr@s rminzTDigestCommands.min ##K55rc.|jt|S)z Return maximum value from the sketch `key`. Will return DBL_MIN if the sketch is empty. For more information see `TDIGEST.MAX `_. )r TDIGEST_MAXr@s rmaxzTDigestCommands.maxrrc4|jt||g|S)ah Returns estimates of one or more cutoffs such that a specified fraction of the observations added to this t-digest would be less than or equal to each of the specified cutoffs. (Multiple quantiles can be returned with one call) For more information see `TDIGEST.QUANTILE `_. )r TDIGEST_QUANTILE)rrquantile quantiless rrzTDigestCommands.quantiles!$t##$4c8PiPPrc4|jt||g|S)z Return double fraction of all points added which are <= value. For more information see `TDIGEST.CDF `_. )r TDIGEST_CDFrrvaluers rcdfzTDigestCommands.cdfs $t##KeEfEErc.|jt|S)z Return Compression, Capacity, Merged Nodes, Unmerged Nodes, Merged Weight, Unmerged Weight and Total Compressions. For more information see `TDIGEST.INFO `_. )r TDIGEST_INFOr@s rrAzTDigestCommands.infos ##L#66rc2|jt|||S)z Return mean value from the sketch, excluding observation values outside the low and high cutoff quantiles. For more information see `TDIGEST.TRIMMED_MEAN `_. )r TDIGEST_TRIMMED_MEAN)rrlow_cut_quantilehigh_cut_quantiles r trimmed_meanzTDigestCommands.trimmed_means" ## #'79J  rc4|jt||g|S)a Retrieve the estimated rank of value (the number of observations in the sketch that are smaller than value + half the number of observations that are equal to value). For more information see `TDIGEST.RANK `_. )r TDIGEST_RANKrs rrankzTDigestCommands.ranks $t##L#uFvFFrc4|jt||g|S)a! Retrieve the estimated rank of value (the number of observations in the sketch that are larger than value + half the number of observations that are equal to value). For more information see `TDIGEST.REVRANK `_. )r TDIGEST_REVRANKrs rrevrankzTDigestCommands.revranks $t##OS%I&IIrc4|jt||g|S)z Retrieve an estimation of the value with the given rank. For more information see `TDIGEST.BY_RANK `_. )r TDIGEST_BYRANKrrrrankss rbyrankzTDigestCommands.byranks $t##NCFFFrc4|jt||g|S)z Retrieve an estimation of the value with the given reverse rank. For more information see `TDIGEST.BY_REVRANK `_. )r TDIGEST_BYREVRANKrs r byrevrankzTDigestCommands.byrevranks! $t##$5sDI5IIr)d)rGrHrIrrrrrrrrrArrrrrrLrrrrksYU8?CGQV<"66QF7 GJGJrrc8eZdZdZdZdZdZdZgfdZdZ y) CMSCommandszCount-Min Sketch Commandsc2|jt|||S)z Initialize a Count-Min Sketch `key` to dimensions (`width`, `depth`) specified by user. For more information see `CMS.INITBYDIM `_. )r CMS_INITBYDIM)rrrvrws r initbydimzCMSCommands.initbydims ##M3uEErc2|jt|||S)z Initialize a Count-Min Sketch `key` to characteristics (`error`, `probability`) specified by user. For more information see `CMS.INITBYPROB `_. )r CMS_INITBYPROB)rrr) probabilitys r initbyprobzCMSCommands.initbyprobs ##NC LLrc\|g}|j||||jtg|S)a Add/increase `items` to a Count-Min Sketch `key` by ''increments''. Both `items` and `increments` are lists. For more information see `CMS.INCRBY `_. Example: >>> cmsincrby('A', ['foo'], [1]) )r|r CMS_INCRBYr~s rrzCMSCommands.incrbys5 (( C#t##J888rc2|jt|g|S)z Return count for an `item` from `key`. Multiple items can be queried with one call. For more information see `CMS.QUERY `_. )r CMS_QUERYr s rrzCMSCommands.querys $t##Is;U;;rcf||g}||z }|j|||jtg|S)an Merge `numKeys` of sketches into `destKey`. Sketches specified in `srcKeys`. All sketches must have identical width and depth. `Weights` can be used to multiply certain sketches. Default weight is 1. Both `srcKeys` and `weights` are lists. For more information see `CMS.MERGE `_. )append_weightsr CMS_MERGE)rdestKeynumKeyssrcKeysweightsrs rrzCMSCommands.merge s@7#' FG,#t##I777rc.|jt|S)z Return width, depth and total count of the sketch. For more information see `CMS.INFO `_. )r CMS_INFOr@s rrAzCMSCommands.infos ##Hc22rN) rGrHrIrJrrrrrrArLrrrrs*#FM 9<8: 83rrN)= redis.clientrredis.exceptionsr redis.utilsrrr rrr(r-r1r5r:r?rCrRrVrXr[r_rbrdrfrirlrnrprrrrrrrtrzr}rrrrrrrrrrrrrrrrrrrrNrrrrrLrrrsF%(>                      !          !    %   - #!'r2r2jt2t2n@4@4FxJxJv8383r