jakub 9 months ago
parent 8f2c8d3cff
commit fca9963b37
  1. 56
      client/css/game.css
  2. 2
      client/css/game.css.map
  3. 39
      client/css/game.scss
  4. 46
      client/css/main.css
  5. 2
      client/css/main.css.map
  6. 46
      client/css/main.scss
  7. 31
      client/game.html
  8. 3
      client/javascript/communication.js
  9. 10
      client/new.html
  10. BIN
      client/resources/fonts/Pacifico-Regular.ttf
  11. BIN
      client/resources/fonts/PoetsenOne-Regular.ttf
  12. 3
      server/communication.js
  13. 102
      server/node_modules/.package-lock.json
  14. 14
      server/node_modules/@redis/bloom/README.md
  15. 3
      server/node_modules/@redis/bloom/dist/commands/bloom/ADD.d.ts
  16. 10
      server/node_modules/@redis/bloom/dist/commands/bloom/ADD.js
  17. 4
      server/node_modules/@redis/bloom/dist/commands/bloom/CARD.d.ts
  18. 9
      server/node_modules/@redis/bloom/dist/commands/bloom/CARD.js
  19. 4
      server/node_modules/@redis/bloom/dist/commands/bloom/EXISTS.d.ts
  20. 11
      server/node_modules/@redis/bloom/dist/commands/bloom/EXISTS.js
  21. 23
      server/node_modules/@redis/bloom/dist/commands/bloom/INFO.d.ts
  22. 19
      server/node_modules/@redis/bloom/dist/commands/bloom/INFO.js
  23. 11
      server/node_modules/@redis/bloom/dist/commands/bloom/INSERT.d.ts
  24. 28
      server/node_modules/@redis/bloom/dist/commands/bloom/INSERT.js
  25. 4
      server/node_modules/@redis/bloom/dist/commands/bloom/LOADCHUNK.d.ts
  26. 8
      server/node_modules/@redis/bloom/dist/commands/bloom/LOADCHUNK.js
  27. 3
      server/node_modules/@redis/bloom/dist/commands/bloom/MADD.d.ts
  28. 10
      server/node_modules/@redis/bloom/dist/commands/bloom/MADD.js
  29. 4
      server/node_modules/@redis/bloom/dist/commands/bloom/MEXISTS.d.ts
  30. 11
      server/node_modules/@redis/bloom/dist/commands/bloom/MEXISTS.js
  31. 8
      server/node_modules/@redis/bloom/dist/commands/bloom/RESERVE.d.ts
  32. 15
      server/node_modules/@redis/bloom/dist/commands/bloom/RESERVE.js
  33. 13
      server/node_modules/@redis/bloom/dist/commands/bloom/SCANDUMP.d.ts
  34. 16
      server/node_modules/@redis/bloom/dist/commands/bloom/SCANDUMP.js
  35. 33
      server/node_modules/@redis/bloom/dist/commands/bloom/index.d.ts
  36. 34
      server/node_modules/@redis/bloom/dist/commands/bloom/index.js
  37. 8
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/INCRBY.d.ts
  38. 20
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/INCRBY.js
  39. 17
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/INFO.d.ts
  40. 17
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/INFO.js
  41. 3
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/INITBYDIM.d.ts
  42. 8
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/INITBYDIM.js
  43. 3
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/INITBYPROB.d.ts
  44. 8
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/INITBYPROB.js
  45. 9
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/MERGE.d.ts
  46. 28
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/MERGE.js
  47. 5
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/QUERY.d.ts
  48. 10
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/QUERY.js
  49. 21
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/index.d.ts
  50. 22
      server/node_modules/@redis/bloom/dist/commands/count-min-sketch/index.js
  51. 3
      server/node_modules/@redis/bloom/dist/commands/cuckoo/ADD.d.ts
  52. 10
      server/node_modules/@redis/bloom/dist/commands/cuckoo/ADD.js
  53. 3
      server/node_modules/@redis/bloom/dist/commands/cuckoo/ADDNX.d.ts
  54. 10
      server/node_modules/@redis/bloom/dist/commands/cuckoo/ADDNX.js
  55. 3
      server/node_modules/@redis/bloom/dist/commands/cuckoo/COUNT.d.ts
  56. 8
      server/node_modules/@redis/bloom/dist/commands/cuckoo/COUNT.js
  57. 3
      server/node_modules/@redis/bloom/dist/commands/cuckoo/DEL.d.ts
  58. 10
      server/node_modules/@redis/bloom/dist/commands/cuckoo/DEL.js
  59. 4
      server/node_modules/@redis/bloom/dist/commands/cuckoo/EXISTS.d.ts
  60. 11
      server/node_modules/@redis/bloom/dist/commands/cuckoo/EXISTS.js
  61. 32
      server/node_modules/@redis/bloom/dist/commands/cuckoo/INFO.d.ts
  62. 22
      server/node_modules/@redis/bloom/dist/commands/cuckoo/INFO.js
  63. 5
      server/node_modules/@redis/bloom/dist/commands/cuckoo/INSERT.d.ts
  64. 11
      server/node_modules/@redis/bloom/dist/commands/cuckoo/INSERT.js
  65. 5
      server/node_modules/@redis/bloom/dist/commands/cuckoo/INSERTNX.d.ts
  66. 11
      server/node_modules/@redis/bloom/dist/commands/cuckoo/INSERTNX.js
  67. 4
      server/node_modules/@redis/bloom/dist/commands/cuckoo/LOADCHUNK.d.ts
  68. 8
      server/node_modules/@redis/bloom/dist/commands/cuckoo/LOADCHUNK.js
  69. 9
      server/node_modules/@redis/bloom/dist/commands/cuckoo/RESERVE.d.ts
  70. 18
      server/node_modules/@redis/bloom/dist/commands/cuckoo/RESERVE.js
  71. 12
      server/node_modules/@redis/bloom/dist/commands/cuckoo/SCANDUMP.d.ts
  72. 15
      server/node_modules/@redis/bloom/dist/commands/cuckoo/SCANDUMP.js
  73. 42
      server/node_modules/@redis/bloom/dist/commands/cuckoo/index.d.ts
  74. 51
      server/node_modules/@redis/bloom/dist/commands/cuckoo/index.js
  75. 111
      server/node_modules/@redis/bloom/dist/commands/index.d.ts
  76. 14
      server/node_modules/@redis/bloom/dist/commands/index.js
  77. 4
      server/node_modules/@redis/bloom/dist/commands/t-digest/ADD.d.ts
  78. 12
      server/node_modules/@redis/bloom/dist/commands/t-digest/ADD.js
  79. 5
      server/node_modules/@redis/bloom/dist/commands/t-digest/BYRANK.d.ts
  80. 15
      server/node_modules/@redis/bloom/dist/commands/t-digest/BYRANK.js
  81. 5
      server/node_modules/@redis/bloom/dist/commands/t-digest/BYREVRANK.d.ts
  82. 15
      server/node_modules/@redis/bloom/dist/commands/t-digest/BYREVRANK.js
  83. 5
      server/node_modules/@redis/bloom/dist/commands/t-digest/CDF.d.ts
  84. 15
      server/node_modules/@redis/bloom/dist/commands/t-digest/CDF.js
  85. 5
      server/node_modules/@redis/bloom/dist/commands/t-digest/CREATE.d.ts
  86. 9
      server/node_modules/@redis/bloom/dist/commands/t-digest/CREATE.js
  87. 31
      server/node_modules/@redis/bloom/dist/commands/t-digest/INFO.d.ts
  88. 24
      server/node_modules/@redis/bloom/dist/commands/t-digest/INFO.js
  89. 5
      server/node_modules/@redis/bloom/dist/commands/t-digest/MAX.d.ts
  90. 14
      server/node_modules/@redis/bloom/dist/commands/t-digest/MAX.js
  91. 9
      server/node_modules/@redis/bloom/dist/commands/t-digest/MERGE.d.ts
  92. 15
      server/node_modules/@redis/bloom/dist/commands/t-digest/MERGE.js
  93. 5
      server/node_modules/@redis/bloom/dist/commands/t-digest/MIN.d.ts
  94. 14
      server/node_modules/@redis/bloom/dist/commands/t-digest/MIN.js
  95. 5
      server/node_modules/@redis/bloom/dist/commands/t-digest/QUANTILE.d.ts
  96. 18
      server/node_modules/@redis/bloom/dist/commands/t-digest/QUANTILE.js
  97. 5
      server/node_modules/@redis/bloom/dist/commands/t-digest/RANK.d.ts
  98. 13
      server/node_modules/@redis/bloom/dist/commands/t-digest/RANK.js
  99. 4
      server/node_modules/@redis/bloom/dist/commands/t-digest/RESET.d.ts
  100. 8
      server/node_modules/@redis/bloom/dist/commands/t-digest/RESET.js
  101. Some files were not shown because too many files have changed in this diff Show More

