CircularArray,
Configuration,
Constants,
- MessageChannelUtils,
Utils,
+ buildPerformanceStatisticsMessage,
logger,
+ median,
+ nthPercentile,
+ stdDeviation,
} from '../utils';
export class PerformanceStatistics {
this.statistics.statisticsData.has(command) &&
this.statistics.statisticsData.get(command)?.countRequest
) {
- this.statistics.statisticsData.get(command).countRequest++;
+ ++this.statistics.statisticsData.get(command).countRequest;
} else {
this.statistics.statisticsData.set(command, {
...this.statistics.statisticsData.get(command),
this.statistics.statisticsData.has(command) &&
this.statistics.statisticsData.get(command)?.countResponse
) {
- this.statistics.statisticsData.get(command).countResponse++;
+ ++this.statistics.statisticsData.get(command).countResponse;
} else {
this.statistics.statisticsData.set(command, {
...this.statistics.statisticsData.get(command),
this.statistics.statisticsData.has(command) &&
this.statistics.statisticsData.get(command)?.countError
) {
- this.statistics.statisticsData.get(command).countError++;
+ ++this.statistics.statisticsData.get(command).countError;
} else {
this.statistics.statisticsData.set(command, {
...this.statistics.statisticsData.get(command),
}
private startLogStatisticsInterval(): void {
- const logStatisticsInterval = Configuration.getLogStatisticsInterval();
+ const logStatisticsInterval = Configuration.getLog().enabled
+ ? Configuration.getLog().statisticsInterval
+ : 0;
if (logStatisticsInterval > 0 && !this.displayInterval) {
this.displayInterval = setInterval(() => {
this.logStatistics();
logStatisticsInterval
)}`
);
- } else {
+ } else if (Configuration.getLog().enabled) {
logger.info(
`${this.logPrefix()} log interval is set to ${logStatisticsInterval?.toString()}. Not logging statistics`
);
timestamp: entry.startTime,
value: entry.duration,
}));
- this.statistics.statisticsData.get(entryName).medTimeMeasurement = Utils.median(
+ this.statistics.statisticsData.get(entryName).medTimeMeasurement = median(
this.extractTimeSeriesValues(
this.statistics.statisticsData.get(entryName).timeMeasurementSeries
)
);
this.statistics.statisticsData.get(entryName).ninetyFiveThPercentileTimeMeasurement =
- Utils.percentile(
+ nthPercentile(
this.extractTimeSeriesValues(
this.statistics.statisticsData.get(entryName).timeMeasurementSeries
),
95
);
- this.statistics.statisticsData.get(entryName).stdDevTimeMeasurement = Utils.stdDeviation(
+ this.statistics.statisticsData.get(entryName).stdDevTimeMeasurement = stdDeviation(
this.extractTimeSeriesValues(
this.statistics.statisticsData.get(entryName).timeMeasurementSeries
)
);
if (Configuration.getPerformanceStorage().enabled) {
- parentPort?.postMessage(
- MessageChannelUtils.buildPerformanceStatisticsMessage(this.statistics)
- );
+ parentPort?.postMessage(buildPerformanceStatisticsMessage(this.statistics));
}
}