fluencelabs/js-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p synced 2025-04-25 18:42:15 +00:00
Code Issues Projects Releases Wiki Activity

fix: moving averages record types (#935)

Browse Source
This commit is contained in:
Vasco Santos 2021-04-30 15:42:34 +02:00 committed by GitHub
parent e5187d02ba
commit b5a9eb2087
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/metrics/stats.js
View File

@ -6,6 +6,10 @@ const { BigNumber: Big } = require('bignumber.js')
const MovingAverage = require('@vascosantos/moving-average') const MovingAverage = require('@vascosantos/moving-average')
const retimer = require('retimer') const retimer = require('retimer')
/**
* @typedef {import('@vascosantos/moving-average').IMovingAverage} IMovingAverage
*/
class Stats extends EventEmitter { class Stats extends EventEmitter {
/** /**
* A queue based manager for stat processing * A queue based manager for stat processing
@ -29,7 +33,7 @@ class Stats extends EventEmitter {
this._frequencyLastTime = Date.now() this._frequencyLastTime = Date.now()
this._frequencyAccumulators = {} this._frequencyAccumulators = {}
/** @type {{ dataReceived: MovingAverage[], dataSent: MovingAverage[] }} */ /** @type {{ dataReceived: IMovingAverage[], dataSent: IMovingAverage[] }} */
this._movingAverages = {} this._movingAverages = {}
this._update = this._update.bind(this) this._update = this._update.bind(this)