@ -1,3 +1,41 @@
#menu {
position: absolute;
top: 50%;
left: 50%;
translate: -50% -50%;
}
#menu h1 {
text-align: center;
font-size: 50px;
margin: 10px;
color: rgb(97, 47, 0);
}
#menu .box {
background: rgb(180, 124, 52);
box-shadow: 0 0 70px rgba(0, 0, 0, 0.7);
padding: 10px 25px;
border-radius: 8px;
display: box;
}
#menu .box input {
display: block;
margin: 15px;
padding: 10px 0px;
font-size: 22px;
width: 250px !important;
margin-left: auto;
margin-right: auto;
}
#menu .box button {
display: block;
margin: 15px;
padding: 10px 20px;
font-size: 22px;
width: 250px;
margin-left: auto;
margin-right: auto;
}
#pieces-area {
width: 100%;
height: 100%;
@ -66,4 +104,22 @@
}
#game #playfield .row:nth-child(odd) .tile:nth-child(odd) {
background: black;
}
@keyframes invalid-move-animation {
0% {
transform: translateX(0);
}
25% {
transform: translateX(5px);
}
50% {
transform: translateX(-5px);
}
75% {
transform: translateX(5px);
}
100% {
transform: translateX(0);
}
}/*# sourceMappingURL=game.css.map */

@ -1 +1 @@
{"version":3,"sources":["game.scss","game.css"],"names":[],"mappings":"AAAA;EAGI,WAAA;EACA,YAAA;EACA,kBAAA;ACDJ;ADGI;EACI,WAAA;EACA,kBAAA;EACA,eAAA;EACA,2BAAA;EACA,qBAAA;EACA,4BAAA;EACA,yBAAA;EACA,8BAAA;EACA,kEAAA;EACA,UAAA;EACA,kBAAA;EAEA,eAAA;ACFR;ADGQ;EACI,qCAAA;EACA,0CAAA;ACDZ;ADIY;EACI,4DAAA;ACFhB;ADIY;EACI,4DAAA;ACFhB;ADOY;EACI,4DAAA;ACLhB;ADOY;EACI,4DAAA;ACLhB;;ADWI;EACI,6BAAA;EACA,aAAA;EACA,wCAAA;EACA,YAAA;EACA,kBAAA;EACA,uBAAA;EAAA,kBAAA;EACA,kBAAA;ACRR;ADSQ;EACI,qBAAA;ACPZ;ADQY;EACI,kBAAA;EACA,WAAA;EACA,kBAAA;EACA,eAAA;EACA,WAAA;EACA,eAAA;EACA,iBAAA;ACNhB;ADQgB;EACI,iBAAA;EACA,qDAAA;ACNpB;ADUgB;EACI,iBAAA;EACA,qDAAA;ACRpB;ADUgB;EACI,iBAAA;ACRpB","file":"game.css"}
{"version":3,"sources":["game.scss","game.css"],"names":[],"mappings":"AAAA;EACI,kBAAA;EACA,QAAA;EACA,SAAA;EACA,oBAAA;ACCJ;ADAI;EACI,kBAAA;EACA,eAAA;EACA,YAAA;EACA,qBAAA;ACER;ADAI;EACI,6BAAA;EACA,uCAAA;EACA,kBAAA;EACA,kBAAA;EACA,YAAA;ACER;ADDQ;EACI,cAAA;EACA,YAAA;EACA,iBAAA;EACA,eAAA;EACA,uBAAA;EACA,iBAAA;EACA,kBAAA;ACGZ;ADDQ;EACI,cAAA;EACA,YAAA;EACA,kBAAA;EACA,eAAA;EACA,YAAA;EACA,iBAAA;EACA,kBAAA;ACGZ;;ADGA;EAGI,WAAA;EACA,YAAA;EACA,kBAAA;ACFJ;ADII;EACI,WAAA;EACA,kBAAA;EACA,eAAA;EACA,2BAAA;EACA,qBAAA;EACA,4BAAA;EACA,yBAAA;EACA,8BAAA;EACA,kEAAA;EACA,UAAA;EACA,kBAAA;EAEA,eAAA;ACHR;ADIQ;EACI,qCAAA;EACA,0CAAA;ACFZ;ADKY;EACI,4DAAA;ACHhB;ADKY;EACI,4DAAA;ACHhB;ADQY;EACI,4DAAA;ACNhB;ADQY;EACI,4DAAA;ACNhB;;ADaI;EACI,6BAAA;EACA,aAAA;EACA,wCAAA;EACA,YAAA;EACA,kBAAA;EACA,uBAAA;EAAA,kBAAA;EACA,kBAAA;ACVR;ADWQ;EACI,qBAAA;ACTZ;ADUY;EACI,kBAAA;EACA,WAAA;EACA,kBAAA;EACA,eAAA;EACA,WAAA;EACA,eAAA;EACA,iBAAA;ACRhB;ADUgB;EACI,iBAAA;EACA,qDAAA;ACRpB;ADYgB;EACI,iBAAA;EACA,qDAAA;ACVpB;ADYgB;EACI,iBAAA;ACVpB;;ADmBA;EACI;IAAK,wBAAA;ECfP;EDgBE;IAAM,0BAAA;ECbR;EDcE;IAAM,2BAAA;ECXR;EDYE;IAAM,0BAAA;ECTR;EDUE;IAAO,wBAAA;ECPT;AACF","file":"game.css"}

@ -1,3 +1,42 @@
#menu{
position: absolute;
top: 50%;
left: 50%;
translate: -50% -50%;
h1{
text-align: center;
font-size: 50px;
margin: 10px;
color: rgb(97, 47, 0);
}
.box{
background: rgb(180, 124, 52);
box-shadow: 0 0 70px rgba(0,0,0,0.7);
padding: 10px 25px;
border-radius: 8px;
display: box;
input{
display:block;
margin: 15px;
padding: 10px 0px;
font-size: 22px;
width: 250px !important;
margin-left: auto;
margin-right: auto;
}
button{
display:block;
margin: 15px;
padding: 10px 20px;
font-size: 22px;
width: 250px;
margin-left: auto;
margin-right: auto;
}
}
}
#pieces-area{

