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

View File

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

View File

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