Compare commits

...

9 Commits

Author SHA1 Message Date
philipyoo 6039da8bd5 s 2018-06-25 20:44:37 -07:00
philipyoo f2014202f4 bump 2018-06-25 19:59:00 -07:00
philipyoo f1ec95b92e s 2018-06-25 19:56:25 -07:00
philipyoo 6d00012797 post-change 2018-06-25 13:10:10 -07:00
philipyoo 289eafc420 t 2018-06-25 13:04:05 -07:00
philipyoo 4353beb3e8 s 2018-06-25 12:48:35 -07:00
philipyoo d01d32bfb6 test 2018-06-25 11:53:18 -07:00
philipyoo 9050fbb7b0 test 2018-06-25 11:37:54 -07:00
philipyoo 6f86b38f99 s 2018-06-25 11:06:18 -07:00
3 changed files with 9 additions and 1 deletions

View File

@ -17,6 +17,8 @@ class Metrics {
(EXPIRY + INTERVAL));
this._validSites = validSites;
this._internalStart = internalStart;
console.log('\n\nREDIS CONFIG:', redisConfig, '\n\n');
}
/**
@ -27,6 +29,7 @@ class Metrics {
* @return {undefined}
*/
_queryStats(ops, site, cb) {
console.log('IN QUERYSTATS')
return async.map(ops, (op, done) => {
if (site === 'all') {
const queryString = `*:${op}:*`;
@ -47,6 +50,8 @@ class Metrics {
});
const reducedKeys = [...new Set(allKeys)];
console.log(reducedKeys)
return this._statsClient.getAllStats(this._logger,
reducedKeys, done);
});
@ -62,6 +67,7 @@ class Metrics {
});
}
const queryString = `${site}:${op}`;
console.log(queryString)
return this._statsClient.getStats(this._logger, queryString, done);
}, cb);
}

View File

@ -169,6 +169,8 @@ class StatsClient {
req500sKeys.push(['get', this._buildKey(`${id}:500s`, d)]);
this._setPrevInterval(d);
}
console.log('STATSCLIENT:', reqsKeys);
return async.parallel([
next => this._redis.batch(reqsKeys, next),
next => this._redis.batch(req500sKeys, next),

View File

@ -3,7 +3,7 @@
"engines": {
"node": ">=6.9.5"
},
"version": "8.0.0",
"version": "8.2.6",
"description": "Common utilities for the S3 project components",
"main": "index.js",
"repository": {