@ -1,8 +1,54 @@
@font-face {
font-family: pacifico;
src: url("./../resources/fonts/Pacifico-Regular.ttf");
}
@font-face {
font-family: PoetsenOne;
src: url("./../resources/fonts/PoetsenOne-Regular.ttf");
}
body {
font-family: PoetsenOne;
background-color: rgb(223, 201, 172);
margin: 0;
padding: 0;
}
body h1 {
font-family: Pacifico;
}
body input {
font-family: PoetsenOne;
cursor: pointer;
padding: 5px 20px;
font-size: 18px;
border-radius: 5px;
text-align: center;
width: -moz-fit-content;
width: fit-content;
box-shadow: 3px 5px 10px rgba(0, 0, 0, 0.5) inset;
background: rgba(255, 255, 255, 0.3);
border: none;
}
body input:focus {
background: rgba(255, 255, 255, 0.5);
outline: none;
}
body button {
font-family: PoetsenOne;
cursor: pointer;
padding: 5px 20px;
font-size: 18px;
border: none;
border-radius: 5px;
background: linear-gradient(45deg, rgb(204, 150, 34), rgb(236, 199, 119));
box-shadow: 3px 3px 10px rgba(0, 0, 0, 0.4);
transition: 0.2s;
}
body button:hover {
box-shadow: 5px 10px 10px rgba(0, 0, 0, 0.4);
}
body button:active {
scale: 0.9;
}
body #game {
position: absolute;
top: 50%;

@ -1 +1 @@
{"version":3,"sources":["main.scss","main.css"],"names":[],"mappings":"AAAA;EACI,oCAAA;EACA,SAAA;EACA,UAAA;ACCJ;ADAI;EACI,kBAAA;EACA,QAAA;EACA,SAAA;EACA,oBAAA;ACER","file":"main.css"}
{"version":3,"sources":["main.scss","main.css"],"names":[],"mappings":"AAAA;EACI,qBAAA;EACA,qDAAA;ACCJ;ADCA;EACI,uBAAA;EACA,uDAAA;ACCJ;ADEA;EACI,uBAAA;EACA,oCAAA;EACA,SAAA;EACA,UAAA;ACAJ;ADCI;EACI,qBAAA;ACCR;ADCI;EACI,uBAAA;EACA,eAAA;EACA,iBAAA;EACA,eAAA;EACA,kBAAA;EACA,kBAAA;EACA,uBAAA;EAAA,kBAAA;EACA,iDAAA;EACA,oCAAA;EACA,YAAA;ACCR;ADAQ;EACI,oCAAA;EACA,aAAA;ACEZ;ADCI;EACI,uBAAA;EACA,eAAA;EACA,iBAAA;EACA,eAAA;EACA,YAAA;EACA,kBAAA;EACA,yEAAA;EACA,2CAAA;EACA,gBAAA;ACCR;ADAQ;EACI,4CAAA;ACEZ;ADAQ;EACI,UAAA;ACEZ;ADCI;EACI,kBAAA;EACA,QAAA;EACA,SAAA;EACA,oBAAA;ACCR","file":"main.css"}

