X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fperformance%2FPerformanceStatistics.ts;h=b7bc5d27f894c27c9984571e90a4b07187ed8fed;hb=42b8cf5cdca8eaab1e7442f7c92c2a5ed97434f6;hp=281075c7eb95a0b3ccb3de85183ba9238d1c6cee;hpb=c7ba22b7e881dc5f0c7f99dfa5d67390bc46fdf6;p=e-mobility-charging-stations-simulator.git diff --git a/src/performance/PerformanceStatistics.ts b/src/performance/PerformanceStatistics.ts index 281075c7..b7bc5d27 100644 --- a/src/performance/PerformanceStatistics.ts +++ b/src/performance/PerformanceStatistics.ts @@ -28,7 +28,9 @@ import { generateUUID, logPrefix, logger, + max, median, + min, nthPercentile, stdDeviation, } from '../utils'; @@ -211,58 +213,47 @@ export class PerformanceStatistics { } private addPerformanceEntryToStatistics(entry: PerformanceEntry): void { - const entryName = entry.name; // Initialize command statistics - if (!this.statistics.statisticsData.has(entryName)) { - this.statistics.statisticsData.set(entryName, {}); + if (!this.statistics.statisticsData.has(entry.name)) { + this.statistics.statisticsData.set(entry.name, {}); } // Update current statistics - this.statistics.updatedAt = new Date(); - this.statistics.statisticsData.get(entryName)!.timeMeasurementCount = - (this.statistics.statisticsData.get(entryName)?.timeMeasurementCount ?? 0) + 1; - this.statistics.statisticsData.get(entryName)!.currentTimeMeasurement = entry.duration; - this.statistics.statisticsData.get(entryName)!.minTimeMeasurement = Math.min( + this.statistics.statisticsData.get(entry.name)!.timeMeasurementCount = + (this.statistics.statisticsData.get(entry.name)?.timeMeasurementCount ?? 0) + 1; + this.statistics.statisticsData.get(entry.name)!.currentTimeMeasurement = entry.duration; + this.statistics.statisticsData.get(entry.name)!.minTimeMeasurement = min( entry.duration, - this.statistics.statisticsData.get(entryName)?.minTimeMeasurement ?? Infinity, + this.statistics.statisticsData.get(entry.name)?.minTimeMeasurement ?? Infinity, ); - this.statistics.statisticsData.get(entryName)!.maxTimeMeasurement = Math.max( + this.statistics.statisticsData.get(entry.name)!.maxTimeMeasurement = max( entry.duration, - this.statistics.statisticsData.get(entryName)?.maxTimeMeasurement ?? -Infinity, + this.statistics.statisticsData.get(entry.name)?.maxTimeMeasurement ?? -Infinity, ); - this.statistics.statisticsData.get(entryName)!.totalTimeMeasurement = - (this.statistics.statisticsData.get(entryName)?.totalTimeMeasurement ?? 0) + entry.duration; - this.statistics.statisticsData.get(entryName)?.measurementTimeSeries instanceof CircularArray + this.statistics.statisticsData.get(entry.name)!.totalTimeMeasurement = + (this.statistics.statisticsData.get(entry.name)?.totalTimeMeasurement ?? 0) + entry.duration; + this.statistics.statisticsData.get(entry.name)?.measurementTimeSeries instanceof CircularArray ? this.statistics.statisticsData - .get(entryName) + .get(entry.name) ?.measurementTimeSeries?.push({ timestamp: entry.startTime, value: entry.duration }) - : (this.statistics.statisticsData.get(entryName)!.measurementTimeSeries = + : (this.statistics.statisticsData.get(entry.name)!.measurementTimeSeries = new CircularArray(Constants.DEFAULT_CIRCULAR_BUFFER_CAPACITY, { timestamp: entry.startTime, value: entry.duration, })); - this.statistics.statisticsData.get(entryName)!.avgTimeMeasurement = average( - extractTimeSeriesValues( - this.statistics.statisticsData.get(entryName)!.measurementTimeSeries!, - ), - ); - this.statistics.statisticsData.get(entryName)!.medTimeMeasurement = median( - extractTimeSeriesValues( - this.statistics.statisticsData.get(entryName)!.measurementTimeSeries!, - ), + const timeMeasurementValues = extractTimeSeriesValues( + this.statistics.statisticsData.get(entry.name)!.measurementTimeSeries!, ); - this.statistics.statisticsData.get(entryName)!.ninetyFiveThPercentileTimeMeasurement = - nthPercentile( - extractTimeSeriesValues( - this.statistics.statisticsData.get(entryName)!.measurementTimeSeries!, - ), - 95, - ); - this.statistics.statisticsData.get(entryName)!.stdDevTimeMeasurement = stdDeviation( - extractTimeSeriesValues( - this.statistics.statisticsData.get(entryName)!.measurementTimeSeries!, - ), - this.statistics.statisticsData.get(entryName)!.avgTimeMeasurement, + this.statistics.statisticsData.get(entry.name)!.avgTimeMeasurement = + average(timeMeasurementValues); + this.statistics.statisticsData.get(entry.name)!.medTimeMeasurement = + median(timeMeasurementValues); + this.statistics.statisticsData.get(entry.name)!.ninetyFiveThPercentileTimeMeasurement = + nthPercentile(timeMeasurementValues, 95); + this.statistics.statisticsData.get(entry.name)!.stdDevTimeMeasurement = stdDeviation( + timeMeasurementValues, + this.statistics.statisticsData.get(entry.name)!.avgTimeMeasurement, ); + this.statistics.updatedAt = new Date(); if ( Configuration.getConfigurationSection( ConfigurationSection.performanceStorage,