You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-07-31 05:44:24 +03:00
b2d35c5286
RESP3 Support - Some commands responses in RESP3 aren't stable yet and therefore return an "untyped" ReplyUnion. Sentinel TypeMapping Correctly types Multi commands Note: some API changes to be further documented in v4-to-v5.md
80 lines
2.2 KiB
JavaScript
80 lines
2.2 KiB
JavaScript
// This example demonstrates the use of the Cuckoo Filter
|
|
// in the RedisBloom module (https://redis.io/docs/stack/bloom/)
|
|
|
|
import { createClient } from 'redis';
|
|
|
|
const client = createClient();
|
|
|
|
await client.connect();
|
|
|
|
// Delete any pre-existing Cuckoo Filter.
|
|
await client.del('mycuckoo');
|
|
|
|
// Reserve a Cuckoo Filter with a capacity of 10000 items.
|
|
// https://redis.io/commands/cf.reserve/
|
|
try {
|
|
await client.cf.reserve('mycuckoo', 10000);
|
|
console.log('Reserved Cuckoo Filter.');
|
|
} catch (e) {
|
|
console.log('Error, maybe RedisBloom is not installed?:');
|
|
console.log(e);
|
|
}
|
|
|
|
// Add items to Cuckoo Filter individually with CF.ADD command.
|
|
// https://redis.io/commands/cf.add/
|
|
await Promise.all([
|
|
client.cf.add('mycuckoo', 'leibale'),
|
|
client.cf.add('mycuckoo', 'simon'),
|
|
client.cf.add('mycuckoo', 'guy'),
|
|
client.cf.add('mycuckoo', 'suze'),
|
|
client.cf.add('mycuckoo', 'brian'),
|
|
client.cf.add('mycuckoo', 'steve'),
|
|
client.cf.add('mycuckoo', 'kyle'),
|
|
client.cf.add('mycuckoo', 'josefin'),
|
|
client.cf.add('mycuckoo', 'alex'),
|
|
client.cf.add('mycuckoo', 'nava'),
|
|
]);
|
|
|
|
// Add items to the Cuckoo Filter only if they don't exist in it...
|
|
// https://redis.io/commands/cf.addnx/
|
|
const nxReply = await Promise.all([
|
|
client.cf.addNX('mycuckoo', 'kaitlyn'), // New
|
|
client.cf.addNX('mycuckoo', 'rachel'), // New
|
|
client.cf.addNX('mycuckoo', 'brian') // Previously added
|
|
]);
|
|
|
|
console.log('Added members to Cuckoo Filter.');
|
|
console.log('nxReply:');
|
|
|
|
// nxReply looks like this:
|
|
// [
|
|
// true,
|
|
// true,
|
|
// false
|
|
// ]
|
|
console.log(nxReply);
|
|
|
|
// Check whether a member exists with the CF.EXISTS command.
|
|
// https://redis.io/commands/cf.exists/
|
|
const simonExists = await client.bf.exists('mycuckoo', 'simon');
|
|
console.log(`simon ${simonExists ? 'may' : 'does not'} exist in the Cuckoo Filter.`);
|
|
|
|
// Get stats for the Cuckoo Filter with the CF.INFO command:
|
|
// https://redis.io/commands/cf.info/
|
|
const info = await client.cf.info('mycuckoo');
|
|
|
|
// info looks like this:
|
|
// {
|
|
// size: 16440,
|
|
// numberOfBuckets: 8192,
|
|
// numberOfFilters: 1,
|
|
// numberOfInsertedItems: 12,
|
|
// numberOfDeletedItems: 0,
|
|
// bucketSize: 2,
|
|
// expansionRate: 1,
|
|
// maxIteration: 20
|
|
// }
|
|
console.log(info);
|
|
|
|
client.destroy();
|