@ -1,7 +1,53 @@
@font-face {
font-family: pacifico;
src: url('./../resources/fonts/Pacifico-Regular.ttf');
}
@font-face {
font-family: PoetsenOne;
src: url('./../resources/fonts/PoetsenOne-Regular.ttf');
}
body{
font-family: PoetsenOne;
background-color: rgb(223, 201, 172);
margin: 0;
padding: 0;
h1{
font-family: Pacifico;
}
input{
font-family: PoetsenOne;
cursor: pointer;
padding: 5px 20px;
font-size: 18px;
border-radius: 5px;
text-align: center;
width: fit-content;
box-shadow: 3px 5px 10px rgba(0,0,0,0.5) inset;
background: rgba(255, 255, 255, 0.3);
border: none;
&:focus{
background: rgba(255, 255, 255, 0.5);
outline: none;
}
}
button{
font-family: PoetsenOne;
cursor: pointer;
padding: 5px 20px;
font-size: 18px;
border: none;
border-radius: 5px;
background: linear-gradient(45deg,rgb(204, 150, 34), rgb(236, 199, 119));
box-shadow: 3px 3px 10px rgba(0,0,0,0.4);
transition: 0.2s;
&:hover{
box-shadow: 5px 10px 10px rgba(0,0,0,0.4);
}
&:active{
scale: 0.9;
}
}
#game{
position: absolute;
top: 50%;

@ -0,0 +1,31 @@
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<title>Dáma Online</title>
<link rel="stylesheet" href="./css/game.css">
<link rel="stylesheet" href="./css/main.css">
</head>
<body>
<section id="game" class="invalid-move">
<div id="pieces-area"></div>
<div id="playfield"></div>
</section>
<section id="menu">
<h1>Dáma online</h1>
<div class="box">
<input type="text" name="nickname" id="nickname" placeholder="Zvoj si jméno">
<button>Začít Hrát</button>
<button>Seznam Místností</button>
<button>Založit místnost</button>
<button>Připojit se s kódem</button>
</div>
</section>
<script src="https://cdn.socket.io/4.8.1/socket.io.min.js"></script>
<script src="./javascript/game-logic.js"></script>
<script src="./javascript/communication.js"></script>
<script src="./javascript/client.js"></script>
</body>
</html>

@ -0,0 +1,3 @@
//const socket = io("ws://localhost:3000");
document.getElementById("game").style.display = "none";
document.getElementById("form").style.display = "block";

@ -24,6 +24,16 @@
</form>
<script>
const socket = io("ws://localhost:3000");
const form = document.getElementById('form');
const input = document.getElementById('input');
form.addEventListener('submit', (e) => {
e.preventDefault();
if (input.value) {
socket.emit('chat message', input.value);
input.value = '';
}
});
</script>
</body>
</html>

@ -14,6 +14,9 @@ io.on('connection', (socket) => {
socket.on('disconnect', () => {
console.log('user disconnected');
});
socket.on('chat message', (msg) => {
console.log('message: ' + msg);
});
});
server.listen(3000, () => {

@ -1,9 +1,68 @@
{
"name": "socket-chat-example",
"name": "dama-online-backend",
"version": "0.0.1",
"lockfileVersion": 3,
"requires": true,
"packages": {
"node_modules/@redis/bloom": {
"version": "1.2.0",
"resolved": "https://registry.npmjs.org/@redis/bloom/-/bloom-1.2.0.tgz",
"integrity": "sha512-HG2DFjYKbpNmVXsa0keLHp/3leGJz1mjh09f2RLGGLQZzSHpkmZWuwJbAvo3QcRY8p80m5+ZdXZdYOSBLlp7Cg==",
"license": "MIT",
"peerDependencies": {
"@redis/client": "^1.0.0"
}
},
"node_modules/@redis/client": {
"version": "1.6.0",
"resolved": "https://registry.npmjs.org/@redis/client/-/client-1.6.0.tgz",
"integrity": "sha512-aR0uffYI700OEEH4gYnitAnv3vzVGXCFvYfdpu/CJKvk4pHfLPEy/JSZyrpQ+15WhXe1yJRXLtfQ84s4mEXnPg==",
"license": "MIT",
"dependencies": {
"cluster-key-slot": "1.1.2",
"generic-pool": "3.9.0",
"yallist": "4.0.0"
},
"engines": {
"node": ">=14"
}
},
"node_modules/@redis/graph": {
"version": "1.1.1",
"resolved": "https://registry.npmjs.org/@redis/graph/-/graph-1.1.1.tgz",
"integrity": "sha512-FEMTcTHZozZciLRl6GiiIB4zGm5z5F3F6a6FZCyrfxdKOhFlGkiAqlexWMBzCi4DcRoyiOsuLfW+cjlGWyExOw==",
"license": "MIT",
"peerDependencies": {
"@redis/client": "^1.0.0"
}
},
"node_modules/@redis/json": {
"version": "1.0.7",
"resolved": "https://registry.npmjs.org/@redis/json/-/json-1.0.7.tgz",
"integrity": "sha512-6UyXfjVaTBTJtKNG4/9Z8PSpKE6XgSyEb8iwaqDcy+uKrd/DGYHTWkUdnQDyzm727V7p21WUMhsqz5oy65kPcQ==",
"license": "MIT",
"peerDependencies": {
"@redis/client": "^1.0.0"
}
},
"node_modules/@redis/search": {
"version": "1.2.0",
"resolved": "https://registry.npmjs.org/@redis/search/-/search-1.2.0.tgz",
"integrity": "sha512-tYoDBbtqOVigEDMAcTGsRlMycIIjwMCgD8eR2t0NANeQmgK/lvxNAvYyb6bZDD4frHRhIHkJu2TBRvB0ERkOmw==",
"license": "MIT",
"peerDependencies": {
"@redis/client": "^1.0.0"
}
},
"node_modules/@redis/time-series": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/@redis/time-series/-/time-series-1.1.0.tgz",
"integrity": "sha512-c1Q99M5ljsIuc4YdaCwfUEXsofakb9c8+Zse2qxTadu8TalLXuAESzLvFAvNVbkmSlvlzIQOLpBCmWI9wTOt+g==",
"license": "MIT",
"peerDependencies": {
"@redis/client": "^1.0.0"
}
},
"node_modules/@socket.io/component-emitter": {
"version": "3.1.2",
"resolved": "https://registry.npmjs.org/@socket.io/component-emitter/-/component-emitter-3.1.2.tgz",
@ -118,6 +177,15 @@
"url": "https://github.com/sponsors/ljharb"
}
},
"node_modules/cluster-key-slot": {
"version": "1.1.2",
"resolved": "https://registry.npmjs.org/cluster-key-slot/-/cluster-key-slot-1.1.2.tgz",
"integrity": "sha512-RMr0FhtfXemyinomL4hrWcYJxmX6deFdCxpJzhDttxgO1+bcCnkk+9drydLVDmAMG7NE6aN/fl4F7ucU/90gAA==",
"license": "Apache-2.0",
"engines": {
"node": ">=0.10.0"
}
},
"node_modules/content-disposition": {
"version": "0.5.4",
"resolved": "https://registry.npmjs.org/content-disposition/-/content-disposition-0.5.4.tgz",
@ -421,6 +489,15 @@
"url": "https://github.com/sponsors/ljharb"
}
},
"node_modules/generic-pool": {
"version": "3.9.0",
"resolved": "https://registry.npmjs.org/generic-pool/-/generic-pool-3.9.0.tgz",
"integrity": "sha512-hymDOu5B53XvN4QT9dBmZxPX4CWhBPPLguTZ9MMFeFa/Kg0xWVfylOVNlJji/E7yTZWFd/q9GO5TxDLq156D7g==",
"license": "MIT",
"engines": {
"node": ">= 4"
}
},
"node_modules/get-intrinsic": {
"version": "1.3.0",
"resolved": "https://registry.npmjs.org/get-intrinsic/-/get-intrinsic-1.3.0.tgz",
@ -721,6 +798,23 @@
"node": ">= 0.8"
}
},
"node_modules/redis": {
"version": "4.7.0",
"resolved": "https://registry.npmjs.org/redis/-/redis-4.7.0.tgz",
"integrity": "sha512-zvmkHEAdGMn+hMRXuMBtu4Vo5P6rHQjLoHftu+lBqq8ZTA3RCVC/WzD790bkKKiNFp7d5/9PcSD19fJyyRvOdQ==",
"license": "MIT",
"workspaces": [
"./packages/*"
],
"dependencies": {
"@redis/bloom": "1.2.0",
"@redis/client": "1.6.0",
"@redis/graph": "1.1.1",
"@redis/json": "1.0.7",
"@redis/search": "1.2.0",
"@redis/time-series": "1.1.0"
}
},
"node_modules/safe-buffer": {
"version": "5.2.1",
"resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz",
@ -1073,6 +1167,12 @@
"optional": true
}
}
},
"node_modules/yallist": {
"version": "4.0.0",
"resolved": "https://registry.npmjs.org/yallist/-/yallist-4.0.0.tgz",
"integrity": "sha512-3wdGidZyq5PB084XLES5TpOSRA3wjXAlIWMhum2kRcv/41Sn2emQ0dycQW4uZXLejwKvg6EsvbdlVL+FYEct7A==",
"license": "ISC"
}
}
}

@ -0,0 +1,14 @@
# @redis/bloom
This package provides support for the [RedisBloom](https://redisbloom.io) module, which adds additional probabilistic data structures to Redis. It extends the [Node Redis client](https://github.com/redis/node-redis) to include functions for each of the RediBloom commands.
To use these extra commands, your Redis server must have the RedisBloom module installed.
RedisBloom provides the following probabilistic data structures:
* Bloom Filter: for checking set membership with a high degree of certainty.
* Cuckoo Filter: for checking set membership with a high degree of certainty.
* Count-Min Sketch: Determine the frequency of events in a stream.
* Top-K: Maintain a list of k most frequently seen items.
For complete examples, see `bloom-filter.js`, `cuckoo-filter.js`, `count-min-sketch.js` and `topk.js` in the Node Redis examples folder.

@ -0,0 +1,3 @@
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, item: string): Array<string>;
export { transformBooleanReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,10 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, item) {
return ['BF.ADD', key, item];
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanReply; } });

@ -0,0 +1,4 @@
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: string): Array<string>;
export declare function transformReply(): number;

@ -0,0 +1,9 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key) {
return ['BF.CARD', key];
}
exports.transformArguments = transformArguments;

@ -0,0 +1,4 @@
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: string, item: string): Array<string>;
export { transformBooleanReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,11 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, item) {
return ['BF.EXISTS', key, item];
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanReply; } });

@ -0,0 +1,23 @@
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: string): Array<string>;
export type InfoRawReply = [
_: string,
capacity: number,
_: string,
size: number,
_: string,
numberOfFilters: number,
_: string,
numberOfInsertedItems: number,
_: string,
expansionRate: number
];
export interface InfoReply {
capacity: number;
size: number;
numberOfFilters: number;
numberOfInsertedItems: number;
expansionRate: number;
}
export declare function transformReply(reply: InfoRawReply): InfoReply;

@ -0,0 +1,19 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key) {
return ['BF.INFO', key];
}
exports.transformArguments = transformArguments;
function transformReply(reply) {
return {
capacity: reply[1],
size: reply[3],
numberOfFilters: reply[5],
numberOfInsertedItems: reply[7],
expansionRate: reply[9]
};
}
exports.transformReply = transformReply;

