You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-04 15:02:09 +03:00
* refactor pubsub, add support for sharded pub sub * run tests in redis 7 only, fix PUBSUB SHARDCHANNELS test * add some comments and fix some bugs * PubSubType, not PubSubTypes 🤦♂️ * remove test.txt * fix some bugs, add tests * add some tests * fix #2345 - allow PING in PubSub mode (remove client side validation) * remove .only * revert changes in cluster/index.ts * fix tests minimum version * handle server sunsubscribe * add 'sharded-channel-moved' event to docs, improve the events section in the main README (fix #2302) * exit "resubscribe" if pubsub not active * Update commands-queue.ts * Release client@1.5.0-rc.0 * WIP * use `node:util` instead of `node:util/types` (to support node 14) * run PubSub resharding test with Redis 7+ * fix inconsistency in live resharding test * add some tests * fix iterateAllNodes when starting from a replica * fix iterateAllNodes random * fix slotNodesIterator * fix slotNodesIterator * clear pubSubNode when node in use * wait for all nodes cluster state to be ok before testing * `cluster.minimizeConections` tests * `client.reconnectStrategry = false | 0` tests * sharded pubsub + cluster 🎉 * add minimum version to sharded pubsub tests * add cluster sharded pubsub live reshard test, use stable dockers for tests, make sure to close pubsub clients when a node disconnects from the cluster * fix "ssubscribe & sunsubscribe" test * lock search docker to 2.4.9 * change numberOfMasters default to 2 * use edge for bloom * add tests * add back getMasters and getSlotMaster as deprecated functions * add some tests * fix reconnect strategy + docs * sharded pubsub docs * Update pub-sub.md * some jsdoc, docs, cluster topology test * clean pub-sub docs Co-authored-by: Simon Prickett <simon@redislabs.com> * reconnect startegy docs and bug fix Co-authored-by: Simon Prickett <simon@redislabs.com> * refine jsdoc and some docs Co-authored-by: Simon Prickett <simon@redislabs.com> * I'm stupid * fix cluster topology test * fix cluster topology test * Update README.md * Update clustering.md * Update pub-sub.md Co-authored-by: Simon Prickett <simon@redislabs.com>
56 lines
1.7 KiB
TypeScript
56 lines
1.7 KiB
TypeScript
import { strict as assert } from 'assert';
|
|
import testUtils, { GLOBAL } from '../test-utils';
|
|
import { transformArguments, transformReply } from './CLUSTER_INFO';
|
|
|
|
describe('CLUSTER INFO', () => {
|
|
it('transformArguments', () => {
|
|
assert.deepEqual(
|
|
transformArguments(),
|
|
['CLUSTER', 'INFO']
|
|
);
|
|
});
|
|
|
|
it('transformReply', () => {
|
|
assert.deepEqual(
|
|
transformReply([
|
|
'cluster_state:ok',
|
|
'cluster_slots_assigned:16384',
|
|
'cluster_slots_ok:16384',
|
|
'cluster_slots_pfail:0',
|
|
'cluster_slots_fail:0',
|
|
'cluster_known_nodes:6',
|
|
'cluster_size:3',
|
|
'cluster_current_epoch:6',
|
|
'cluster_my_epoch:2',
|
|
'cluster_stats_messages_sent:1483972',
|
|
'cluster_stats_messages_received:1483968'
|
|
].join('\r\n')),
|
|
{
|
|
state: 'ok',
|
|
slots: {
|
|
assigned: 16384,
|
|
ok: 16384,
|
|
pfail: 0,
|
|
fail: 0
|
|
},
|
|
knownNodes: 6,
|
|
size: 3,
|
|
currentEpoch: 6,
|
|
myEpoch: 2,
|
|
stats: {
|
|
messagesSent: 1483972,
|
|
messagesReceived: 1483968
|
|
}
|
|
}
|
|
);
|
|
});
|
|
|
|
testUtils.testWithCluster('clusterNode.clusterInfo', async cluster => {
|
|
const client = await cluster.nodeClient(cluster.masters[0]);
|
|
assert.notEqual(
|
|
await client.clusterInfo(),
|
|
null
|
|
);
|
|
}, GLOBAL.CLUSTERS.OPEN);
|
|
});
|