Ioredis: scanStream in cluster mode?

[bkw]

it seems that scanStream() is not available when using ioredis.Cluster(), although scan() is.
Any particular reason for this, or is this a requestable feature? ;-)

[luin]

Commands that doesn't have a key name as the arguments(e.g. scan, keys & info) will be sent to a random node of the cluster. So that it doesn't make sense to provide scanStream in the cluster mode since it will only scan a random node instead of the whole cluster.

[bkw]

Ah, thanks for clearing that up.

[bkw]

Is that also the case for the other scan commands like hscan?
I mean, they do have a key as an argument. Couldn't that work? And please excuse my ignorance about cluster internals.

[luin]

Yes, you're right. Other scan commands work with cluster. I'll consider whether to implement it.
Any pr is welcome :-)

[luin]

Released in v1.11.0 :rocket:

[geogeim]

tested with ioredis 3.1.4 and scanStream function is missing from Redis.Cluster

[AndyGura]

+1 on this. There is still no scanStream function in Redis.Cluster. However you can use cluster.subscriber.scanStream to scan on currently connected slot.

[jseparator]

    let nodes = redis.nodes('master'),
        scanNode = (nodeIndex) => {
            let node = nodes[nodeIndex];
            node.scanStream({
                count: 10000
            }).on('data', rs => {
                rs.forEach(r => console.debug("key", r));
            }).on('end', () => {
                console.info("scan end, node %s:%d", node.options.host, node.options.port);
                if (++nodeIndex < nodes.length) {
                    scanNode(nodeIndex);
                } else {
                    console.info("scan finished");
                    redis.quit();
                }
            });
            console.info("scan start, node %s:%d", node.options.host, node.options.port);
        };
    scanNode(0);

Iterate over all Cluster Master Nodes, and then scan every single Node