@ -0,0 +1,11 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
interface InsertOptions {
CAPACITY?: number;
ERROR?: number;
EXPANSION?: number;
NOCREATE?: true;
NONSCALING?: true;
}
export declare function transformArguments(key: string, items: RedisCommandArgument | Array<RedisCommandArgument>, options?: InsertOptions): RedisCommandArguments;
export { transformBooleanArrayReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,28 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
const generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, items, options) {
const args = ['BF.INSERT', key];
if (options?.CAPACITY) {
args.push('CAPACITY', options.CAPACITY.toString());
}
if (options?.ERROR) {
args.push('ERROR', options.ERROR.toString());
}
if (options?.EXPANSION) {
args.push('EXPANSION', options.EXPANSION.toString());
}
if (options?.NOCREATE) {
args.push('NOCREATE');
}
if (options?.NONSCALING) {
args.push('NONSCALING');
}
args.push('ITEMS');
return (0, generic_transformers_1.pushVerdictArguments)(args, items);
}
exports.transformArguments = transformArguments;
var generic_transformers_2 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_2.transformBooleanArrayReply; } });

@ -0,0 +1,4 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, iteretor: number, chunk: RedisCommandArgument): RedisCommandArguments;
export declare function transformReply(): 'OK';

@ -0,0 +1,8 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, iteretor, chunk) {
return ['BF.LOADCHUNK', key, iteretor.toString(), chunk];
}
exports.transformArguments = transformArguments;

@ -0,0 +1,3 @@
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, items: Array<string>): Array<string>;
export { transformBooleanArrayReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,10 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, items) {
return ['BF.MADD', key, ...items];
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanArrayReply; } });

@ -0,0 +1,4 @@
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: string, items: Array<string>): Array<string>;
export { transformBooleanArrayReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,11 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, items) {
return ['BF.MEXISTS', key, ...items];
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanArrayReply; } });

@ -0,0 +1,8 @@
export declare const FIRST_KEY_INDEX = 1;
interface ReserveOptions {
EXPANSION?: number;
NONSCALING?: true;
}
export declare function transformArguments(key: string, errorRate: number, capacity: number, options?: ReserveOptions): Array<string>;
export declare function transformReply(): 'OK';
export {};

@ -0,0 +1,15 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, errorRate, capacity, options) {
const args = ['BF.RESERVE', key, errorRate.toString(), capacity.toString()];
if (options?.EXPANSION) {
args.push('EXPANSION', options.EXPANSION.toString());
}
if (options?.NONSCALING) {
args.push('NONSCALING');
}
return args;
}
exports.transformArguments = transformArguments;

@ -0,0 +1,13 @@
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: string, iterator: number): Array<string>;
type ScanDumpRawReply = [
iterator: number,
chunk: string
];
interface ScanDumpReply {
iterator: number;
chunk: string;
}
export declare function transformReply([iterator, chunk]: ScanDumpRawReply): ScanDumpReply;
export {};

@ -0,0 +1,16 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, iterator) {
return ['BF.SCANDUMP', key, iterator.toString()];
}
exports.transformArguments = transformArguments;
function transformReply([iterator, chunk]) {
return {
iterator,
chunk
};
}
exports.transformReply = transformReply;

@ -0,0 +1,33 @@
import * as ADD from './ADD';
import * as CARD from './CARD';
import * as EXISTS from './EXISTS';
import * as INFO from './INFO';
import * as INSERT from './INSERT';
import * as LOADCHUNK from './LOADCHUNK';
import * as MADD from './MADD';
import * as MEXISTS from './MEXISTS';
import * as RESERVE from './RESERVE';
import * as SCANDUMP from './SCANDUMP';
declare const _default: {
ADD: typeof ADD;
add: typeof ADD;
CARD: typeof CARD;
card: typeof CARD;
EXISTS: typeof EXISTS;
exists: typeof EXISTS;
INFO: typeof INFO;
info: typeof INFO;
INSERT: typeof INSERT;
insert: typeof INSERT;
LOADCHUNK: typeof LOADCHUNK;
loadChunk: typeof LOADCHUNK;
MADD: typeof MADD;
mAdd: typeof MADD;
MEXISTS: typeof MEXISTS;
mExists: typeof MEXISTS;
RESERVE: typeof RESERVE;
reserve: typeof RESERVE;
SCANDUMP: typeof SCANDUMP;
scanDump: typeof SCANDUMP;
};
export default _default;

@ -0,0 +1,34 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const ADD = require("./ADD");
const CARD = require("./CARD");
const EXISTS = require("./EXISTS");
const INFO = require("./INFO");
const INSERT = require("./INSERT");
const LOADCHUNK = require("./LOADCHUNK");
const MADD = require("./MADD");
const MEXISTS = require("./MEXISTS");
const RESERVE = require("./RESERVE");
const SCANDUMP = require("./SCANDUMP");
exports.default = {
ADD,
add: ADD,
CARD,
card: CARD,
EXISTS,
exists: EXISTS,
INFO,
info: INFO,
INSERT,
insert: INSERT,
LOADCHUNK,
loadChunk: LOADCHUNK,
MADD,
mAdd: MADD,
MEXISTS,
mExists: MEXISTS,
RESERVE,
reserve: RESERVE,
SCANDUMP,
scanDump: SCANDUMP
};

@ -0,0 +1,8 @@
export declare const FIRST_KEY_INDEX = 1;
interface IncrByItem {
item: string;
incrementBy: number;
}
export declare function transformArguments(key: string, items: IncrByItem | Array<IncrByItem>): Array<string>;
export declare function transformReply(): Array<number>;
export {};

@ -0,0 +1,20 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, items) {
const args = ['CMS.INCRBY', key];
if (Array.isArray(items)) {
for (const item of items) {
pushIncrByItem(args, item);
}
}
else {
pushIncrByItem(args, items);
}
return args;
}
exports.transformArguments = transformArguments;
function pushIncrByItem(args, { item, incrementBy }) {
args.push(item, incrementBy.toString());
}

@ -0,0 +1,17 @@
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: string): Array<string>;
export type InfoRawReply = [
_: string,
width: number,
_: string,
depth: number,
_: string,
count: number
];
export interface InfoReply {
width: number;
depth: number;
count: number;
}
export declare function transformReply(reply: InfoRawReply): InfoReply;

@ -0,0 +1,17 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key) {
return ['CMS.INFO', key];
}
exports.transformArguments = transformArguments;
function transformReply(reply) {
return {
width: reply[1],
depth: reply[3],
count: reply[5]
};
}
exports.transformReply = transformReply;

@ -0,0 +1,3 @@
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, width: number, depth: number): Array<string>;
export declare function transformReply(): 'OK';

@ -0,0 +1,8 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, width, depth) {
return ['CMS.INITBYDIM', key, width.toString(), depth.toString()];
}
exports.transformArguments = transformArguments;

@ -0,0 +1,3 @@
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, error: number, probability: number): Array<string>;
export declare function transformReply(): 'OK';

@ -0,0 +1,8 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, error, probability) {
return ['CMS.INITBYPROB', key, error.toString(), probability.toString()];
}
exports.transformArguments = transformArguments;

@ -0,0 +1,9 @@
export declare const FIRST_KEY_INDEX = 1;
interface Sketch {
name: string;
weight: number;
}
type Sketches = Array<string> | Array<Sketch>;
export declare function transformArguments(dest: string, src: Sketches): Array<string>;
export declare function transformReply(): 'OK';
export {};

@ -0,0 +1,28 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(dest, src) {
const args = [
'CMS.MERGE',
dest,
src.length.toString()
];
if (isStringSketches(src)) {
args.push(...src);
}
else {
for (const sketch of src) {
args.push(sketch.name);
}
args.push('WEIGHTS');
for (const sketch of src) {
args.push(sketch.weight.toString());
}
}
return args;
}
exports.transformArguments = transformArguments;
function isStringSketches(src) {
return typeof src[0] === 'string';
}

