pm2-cluster-cache
v2.1.7
Published
pm2 cluster memory cache with ttl and more possibilities of data store in cluster
Downloads
327
Maintainers
Readme
pm2 cluster memory cache
A cluster memory cache for pm2 with some different possibilities of data store. From version 1.0.5 is safe to use without pm2 too, but storage type will be forced to 'self'.
Instalation
npm install pm2-cluster-cache --save
Tests
npm run test
Remember: testing environment may vary depending on storage types. Therefore tests are divided into 4 separate running tests. If you run npm run test
, all test will be performed, but you can run specific test, for example npm run test-cluster
for cluster type, or npm run test-master
for master type, and so on. Every test will create server with max processes, and test against api running on this cluster server.
Usage
const pm2ClusterCache = require('pm2-cluster-cache');
let cache = pm2ClusterCache.init({storage: "cluster"});
//set value to cache for 1s
cache.set('key', 'data', 1000).then(() => {
console.log('ok');
});
//get cached value
cache.get('key', "someDefaultValue").then(result => {
console.log(result);
});
//get value from cache with metadata
cache.withMeta().get('key', "someDefaultValue").then(result => {
console.log(result.data);
console.log(result.metadata);
});
//get cluster data map
cache.keys().then(map => {
console.log(map);
});
API
init(options)
- create new cluster cache. Options object can have following keys:defaultTtl
- default time to live for keys in ms. Default value is1000
ms.logger
- default console. May be any class with impemented methodslog
andwarn
.storage
- can be one ofself
,all
,master
,cluster
. Default value iscluster
.self
- store to actual process, read from actual process. Every process has his own cache, so this cache is not shared between processes.all
- store to all processes, read from actual process. Data are duplicated and on every process is stored full replica of all data. If one process restarts, other process are not affected with cache misses.master
- store to master, read from master. If actual process restarts, other process are not affected with cache miss, if actual process is not master. If master restarts, every process in cluster will lost all cached data.cluster
- store to specific process, read from specific process. Every process in cluster has part of data, so if one process restarts, other process will lost only part of data. Targer process for storage is detemined by key.
set(key, value, [ttl])
- store value under key, with given ttl (in ms).get(key, [defaultValue])
- get value stored under key 'key'.inc(key)
- increment key by 1. If key not exists, creates it with value 0 and returns.dec(key)
- decrement key by 1. If key not exists, creates it with value 0 and returns.delete(key)
- removes key from all process where is given key stored. Returns in Promise array of processes deleted from.flush()
- removes all keys from all processes.keys()
- returns in Promise map of cluster with numbers of stored keys.withMeta()
- returns decoratedget
andset
method that are returning metadata with data.
metadata
object is object with keys:
storedOn
- array of int. Processes that have key stored.readFrom
- int. Proccess which provided data.servedBy
- int. Actual process.
PM2 metrics
with command pm2 describe <your app name>
you can see in Code metrics cache hit rate and miss rate on every process.