You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-04 15:02:09 +03:00
94 lines
3.1 KiB
TypeScript
94 lines
3.1 KiB
TypeScript
export function transformArguments(): Array<string> {
|
|
return ['MEMORY', 'STATS'];
|
|
}
|
|
|
|
interface MemoryStatsReply {
|
|
peakAllocated: number;
|
|
totalAllocated: number;
|
|
startupAllocated: number;
|
|
replicationBacklog: number;
|
|
clientsReplicas: number;
|
|
clientsNormal: number;
|
|
aofBuffer: number;
|
|
luaCaches: number;
|
|
overheadTotal: number;
|
|
keysCount: number;
|
|
keysBytesPerKey: number;
|
|
datasetBytes: number;
|
|
datasetPercentage: number;
|
|
peakPercentage: number;
|
|
allocatorAllocated?: number,
|
|
allocatorActive?: number;
|
|
allocatorResident?: number;
|
|
allocatorFragmentationRatio?: number;
|
|
allocatorFragmentationBytes?: number;
|
|
allocatorRssRatio?: number;
|
|
allocatorRssBytes?: number;
|
|
rssOverheadRatio?: number;
|
|
rssOverheadBytes?: number;
|
|
fragmentation?: number;
|
|
fragmentationBytes: number;
|
|
db: {
|
|
[key: number]: {
|
|
overheadHashtableMain: number;
|
|
overheadHashtableExpires: number;
|
|
};
|
|
};
|
|
}
|
|
|
|
const FIELDS_MAPPING = {
|
|
'peak.allocated': 'peakAllocated',
|
|
'total.allocated': 'totalAllocated',
|
|
'startup.allocated': 'startupAllocated',
|
|
'replication.backlog': 'replicationBacklog',
|
|
'clients.slaves': 'clientsReplicas',
|
|
'clients.normal': 'clientsNormal',
|
|
'aof.buffer': 'aofBuffer',
|
|
'lua.caches': 'luaCaches',
|
|
'overhead.total': 'overheadTotal',
|
|
'keys.count': 'keysCount',
|
|
'keys.bytes-per-key': 'keysBytesPerKey',
|
|
'dataset.bytes': 'datasetBytes',
|
|
'dataset.percentage': 'datasetPercentage',
|
|
'peak.percentage': 'peakPercentage',
|
|
'allocator.allocated': 'allocatorAllocated',
|
|
'allocator.active': 'allocatorActive',
|
|
'allocator.resident': 'allocatorResident',
|
|
'allocator-fragmentation.ratio': 'allocatorFragmentationRatio',
|
|
'allocator-fragmentation.bytes': 'allocatorFragmentationBytes',
|
|
'allocator-rss.ratio': 'allocatorRssRatio',
|
|
'allocator-rss.bytes': 'allocatorRssBytes',
|
|
'rss-overhead.ratio': 'rssOverheadRatio',
|
|
'rss-overhead.bytes': 'rssOverheadBytes',
|
|
'fragmentation': 'fragmentation',
|
|
'fragmentation.bytes': 'fragmentationBytes'
|
|
},
|
|
DB_FIELDS_MAPPING = {
|
|
'overhead.hashtable.main': 'overheadHashtableMain',
|
|
'overhead.hashtable.expires': 'overheadHashtableExpires'
|
|
};
|
|
|
|
export function transformReply(rawReply: Array<string | number | Array<string | number>>): MemoryStatsReply {
|
|
const reply: any = {
|
|
db: {}
|
|
};
|
|
|
|
for (let i = 0; i < rawReply.length; i += 2) {
|
|
const key = rawReply[i] as string;
|
|
if (key.startsWith('db.')) {
|
|
const dbTuples = rawReply[i + 1] as Array<string | number>,
|
|
db: any = {};
|
|
for (let j = 0; j < dbTuples.length; j += 2) {
|
|
db[DB_FIELDS_MAPPING[dbTuples[j] as keyof typeof DB_FIELDS_MAPPING]] = dbTuples[j + 1];
|
|
}
|
|
|
|
reply.db[key.substring(3)] = db;
|
|
continue;
|
|
}
|
|
|
|
reply[FIELDS_MAPPING[key as keyof typeof FIELDS_MAPPING]] = Number(rawReply[i + 1]);
|
|
}
|
|
|
|
return reply as MemoryStatsReply;
|
|
}
|