mirror of
https://github.com/grafana/grafana.git
synced 2025-02-20 11:48:34 -06:00
287 lines
9.3 KiB
JavaScript
287 lines
9.3 KiB
JavaScript
define([
|
|
'angular',
|
|
'lodash',
|
|
'./query_builder',
|
|
],
|
|
function (angular, _, InfluxQueryBuilder) {
|
|
'use strict';
|
|
|
|
var module = angular.module('grafana.controllers');
|
|
|
|
module.controller('InfluxQueryCtrl', function($scope, $timeout, $sce, templateSrv, $q, uiSegmentSrv) {
|
|
|
|
$scope.init = function() {
|
|
if (!$scope.target) { return; }
|
|
|
|
var target = $scope.target;
|
|
target.tags = target.tags || [];
|
|
target.groupBy = target.groupBy || [{type: 'time', interval: 'auto'}];
|
|
target.fields = target.fields || [{name: 'value', func: target.function || 'mean'}];
|
|
|
|
$scope.queryBuilder = new InfluxQueryBuilder(target);
|
|
|
|
if (!target.measurement) {
|
|
$scope.measurementSegment = uiSegmentSrv.newSelectMeasurement();
|
|
} else {
|
|
$scope.measurementSegment = uiSegmentSrv.newSegment(target.measurement);
|
|
}
|
|
|
|
$scope.tagSegments = [];
|
|
_.each(target.tags, function(tag) {
|
|
if (!tag.operator) {
|
|
if (/^\/.*\/$/.test(tag.value)) {
|
|
tag.operator = "=~";
|
|
} else {
|
|
tag.operator = '=';
|
|
}
|
|
}
|
|
|
|
if (tag.condition) {
|
|
$scope.tagSegments.push(uiSegmentSrv.newCondition(tag.condition));
|
|
}
|
|
|
|
$scope.tagSegments.push(uiSegmentSrv.newKey(tag.key));
|
|
$scope.tagSegments.push(uiSegmentSrv.newOperator(tag.operator));
|
|
$scope.tagSegments.push(uiSegmentSrv.newKeyValue(tag.value));
|
|
});
|
|
|
|
$scope.fixTagSegments();
|
|
$scope.removeTagFilterSegment = uiSegmentSrv.newSegment({fake: true, value: '-- remove tag filter --'});
|
|
};
|
|
|
|
$scope.fixTagSegments = function() {
|
|
var count = $scope.tagSegments.length;
|
|
var lastSegment = $scope.tagSegments[Math.max(count-1, 0)];
|
|
|
|
if (!lastSegment || lastSegment.type !== 'plus-button') {
|
|
$scope.tagSegments.push(uiSegmentSrv.newPlusButton());
|
|
}
|
|
};
|
|
|
|
$scope.addGroupBy = function() {
|
|
$scope.target.groupBy.push({type: 'tag', key: "select tag"});
|
|
};
|
|
|
|
$scope.removeGroupBy = function(index) {
|
|
$scope.target.groupBy.splice(index, 1);
|
|
$scope.get_data();
|
|
};
|
|
|
|
$scope.addSelect = function() {
|
|
$scope.target.fields.push({name: "select field", func: 'mean'});
|
|
};
|
|
|
|
$scope.removeSelect = function(index) {
|
|
$scope.target.fields.splice(index, 1);
|
|
$scope.get_data();
|
|
};
|
|
|
|
$scope.changeFunction = function(func) {
|
|
$scope.target.function = func;
|
|
$scope.$parent.get_data();
|
|
};
|
|
|
|
$scope.measurementChanged = function() {
|
|
$scope.target.measurement = $scope.measurementSegment.value;
|
|
$scope.$parent.get_data();
|
|
};
|
|
|
|
$scope.getFields = function() {
|
|
var fieldsQuery = $scope.queryBuilder.buildExploreQuery('FIELDS');
|
|
return $scope.datasource.metricFindQuery(fieldsQuery)
|
|
.then($scope.transformToSegments(false), $scope.handleQueryError);
|
|
};
|
|
|
|
$scope.toggleQueryMode = function () {
|
|
$scope.target.rawQuery = !$scope.target.rawQuery;
|
|
};
|
|
|
|
$scope.getMeasurements = function () {
|
|
var query = $scope.queryBuilder.buildExploreQuery('MEASUREMENTS');
|
|
return $scope.datasource.metricFindQuery(query)
|
|
.then($scope.transformToSegments(true), $scope.handleQueryError);
|
|
};
|
|
|
|
$scope.getFunctions = function () {
|
|
var functionList = ['count', 'mean', 'sum', 'min', 'max', 'mode', 'distinct', 'median',
|
|
'stddev', 'first', 'last'
|
|
];
|
|
return $q.when(_.map(functionList, function(func) {
|
|
return uiSegmentSrv.newSegment(func);
|
|
}));
|
|
};
|
|
|
|
$scope.getGroupByTimeIntervals = function () {
|
|
var times = ['auto', '1s', '10s', '1m', '2m', '5m', '10m', '30m', '1h', '1d'];
|
|
return $q.when(_.map(times, function(func) {
|
|
return uiSegmentSrv.newSegment(func);
|
|
}));
|
|
};
|
|
|
|
$scope.handleQueryError = function(err) {
|
|
$scope.parserError = err.message || 'Failed to issue metric query';
|
|
return [];
|
|
};
|
|
|
|
$scope.transformToSegments = function(addTemplateVars) {
|
|
return function(results) {
|
|
var segments = _.map(results, function(segment) {
|
|
return uiSegmentSrv.newSegment({ value: segment.text, expandable: segment.expandable });
|
|
});
|
|
|
|
if (addTemplateVars) {
|
|
_.each(templateSrv.variables, function(variable) {
|
|
segments.unshift(uiSegmentSrv.newSegment({ type: 'template', value: '/$' + variable.name + '$/', expandable: true }));
|
|
});
|
|
}
|
|
|
|
return segments;
|
|
};
|
|
};
|
|
|
|
$scope.getTagsOrValues = function(segment, index) {
|
|
if (segment.type === 'condition') {
|
|
return $q.when([uiSegmentSrv.newSegment('AND'), uiSegmentSrv.newSegment('OR')]);
|
|
}
|
|
if (segment.type === 'operator') {
|
|
var nextValue = $scope.tagSegments[index+1].value;
|
|
if (/^\/.*\/$/.test(nextValue)) {
|
|
return $q.when(uiSegmentSrv.newOperators(['=~', '!~']));
|
|
} else {
|
|
return $q.when(uiSegmentSrv.newOperators(['=', '<>', '<', '>']));
|
|
}
|
|
}
|
|
|
|
var query, addTemplateVars;
|
|
if (segment.type === 'key' || segment.type === 'plus-button') {
|
|
query = $scope.queryBuilder.buildExploreQuery('TAG_KEYS');
|
|
addTemplateVars = false;
|
|
} else if (segment.type === 'value') {
|
|
query = $scope.queryBuilder.buildExploreQuery('TAG_VALUES', $scope.tagSegments[index-2].value);
|
|
addTemplateVars = true;
|
|
}
|
|
|
|
return $scope.datasource.metricFindQuery(query)
|
|
.then($scope.transformToSegments(addTemplateVars))
|
|
.then(function(results) {
|
|
if (segment.type === 'key') {
|
|
results.splice(0, 0, angular.copy($scope.removeTagFilterSegment));
|
|
}
|
|
return results;
|
|
})
|
|
.then(null, $scope.handleQueryError);
|
|
};
|
|
|
|
$scope.getFieldSegments = function() {
|
|
var fieldsQuery = $scope.queryBuilder.buildExploreQuery('FIELDS');
|
|
return $scope.datasource.metricFindQuery(fieldsQuery)
|
|
.then($scope.transformToSegments(false))
|
|
.then(null, $scope.handleQueryError);
|
|
};
|
|
|
|
$scope.addField = function() {
|
|
$scope.target.fields.push({name: $scope.addFieldSegment.value, func: 'mean'});
|
|
_.extend($scope.addFieldSegment, uiSegmentSrv.newPlusButton());
|
|
};
|
|
|
|
$scope.fieldChanged = function(field) {
|
|
if (field.name === '-- remove from select --') {
|
|
$scope.target.fields = _.without($scope.target.fields, field);
|
|
}
|
|
$scope.get_data();
|
|
};
|
|
|
|
$scope.getTagOptions = function() {
|
|
var query = $scope.queryBuilder.buildExploreQuery('TAG_KEYS');
|
|
|
|
return $scope.datasource.metricFindQuery(query)
|
|
.then($scope.transformToSegments(false))
|
|
.then(null, $scope.handleQueryError);
|
|
};
|
|
|
|
$scope.setFill = function(fill) {
|
|
$scope.target.fill = fill;
|
|
$scope.get_data();
|
|
};
|
|
|
|
$scope.tagSegmentUpdated = function(segment, index) {
|
|
$scope.tagSegments[index] = segment;
|
|
|
|
// handle remove tag condition
|
|
if (segment.value === $scope.removeTagFilterSegment.value) {
|
|
$scope.tagSegments.splice(index, 3);
|
|
if ($scope.tagSegments.length === 0) {
|
|
$scope.tagSegments.push(uiSegmentSrv.newPlusButton());
|
|
} else if ($scope.tagSegments.length > 2) {
|
|
$scope.tagSegments.splice(Math.max(index-1, 0), 1);
|
|
if ($scope.tagSegments[$scope.tagSegments.length-1].type !== 'plus-button') {
|
|
$scope.tagSegments.push(uiSegmentSrv.newPlusButton());
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
if (segment.type === 'plus-button') {
|
|
if (index > 2) {
|
|
$scope.tagSegments.splice(index, 0, uiSegmentSrv.newCondition('AND'));
|
|
}
|
|
$scope.tagSegments.push(uiSegmentSrv.newOperator('='));
|
|
$scope.tagSegments.push(uiSegmentSrv.newFake('select tag value', 'value', 'query-segment-value'));
|
|
segment.type = 'key';
|
|
segment.cssClass = 'query-segment-key';
|
|
}
|
|
|
|
if ((index+1) === $scope.tagSegments.length) {
|
|
$scope.tagSegments.push(uiSegmentSrv.newPlusButton());
|
|
}
|
|
}
|
|
|
|
$scope.rebuildTargetTagConditions();
|
|
};
|
|
|
|
$scope.rebuildTargetTagConditions = function() {
|
|
var tags = [];
|
|
var tagIndex = 0;
|
|
var tagOperator = "";
|
|
_.each($scope.tagSegments, function(segment2, index) {
|
|
if (segment2.type === 'key') {
|
|
if (tags.length === 0) {
|
|
tags.push({});
|
|
}
|
|
tags[tagIndex].key = segment2.value;
|
|
}
|
|
else if (segment2.type === 'value') {
|
|
tagOperator = $scope.getTagValueOperator(segment2.value, tags[tagIndex].operator);
|
|
if (tagOperator) {
|
|
$scope.tagSegments[index-1] = uiSegmentSrv.newOperator(tagOperator);
|
|
tags[tagIndex].operator = tagOperator;
|
|
}
|
|
tags[tagIndex].value = segment2.value;
|
|
}
|
|
else if (segment2.type === 'condition') {
|
|
tags.push({ condition: segment2.value });
|
|
tagIndex += 1;
|
|
}
|
|
else if (segment2.type === 'operator') {
|
|
tags[tagIndex].operator = segment2.value;
|
|
}
|
|
});
|
|
|
|
$scope.target.tags = tags;
|
|
$scope.$parent.get_data();
|
|
};
|
|
|
|
$scope.getTagValueOperator = function(tagValue, tagOperator) {
|
|
if (tagOperator !== '=~' && tagOperator !== '!~' && /^\/.*\/$/.test(tagValue)) {
|
|
return '=~';
|
|
}
|
|
else if ((tagOperator === '=~' || tagOperator === '!~') && /^(?!\/.*\/$)/.test(tagValue)) {
|
|
return '=';
|
|
}
|
|
};
|
|
|
|
$scope.init();
|
|
|
|
});
|
|
|
|
});
|