redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-07 13:22:56 +03:00
Code Activity

Disable readOnly for cluster s/pubsub client (#2950)

Browse Source
This commit is contained in:
Hristo Temelski
2025-05-08 10:29:05 +03:00
committed by GitHub
parent 86480aaa74
commit bb7845dfe3
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/client/lib/cluster/cluster-slots.ts
View File

@@ -518,7 +518,7 @@ export default class RedisClusterSlots<
node = index < this.masters.length ? node = index < this.masters.length ?
this.masters[index] : this.masters[index] :
this.replicas[index - this.masters.length], this.replicas[index - this.masters.length],
client = this.#createClient(node, index >= this.masters.length); client = this.#createClient(node, false);
this.pubSubNode = { this.pubSubNode = {
address: node.address, address: node.address,
@@ -563,7 +563,7 @@ export default class RedisClusterSlots<
} }
async #initiateShardedPubSubClient(master: MasterNode<M, F, S, RESP, TYPE_MAPPING>) { async #initiateShardedPubSubClient(master: MasterNode<M, F, S, RESP, TYPE_MAPPING>) {
const client = this.#createClient(master, true) const client = this.#createClient(master, false)
.on('server-sunsubscribe', async (channel, listeners) => { .on('server-sunsubscribe', async (channel, listeners) => {
try { try {
await this.rediscover(client); await this.rediscover(client);