Initial
This commit is contained in:
Alexander Zobnin
359
zabbix/datasource.js
Normal file
359
zabbix/datasource.js
Normal file
@@ -0,0 +1,359 @@
|
||||
define([
|
||||
'angular',
|
||||
'lodash',
|
||||
'kbn',
|
||||
'./queryCtrl',
|
||||
],
|
||||
function (angular, _, kbn) {
|
||||
'use strict';
|
||||
|
||||
var module = angular.module('grafana.services');
|
||||
|
||||
module.factory('ZabbixAPIDatasource', function($q, backendSrv, templateSrv) {
|
||||
|
||||
function ZabbixAPIDatasource(datasource) {
|
||||
this.name = datasource.name;
|
||||
this.type = 'ZabbixAPIDatasource';
|
||||
this.supportMetrics = true;
|
||||
this.url = datasource.url;
|
||||
|
||||
// from plugin.json file
|
||||
this.username = datasource.meta.username;
|
||||
this.password = datasource.meta.password;
|
||||
// No limits by default
|
||||
this.limitmetrics = datasource.meta.limitmetrics || 0;
|
||||
|
||||
this.partials = datasource.partials || 'plugins/datasource/zabbix/partials';
|
||||
this.editorSrc = this.partials + '/query.editor.html';
|
||||
|
||||
this.annotationEditorSrc = this.partials + '/annotations.editor.html';
|
||||
this.supportAnnotations = true;
|
||||
|
||||
// Get authentication token
|
||||
var authRequestData = {
|
||||
jsonrpc: '2.0',
|
||||
method: 'user.login',
|
||||
params: {
|
||||
user: this.username,
|
||||
password: this.password
|
||||
},
|
||||
auth: null,
|
||||
id: 1
|
||||
};
|
||||
var zabbixDataSource = this;
|
||||
this.doZabbixAPIRequest({'data': authRequestData})
|
||||
.then(function (response) {
|
||||
zabbixDataSource.auth = response.data.result;
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
ZabbixAPIDatasource.prototype.doZabbixAPIRequest = function(options) {
|
||||
options.url = this.url;
|
||||
options.method = 'POST';
|
||||
options.headers = {'Content-Type': 'application/json'};
|
||||
return backendSrv.datasourceRequest(options);
|
||||
};
|
||||
|
||||
///////////////////////////////////////////////////////////////////////
|
||||
/// Query methods
|
||||
///////////////////////////////////////////////////////////////////////
|
||||
|
||||
|
||||
ZabbixAPIDatasource.prototype.query = function(options) {
|
||||
// get from & to in seconds
|
||||
var from = kbn.parseDate(options.range.from).getTime();
|
||||
var to = kbn.parseDate(options.range.to).getTime();
|
||||
// Need for find target alias
|
||||
var targets = options.targets;
|
||||
|
||||
// Check that all targets defined
|
||||
var targetsDefined = options.targets.every(function (target, index, array) {
|
||||
return target.item;
|
||||
});
|
||||
if (targetsDefined) {
|
||||
// Extract zabbix api item objects from targets
|
||||
var target_items = _.map(options.targets, 'item');
|
||||
} else {
|
||||
|
||||
// No valid targets, return the empty dataset
|
||||
var d = $q.defer();
|
||||
d.resolve({ data: [] });
|
||||
return d.promise;
|
||||
}
|
||||
|
||||
from = Math.ceil(from/1000);
|
||||
to = Math.ceil(to/1000);
|
||||
|
||||
return this.performTimeSeriesQuery(target_items, from, to)
|
||||
.then(function (response) {
|
||||
// Response should be in the format:
|
||||
// data: [
|
||||
// {
|
||||
// target: "Metric name",
|
||||
// datapoints: [[<value>, <unixtime>], ...]
|
||||
// },
|
||||
// {
|
||||
// target: "Metric name",
|
||||
// datapoints: [[<value>, <unixtime>], ...]
|
||||
// },
|
||||
// ]
|
||||
|
||||
// Index returned datapoints by item/metric id
|
||||
var indexed_result = _.groupBy(response.data.result, function (history_item) {
|
||||
return history_item.itemid;
|
||||
});
|
||||
|
||||
// Reduce timeseries to the same size for stacking and tooltip work properly
|
||||
var min_length = _.min(_.map(indexed_result, function (history) {
|
||||
return history.length;
|
||||
}));
|
||||
_.each(indexed_result, function (item) {
|
||||
item.splice(0, item.length - min_length);
|
||||
});
|
||||
|
||||
// Sort result as the same as targets for display
|
||||
// stacked timeseries in proper order
|
||||
var sorted_history = _.sortBy(indexed_result, function (value, key, list) {
|
||||
return _.indexOf(_.map(target_items, 'itemid'), key);
|
||||
});
|
||||
|
||||
var series = _.map(sorted_history,
|
||||
// Foreach itemid index: iterate over the data points and
|
||||
// normalize to Grafana response format.
|
||||
function (history, index) {
|
||||
return {
|
||||
// Lookup itemid:alias map
|
||||
//target: targets[itemid].alias,
|
||||
target: targets[index].alias,
|
||||
|
||||
datapoints: _.map(history, function (p) {
|
||||
|
||||
// Value must be a number for properly work
|
||||
var value = Number(p.value);
|
||||
|
||||
// TODO: Correct time for proper stacking
|
||||
//var clock = Math.round(Number(p.clock) / 60) * 60;
|
||||
return [value, p.clock * 1000];
|
||||
})
|
||||
};
|
||||
})
|
||||
return $q.when({data: series});
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
/**
|
||||
* Perform time series query to Zabbix API
|
||||
*
|
||||
* @param items: array of zabbix api item objects
|
||||
*/
|
||||
ZabbixAPIDatasource.prototype.performTimeSeriesQuery = function(items, start, end) {
|
||||
var item_ids = items.map(function (item, index, array) {
|
||||
return item.itemid;
|
||||
});
|
||||
// TODO: if different value types passed?
|
||||
// Perform multiple api request.
|
||||
var hystory_type = items[0].value_type;
|
||||
var options = {
|
||||
method: 'POST',
|
||||
url: this.url,
|
||||
data: {
|
||||
jsonrpc: '2.0',
|
||||
method: 'history.get',
|
||||
params: {
|
||||
output: 'extend',
|
||||
history: hystory_type,
|
||||
itemids: item_ids,
|
||||
sortfield: 'clock',
|
||||
sortorder: 'ASC',
|
||||
limit: this.limitmetrics,
|
||||
time_from: start,
|
||||
},
|
||||
auth: this.auth,
|
||||
id: 1
|
||||
},
|
||||
};
|
||||
// Relative queries (e.g. last hour) don't include an end time
|
||||
if (end) {
|
||||
options.data.params.time_till = end;
|
||||
}
|
||||
|
||||
return this.doZabbixAPIRequest(options);
|
||||
};
|
||||
|
||||
|
||||
// Get the list of host groups
|
||||
ZabbixAPIDatasource.prototype.performHostGroupSuggestQuery = function() {
|
||||
var options = {
|
||||
url : this.url,
|
||||
method : 'POST',
|
||||
data: {
|
||||
jsonrpc: '2.0',
|
||||
method: 'hostgroup.get',
|
||||
params: {
|
||||
output: ['name'],
|
||||
sortfield: 'name'
|
||||
},
|
||||
auth: this.auth,
|
||||
id: 1
|
||||
},
|
||||
};
|
||||
return this.doZabbixAPIRequest(options).then(function (result) {
|
||||
if (!result.data) {
|
||||
return [];
|
||||
}
|
||||
return result.data.result;
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
// Get the list of hosts
|
||||
ZabbixAPIDatasource.prototype.performHostSuggestQuery = function(groupid) {
|
||||
var options = {
|
||||
url : this.url,
|
||||
method : 'POST',
|
||||
data: {
|
||||
jsonrpc: '2.0',
|
||||
method: 'host.get',
|
||||
params: {
|
||||
output: ['name'],
|
||||
sortfield: 'name'
|
||||
},
|
||||
auth: this.auth,
|
||||
id: 1
|
||||
},
|
||||
};
|
||||
if (groupid) {
|
||||
options.data.params.groupids = groupid;
|
||||
}
|
||||
return this.doZabbixAPIRequest(options).then(function (result) {
|
||||
if (!result.data) {
|
||||
return [];
|
||||
}
|
||||
return result.data.result;
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
// Get the list of applications
|
||||
ZabbixAPIDatasource.prototype.performAppSuggestQuery = function(hostid) {
|
||||
var options = {
|
||||
url : this.url,
|
||||
method : 'POST',
|
||||
data: {
|
||||
jsonrpc: '2.0',
|
||||
method: 'application.get',
|
||||
params: {
|
||||
output: ['name'],
|
||||
sortfield: 'name',
|
||||
hostids: hostid
|
||||
},
|
||||
auth: this.auth,
|
||||
id: 1
|
||||
},
|
||||
};
|
||||
return this.doZabbixAPIRequest(options).then(function (result) {
|
||||
if (!result.data) {
|
||||
return [];
|
||||
}
|
||||
return result.data.result;
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
// Get the list of host items
|
||||
ZabbixAPIDatasource.prototype.performItemSuggestQuery = function(hostid, applicationid) {
|
||||
var options = {
|
||||
url : this.url,
|
||||
method : 'POST',
|
||||
data: {
|
||||
jsonrpc: '2.0',
|
||||
method: 'item.get',
|
||||
params: {
|
||||
output: ['name', 'key_', 'value_type', 'delay'],
|
||||
sortfield: 'name',
|
||||
hostids: hostid
|
||||
},
|
||||
auth: this.auth,
|
||||
id: 1
|
||||
},
|
||||
};
|
||||
// If application selected return only relative items
|
||||
if (applicationid) {
|
||||
options.data.params.applicationids = applicationid;
|
||||
}
|
||||
return this.doZabbixAPIRequest(options).then(function (result) {
|
||||
if (!result.data) {
|
||||
return [];
|
||||
}
|
||||
return result.data.result;
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
ZabbixAPIDatasource.prototype.annotationQuery = function(annotation, rangeUnparsed) {
|
||||
var from = kbn.parseDate(rangeUnparsed.from).getTime();
|
||||
var to = kbn.parseDate(rangeUnparsed.to).getTime();
|
||||
var self = this;
|
||||
from = Math.ceil(from/1000);
|
||||
to = Math.ceil(to/1000);
|
||||
|
||||
var tid_options = {
|
||||
method: 'POST',
|
||||
url: self.url + '',
|
||||
data: {
|
||||
jsonrpc: '2.0',
|
||||
method: 'trigger.get',
|
||||
params: {
|
||||
output: ['triggerid', 'description'],
|
||||
itemids: annotation.aids.split(','), // TODO: validate / pull automatically from dashboard.
|
||||
limit: self.limitmetrics,
|
||||
},
|
||||
auth: self.auth,
|
||||
id: 1
|
||||
},
|
||||
};
|
||||
|
||||
return this.doZabbixAPIRequest(tid_options).then(function(result) {
|
||||
var obs = {};
|
||||
obs = _.indexBy(result.data.result, 'triggerid');
|
||||
|
||||
var options = {
|
||||
method: 'POST',
|
||||
url: self.url + '',
|
||||
data: {
|
||||
jsonrpc: '2.0',
|
||||
method: 'event.get',
|
||||
params: {
|
||||
output: 'extend',
|
||||
sortorder: 'DESC',
|
||||
time_from: from,
|
||||
time_till: to,
|
||||
objectids: _.keys(obs),
|
||||
limit: self.limitmetrics,
|
||||
},
|
||||
auth: self.auth,
|
||||
id: 1
|
||||
},
|
||||
};
|
||||
|
||||
return this.doZabbixAPIRequest(options).then(function(result2) {
|
||||
var list = [];
|
||||
_.each(result2.data.result, function(e) {
|
||||
list.push({
|
||||
annotation: annotation,
|
||||
time: e.clock * 1000,
|
||||
title: obs[e.objectid].description,
|
||||
text: e.eventid,
|
||||
});
|
||||
});
|
||||
return list;
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
return ZabbixAPIDatasource;
|
||||
});
|
||||
});
|
||||
8
zabbix/partials/annotations.editor.html
Normal file
8
zabbix/partials/annotations.editor.html
Normal file
@@ -0,0 +1,8 @@
|
||||
<div class="editor-row">
|
||||
<div class="section">
|
||||
<h5>Item ids <tip>Example: 123, 45, 678</tip></h5>
|
||||
<div class="editor-option">
|
||||
<input type="text" class="span10" ng-model='currentAnnotation.aids' placeholder="###, ###, ##"></input>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
36
zabbix/partials/config.html
Normal file
36
zabbix/partials/config.html
Normal file
@@ -0,0 +1,36 @@
|
||||
<div ng-include="httpConfigPartialSrc"></div>
|
||||
|
||||
<br>
|
||||
|
||||
<h5>Zabbix Details</h5>
|
||||
|
||||
<div class="tight-form">
|
||||
<ul class="tight-form-list">
|
||||
<li class="tight-form-item" style="width: 80px">
|
||||
Database
|
||||
</li>
|
||||
<li>
|
||||
<input type="text" class="tight-form-input input-large" ng-model='current.database' placeholder="" required></input>
|
||||
</li>
|
||||
</ul>
|
||||
<div class="clearfix"></div>
|
||||
</div>
|
||||
<div class="tight-form last">
|
||||
<ul class="tight-form-list">
|
||||
<li class="tight-form-item" style="width: 80px">
|
||||
User
|
||||
</li>
|
||||
<li>
|
||||
<input type="text" class="tight-form-input input-large" ng-model='current.user' placeholder=""></input>
|
||||
</li>
|
||||
<li class="tight-form-item">
|
||||
Password
|
||||
</li>
|
||||
<li>
|
||||
<input type="password" class="tight-form-input input-large" ng-model='current.password' placeholder="password"></input>
|
||||
</li>
|
||||
</ul>
|
||||
<div class="clearfix"></div>
|
||||
</div>
|
||||
|
||||
|
||||
143
zabbix/partials/query.editor.html
Normal file
143
zabbix/partials/query.editor.html
Normal file
@@ -0,0 +1,143 @@
|
||||
<div class="editor-row">
|
||||
|
||||
<div ng-repeat="target in panel.targets"
|
||||
class="grafana-target"
|
||||
ng-class="{'grafana-target-hidden': target.hide}"
|
||||
ng-controller="ZabbixAPIQueryCtrl"
|
||||
ng-init="init()">
|
||||
|
||||
<ul class="tight-form-list pull-right">
|
||||
<li class="tight-form-item">
|
||||
<div class="dropdown">
|
||||
<a class="pointer dropdown-toggle"
|
||||
data-toggle="dropdown"
|
||||
tabindex="1">
|
||||
<i class="fa fa-bars"></i>
|
||||
</a>
|
||||
<ul class="dropdown-menu pull-right" role="menu">
|
||||
<li role="menuitem">
|
||||
<a tabindex="1"
|
||||
ng-click="duplicate()">
|
||||
Duplicate
|
||||
</a>
|
||||
</li>
|
||||
<li role="menuitem">
|
||||
<a tabindex="1"
|
||||
ng-click="moveMetricQuery($index, $index-1)">
|
||||
Move up
|
||||
</a>
|
||||
</li>
|
||||
<li role="menuitem">
|
||||
<a tabindex="1"
|
||||
ng-click="moveMetricQuery($index, $index+1)">
|
||||
Move down
|
||||
</a>
|
||||
</li>
|
||||
</ul>
|
||||
</div>
|
||||
</li>
|
||||
<li class="tight-form-item last">
|
||||
<a class="pointer" tabindex="1" ng-click="removeDataQuery(target)">
|
||||
<i class="fa fa-remove"></i>
|
||||
</a>
|
||||
</li>
|
||||
</ul>
|
||||
|
||||
<ul class="tight-form-list">
|
||||
<li>
|
||||
<a class="tight-form-item"
|
||||
ng-click="target.hide = !target.hide; get_data();"
|
||||
role="menuitem">
|
||||
<i class="fa fa-eye"></i>
|
||||
</a>
|
||||
</li>
|
||||
</ul>
|
||||
|
||||
<!-- <ul class="grafana-segment-list">
|
||||
<li class="grafana-target-segment" style="min-width: 15px; text-align: center">
|
||||
{{targetLetters[$index]}}
|
||||
</li>
|
||||
<li>
|
||||
<a class="grafana-target-segment"
|
||||
ng-click="target.hide = !target.hide; targetBlur();"
|
||||
role="menuitem">
|
||||
<i class="icon-eye-open"></i>
|
||||
</a>
|
||||
</li>
|
||||
</ul> -->
|
||||
|
||||
<ul class="tight-form-list" role="menu">
|
||||
<li class="tight-form-item">
|
||||
<input type="text" class="input-medium grafana-target-text-input" ng-model="target.alias"
|
||||
spellcheck='false' placeholder="alias" ng-blur="targetBlur()">
|
||||
</li>
|
||||
<!-- Select Host Group -->
|
||||
<li class="tight-form-item">
|
||||
<select style="width: 10em"
|
||||
class=""
|
||||
ng-change="selectHostGroup()"
|
||||
ng-model="target.hostGroup"
|
||||
bs-tooltip="target.hostGroup.name.length > 25 ? target.hostGroup.name : ''"
|
||||
ng-options="hostgroup.name for hostgroup in metric.hostGroupList" >
|
||||
<option value="">All</option>
|
||||
</select>
|
||||
<a bs-tooltip="target.errors.metric"
|
||||
style="color: rgb(229, 189, 28)"
|
||||
ng-show="target.errors.metric">
|
||||
<i class="icon-warning-sign"></i>
|
||||
</a>
|
||||
</li>
|
||||
<!-- Select Host -->
|
||||
<li class="tight-form-item">
|
||||
<select style="width: 15em"
|
||||
class=""
|
||||
ng-change="selectHost()"
|
||||
ng-model="target.host"
|
||||
bs-tooltip="target.host.name.length > 25 ? target.host.name : ''"
|
||||
ng-options="host.name for host in metric.hostList" >
|
||||
<option value="">-- select host --</option>
|
||||
</select>
|
||||
<a bs-tooltip="target.errors.metric"
|
||||
style="color: rgb(229, 189, 28)"
|
||||
ng-show="target.errors.metric">
|
||||
<i class="icon-warning-sign"></i>
|
||||
</a>
|
||||
</li>
|
||||
<!-- Select Application -->
|
||||
<li class="tight-form-item">
|
||||
<select style="width: 10em"
|
||||
class="input-medium grafana-target-segment-input"
|
||||
ng-change="selectApplication()"
|
||||
ng-model="target.application"
|
||||
bs-tooltip="target.application.name.length > 15 ? target.application.name : ''"
|
||||
ng-options="app.name for app in metric.applicationList" >
|
||||
<option value="">All</option>
|
||||
</select>
|
||||
<a bs-tooltip="target.errors.metric"
|
||||
style="color: rgb(229, 189, 28)"
|
||||
ng-show="target.errors.metric">
|
||||
<i class="icon-warning-sign"></i>
|
||||
</a>
|
||||
</li>
|
||||
<!-- Select Item -->
|
||||
<li class="tight-form-item">
|
||||
<select style="width: 20em"
|
||||
class="input-medium grafana-target-segment-input"
|
||||
ng-change="selectItem()"
|
||||
ng-model="target.item"
|
||||
bs-tooltip="target.expandedName.length > 30 ? target.expandedName : ''"
|
||||
ng-options="item.expandedName for item in metric.itemList" >
|
||||
<option value="">--select item--</option>
|
||||
</select>
|
||||
<a bs-tooltip="target.errors.metric"
|
||||
style="color: rgb(229, 189, 28)"
|
||||
ng-show="target.errors.metric">
|
||||
<i class="icon-warning-sign"></i>
|
||||
</a>
|
||||
</li>
|
||||
</ul>
|
||||
|
||||
<div class="clearfix"></div>
|
||||
|
||||
</div>
|
||||
</div>
|
||||
20
zabbix/plugin.json
Normal file
20
zabbix/plugin.json
Normal file
@@ -0,0 +1,20 @@
|
||||
{
|
||||
"pluginType": "datasource",
|
||||
"name": "Zabbix",
|
||||
|
||||
"type": "zabbix",
|
||||
"serviceName": "ZabbixAPIDatasource",
|
||||
|
||||
"module": "plugins/datasource/zabbix/datasource",
|
||||
|
||||
"partials": {
|
||||
"config": "app/plugins/datasource/zabbix/partials/config.html",
|
||||
"query": "app/plugins/datasource/zabbix/partials/query.editor.html",
|
||||
"annotations": "app/plugins/datasource/zabbix/partials/annotations.editor.html"
|
||||
},
|
||||
|
||||
"username": "guest",
|
||||
"password": "",
|
||||
|
||||
"metrics": true
|
||||
}
|
||||
238
zabbix/queryCtrl.js
Normal file
238
zabbix/queryCtrl.js
Normal file
@@ -0,0 +1,238 @@
|
||||
define([
|
||||
'angular',
|
||||
'lodash'
|
||||
],
|
||||
function (angular, _) {
|
||||
'use strict';
|
||||
|
||||
var module = angular.module('grafana.controllers');
|
||||
var targetLetters = 'ABCDEFGHIJKLMNOPQRSTUVWXYZ';
|
||||
|
||||
module.controller('ZabbixAPIQueryCtrl', function($scope) {
|
||||
|
||||
$scope.init = function() {
|
||||
$scope.targetLetters = targetLetters;
|
||||
$scope.metric = {
|
||||
hostGroupList: ["Loading..."],
|
||||
hostList: ["Loading..."],
|
||||
applicationList: ["Loading..."],
|
||||
itemList: ["Loading..."]
|
||||
};
|
||||
|
||||
// Update host group, host, application and item lists
|
||||
$scope.updateHostGroupList();
|
||||
$scope.updateHostList();
|
||||
if ($scope.target.host) {
|
||||
$scope.updateAppList($scope.target.host.hostid);
|
||||
if ($scope.target.application) {
|
||||
$scope.updateItemList($scope.target.host.hostid, $scope.target.application.applicationid);
|
||||
} else {
|
||||
$scope.updateItemList($scope.target.host.hostid, null);
|
||||
}
|
||||
}
|
||||
|
||||
$scope.target.errors = validateTarget($scope.target);
|
||||
};
|
||||
|
||||
$scope.targetBlur = function() {
|
||||
$scope.target.errors = validateTarget($scope.target);
|
||||
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
||||
$scope.oldTarget = angular.copy($scope.target);
|
||||
$scope.get_data();
|
||||
}
|
||||
};
|
||||
|
||||
// Call when host group selected
|
||||
$scope.selectHostGroup = function() {
|
||||
|
||||
// Update host list
|
||||
if ($scope.target.hostGroup) {
|
||||
$scope.updateHostList($scope.target.hostGroup.groupid);
|
||||
} else {
|
||||
$scope.updateHostList('');
|
||||
}
|
||||
|
||||
$scope.target.errors = validateTarget($scope.target);
|
||||
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
||||
$scope.oldTarget = angular.copy($scope.target);
|
||||
$scope.get_data();
|
||||
}
|
||||
};
|
||||
|
||||
// Call when host selected
|
||||
$scope.selectHost = function() {
|
||||
|
||||
// Update item list
|
||||
if ($scope.target.application) {
|
||||
$scope.updateItemList($scope.target.host.hostid, $scope.target.application.applicationid);
|
||||
} else {
|
||||
$scope.updateItemList($scope.target.host.hostid, null);
|
||||
}
|
||||
|
||||
// Update application list
|
||||
$scope.updateAppList($scope.target.host.hostid);
|
||||
|
||||
$scope.target.errors = validateTarget($scope.target);
|
||||
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
||||
$scope.oldTarget = angular.copy($scope.target);
|
||||
$scope.get_data();
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
// Call when application selected
|
||||
$scope.selectApplication = function() {
|
||||
|
||||
// Update item list
|
||||
if ($scope.target.application) {
|
||||
$scope.updateItemList($scope.target.host.hostid, $scope.target.application.applicationid);
|
||||
} else {
|
||||
$scope.updateItemList($scope.target.host.hostid, null);
|
||||
}
|
||||
|
||||
$scope.target.errors = validateTarget($scope.target);
|
||||
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
||||
$scope.oldTarget = angular.copy($scope.target);
|
||||
$scope.get_data();
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
// Call when item selected
|
||||
$scope.selectItem = function() {
|
||||
$scope.target.errors = validateTarget($scope.target);
|
||||
if (!_.isEqual($scope.oldTarget, $scope.target) && _.isEmpty($scope.target.errors)) {
|
||||
$scope.oldTarget = angular.copy($scope.target);
|
||||
$scope.get_data();
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
$scope.duplicate = function() {
|
||||
var clone = angular.copy($scope.target);
|
||||
$scope.panel.targets.push(clone);
|
||||
};
|
||||
|
||||
|
||||
$scope.moveMetricQuery = function(fromIndex, toIndex) {
|
||||
_.move($scope.panel.targets, fromIndex, toIndex);
|
||||
};
|
||||
|
||||
//////////////////////////////
|
||||
// SUGGESTION QUERIES
|
||||
//////////////////////////////
|
||||
|
||||
|
||||
/**
|
||||
* Update list of host groups
|
||||
*/
|
||||
$scope.updateHostGroupList = function() {
|
||||
$scope.datasource.performHostGroupSuggestQuery().then(function (series) {
|
||||
$scope.metric.hostGroupList = series;
|
||||
if ($scope.target.hostGroup) {
|
||||
$scope.target.hostGroup = $scope.metric.hostGroupList.filter(function (item, index, array) {
|
||||
|
||||
// Find selected host in metric.hostList
|
||||
return (item.groupid == $scope.target.hostGroup.groupid);
|
||||
}).pop();
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
/**
|
||||
* Update list of hosts
|
||||
*/
|
||||
$scope.updateHostList = function(groupid) {
|
||||
$scope.datasource.performHostSuggestQuery(groupid).then(function (series) {
|
||||
$scope.metric.hostList = series;
|
||||
$scope.target.host = $scope.metric.hostList.filter(function (item, index, array) {
|
||||
|
||||
// Find selected host in metric.hostList
|
||||
return (item.hostid == $scope.target.host.hostid);
|
||||
}).pop();
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
/**
|
||||
* Update list of host applications
|
||||
*/
|
||||
$scope.updateAppList = function(hostid) {
|
||||
$scope.datasource.performAppSuggestQuery(hostid).then(function (series) {
|
||||
$scope.metric.applicationList = series;
|
||||
if ($scope.target.application) {
|
||||
$scope.target.application = $scope.metric.applicationList.filter(function (item, index, array) {
|
||||
|
||||
// Find selected application in metric.hostList
|
||||
return (item.applicationid == $scope.target.application.applicationid);
|
||||
}).pop();
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
/**
|
||||
* Update list of items
|
||||
*/
|
||||
$scope.updateItemList = function(hostid, applicationid) {
|
||||
|
||||
// Update only if host selected
|
||||
if (hostid) {
|
||||
$scope.datasource.performItemSuggestQuery(hostid, applicationid).then(function (series) {
|
||||
$scope.metric.itemList = series;
|
||||
|
||||
// Expand item parameters
|
||||
$scope.metric.itemList.forEach(function (item, index, array) {
|
||||
if (item && item.key_ && item.name) {
|
||||
item.expandedName = expandItemName(item);
|
||||
}
|
||||
});
|
||||
$scope.target.item = $scope.metric.itemList.filter(function (item, index, array) {
|
||||
|
||||
// Find selected item in metric.hostList
|
||||
return (item.itemid == $scope.target.item.itemid);
|
||||
}).pop();
|
||||
});
|
||||
} else {
|
||||
$scope.metric.itemList = [];
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
/**
|
||||
* Expand item parameters, for example:
|
||||
* CPU $2 time ($3) --> CPU system time (avg1)
|
||||
*
|
||||
* @param item: zabbix api item object
|
||||
* @return: expanded item name (string)
|
||||
*/
|
||||
function expandItemName(item) {
|
||||
var name = item.name;
|
||||
var key = item.key_;
|
||||
|
||||
// extract params from key:
|
||||
// "system.cpu.util[,system,avg1]" --> ["", "system", "avg1"]
|
||||
var key_params = key.substring(key.indexOf('[') + 1, key.lastIndexOf(']')).split(',');
|
||||
|
||||
// replace item parameters
|
||||
for (var i = key_params.length; i >= 1; i--) {
|
||||
name = name.replace('$' + i, key_params[i - 1]);
|
||||
};
|
||||
return name;
|
||||
};
|
||||
|
||||
|
||||
//////////////////////////////
|
||||
// VALIDATION
|
||||
//////////////////////////////
|
||||
|
||||
function validateTarget(target) {
|
||||
var errs = {};
|
||||
|
||||
return errs;
|
||||
}
|
||||
|
||||
});
|
||||
|
||||
});
|
||||
Reference in New Issue
Block a user