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

fix: metrics stats and moving averages types (#915)

Browse Source 
* fix: give stats initial values

Otherwise the compiler cannot derive the type and thinks `stats.snapshot` returns `{}`

* fix: add type shape to moving averages as well
This commit is contained in:
Alex Potsides 2021-04-16 16:10:22 +01:00 committed by GitHub
parent 55ee332907
commit 3d0a79eff3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/metrics/stats.js
View File

@ -2,7 +2,7 @@
'use strict' 'use strict'
const EventEmitter = require('events') const EventEmitter = require('events')
const Big = require('bignumber.js') const { BigNumber: Big } = require('bignumber.js')
const MovingAverage = require('moving-average') const MovingAverage = require('moving-average')
const retimer = require('retimer') const retimer = require('retimer')
@ -19,11 +19,17 @@ class Stats extends EventEmitter {
this._options = options this._options = options
this._queue = [] this._queue = []
this._stats = {}
/** @type {{ dataReceived: Big, dataSent: Big }} */
this._stats = {
dataReceived: Big(0),
dataSent: Big(0)
}
this._frequencyLastTime = Date.now() this._frequencyLastTime = Date.now()
this._frequencyAccumulators = {} this._frequencyAccumulators = {}
/** @type {{ dataReceived: MovingAverage[], dataSent: MovingAverage[] }} */
this._movingAverages = {} this._movingAverages = {}
this._update = this._update.bind(this) this._update = this._update.bind(this)