mirrors/dbgate
1
0
Fork 0
mirror of https://github.com/dbgate/dbgate synced 2024-11-07 20:26:23 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

redis key sizes

Browse Source
This commit is contained in:
Jan Prochazka 2022-03-05 21:38:36 +01:00
parent 750e929d1e
commit 74ad345ba5
2 changed files with 38 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/web/src/widgets/DbKeysTreeNode.svelte
View File

@ -48,8 +48,16 @@
title={item.text}
expandIcon={item.type == 'dir' ? plusExpandIcon(isExpanded) : 'icon invisible-box'}
on:expand={() => {
isExpanded = !isExpanded;
if (item.type == 'dir') {
isExpanded = !isExpanded;
}
}}
on:click={() => {
if (item.type == 'dir') {
isExpanded = !isExpanded;
}
}}
extInfo={item.count ? `(${item.count})` : null}
{indentLevel}
/>
<!-- <div on:click={() => (isExpanded = !isExpanded)}>

38
plugins/dbgate-plugin-redis/src/backend/driver.js
View File

@ -93,17 +93,24 @@ const driver = {
if (!key.startsWith(prefix)) continue;
const keySplit = key.split(':');
if (keySplit.length > rootSplit.length) {
const text = keySplit[rootSplit.length];
if (keySplit.length == rootSplit.length + 1) {
res[keySplit[rootSplit.length]] = {
text: keySplit[rootSplit.length],
res[text] = {
text,
key,
};
} else {
res[keySplit[rootSplit.length]] = {
text: keySplit[rootSplit.length],
type: 'dir',
root: keySplit.slice(0, rootSplit.length + 1).join(':'),
};
const dctKey = '::' + text;
if (res[dctKey]) {
res[dctKey].count++;
} else {
res[dctKey] = {
text: text + ':*',
type: 'dir',
root: keySplit.slice(0, rootSplit.length + 1).join(':'),
count: 1,
};
}
}
}
}
@ -111,8 +118,21 @@ const driver = {
},
async enrichOneKeyInfo(pool, item) {
const type = await pool.type(item.key);
item.type = type;
item.type = await pool.type(item.key);
switch (item.type) {
case 'list':
item.count = await pool.llen(item.key);
break;
case 'set':
item.count = await pool.scard(item.key);
break;
case 'zset':
item.count = await pool.zcard(item.key);
break;
case 'stream':
item.count = await pool.xlen(item.key);
break;
}
},
async enrichKeyInfo(pool, levelInfo) {