forked from benschmaus/nodeload
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Break reporting module into multiple files
Add comment to release notes about jmxstat & spawnAndMonitor example/nodeload.ex.js uses persistent connections
- Loading branch information
Showing
7 changed files
with
224 additions
and
215 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,208 +1,6 @@ | ||
| // ------------------------------------ | ||
| // Progress Reporting | ||
| // ------------------------------------ | ||
| // | ||
| // This file defines Report, Chart, and REPORT_MANAGER | ||
| // | ||
| // A Report contains a summary and a number of charts. Reports added to the global REPORT_MANAGER are | ||
| // served by the global HTTP_SERVER instance (defaults to http://localhost:8000/) and written to disk | ||
| // at regular intervals. | ||
| // | ||
| var BUILD_AS_SINGLE_FILE; | ||
| if (!BUILD_AS_SINGLE_FILE) { | ||
| var util = require('../util'); | ||
| var querystring = require('querystring'); | ||
| var LogFile = require('../stats').LogFile; | ||
| var template = require('./template'); | ||
| var config = require('../config'); | ||
|
|
||
| var REPORT_SUMMARY_TEMPLATE = require('./summary.tpl.js').REPORT_SUMMARY_TEMPLATE; | ||
| var NODELOAD_CONFIG = config.NODELOAD_CONFIG; | ||
| var START = NODELOAD_CONFIG.START; | ||
| var DYGRAPH_SOURCE = require('./dygraph.tpl.js').DYGRAPH_SOURCE; | ||
| var HTTP_SERVER = require('../http').HTTP_SERVER; | ||
| } | ||
|
|
||
| var Chart, timeFromStart; | ||
|
|
||
| /** A Report contains a summary object and set of charts. It can be easily updated using the stats from | ||
| a monitor.js#Monitor or monitor.js#MonitorGroup using updateFromMonitor()/updateFromMonitorGroup(). | ||
| @param name A name for the report. Generally corresponds to the test name. | ||
| @param updater A function(report) that should update the summary and chart data. */ | ||
| var Report = exports.Report = function(name) { | ||
| this.name = name; | ||
| this.uid = util.uid(); | ||
| this.summary = {}; | ||
| this.charts = {}; | ||
| }; | ||
| Report.prototype = { | ||
| getChart: function(name) { | ||
| if (!this.charts[name]) { | ||
| this.charts[name] = new Chart(name); | ||
| } | ||
| return this.charts[name]; | ||
| }, | ||
| /** Update this report automatically each time the Monitor emits an 'update' event */ | ||
| updateFromMonitor: function(monitor) { | ||
| monitor.on('update', this.doUpdateFromMonitor_.bind(this, monitor, '')); | ||
| return this; | ||
| }, | ||
| /** Update this report automatically each time the MonitorGroup emits an 'update' event */ | ||
| updateFromMonitorGroup: function(monitorGroup) { | ||
| var self = this; | ||
| monitorGroup.on('update', function() { | ||
| util.forEach(monitorGroup.monitors, function(monitorname, monitor) { | ||
| self.doUpdateFromMonitor_(monitor, monitorname); | ||
| }); | ||
| }); | ||
| return self; | ||
| }, | ||
| doUpdateFromMonitor_: function(monitor, monitorname) { | ||
| var self = this; | ||
| monitorname = monitorname ? monitorname + ' ' : ''; | ||
| util.forEach(monitor.stats, function(statname, stat) { | ||
| util.forEach(stat.summary(), function(name, val) { | ||
| self.summary[self.name + ' ' + monitorname + statname + ' ' + name] = val; | ||
| }); | ||
| if (monitor.interval[statname]) { | ||
| self.getChart(monitorname + statname) | ||
| .put(monitor.interval[statname].summary()); | ||
| } | ||
| }); | ||
| } | ||
| }; | ||
|
|
||
| /** A Chart represents a collection of lines over time represented as: | ||
| columns: ["x values", "line 1", "line 2", "line 3", ...] | ||
| rows: [[timestamp1, line1[0], line2[0], line3[0], ...], | ||
| [timestamp2, line1[1], line2[1], line3[1], ...], | ||
| [timestamp3, line1[2], line2[2], line3[2], ...], | ||
| ... | ||
| ] | ||
| @param name A name for the chart */ | ||
| var Chart = exports.Chart = function(name) { | ||
| this.name = name; | ||
| this.uid = util.uid(); | ||
| this.columns = ["time"]; | ||
| this.rows = [[timeFromStart()]]; | ||
| }; | ||
| Chart.prototype = { | ||
| /** Put a row of data into the chart. The current time will be used as the x-value. The lines in the | ||
| chart are extracted from the "data". New lines can be added to the chart at any time by including it | ||
| in data. | ||
| @param data An object representing one row of data: { | ||
| "line name 1": value1 | ||
| "line name 2": value2 | ||
| ... | ||
| } | ||
| */ | ||
| put: function(data) { | ||
| var self = this, row = [timeFromStart()]; | ||
| util.forEach(data, function(column, val) { | ||
| var col = self.columns.indexOf(column); | ||
| if (col < 0) { | ||
| col = self.columns.length; | ||
| self.columns.push(column); | ||
| self.rows[0].push(0); | ||
| } | ||
| row[col] = val; | ||
| }); | ||
| self.rows.push(row); | ||
| }, | ||
| /** Update chart using data from event emitter each time it emits an event. 'eventEmitter' should | ||
| emit the given 'event' (defaults to 'data') with a single object. 'fields' are read from the object | ||
| and added to the chart. For example, a chart can track the output form a child process output using | ||
| chart.updateFromEventEmitter(spawnAndMonitor('cmd', ['args'], /val: (.*)/, ['val']), ['val']) | ||
| */ | ||
| updateFromEventEmitter: function(eventEmitter, fields, event) { | ||
| eventEmitter.on(event || 'data', function(data) { | ||
| var row = {}; | ||
| fields.forEach(function(i) { | ||
| if (data[i] !== undefined) { row[i] = data[i]; } | ||
| }); | ||
| this.put(row); | ||
| }); | ||
| } | ||
| }; | ||
|
|
||
| var ReportGroup = exports.ReportGroup = function() { | ||
| this.reports = []; | ||
| this.logNameOrObject = 'results-' + START.getTime() + '.html'; | ||
| }; | ||
| ReportGroup.prototype = { | ||
| addReport: function(report) { | ||
| report = (typeof report === 'string') ? new Report(report) : report; | ||
| this.reports.push(report); | ||
| return report; | ||
| }, | ||
| setLogFile: function(logNameOrObject) { | ||
| this.logNameOrObject = logNameOrObject; | ||
| }, | ||
| setLoggingEnabled: function(enabled) { | ||
| clearTimeout(this.loggingTimeoutId); | ||
| if (enabled) { | ||
| this.logger = this.logger || (typeof this.logNameOrObject === 'string') ? new LogFile(this.logNameOrObject) : this.logNameOrObject; | ||
| this.loggingTimeoutId = setTimeout(this.writeToLog_.bind(this), this.refreshIntervalMs); | ||
| } else if (this.logger) { | ||
| this.logger.close(); | ||
| this.logger = null; | ||
| } | ||
| return this; | ||
| }, | ||
| reset: function() { | ||
| this.reports = {}; | ||
| }, | ||
| getHtml: function() { | ||
| var self = this, | ||
| t = template.create(REPORT_SUMMARY_TEMPLATE); | ||
| return t({ | ||
| DYGRAPH_SOURCE: DYGRAPH_SOURCE, | ||
| querystring: querystring, | ||
| refreshPeriodMs: self.refreshIntervalMs, | ||
| reports: self.reports | ||
| }); | ||
| }, | ||
| writeToLog_: function() { | ||
| this.loggingTimeoutId = setTimeout(this.writeToLog_.bind(this), this.refreshIntervalMs); | ||
| this.logger.clear(this.getHtml()); | ||
| } | ||
| }; | ||
|
|
||
| // ================= | ||
| // Singletons | ||
| // ================= | ||
|
|
||
| /** A global report manager used by nodeload to keep the summary webpage up to date during a load test */ | ||
| var REPORT_MANAGER = exports.REPORT_MANAGER = new ReportGroup(); | ||
| NODELOAD_CONFIG.on('apply', function() { | ||
| REPORT_MANAGER.refreshIntervalMs = REPORT_MANAGER.refreshIntervalMs || NODELOAD_CONFIG.AJAX_REFRESH_INTERVAL_MS; | ||
| REPORT_MANAGER.setLoggingEnabled(NODELOAD_CONFIG.LOGS_ENABLED); | ||
| }); | ||
|
|
||
| HTTP_SERVER.addRoute('^/$', function(url, req, res) { | ||
| var html = REPORT_MANAGER.getHtml(); | ||
| res.writeHead(200, {"Content-Type": "text/html", "Content-Length": html.length}); | ||
| res.write(html); | ||
| res.end(); | ||
| }); | ||
| HTTP_SERVER.addRoute('^/reports$', function(url, req, res) { | ||
| var json = JSON.stringify(REPORT_MANAGER.reports); | ||
| res.writeHead(200, {"Content-Type": "application/json", "Content-Length": json.length}); | ||
| res.write(json); | ||
| res.end(); | ||
| }); | ||
|
|
||
| // ================= | ||
| // Private methods | ||
| // ================= | ||
|
|
||
| /** current time from start of nodeload process in 100ths of a minute */ | ||
| function timeFromStart() { | ||
| return (Math.floor((new Date().getTime() - START) / 600) / 100); | ||
| } | ||
| var report = require('./report'); | ||
| exports.Report = report.Report; | ||
| exports.Chart = report.Chart; | ||
| exports.ReportGroup = report.ReportGroup; | ||
| exports.REPORT_MANAGER= require('./reportmanager').REPORT_MANAGER; | ||
| exports.spawnAndMonitor = require('./process').spawnAndMonitor; |
Oops, something went wrong.