@ -0,0 +1,5 @@
import { RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: string, items: string | Array<string>): RedisCommandArguments;
export declare function transformReply(): Array<number>;

@ -0,0 +1,10 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
const generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, items) {
return (0, generic_transformers_1.pushVerdictArguments)(['CMS.QUERY', key], items);
}
exports.transformArguments = transformArguments;

@ -0,0 +1,21 @@
import * as INCRBY from './INCRBY';
import * as INFO from './INFO';
import * as INITBYDIM from './INITBYDIM';
import * as INITBYPROB from './INITBYPROB';
import * as MERGE from './MERGE';
import * as QUERY from './QUERY';
declare const _default: {
INCRBY: typeof INCRBY;
incrBy: typeof INCRBY;
INFO: typeof INFO;
info: typeof INFO;
INITBYDIM: typeof INITBYDIM;
initByDim: typeof INITBYDIM;
INITBYPROB: typeof INITBYPROB;
initByProb: typeof INITBYPROB;
MERGE: typeof MERGE;
merge: typeof MERGE;
QUERY: typeof QUERY;
query: typeof QUERY;
};
export default _default;

@ -0,0 +1,22 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const INCRBY = require("./INCRBY");
const INFO = require("./INFO");
const INITBYDIM = require("./INITBYDIM");
const INITBYPROB = require("./INITBYPROB");
const MERGE = require("./MERGE");
const QUERY = require("./QUERY");
exports.default = {
INCRBY,
incrBy: INCRBY,
INFO,
info: INFO,
INITBYDIM,
initByDim: INITBYDIM,
INITBYPROB,
initByProb: INITBYPROB,
MERGE,
merge: MERGE,
QUERY,
query: QUERY
};

@ -0,0 +1,3 @@
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, item: string): Array<string>;
export { transformBooleanReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,10 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, item) {
return ['CF.ADD', key, item];
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanReply; } });

@ -0,0 +1,3 @@
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, item: string): Array<string>;
export { transformBooleanReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,10 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, item) {
return ['CF.ADDNX', key, item];
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanReply; } });

@ -0,0 +1,3 @@
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, item: string): Array<string>;
export declare function transformReply(): number;

@ -0,0 +1,8 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, item) {
return ['CF.COUNT', key, item];
}
exports.transformArguments = transformArguments;

@ -0,0 +1,3 @@
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, item: string): Array<string>;
export { transformBooleanReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,10 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, item) {
return ['CF.DEL', key, item];
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanReply; } });

@ -0,0 +1,4 @@
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: string, item: string): Array<string>;
export { transformBooleanReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,11 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, item) {
return ['CF.EXISTS', key, item];
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanReply; } });

@ -0,0 +1,32 @@
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: string): Array<string>;
export type InfoRawReply = [
_: string,
size: number,
_: string,
numberOfBuckets: number,
_: string,
numberOfFilters: number,
_: string,
numberOfInsertedItems: number,
_: string,
numberOfDeletedItems: number,
_: string,
bucketSize: number,
_: string,
expansionRate: number,
_: string,
maxIteration: number
];
export interface InfoReply {
size: number;
numberOfBuckets: number;
numberOfFilters: number;
numberOfInsertedItems: number;
numberOfDeletedItems: number;
bucketSize: number;
expansionRate: number;
maxIteration: number;
}
export declare function transformReply(reply: InfoRawReply): InfoReply;

@ -0,0 +1,22 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key) {
return ['CF.INFO', key];
}
exports.transformArguments = transformArguments;
function transformReply(reply) {
return {
size: reply[1],
numberOfBuckets: reply[3],
numberOfFilters: reply[5],
numberOfInsertedItems: reply[7],
numberOfDeletedItems: reply[9],
bucketSize: reply[11],
expansionRate: reply[13],
maxIteration: reply[15]
};
}
exports.transformReply = transformReply;

@ -0,0 +1,5 @@
import { RedisCommandArguments } from '@redis/client/dist/lib/commands';
import { InsertOptions } from ".";
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, items: string | Array<string>, options?: InsertOptions): RedisCommandArguments;
export { transformBooleanArrayReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,11 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
const _1 = require(".");
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, items, options) {
return (0, _1.pushInsertOptions)(['CF.INSERT', key], items, options);
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanArrayReply; } });

@ -0,0 +1,5 @@
import { RedisCommandArguments } from '@redis/client/dist/lib/commands';
import { InsertOptions } from ".";
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, items: string | Array<string>, options?: InsertOptions): RedisCommandArguments;
export { transformBooleanArrayReply as transformReply } from '@redis/client/dist/lib/commands/generic-transformers';

@ -0,0 +1,11 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
const _1 = require(".");
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, items, options) {
return (0, _1.pushInsertOptions)(['CF.INSERTNX', key], items, options);
}
exports.transformArguments = transformArguments;
var generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return generic_transformers_1.transformBooleanArrayReply; } });

@ -0,0 +1,4 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, iterator: number, chunk: RedisCommandArgument): RedisCommandArguments;
export declare function transformReply(): 'OK';

@ -0,0 +1,8 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, iterator, chunk) {
return ['CF.LOADCHUNK', key, iterator.toString(), chunk];
}
exports.transformArguments = transformArguments;

@ -0,0 +1,9 @@
export declare const FIRST_KEY_INDEX = 1;
interface ReserveOptions {
BUCKETSIZE?: number;
MAXITERATIONS?: number;
EXPANSION?: number;
}
export declare function transformArguments(key: string, capacity: number, options?: ReserveOptions): Array<string>;
export declare function transformReply(): 'OK';
export {};

@ -0,0 +1,18 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, capacity, options) {
const args = ['CF.RESERVE', key, capacity.toString()];
if (options?.BUCKETSIZE) {
args.push('BUCKETSIZE', options.BUCKETSIZE.toString());
}
if (options?.MAXITERATIONS) {
args.push('MAXITERATIONS', options.MAXITERATIONS.toString());
}
if (options?.EXPANSION) {
args.push('EXPANSION', options.EXPANSION.toString());
}
return args;
}
exports.transformArguments = transformArguments;

@ -0,0 +1,12 @@
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: string, iterator: number): Array<string>;
type ScanDumpRawReply = [
iterator: number,
chunk: string | null
];
interface ScanDumpReply {
iterator: number;
chunk: string | null;
}
export declare function transformReply([iterator, chunk]: ScanDumpRawReply): ScanDumpReply;
export {};

@ -0,0 +1,15 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, iterator) {
return ['CF.SCANDUMP', key, iterator.toString()];
}
exports.transformArguments = transformArguments;
function transformReply([iterator, chunk]) {
return {
iterator,
chunk
};
}
exports.transformReply = transformReply;

