Ottomata has uploaded a new change for review. (
https://gerrit.wikimedia.org/r/403461 )
Change subject: Fixes for updated linter
......................................................................
Fixes for updated linter
Bug: T171011
Change-Id: I68bc0200d51b4a82f36f4116cd7ef06c45a48a43
---
M lib/eventstreams-util.js
M routes/stream.js
2 files changed, 2 insertions(+), 3 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/mediawiki/services/eventstreams
refs/changes/61/403461/1
diff --git a/lib/eventstreams-util.js b/lib/eventstreams-util.js
index 71e3535..0b4a3bc 100644
--- a/lib/eventstreams-util.js
+++ b/lib/eventstreams-util.js
@@ -128,14 +128,14 @@
*/
class IntervalCounter {
/**
- * @param {function} cb cb function that takes key, value.
+ * @param {callback} cb cb function that takes key, value.
* This will be called for each stored
counter
* @param {integer} intervalMs cb will be called for every key, count
this often.
* Default: 5000
* @param {boolean} shouldReset If true, each stored counter will be
nulled every
* interval ms. Default: false
*
- * @constructor
+ * @class
*/
constructor(cb, intervalMs, shouldReset) {
this.cb = cb;
diff --git a/routes/stream.js b/routes/stream.js
index a7c53fb..b48b701 100644
--- a/routes/stream.js
+++ b/routes/stream.js
@@ -2,7 +2,6 @@
const os = require('os');
const kafkaSse = require('kafka-sse');
-const rdkafkaStatsd = require('node-rdkafka-statsd');
const sUtil = require('../lib/util');
const eUtil = require('../lib/eventstreams-util');
--
To view, visit https://gerrit.wikimedia.org/r/403461
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I68bc0200d51b4a82f36f4116cd7ef06c45a48a43
Gerrit-PatchSet: 1
Gerrit-Project: mediawiki/services/eventstreams
Gerrit-Branch: master
Gerrit-Owner: Ottomata <[email protected]>
_______________________________________________
MediaWiki-commits mailing list
[email protected]
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
