[6a3a178] | 1 | import { NO_TAG } from "./Histogram";
|
---|
| 2 | import { encodeIntoCompressedBase64 } from "./encoding";
|
---|
| 3 | import { floatFormatter } from "./formatters";
|
---|
| 4 | import Histogram from "./Histogram";
|
---|
| 5 |
|
---|
| 6 | export interface Writable {
|
---|
| 7 | (c: string): void;
|
---|
| 8 | }
|
---|
| 9 |
|
---|
| 10 | const HISTOGRAM_LOG_FORMAT_VERSION = "1.3";
|
---|
| 11 | const timeFormatter = floatFormatter(5, 3);
|
---|
| 12 |
|
---|
| 13 | class HistogramLogWriter {
|
---|
| 14 | /**
|
---|
| 15 | * Base time to subtract from supplied histogram start/end timestamps when
|
---|
| 16 | * logging based on histogram timestamps.
|
---|
| 17 | * Base time is expected to be in msec since the epoch, as histogram start/end times
|
---|
| 18 | * are typically stamped with absolute times in msec since the epoch.
|
---|
| 19 | */
|
---|
| 20 | baseTime = 0;
|
---|
| 21 |
|
---|
| 22 | constructor(private log: Writable) {}
|
---|
| 23 |
|
---|
| 24 | /**
|
---|
| 25 | * Output an interval histogram, with the given timestamp information and the [optional] tag
|
---|
| 26 | * associated with the histogram, using a configurable maxValueUnitRatio. (note that the
|
---|
| 27 | * specified timestamp information will be used, and the timestamp information in the actual
|
---|
| 28 | * histogram will be ignored).
|
---|
| 29 | * The max value reported with the interval line will be scaled by the given maxValueUnitRatio.
|
---|
| 30 | * @param startTimeStampSec The start timestamp to log with the interval histogram, in seconds.
|
---|
| 31 | * @param endTimeStampSec The end timestamp to log with the interval histogram, in seconds.
|
---|
| 32 | * @param histogram The interval histogram to log.
|
---|
| 33 | * @param maxValueUnitRatio The ratio by which to divide the histogram's max value when reporting on it.
|
---|
| 34 | */
|
---|
| 35 | outputIntervalHistogram(
|
---|
| 36 | histogram: Histogram,
|
---|
| 37 | startTimeStampSec = (histogram.startTimeStampMsec - this.baseTime) / 1000,
|
---|
| 38 | endTimeStampSec = (histogram.endTimeStampMsec - this.baseTime) / 1000,
|
---|
| 39 | maxValueUnitRatio = 1000
|
---|
| 40 | ) {
|
---|
| 41 | const base64 = encodeIntoCompressedBase64(histogram);
|
---|
| 42 | const start = timeFormatter(startTimeStampSec);
|
---|
| 43 | const duration = timeFormatter(endTimeStampSec - startTimeStampSec);
|
---|
| 44 | const max = timeFormatter(histogram.maxValue / maxValueUnitRatio);
|
---|
| 45 | const lineContent = `${start},${duration},${max},${base64}\n`;
|
---|
| 46 | if (histogram.tag && histogram.tag !== NO_TAG) {
|
---|
| 47 | this.log(`Tag=${histogram.tag},${lineContent}`);
|
---|
| 48 | } else {
|
---|
| 49 | this.log(lineContent);
|
---|
| 50 | }
|
---|
| 51 | }
|
---|
| 52 |
|
---|
| 53 | /**
|
---|
| 54 | * Log a comment to the log.
|
---|
| 55 | * Comments will be preceded with with the '#' character.
|
---|
| 56 | * @param comment the comment string.
|
---|
| 57 | */
|
---|
| 58 | outputComment(comment: string) {
|
---|
| 59 | this.log(`#${comment}\n`);
|
---|
| 60 | }
|
---|
| 61 |
|
---|
| 62 | /**
|
---|
| 63 | * Log a start time in the log.
|
---|
| 64 | * @param startTimeMsec time (in milliseconds) since the absolute start time (the epoch)
|
---|
| 65 | */
|
---|
| 66 | outputStartTime(startTimeMsec: number) {
|
---|
| 67 | this.outputComment(
|
---|
| 68 | `[StartTime: ${floatFormatter(
|
---|
| 69 | 5,
|
---|
| 70 | 3
|
---|
| 71 | )(startTimeMsec / 1000)} (seconds since epoch), ${new Date(
|
---|
| 72 | startTimeMsec
|
---|
| 73 | )}]\n`
|
---|
| 74 | );
|
---|
| 75 | }
|
---|
| 76 |
|
---|
| 77 | /**
|
---|
| 78 | * Output a legend line to the log.
|
---|
| 79 | */
|
---|
| 80 | outputLegend() {
|
---|
| 81 | this.log(
|
---|
| 82 | '"StartTimestamp","Interval_Length","Interval_Max","Interval_Compressed_Histogram"\n'
|
---|
| 83 | );
|
---|
| 84 | }
|
---|
| 85 |
|
---|
| 86 | /**
|
---|
| 87 | * Output a log format version to the log.
|
---|
| 88 | */
|
---|
| 89 | outputLogFormatVersion() {
|
---|
| 90 | this.outputComment(
|
---|
| 91 | "[Histogram log format version " + HISTOGRAM_LOG_FORMAT_VERSION + "]"
|
---|
| 92 | );
|
---|
| 93 | }
|
---|
| 94 | }
|
---|
| 95 |
|
---|
| 96 | export default HistogramLogWriter;
|
---|