Compare commits
9 Commits
developmen
...
test/crrte
Author | SHA1 | Date |
---|---|---|
philipyoo | 6039da8bd5 | |
philipyoo | f2014202f4 | |
philipyoo | f1ec95b92e | |
philipyoo | 6d00012797 | |
philipyoo | 289eafc420 | |
philipyoo | 4353beb3e8 | |
philipyoo | d01d32bfb6 | |
philipyoo | 9050fbb7b0 | |
philipyoo | 6f86b38f99 |
|
@ -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);
|
||||||
}
|
}
|
||||||
|
|
|
@ -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),
|
||||||
|
|
|
@ -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": {
|
||||||
|
|
Loading…
Reference in New Issue