mirror of
https://github.com/prometheus/prometheus.git
synced 2024-11-12 00:24:04 -08:00
81d37a04aa
For some of the queries, the fuzzy lookup was not filtering properly. The problem is due to the "replace" beind made on the query itself. It accidently removes only the first underscore. This patch changes it so that it removes all of the whitespaces, letting the fuzzy algorithm do its magic, also fixing this problem. Originally, the underscore were replaced by a space for this specific reason, to let the user type a space and have the lookup treat it as the word break. Fixes #2380
871 lines
25 KiB
JavaScript
871 lines
25 KiB
JavaScript
var Prometheus = Prometheus || {};
|
|
var graphTemplate;
|
|
|
|
var SECOND = 1000;
|
|
|
|
Prometheus.Graph = function(element, options, handleChange, handleRemove) {
|
|
this.el = element;
|
|
this.graphHTML = null;
|
|
this.options = options;
|
|
this.handleChange = handleChange;
|
|
this.handleRemove = function() {
|
|
handleRemove(this);
|
|
};
|
|
this.rickshawGraph = null;
|
|
this.data = [];
|
|
|
|
this.initialize();
|
|
};
|
|
|
|
Prometheus.Graph.timeFactors = {
|
|
"y": 60 * 60 * 24 * 365,
|
|
"w": 60 * 60 * 24 * 7,
|
|
"d": 60 * 60 * 24,
|
|
"h": 60 * 60,
|
|
"m": 60,
|
|
"s": 1
|
|
};
|
|
|
|
Prometheus.Graph.stepValues = [
|
|
"1s", "10s", "1m", "5m", "15m", "30m", "1h", "2h", "6h", "12h", "1d", "2d",
|
|
"1w", "2w", "4w", "8w", "1y", "2y"
|
|
];
|
|
|
|
Prometheus.Graph.numGraphs = 0;
|
|
|
|
Prometheus.Graph.prototype.initialize = function() {
|
|
var self = this;
|
|
self.id = Prometheus.Graph.numGraphs++;
|
|
|
|
// Set default options.
|
|
self.options.id = self.id;
|
|
self.options.range_input = self.options.range_input || "1h";
|
|
if (self.options.tab === undefined) {
|
|
self.options.tab = 1;
|
|
}
|
|
|
|
// Draw graph controls and container from Handlebars template.
|
|
|
|
var options = {'pathPrefix': PATH_PREFIX};
|
|
jQuery.extend(options, self.options);
|
|
self.graphHTML = $(Mustache.render(graphTemplate, options));
|
|
self.el.append(self.graphHTML);
|
|
|
|
// Get references to all the interesting elements in the graph container and
|
|
// bind event handlers.
|
|
var graphWrapper = self.el.find("#graph_wrapper" + self.id);
|
|
self.queryForm = graphWrapper.find(".query_form");
|
|
|
|
self.expr = graphWrapper.find("textarea[name=expr]");
|
|
self.expr.keypress(function(e) {
|
|
// Enter was pressed without the shift key.
|
|
if (e.which == 13 && !e.shiftKey) {
|
|
self.queryForm.submit();
|
|
e.preventDefault();
|
|
}
|
|
|
|
// Auto-resize the text area on input.
|
|
var offset = this.offsetHeight - this.clientHeight;
|
|
var resizeTextarea = function(el) {
|
|
$(el).css('height', 'auto').css('height', el.scrollHeight + offset);
|
|
};
|
|
$(this).on('keyup input', function() { resizeTextarea(this); });
|
|
});
|
|
self.expr.change(self.handleChange);
|
|
|
|
self.rangeInput = self.queryForm.find("input[name=range_input]");
|
|
self.stackedBtn = self.queryForm.find(".stacked_btn");
|
|
self.stacked = self.queryForm.find("input[name=stacked]");
|
|
self.insertMetric = self.queryForm.find("select[name=insert_metric]");
|
|
self.refreshInterval = self.queryForm.find("select[name=refresh]");
|
|
|
|
self.consoleTab = graphWrapper.find(".console");
|
|
self.graphTab = graphWrapper.find(".graph_container");
|
|
|
|
self.tabs = graphWrapper.find("a[data-toggle='tab']");
|
|
self.tabs.eq(self.options.tab).tab("show");
|
|
self.tabs.on("shown.bs.tab", function(e) {
|
|
var target = $(e.target);
|
|
self.options.tab = target.parent().index();
|
|
self.handleChange();
|
|
if ($("#" + target.attr("aria-controls")).hasClass("reload")) {
|
|
self.submitQuery();
|
|
}
|
|
});
|
|
|
|
// Return moves focus back to expr instead of submitting.
|
|
self.insertMetric.bind("keydown", "return", function(e) {
|
|
self.expr.focus();
|
|
self.expr.val(self.expr.val());
|
|
return e.preventDefault();
|
|
})
|
|
|
|
self.error = graphWrapper.find(".error").hide();
|
|
self.graphArea = graphWrapper.find(".graph_area");
|
|
self.graph = self.graphArea.find(".graph");
|
|
self.yAxis = self.graphArea.find(".y_axis");
|
|
self.legend = graphWrapper.find(".legend");
|
|
self.spinner = graphWrapper.find(".spinner");
|
|
self.evalStats = graphWrapper.find(".eval_stats");
|
|
|
|
self.endDate = graphWrapper.find("input[name=end_input]");
|
|
self.endDate.datetimepicker({
|
|
locale: 'en',
|
|
format: 'YYYY-MM-DD HH:mm',
|
|
toolbarPlacement: 'bottom',
|
|
sideBySide: true,
|
|
showTodayButton: true,
|
|
showClear: true,
|
|
showClose: true,
|
|
});
|
|
if (self.options.end_input) {
|
|
self.endDate.data('DateTimePicker').date(self.options.end_input);
|
|
}
|
|
self.endDate.on("dp.change", function() { self.submitQuery(); });
|
|
self.refreshInterval.change(function() { self.updateRefresh(); });
|
|
|
|
self.isStacked = function() {
|
|
return self.stacked.val() === '1';
|
|
};
|
|
|
|
var styleStackBtn = function() {
|
|
var icon = self.stackedBtn.find('.glyphicon');
|
|
if (self.isStacked()) {
|
|
self.stackedBtn.addClass("btn-primary");
|
|
icon.addClass("glyphicon-check");
|
|
icon.removeClass("glyphicon-unchecked");
|
|
} else {
|
|
self.stackedBtn.removeClass("btn-primary");
|
|
icon.addClass("glyphicon-unchecked");
|
|
icon.removeClass("glyphicon-check");
|
|
}
|
|
};
|
|
styleStackBtn();
|
|
|
|
self.stackedBtn.click(function() {
|
|
if (self.isStacked() && self.graphJSON) {
|
|
// If the graph was stacked, the original series data got mutated
|
|
// (scaled) and we need to reconstruct it from the original JSON data.
|
|
self.data = self.transformData(self.graphJSON);
|
|
}
|
|
self.stacked.val(self.isStacked() ? '0' : '1');
|
|
styleStackBtn();
|
|
self.updateGraph();
|
|
});
|
|
|
|
self.queryForm.submit(function() {
|
|
self.consoleTab.addClass("reload");
|
|
self.graphTab.addClass("reload");
|
|
self.submitQuery();
|
|
return false;
|
|
});
|
|
self.spinner.hide();
|
|
|
|
self.queryForm.find("button[name=inc_range]").click(function() { self.increaseRange(); });
|
|
self.queryForm.find("button[name=dec_range]").click(function() { self.decreaseRange(); });
|
|
|
|
self.queryForm.find("button[name=inc_end]").click(function() { self.increaseEnd(); });
|
|
self.queryForm.find("button[name=dec_end]").click(function() { self.decreaseEnd(); });
|
|
|
|
self.insertMetric.change(function() {
|
|
self.expr.selection("replace", {text: self.insertMetric.val(), mode: "before"});
|
|
self.expr.focus(); // refocusing
|
|
});
|
|
|
|
var removeBtn = graphWrapper.find("[name=remove]");
|
|
removeBtn.click(function() {
|
|
self.remove();
|
|
return false;
|
|
});
|
|
|
|
self.populateInsertableMetrics();
|
|
|
|
if (self.expr.val()) {
|
|
self.submitQuery();
|
|
}
|
|
};
|
|
|
|
Prometheus.Graph.prototype.populateInsertableMetrics = function() {
|
|
var self = this;
|
|
$.ajax({
|
|
method: "GET",
|
|
url: PATH_PREFIX + "/api/v1/label/__name__/values",
|
|
dataType: "json",
|
|
success: function(json, textStatus) {
|
|
if (json.status !== "success") {
|
|
self.showError("Error loading available metrics!");
|
|
return;
|
|
}
|
|
var metrics = json.data;
|
|
for (var i = 0; i < metrics.length; i++) {
|
|
self.insertMetric[0].options.add(new Option(metrics[i], metrics[i]));
|
|
}
|
|
|
|
self.fuzzyResult = {
|
|
query: null,
|
|
result: null,
|
|
map: {}
|
|
}
|
|
|
|
self.expr.typeahead({
|
|
source: metrics,
|
|
items: "all",
|
|
matcher: function(item) {
|
|
// If we have result for current query, skip
|
|
if (self.fuzzyResult.query === null || self.fuzzyResult.query !== this.query) {
|
|
self.fuzzyResult.query = this.query;
|
|
self.fuzzyResult.map = {};
|
|
self.fuzzyResult.result = fuzzy.filter(this.query.replace(/ /g, ''), metrics, {
|
|
pre: '<strong>',
|
|
post: '</strong>'
|
|
});
|
|
self.fuzzyResult.result.forEach(function(r) {
|
|
self.fuzzyResult.map[r.original] = r;
|
|
});
|
|
}
|
|
|
|
return item in self.fuzzyResult.map;
|
|
},
|
|
|
|
sorter: function(items) {
|
|
items.sort(function(a,b) {
|
|
var i = self.fuzzyResult.map[b].score - self.fuzzyResult.map[a].score;
|
|
return i === 0 ? a.localeCompare(b) : i;
|
|
});
|
|
return items;
|
|
},
|
|
|
|
highlighter: function (item) {
|
|
return $('<div>' + self.fuzzyResult.map[item].string + '</div>')
|
|
},
|
|
});
|
|
// This needs to happen after attaching the typeahead plugin, as it
|
|
// otherwise breaks the typeahead functionality.
|
|
self.expr.focus();
|
|
},
|
|
error: function() {
|
|
self.showError("Error loading available metrics!");
|
|
},
|
|
});
|
|
};
|
|
|
|
Prometheus.Graph.prototype.getOptions = function() {
|
|
var self = this;
|
|
var options = {};
|
|
|
|
var optionInputs = [
|
|
"range_input",
|
|
"end_input",
|
|
"step_input",
|
|
"stacked"
|
|
];
|
|
|
|
self.queryForm.find("input").each(function(index, element) {
|
|
var name = element.name;
|
|
if ($.inArray(name, optionInputs) >= 0) {
|
|
if (element.value.length > 0) {
|
|
options[name] = element.value;
|
|
}
|
|
}
|
|
});
|
|
options.expr = self.expr.val();
|
|
options.tab = self.options.tab;
|
|
return options;
|
|
};
|
|
|
|
Prometheus.Graph.prototype.parseDuration = function(rangeText) {
|
|
var rangeRE = new RegExp("^([0-9]+)([ywdhms]+)$");
|
|
var matches = rangeText.match(rangeRE);
|
|
if (!matches) { return; }
|
|
if (matches.length != 3) {
|
|
return 60;
|
|
}
|
|
var value = parseInt(matches[1]);
|
|
var unit = matches[2];
|
|
return value * Prometheus.Graph.timeFactors[unit];
|
|
};
|
|
|
|
Prometheus.Graph.prototype.increaseRange = function() {
|
|
var self = this;
|
|
var rangeSeconds = self.parseDuration(self.rangeInput.val());
|
|
for (var i = 0; i < Prometheus.Graph.stepValues.length; i++) {
|
|
if (rangeSeconds < self.parseDuration(Prometheus.Graph.stepValues[i])) {
|
|
self.rangeInput.val(Prometheus.Graph.stepValues[i]);
|
|
if (self.expr.val()) {
|
|
self.submitQuery();
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
};
|
|
|
|
Prometheus.Graph.prototype.decreaseRange = function() {
|
|
var self = this;
|
|
var rangeSeconds = self.parseDuration(self.rangeInput.val());
|
|
for (var i = Prometheus.Graph.stepValues.length - 1; i >= 0; i--) {
|
|
if (rangeSeconds > self.parseDuration(Prometheus.Graph.stepValues[i])) {
|
|
self.rangeInput.val(Prometheus.Graph.stepValues[i]);
|
|
if (self.expr.val()) {
|
|
self.submitQuery();
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
};
|
|
|
|
Prometheus.Graph.prototype.getEndDate = function() {
|
|
var self = this;
|
|
if (!self.endDate || !self.endDate.val()) {
|
|
return moment();
|
|
}
|
|
return self.endDate.data('DateTimePicker').date();
|
|
};
|
|
|
|
Prometheus.Graph.prototype.getOrSetEndDate = function() {
|
|
var self = this;
|
|
var date = self.getEndDate();
|
|
self.setEndDate(date);
|
|
return date;
|
|
};
|
|
|
|
Prometheus.Graph.prototype.setEndDate = function(date) {
|
|
var self = this;
|
|
self.endDate.data('DateTimePicker').date(date);
|
|
};
|
|
|
|
Prometheus.Graph.prototype.increaseEnd = function() {
|
|
var self = this;
|
|
var newDate = moment(self.getOrSetEndDate());
|
|
newDate.add(self.parseDuration(self.rangeInput.val()) / 2, 'seconds');
|
|
self.setEndDate(newDate);
|
|
self.submitQuery();
|
|
};
|
|
|
|
Prometheus.Graph.prototype.decreaseEnd = function() {
|
|
var self = this;
|
|
var newDate = moment(self.getOrSetEndDate());
|
|
newDate.subtract(self.parseDuration(self.rangeInput.val()) / 2, 'seconds');
|
|
self.setEndDate(newDate);
|
|
self.submitQuery();
|
|
};
|
|
|
|
Prometheus.Graph.prototype.submitQuery = function() {
|
|
var self = this;
|
|
self.clearError();
|
|
if (!self.expr.val()) {
|
|
return;
|
|
}
|
|
|
|
self.spinner.show();
|
|
self.evalStats.empty();
|
|
|
|
var startTime = new Date().getTime();
|
|
var rangeSeconds = self.parseDuration(self.rangeInput.val());
|
|
var resolution = self.queryForm.find("input[name=step_input]").val() || Math.max(Math.floor(rangeSeconds / 250), 1);
|
|
var endDate = self.getEndDate() / 1000;
|
|
|
|
if (self.queryXhr) {
|
|
self.queryXhr.abort();
|
|
}
|
|
var url;
|
|
var success;
|
|
var params = {
|
|
"query": self.expr.val()
|
|
};
|
|
if (self.options.tab === 0) {
|
|
params.start = endDate - rangeSeconds;
|
|
params.end = endDate;
|
|
params.step = resolution;
|
|
url = PATH_PREFIX + "/api/v1/query_range";
|
|
success = function(json, textStatus) { self.handleGraphResponse(json, textStatus); };
|
|
} else {
|
|
params.time = startTime / 1000;
|
|
url = PATH_PREFIX + "/api/v1/query";
|
|
success = function(json, textStatus) { self.handleConsoleResponse(json, textStatus); };
|
|
}
|
|
|
|
self.queryXhr = $.ajax({
|
|
method: self.queryForm.attr("method"),
|
|
url: url,
|
|
dataType: "json",
|
|
data: params,
|
|
success: function(json, textStatus) {
|
|
if (json.status !== "success") {
|
|
self.showError(json.error);
|
|
return;
|
|
}
|
|
success(json.data, textStatus);
|
|
},
|
|
error: function(xhr, resp) {
|
|
if (resp != "abort") {
|
|
var err;
|
|
if (xhr.responseJSON !== undefined) {
|
|
err = xhr.responseJSON.error;
|
|
} else {
|
|
err = xhr.statusText;
|
|
}
|
|
self.showError("Error executing query: " + err);
|
|
}
|
|
},
|
|
complete: function(xhr, resp) {
|
|
if (resp == "abort") {
|
|
return;
|
|
}
|
|
var duration = new Date().getTime() - startTime;
|
|
self.evalStats.html("Load time: " + duration + "ms <br /> Resolution: " + resolution + "s");
|
|
self.spinner.hide();
|
|
}
|
|
});
|
|
};
|
|
|
|
Prometheus.Graph.prototype.showError = function(msg) {
|
|
var self = this;
|
|
self.error.text(msg);
|
|
self.error.show();
|
|
};
|
|
|
|
Prometheus.Graph.prototype.clearError = function(msg) {
|
|
var self = this;
|
|
self.error.text('');
|
|
self.error.hide();
|
|
};
|
|
|
|
Prometheus.Graph.prototype.updateRefresh = function() {
|
|
var self = this;
|
|
|
|
if (self.timeoutID) {
|
|
window.clearTimeout(self.timeoutID);
|
|
}
|
|
|
|
interval = self.parseDuration(self.refreshInterval.val());
|
|
if (!interval) { return; }
|
|
|
|
self.timeoutID = window.setTimeout(function() {
|
|
self.submitQuery();
|
|
self.updateRefresh();
|
|
}, interval * SECOND);
|
|
};
|
|
|
|
Prometheus.Graph.prototype.renderLabels = function(labels) {
|
|
var labelStrings = [];
|
|
for (var label in labels) {
|
|
if (label != "__name__") {
|
|
labelStrings.push("<strong>" + label + "</strong>: " + escapeHTML(labels[label]));
|
|
}
|
|
}
|
|
return labels = "<div class=\"labels\">" + labelStrings.join("<br>") + "</div>";
|
|
};
|
|
|
|
Prometheus.Graph.prototype.metricToTsName = function(labels) {
|
|
var tsName = (labels.__name__ || '') + "{";
|
|
var labelStrings = [];
|
|
for (var label in labels) {
|
|
if (label != "__name__") {
|
|
labelStrings.push(label + "=\"" + labels[label] + "\"");
|
|
}
|
|
}
|
|
tsName += labelStrings.join(",") + "}";
|
|
return tsName;
|
|
};
|
|
|
|
Prometheus.Graph.prototype.parseValue = function(value) {
|
|
var val = parseFloat(value);
|
|
if (isNaN(val)) {
|
|
// "+Inf", "-Inf", "+Inf" will be parsed into NaN by parseFloat(). The
|
|
// can't be graphed, so show them as gaps (null).
|
|
return null;
|
|
}
|
|
return val;
|
|
};
|
|
|
|
Prometheus.Graph.prototype.transformData = function(json) {
|
|
var self = this;
|
|
var palette = new Rickshaw.Color.Palette();
|
|
if (json.resultType != "matrix") {
|
|
self.showError("Result is not of matrix type! Please enter a correct expression.");
|
|
return [];
|
|
}
|
|
var data = json.result.map(function(ts) {
|
|
var name;
|
|
var labels;
|
|
if (ts.metric === null) {
|
|
name = "scalar";
|
|
labels = {};
|
|
} else {
|
|
name = escapeHTML(self.metricToTsName(ts.metric));
|
|
labels = ts.metric;
|
|
}
|
|
return {
|
|
name: name,
|
|
labels: labels,
|
|
data: ts.values.map(function(value) {
|
|
return {
|
|
x: value[0],
|
|
y: self.parseValue(value[1])
|
|
};
|
|
}),
|
|
color: palette.color()
|
|
};
|
|
});
|
|
Rickshaw.Series.zeroFill(data);
|
|
return data;
|
|
};
|
|
|
|
Prometheus.Graph.prototype.updateGraph = function() {
|
|
var self = this;
|
|
if (self.data.length === 0) { return; }
|
|
|
|
// Remove any traces of an existing graph.
|
|
self.legend.empty();
|
|
if (self.graphArea.children().length > 0) {
|
|
self.graph.remove();
|
|
self.yAxis.remove();
|
|
}
|
|
self.graph = $('<div class="graph"></div>');
|
|
self.yAxis = $('<div class="y_axis"></div>');
|
|
self.graphArea.append(self.graph);
|
|
self.graphArea.append(self.yAxis);
|
|
|
|
var endTime = self.getEndDate() / 1000; // Convert to UNIX timestamp.
|
|
var duration = self.parseDuration(self.rangeInput.val()) || 3600; // 1h default.
|
|
var startTime = endTime - duration;
|
|
self.data.forEach(function(s) {
|
|
// Padding series with invisible "null" values at the configured x-axis boundaries ensures
|
|
// that graphs are displayed with a fixed x-axis range instead of snapping to the available
|
|
// time range in the data.
|
|
if (s.data[0].x > startTime) {
|
|
s.data.unshift({x: startTime, y: null});
|
|
}
|
|
if (s.data[s.data.length - 1].x < endTime) {
|
|
s.data.push({x: endTime, y: null});
|
|
}
|
|
});
|
|
|
|
// Now create the new graph.
|
|
self.rickshawGraph = new Rickshaw.Graph({
|
|
element: self.graph[0],
|
|
height: Math.max(self.graph.innerHeight(), 100),
|
|
width: Math.max(self.graph.innerWidth() - 80, 200),
|
|
renderer: (self.isStacked() ? "stack" : "line"),
|
|
interpolation: "linear",
|
|
series: self.data,
|
|
min: "auto",
|
|
});
|
|
|
|
var xAxis = new Rickshaw.Graph.Axis.Time({ graph: self.rickshawGraph });
|
|
|
|
var yAxis = new Rickshaw.Graph.Axis.Y({
|
|
graph: self.rickshawGraph,
|
|
orientation: "left",
|
|
tickFormat: Rickshaw.Fixtures.Number.formatKMBT,
|
|
element: self.yAxis[0],
|
|
});
|
|
|
|
self.rickshawGraph.render();
|
|
|
|
var hoverDetail = new Rickshaw.Graph.HoverDetail({
|
|
graph: self.rickshawGraph,
|
|
formatter: function(series, x, y) {
|
|
var date = '<span class="date">' + new Date(x * 1000).toUTCString() + '</span>';
|
|
var swatch = '<span class="detail_swatch" style="background-color: ' + series.color + '"></span>';
|
|
var content = swatch + (series.labels.__name__ || 'value') + ": <strong>" + y + '</strong>';
|
|
return date + '<br>' + content + '<br>' + self.renderLabels(series.labels);
|
|
}
|
|
});
|
|
|
|
var legend = new Rickshaw.Graph.Legend({
|
|
element: self.legend[0],
|
|
graph: self.rickshawGraph,
|
|
});
|
|
|
|
var highlighter = new Rickshaw.Graph.Behavior.Series.Highlight( {
|
|
graph: self.rickshawGraph,
|
|
legend: legend
|
|
});
|
|
|
|
var shelving = new Rickshaw.Graph.Behavior.Series.Toggle({
|
|
graph: self.rickshawGraph,
|
|
legend: legend
|
|
});
|
|
|
|
self.handleChange();
|
|
};
|
|
|
|
Prometheus.Graph.prototype.resizeGraph = function() {
|
|
var self = this;
|
|
if (self.rickshawGraph !== null) {
|
|
self.rickshawGraph.configure({
|
|
width: Math.max(self.graph.innerWidth() - 80, 200),
|
|
});
|
|
self.rickshawGraph.render();
|
|
}
|
|
};
|
|
|
|
Prometheus.Graph.prototype.handleGraphResponse = function(json, textStatus) {
|
|
var self = this;
|
|
// Rickshaw mutates passed series data for stacked graphs, so we need to save
|
|
// the original AJAX response in order to re-transform it into series data
|
|
// when the user disables the stacking.
|
|
self.graphJSON = json;
|
|
self.data = self.transformData(json);
|
|
if (self.data.length === 0) {
|
|
self.showError("No datapoints found.");
|
|
return;
|
|
}
|
|
self.graphTab.removeClass("reload");
|
|
self.updateGraph();
|
|
};
|
|
|
|
Prometheus.Graph.prototype.handleConsoleResponse = function(data, textStatus) {
|
|
var self = this;
|
|
self.consoleTab.removeClass("reload");
|
|
self.graphJSON = null;
|
|
|
|
var tBody = self.consoleTab.find(".console_table tbody");
|
|
tBody.empty();
|
|
|
|
switch(data.resultType) {
|
|
case "vector":
|
|
if (data.result.length === 0) {
|
|
tBody.append("<tr><td colspan='2'><i>no data</i></td></tr>");
|
|
return;
|
|
}
|
|
for (var i = 0; i < data.result.length; i++) {
|
|
var s = data.result[i];
|
|
var tsName = self.metricToTsName(s.metric);
|
|
tBody.append("<tr><td>" + escapeHTML(tsName) + "</td><td>" + s.value[1] + "</td></tr>");
|
|
}
|
|
break;
|
|
case "matrix":
|
|
if (data.result.length === 0) {
|
|
tBody.append("<tr><td colspan='2'><i>no data</i></td></tr>");
|
|
return;
|
|
}
|
|
for (var i = 0; i < data.result.length; i++) {
|
|
var v = data.result[i];
|
|
var tsName = self.metricToTsName(v.metric);
|
|
var valueText = "";
|
|
for (var j = 0; j < v.values.length; j++) {
|
|
valueText += v.values[j][1] + " @" + v.values[j][0] + "<br/>";
|
|
}
|
|
tBody.append("<tr><td>" + escapeHTML(tsName) + "</td><td>" + valueText + "</td></tr>");
|
|
}
|
|
break;
|
|
case "scalar":
|
|
tBody.append("<tr><td>scalar</td><td>" + data.result[1] + "</td></tr>");
|
|
break;
|
|
case "string":
|
|
tBody.append("<tr><td>string</td><td>" + escapeHTML(data.result[1]) + "</td></tr>");
|
|
break;
|
|
default:
|
|
self.showError("Unsupported value type!");
|
|
break;
|
|
}
|
|
};
|
|
|
|
Prometheus.Graph.prototype.remove = function() {
|
|
var self = this;
|
|
$(self.graphHTML).remove();
|
|
self.handleRemove();
|
|
self.handleChange();
|
|
};
|
|
|
|
function escapeHTML(string) {
|
|
var entityMap = {
|
|
"&": "&",
|
|
"<": "<",
|
|
">": ">",
|
|
'"': '"',
|
|
"'": ''',
|
|
"/": '/'
|
|
};
|
|
|
|
return String(string).replace(/[&<>"'\/]/g, function (s) {
|
|
return entityMap[s];
|
|
});
|
|
}
|
|
|
|
Prometheus.Page = function() {
|
|
this.graphs = [];
|
|
};
|
|
|
|
Prometheus.Page.prototype.init = function() {
|
|
var graphOptions = this.parseURL();
|
|
if (graphOptions.length === 0) {
|
|
graphOptions.push({});
|
|
}
|
|
|
|
graphOptions.forEach(this.addGraph, this);
|
|
|
|
$("#add_graph").click(this.addGraph.bind(this, {}));
|
|
};
|
|
|
|
Prometheus.Page.prototype.parseURL = function() {
|
|
if (window.location.search == "") {
|
|
return [];
|
|
}
|
|
|
|
var queryParams = window.location.search.substring(1).split('&');
|
|
var queryParamHelper = new Prometheus.Page.QueryParamHelper();
|
|
return queryParamHelper.parseQueryParams(queryParams);
|
|
};
|
|
|
|
Prometheus.Page.prototype.addGraph = function(options) {
|
|
var graph = new Prometheus.Graph(
|
|
$("#graph_container"),
|
|
options,
|
|
this.updateURL.bind(this),
|
|
this.removeGraph.bind(this)
|
|
);
|
|
|
|
this.graphs.push(graph);
|
|
$(window).resize(function() {
|
|
graph.resizeGraph();
|
|
});
|
|
};
|
|
|
|
// NOTE: This needs to be kept in sync with /util/strutil/strconv.go:GraphLinkForExpression
|
|
Prometheus.Page.prototype.updateURL = function() {
|
|
var queryString = this.graphs.map(function(graph, index) {
|
|
var graphOptions = graph.getOptions();
|
|
var queryParamHelper = new Prometheus.Page.QueryParamHelper();
|
|
var queryObject = queryParamHelper.generateQueryObject(graphOptions, index);
|
|
return $.param(queryObject);
|
|
}, this).join("&");
|
|
|
|
history.pushState({}, "", "graph?" + queryString);
|
|
};
|
|
|
|
Prometheus.Page.prototype.removeGraph = function(graph) {
|
|
this.graphs = this.graphs.filter(function(g) {return g !== graph});
|
|
};
|
|
|
|
Prometheus.Page.QueryParamHelper = function() {};
|
|
|
|
Prometheus.Page.QueryParamHelper.prototype.parseQueryParams = function(queryParams) {
|
|
var orderedQueryParams = this.filterInvalidParams(queryParams).sort();
|
|
return this.fetchOptionsFromOrderedParams(orderedQueryParams, 0);
|
|
};
|
|
|
|
Prometheus.Page.QueryParamHelper.queryParamFormat = /^g\d+\..+=.+$/;
|
|
|
|
Prometheus.Page.QueryParamHelper.prototype.filterInvalidParams = function(paramTuples) {
|
|
return paramTuples.filter(function(paramTuple) {
|
|
return Prometheus.Page.QueryParamHelper.queryParamFormat.test(paramTuple);
|
|
});
|
|
};
|
|
|
|
Prometheus.Page.QueryParamHelper.prototype.fetchOptionsFromOrderedParams = function(queryParams, graphIndex) {
|
|
if (queryParams.length == 0) {
|
|
return [];
|
|
}
|
|
|
|
var prefixOfThisIndex = this.queryParamPrefix(graphIndex);
|
|
var numberOfParamsForThisGraph = queryParams.filter(function(paramTuple) {
|
|
return paramTuple.startsWith(prefixOfThisIndex);
|
|
}).length;
|
|
|
|
if (numberOfParamsForThisGraph == 0) {
|
|
return [];
|
|
}
|
|
|
|
var paramsForThisGraph = queryParams.splice(0, numberOfParamsForThisGraph);
|
|
|
|
paramsForThisGraph = paramsForThisGraph.map(function(paramTuple) {
|
|
return paramTuple.substring(prefixOfThisIndex.length);
|
|
});
|
|
|
|
var options = this.parseQueryParamsOfOneGraph(paramsForThisGraph);
|
|
var optionAccumulator = this.fetchOptionsFromOrderedParams(queryParams, graphIndex + 1);
|
|
optionAccumulator.unshift(options);
|
|
|
|
return optionAccumulator;
|
|
};
|
|
|
|
Prometheus.Page.QueryParamHelper.prototype.parseQueryParamsOfOneGraph = function(queryParams) {
|
|
var options = {};
|
|
queryParams.forEach(function(tuple) {
|
|
var optionNameAndValue = tuple.split('=');
|
|
var optionName = optionNameAndValue[0];
|
|
|
|
var optionValue = decodeURIComponent(optionNameAndValue[1].replace(/\+/g, " "));
|
|
|
|
if (optionName == "tab") {
|
|
optionValue = parseInt(optionValue); // tab is integer
|
|
}
|
|
|
|
options[optionName] = optionValue;
|
|
});
|
|
|
|
return options;
|
|
};
|
|
|
|
Prometheus.Page.QueryParamHelper.prototype.queryParamPrefix = function(index) {
|
|
return "g" + index + ".";
|
|
};
|
|
|
|
Prometheus.Page.QueryParamHelper.prototype.generateQueryObject = function(graphOptions, index) {
|
|
var prefix = this.queryParamPrefix(index);
|
|
var queryObject = {};
|
|
Object.keys(graphOptions).forEach(function(key) {
|
|
queryObject[prefix + key] = graphOptions[key];
|
|
});
|
|
return queryObject;
|
|
};
|
|
|
|
function init() {
|
|
$.ajaxSetup({
|
|
cache: false
|
|
});
|
|
|
|
$.ajax({
|
|
url: PATH_PREFIX + "/static/js/graph_template.handlebar",
|
|
success: function(data) {
|
|
|
|
graphTemplate = data;
|
|
Mustache.parse(data);
|
|
if (isDeprecatedGraphURL()) {
|
|
redirectToMigratedURL();
|
|
} else {
|
|
var Page = new Prometheus.Page();
|
|
Page.init();
|
|
}
|
|
}
|
|
});
|
|
}
|
|
|
|
|
|
|
|
// These two methods (isDeprecatedGraphURL and redirectToMigratedURL)
|
|
// are added only for backward compatibility to old query format.
|
|
function isDeprecatedGraphURL() {
|
|
if (window.location.hash.length == 0) {
|
|
return false;
|
|
}
|
|
|
|
var decodedFragment = decodeURIComponent(window.location.hash);
|
|
try {
|
|
JSON.parse(decodedFragment.substr(1)); // drop the hash #
|
|
} catch (e) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function redirectToMigratedURL() {
|
|
var decodedFragment = decodeURIComponent(window.location.hash);
|
|
var graphOptions = JSON.parse(decodedFragment.substr(1)); // drop the hash #
|
|
var queryObject = {};
|
|
|
|
graphOptions.map(function(options, index){
|
|
var prefix = "g" + index + ".";
|
|
Object.keys(options).forEach(function(key) {
|
|
queryObject[prefix + key] = options[key];
|
|
});
|
|
});
|
|
var query = $.param(queryObject);
|
|
window.location = "/graph?" + query;
|
|
}
|
|
|
|
$(init);
|