@ -0,0 +1,42 @@
import * as ADD from './ADD';
import * as ADDNX from './ADDNX';
import * as COUNT from './COUNT';
import * as DEL from './DEL';
import * as EXISTS from './EXISTS';
import * as INFO from './INFO';
import * as INSERT from './INSERT';
import * as INSERTNX from './INSERTNX';
import * as LOADCHUNK from './LOADCHUNK';
import * as RESERVE from './RESERVE';
import * as SCANDUMP from './SCANDUMP';
import { RedisCommandArguments } from '@redis/client/dist/lib/commands';
declare const _default: {
ADD: typeof ADD;
add: typeof ADD;
ADDNX: typeof ADDNX;
addNX: typeof ADDNX;
COUNT: typeof COUNT;
count: typeof COUNT;
DEL: typeof DEL;
del: typeof DEL;
EXISTS: typeof EXISTS;
exists: typeof EXISTS;
INFO: typeof INFO;
info: typeof INFO;
INSERT: typeof INSERT;
insert: typeof INSERT;
INSERTNX: typeof INSERTNX;
insertNX: typeof INSERTNX;
LOADCHUNK: typeof LOADCHUNK;
loadChunk: typeof LOADCHUNK;
RESERVE: typeof RESERVE;
reserve: typeof RESERVE;
SCANDUMP: typeof SCANDUMP;
scanDump: typeof SCANDUMP;
};
export default _default;
export interface InsertOptions {
CAPACITY?: number;
NOCREATE?: true;
}
export declare function pushInsertOptions(args: RedisCommandArguments, items: string | Array<string>, options?: InsertOptions): RedisCommandArguments;

@ -0,0 +1,51 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.pushInsertOptions = void 0;
const ADD = require("./ADD");
const ADDNX = require("./ADDNX");
const COUNT = require("./COUNT");
const DEL = require("./DEL");
const EXISTS = require("./EXISTS");
const INFO = require("./INFO");
const INSERT = require("./INSERT");
const INSERTNX = require("./INSERTNX");
const LOADCHUNK = require("./LOADCHUNK");
const RESERVE = require("./RESERVE");
const SCANDUMP = require("./SCANDUMP");
const generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
exports.default = {
ADD,
add: ADD,
ADDNX,
addNX: ADDNX,
COUNT,
count: COUNT,
DEL,
del: DEL,
EXISTS,
exists: EXISTS,
INFO,
info: INFO,
INSERT,
insert: INSERT,
INSERTNX,
insertNX: INSERTNX,
LOADCHUNK,
loadChunk: LOADCHUNK,
RESERVE,
reserve: RESERVE,
SCANDUMP,
scanDump: SCANDUMP
};
function pushInsertOptions(args, items, options) {
if (options?.CAPACITY) {
args.push('CAPACITY');
args.push(options.CAPACITY.toString());
}
if (options?.NOCREATE) {
args.push('NOCREATE');
}
args.push('ITEMS');
return (0, generic_transformers_1.pushVerdictArguments)(args, items);
}
exports.pushInsertOptions = pushInsertOptions;

@ -0,0 +1,111 @@
declare const _default: {
bf: {
ADD: typeof import("./bloom/ADD");
add: typeof import("./bloom/ADD");
CARD: typeof import("./bloom/CARD");
card: typeof import("./bloom/CARD");
EXISTS: typeof import("./bloom/EXISTS");
exists: typeof import("./bloom/EXISTS");
INFO: typeof import("./bloom/INFO");
info: typeof import("./bloom/INFO");
INSERT: typeof import("./bloom/INSERT");
insert: typeof import("./bloom/INSERT");
LOADCHUNK: typeof import("./bloom/LOADCHUNK");
loadChunk: typeof import("./bloom/LOADCHUNK");
MADD: typeof import("./bloom/MADD");
mAdd: typeof import("./bloom/MADD");
MEXISTS: typeof import("./bloom/MEXISTS");
mExists: typeof import("./bloom/MEXISTS");
RESERVE: typeof import("./bloom/RESERVE");
reserve: typeof import("./bloom/RESERVE");
SCANDUMP: typeof import("./bloom/SCANDUMP");
scanDump: typeof import("./bloom/SCANDUMP");
};
cms: {
INCRBY: typeof import("./count-min-sketch/INCRBY");
incrBy: typeof import("./count-min-sketch/INCRBY");
INFO: typeof import("./count-min-sketch/INFO");
info: typeof import("./count-min-sketch/INFO");
INITBYDIM: typeof import("./count-min-sketch/INITBYDIM");
initByDim: typeof import("./count-min-sketch/INITBYDIM");
INITBYPROB: typeof import("./count-min-sketch/INITBYPROB");
initByProb: typeof import("./count-min-sketch/INITBYPROB");
MERGE: typeof import("./count-min-sketch/MERGE");
merge: typeof import("./count-min-sketch/MERGE");
QUERY: typeof import("./count-min-sketch/QUERY");
query: typeof import("./count-min-sketch/QUERY");
};
cf: {
ADD: typeof import("./cuckoo/ADD");
add: typeof import("./cuckoo/ADD");
ADDNX: typeof import("./cuckoo/ADDNX");
addNX: typeof import("./cuckoo/ADDNX");
COUNT: typeof import("./cuckoo/COUNT");
count: typeof import("./cuckoo/COUNT");
DEL: typeof import("./cuckoo/DEL");
del: typeof import("./cuckoo/DEL");
EXISTS: typeof import("./cuckoo/EXISTS");
exists: typeof import("./cuckoo/EXISTS");
INFO: typeof import("./cuckoo/INFO");
info: typeof import("./cuckoo/INFO");
INSERT: typeof import("./cuckoo/INSERT");
insert: typeof import("./cuckoo/INSERT");
INSERTNX: typeof import("./cuckoo/INSERTNX");
insertNX: typeof import("./cuckoo/INSERTNX");
LOADCHUNK: typeof import("./cuckoo/LOADCHUNK");
loadChunk: typeof import("./cuckoo/LOADCHUNK");
RESERVE: typeof import("./cuckoo/RESERVE");
reserve: typeof import("./cuckoo/RESERVE");
SCANDUMP: typeof import("./cuckoo/SCANDUMP");
scanDump: typeof import("./cuckoo/SCANDUMP");
};
tDigest: {
ADD: typeof import("./t-digest/ADD");
add: typeof import("./t-digest/ADD");
BYRANK: typeof import("./t-digest/BYRANK");
byRank: typeof import("./t-digest/BYRANK");
BYREVRANK: typeof import("./t-digest/BYREVRANK");
byRevRank: typeof import("./t-digest/BYREVRANK");
CDF: typeof import("./t-digest/CDF");
cdf: typeof import("./t-digest/CDF");
CREATE: typeof import("./t-digest/CREATE");
create: typeof import("./t-digest/CREATE");
INFO: typeof import("./t-digest/INFO");
info: typeof import("./t-digest/INFO");
MAX: typeof import("./t-digest/MAX");
max: typeof import("./t-digest/MAX");
MERGE: typeof import("./t-digest/MERGE");
merge: typeof import("./t-digest/MERGE");
MIN: typeof import("./t-digest/MIN");
min: typeof import("./t-digest/MIN");
QUANTILE: typeof import("./t-digest/QUANTILE");
quantile: typeof import("./t-digest/QUANTILE");
RANK: typeof import("./t-digest/RANK");
rank: typeof import("./t-digest/RANK");
RESET: typeof import("./t-digest/RESET");
reset: typeof import("./t-digest/RESET");
REVRANK: typeof import("./t-digest/REVRANK");
revRank: typeof import("./t-digest/REVRANK");
TRIMMED_MEAN: typeof import("./t-digest/TRIMMED_MEAN");
trimmedMean: typeof import("./t-digest/TRIMMED_MEAN");
};
topK: {
ADD: typeof import("./top-k/ADD");
add: typeof import("./top-k/ADD");
COUNT: typeof import("./top-k/COUNT");
count: typeof import("./top-k/COUNT");
INCRBY: typeof import("./top-k/INCRBY");
incrBy: typeof import("./top-k/INCRBY");
INFO: typeof import("./top-k/INFO");
info: typeof import("./top-k/INFO");
LIST_WITHCOUNT: typeof import("./top-k/LIST_WITHCOUNT");
listWithCount: typeof import("./top-k/LIST_WITHCOUNT");
LIST: typeof import("./top-k/LIST");
list: typeof import("./top-k/LIST");
QUERY: typeof import("./top-k/QUERY");
query: typeof import("./top-k/QUERY");
RESERVE: typeof import("./top-k/RESERVE");
reserve: typeof import("./top-k/RESERVE");
};
};
export default _default;

