Couchbase cache store for node-cache-manager.
npm install cache-manager-couchbase --saveor
yarn add cache-manager-couchbaseSee examples below on how to implement the Redis cache store.
var cacheManager = require('cache-manager');
var couchbaseStore = require('cache-manager-couchbase');
var config = {
connectionString: 'couchbase://127.0.0.1:8091',
connectionOptions: {
username: 'Administrator',
password: 'couchbase'
},
bucket: 'test-bucket',
ttl: 2
};
var couchbaseCache = cacheManager.caching({
connectionString: config.connectionString,
store: couchbaseStore,
connectionOptions: config.connectionOptions,
scope: config.scope,
bucket: config.bucket,
collection: config.collection,
ttl: 60
});
var ttl = 2;
couchbaseCache.set('foo', 'bar', { ttl: ttl }, (err) => {
if (err) {
throw err;
}
couchbaseCache.get('foo', (err, result) => {
console.log(result);
// >> 'bar'
couchbaseCache.del('foo', (err) => {
});
});
});
function getUser(id, cb) {
setTimeout(() => {
console.log("Returning user from slow database.");
cb(null, { id: id, name: 'Bob' });
}, 100);
}
var userId = 123;
var key = `user_${userId}`;
// Note: ttl is optional in wrap()
couchbaseCache.wrap(key, (cb) => {
getUser(userId, cb);
}, { ttl: ttl }, (err, user) => {
console.log(user);
// Second time fetches user from redisCache
couchbaseCache
.wrap(key, () => getUser(userId))
.then(console.log)
.catch(err => {
// handle error
});
});Couchbase use buckets, scopes and collection to segment customer. The cache-manager-couchbase configuration let you choose between all of them.
Example for couchbase pre-7.x (no scopes and collection):
var config = {
connectionString: 'couchbase://127.0.0.1:8091',
connectionOptions: {
username: 'Administrator',
password: 'your-secret-p@ssw0rd'
},
bucket: 'your-bucket'
};Example for couchbase >7.x:
var config = {
connectionString: 'couchbase://127.0.0.1:8091',
connectionOptions: {
username: 'Administrator',
password: 'your-secret-p@ssw0rd'
},
bucket: 'your-bucket',
scope: 'your-scope',
collection: 'your-collection',
ttl: 2
};The configuration let you customise how the plugin connects to your couchbase cluster.
var config = {
connectionString: 'couchbases://node1.example.com,node2.example.com',
connectionOptions: {
trustStorePath: '/path/to/ca/certificates.pem',
username: 'Administrator',
password: 'couchbase'
},
bucket: 'your-bucket'
};connectionString let you provide one or multiple seed nodes and connectionOptions are passed right away to the underlying couchbase nodejs SDK so that you can use all options provided here on the couchbase documentation
Once your couchbase bucket is set up you will need to create an index so that the keys method can effectively look up for your keys.
Here an example:
CREATE INDEX `all_keys` ON `your-bucket`((meta().`id`))If you see an error like the following:
error properties: Object({ cause: Error: libcouchbase error 401, context: QueryErrorContext({ first_error_code: 4000, first_error_message: 'No index available on keyspace test-bucket that matches your query. Use CREATE INDEX or CREATE PRIMARY INDEX to create an index, or check that your expected index is online.', statement: 'SELECT RAW meta(b).id FROM `test-bucket` b WHERE REGEXP_CONTAINS(META(b).id, $PATTERN)', client_context_id: 'c1ed4896bea27e6c', parameters: '', http_response_code: 404, http_response_body: '' }) })
It means the above mentioned index is missing!
The 'keys' method let you selectively extract keys. This selection on couchbase is implemented through a SQL query using the REGEXP_CONTAINS so tha you can use a regexp to select your keys.
Example:
couchbaseCache.keys('f*')- auto provision
keysindex - Improve connection error handling
- Improve keys method performances
- Verify ttl method compliancy
- Upgrade Couchbase Cluster connection to a non-blocking mode (To Be Checked)
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent