You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-07 13:22:56 +03:00
wip
This commit is contained in:
@@ -1,27 +1,27 @@
|
|||||||
import {strict as assert} from 'assert';
|
// import {strict as assert} from 'assert';
|
||||||
import testUtils, {GLOBAL} from '../test-utils';
|
// import testUtils, {GLOBAL} from '../test-utils';
|
||||||
import { transformArguments } from './LATENCY_LATEST';
|
// import { transformArguments } from './LATENCY_LATEST';
|
||||||
|
|
||||||
describe('LATENCY LATEST', () => {
|
// describe('LATENCY LATEST', () => {
|
||||||
it('transformArguments', () => {
|
// it('transformArguments', () => {
|
||||||
assert.deepEqual(
|
// assert.deepEqual(
|
||||||
transformArguments(),
|
// transformArguments(),
|
||||||
['LATENCY', 'LATEST']
|
// ['LATENCY', 'LATEST']
|
||||||
);
|
// );
|
||||||
});
|
// });
|
||||||
|
|
||||||
testUtils.testWithClient('client.latencyLatest', async client => {
|
// testUtils.testWithClient('client.latencyLatest', async client => {
|
||||||
await Promise.all([
|
// await Promise.all([
|
||||||
client.configSet('latency-monitor-threshold', '100'),
|
// client.configSet('latency-monitor-threshold', '100'),
|
||||||
client.sendCommand(['DEBUG', 'SLEEP', '1'])
|
// client.sendCommand(['DEBUG', 'SLEEP', '1'])
|
||||||
]);
|
// ]);
|
||||||
const latency = await client.latencyLatest();
|
// const latency = await client.latencyLatest();
|
||||||
assert.ok(Array.isArray(latency));
|
// assert.ok(Array.isArray(latency));
|
||||||
for (const [name, timestamp, latestLatency, allTimeLatency] of latency) {
|
// for (const [name, timestamp, latestLatency, allTimeLatency] of latency) {
|
||||||
assert.equal(typeof name, 'string');
|
// assert.equal(typeof name, 'string');
|
||||||
assert.equal(typeof timestamp, 'number');
|
// assert.equal(typeof timestamp, 'number');
|
||||||
assert.equal(typeof latestLatency, 'number');
|
// assert.equal(typeof latestLatency, 'number');
|
||||||
assert.equal(typeof allTimeLatency, 'number');
|
// assert.equal(typeof allTimeLatency, 'number');
|
||||||
}
|
// }
|
||||||
}, GLOBAL.SERVERS.OPEN);
|
// }, GLOBAL.SERVERS.OPEN);
|
||||||
});
|
// });
|
||||||
|
@@ -1,12 +1,12 @@
|
|||||||
import { RedisCommandArguments } from '.';
|
// import { RedisCommandArguments } from '.';
|
||||||
|
|
||||||
export function transformArguments(): RedisCommandArguments {
|
// export function transformArguments(): RedisCommandArguments {
|
||||||
return ['LATENCY', 'LATEST'];
|
// return ['LATENCY', 'LATEST'];
|
||||||
}
|
// }
|
||||||
|
|
||||||
export declare function transformReply(): Array<[
|
// export declare function transformReply(): Array<[
|
||||||
name: string,
|
// name: string,
|
||||||
timestamp: number,
|
// timestamp: number,
|
||||||
latestLatency: number,
|
// latestLatency: number,
|
||||||
allTimeLatency: number
|
// allTimeLatency: number
|
||||||
]>;
|
// ]>;
|
||||||
|
Reference in New Issue
Block a user