@ -0,0 +1,14 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const bloom_1 = require("./bloom");
const count_min_sketch_1 = require("./count-min-sketch");
const cuckoo_1 = require("./cuckoo");
const t_digest_1 = require("./t-digest");
const top_k_1 = require("./top-k");
exports.default = {
bf: bloom_1.default,
cms: count_min_sketch_1.default,
cf: cuckoo_1.default,
tDigest: t_digest_1.default,
topK: top_k_1.default
};

@ -0,0 +1,4 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: RedisCommandArgument, values: Array<number>): RedisCommandArguments;
export declare function transformReply(): 'OK';

@ -0,0 +1,12 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, values) {
const args = ['TDIGEST.ADD', key];
for (const item of values) {
args.push(item.toString());
}
return args;
}
exports.transformArguments = transformArguments;

@ -0,0 +1,5 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: RedisCommandArgument, ranks: Array<number>): RedisCommandArguments;
export { transformDoublesReply as transformReply } from '.';

@ -0,0 +1,15 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, ranks) {
const args = ['TDIGEST.BYRANK', key];
for (const rank of ranks) {
args.push(rank.toString());
}
return args;
}
exports.transformArguments = transformArguments;
var _1 = require(".");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return _1.transformDoublesReply; } });

@ -0,0 +1,5 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: RedisCommandArgument, ranks: Array<number>): RedisCommandArguments;
export { transformDoublesReply as transformReply } from '.';

@ -0,0 +1,15 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, ranks) {
const args = ['TDIGEST.BYREVRANK', key];
for (const rank of ranks) {
args.push(rank.toString());
}
return args;
}
exports.transformArguments = transformArguments;
var _1 = require(".");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return _1.transformDoublesReply; } });

@ -0,0 +1,5 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: RedisCommandArgument, values: Array<number>): RedisCommandArguments;
export { transformDoublesReply as transformReply } from '.';

@ -0,0 +1,15 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, values) {
const args = ['TDIGEST.CDF', key];
for (const item of values) {
args.push(item.toString());
}
return args;
}
exports.transformArguments = transformArguments;
var _1 = require(".");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return _1.transformDoublesReply; } });

@ -0,0 +1,5 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
import { CompressionOption } from '.';
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: RedisCommandArgument, options?: CompressionOption): RedisCommandArguments;
export declare function transformReply(): 'OK';

@ -0,0 +1,9 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
const _1 = require(".");
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key, options) {
return (0, _1.pushCompressionArgument)(['TDIGEST.CREATE', key], options);
}
exports.transformArguments = transformArguments;

@ -0,0 +1,31 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: RedisCommandArgument): RedisCommandArguments;
type InfoRawReply = [
'Compression',
number,
'Capacity',
number,
'Merged nodes',
number,
'Unmerged nodes',
number,
'Merged weight',
string,
'Unmerged weight',
string,
'Total compressions',
number
];
interface InfoReply {
comperssion: number;
capacity: number;
mergedNodes: number;
unmergedNodes: number;
mergedWeight: number;
unmergedWeight: number;
totalCompression: number;
}
export declare function transformReply(reply: InfoRawReply): InfoReply;
export {};

@ -0,0 +1,24 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key) {
return [
'TDIGEST.INFO',
key
];
}
exports.transformArguments = transformArguments;
function transformReply(reply) {
return {
comperssion: reply[1],
capacity: reply[3],
mergedNodes: reply[5],
unmergedNodes: reply[7],
mergedWeight: Number(reply[9]),
unmergedWeight: Number(reply[11]),
totalCompression: reply[13]
};
}
exports.transformReply = transformReply;

@ -0,0 +1,5 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: RedisCommandArgument): RedisCommandArguments;
export { transformDoubleReply as transformReply } from '.';

@ -0,0 +1,14 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key) {
return [
'TDIGEST.MAX',
key
];
}
exports.transformArguments = transformArguments;
var _1 = require(".");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return _1.transformDoubleReply; } });

@ -0,0 +1,9 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
import { CompressionOption } from '.';
export declare const FIRST_KEY_INDEX = 1;
interface MergeOptions extends CompressionOption {
OVERRIDE?: boolean;
}
export declare function transformArguments(destKey: RedisCommandArgument, srcKeys: RedisCommandArgument | Array<RedisCommandArgument>, options?: MergeOptions): RedisCommandArguments;
export declare function transformReply(): 'OK';
export {};

@ -0,0 +1,15 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
const generic_transformers_1 = require("@redis/client/dist/lib/commands/generic-transformers");
const _1 = require(".");
exports.FIRST_KEY_INDEX = 1;
function transformArguments(destKey, srcKeys, options) {
const args = (0, generic_transformers_1.pushVerdictArgument)(['TDIGEST.MERGE', destKey], srcKeys);
(0, _1.pushCompressionArgument)(args, options);
if (options?.OVERRIDE) {
args.push('OVERRIDE');
}
return args;
}
exports.transformArguments = transformArguments;

@ -0,0 +1,5 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: RedisCommandArgument): RedisCommandArguments;
export { transformDoubleReply as transformReply } from '.';

@ -0,0 +1,14 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key) {
return [
'TDIGEST.MIN',
key
];
}
exports.transformArguments = transformArguments;
var _1 = require(".");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return _1.transformDoubleReply; } });

@ -0,0 +1,5 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: RedisCommandArgument, quantiles: Array<number>): RedisCommandArguments;
export { transformDoublesReply as transformReply } from '.';

@ -0,0 +1,18 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, quantiles) {
const args = [
'TDIGEST.QUANTILE',
key
];
for (const quantile of quantiles) {
args.push(quantile.toString());
}
return args;
}
exports.transformArguments = transformArguments;
var _1 = require(".");
Object.defineProperty(exports, "transformReply", { enumerable: true, get: function () { return _1.transformDoublesReply; } });

@ -0,0 +1,5 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare const IS_READ_ONLY = true;
export declare function transformArguments(key: RedisCommandArgument, values: Array<number>): RedisCommandArguments;
export declare function transformReply(): Array<number>;

@ -0,0 +1,13 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
exports.IS_READ_ONLY = true;
function transformArguments(key, values) {
const args = ['TDIGEST.RANK', key];
for (const item of values) {
args.push(item.toString());
}
return args;
}
exports.transformArguments = transformArguments;

@ -0,0 +1,4 @@
import { RedisCommandArgument, RedisCommandArguments } from '@redis/client/dist/lib/commands';
export declare const FIRST_KEY_INDEX = 1;
export declare function transformArguments(key: RedisCommandArgument): RedisCommandArguments;
export declare function transformReply(): 'OK';

@ -0,0 +1,8 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.transformArguments = exports.FIRST_KEY_INDEX = void 0;
exports.FIRST_KEY_INDEX = 1;
function transformArguments(key) {
return ['TDIGEST.RESET', key];
}
exports.transformArguments = transformArguments;

Some files were not shown because too many files have changed in this diff Show More

Loading…
Cancel
Save