mirror of
https://github.com/grafana/grafana.git
synced 2025-02-25 18:55:37 -06:00
230 lines
7.2 KiB
JavaScript
230 lines
7.2 KiB
JavaScript
/*
|
|
|
|
## Table
|
|
|
|
A paginated table of events matching a query
|
|
|
|
### Parameters
|
|
* query :: A string representing then current query
|
|
* size :: Number of events per page to show
|
|
* pages :: Number of pages to show. size * pages = number of cached events.
|
|
Bigger = more memory usage byh the browser
|
|
* offset :: Position from which to start in the array of hits
|
|
* sort :: An array with 2 elements. sort[0]: field, sort[1]: direction ('asc' or 'desc')
|
|
* style :: hash of css properties
|
|
* fields :: columns to show in table
|
|
* sortable :: Allow sorting?
|
|
* spyable :: Show the 'eye' icon that reveals the last ES query for this panel
|
|
### Group Events
|
|
#### Sends
|
|
* table_documents :: An array containing all of the documents in the table.
|
|
Only used by the fields panel so far.
|
|
#### Receives
|
|
* time :: An object containing the time range to use and the index(es) to query
|
|
* query :: An Array of queries, even if its only one
|
|
* sort :: An array with 2 elements. sort[0]: field, sort[1]: direction ('asc' or 'desc')
|
|
* selected_fields :: An array of fields to show
|
|
*/
|
|
|
|
angular.module('kibana.table', [])
|
|
.controller('table', function($scope, eventBus, fields) {
|
|
|
|
// Set and populate defaults
|
|
var _d = {
|
|
query : "*",
|
|
size : 100, // Per page
|
|
pages : 5, // Pages available
|
|
offset : 0,
|
|
sort : ['@timestamp','desc'],
|
|
group : "default",
|
|
style : {'font-size': '9pt'},
|
|
fields : [],
|
|
sortable: true,
|
|
spyable: true,
|
|
}
|
|
_.defaults($scope.panel,_d)
|
|
|
|
$scope.init = function () {
|
|
|
|
$scope.set_listeners($scope.panel.group)
|
|
// Now that we're all setup, request the time from our group
|
|
eventBus.broadcast($scope.$id,$scope.panel.group,"get_time")
|
|
}
|
|
|
|
$scope.set_listeners = function(group) {
|
|
eventBus.register($scope,'time',function(event,time) {
|
|
$scope.panel.offset = 0;
|
|
set_time(time)
|
|
});
|
|
eventBus.register($scope,'query',function(event,query) {
|
|
$scope.panel.offset = 0;
|
|
$scope.panel.query = _.isArray(query) ? query[0] : query;
|
|
$scope.get_data();
|
|
});
|
|
eventBus.register($scope,'sort', function(event,sort){
|
|
$scope.panel.sort = _.clone(sort);
|
|
$scope.get_data();
|
|
});
|
|
eventBus.register($scope,'selected_fields', function(event, fields) {
|
|
$scope.panel.fields = _.clone(fields)
|
|
});
|
|
eventBus.register($scope,'table_documents', function(event, docs) {
|
|
$scope.panel.query = docs.query;
|
|
$scope.data = docs.docs;
|
|
});
|
|
}
|
|
|
|
$scope.set_sort = function(field) {
|
|
if($scope.panel.sort[0] === field)
|
|
$scope.panel.sort[1] = $scope.panel.sort[1] == 'asc' ? 'desc' : 'asc';
|
|
else
|
|
$scope.panel.sort[0] = field;
|
|
$scope.get_data();
|
|
}
|
|
|
|
$scope.toggle_field = function(field) {
|
|
if (_.indexOf($scope.panel.fields,field) > -1)
|
|
$scope.panel.fields = _.without($scope.panel.fields,field)
|
|
else
|
|
$scope.panel.fields.push(field)
|
|
broadcast_results();
|
|
}
|
|
|
|
$scope.toggle_details = function(row) {
|
|
row.kibana = row.kibana || {};
|
|
row.kibana.details = !row.kibana.details ? $scope.without_kibana(row) : false;
|
|
}
|
|
|
|
$scope.page = function(page) {
|
|
$scope.panel.offset = page*$scope.panel.size
|
|
$scope.get_data();
|
|
}
|
|
|
|
$scope.build_search = function(field,value,negate) {
|
|
$scope.panel.query = add_to_query($scope.panel.query,field,value,negate)
|
|
$scope.panel.offset = 0;
|
|
$scope.get_data();
|
|
eventBus.broadcast($scope.$id,$scope.panel.group,'query',$scope.panel.query);
|
|
}
|
|
|
|
$scope.get_data = function(segment,query_id) {
|
|
$scope.panel.error = false;
|
|
|
|
// Make sure we have everything for the request to complete
|
|
if(_.isUndefined($scope.panel.index) || _.isUndefined($scope.time))
|
|
return
|
|
|
|
$scope.panel.loading = true;
|
|
|
|
var _segment = _.isUndefined(segment) ? 0 : segment
|
|
$scope.segment = _segment;
|
|
|
|
var request = $scope.ejs.Request().indices($scope.panel.index[_segment])
|
|
.query(ejs.FilteredQuery(
|
|
ejs.QueryStringQuery($scope.panel.query || '*'),
|
|
ejs.RangeFilter($scope.time.field)
|
|
.from($scope.time.from)
|
|
.to($scope.time.to)
|
|
)
|
|
)
|
|
.size($scope.panel.size*$scope.panel.pages)
|
|
.sort($scope.panel.sort[0],$scope.panel.sort[1]);
|
|
|
|
$scope.populate_modal(request)
|
|
|
|
var results = request.doSearch()
|
|
|
|
// Populate scope when we have results
|
|
results.then(function(results) {
|
|
$scope.panel.loading = false;
|
|
|
|
if(_segment === 0) {
|
|
$scope.hits = 0;
|
|
$scope.data = [];
|
|
query_id = $scope.query_id = new Date().getTime()
|
|
}
|
|
|
|
// Check for error and abort if found
|
|
if(!(_.isUndefined(results.error))) {
|
|
$scope.panel.error = $scope.parse_error(results.error);
|
|
return;
|
|
}
|
|
|
|
// Check that we're still on the same query, if not stop
|
|
if($scope.query_id === query_id) {
|
|
$scope.data= $scope.data.concat(_.map(results.hits.hits, function(hit) {
|
|
return flatten_json(hit['_source']);
|
|
}));
|
|
|
|
$scope.hits += results.hits.total;
|
|
|
|
// Sort the data
|
|
$scope.data = _.sortBy($scope.data, function(v){
|
|
return v[$scope.panel.sort[0]]
|
|
});
|
|
|
|
// Reverse if needed
|
|
if($scope.panel.sort[1] == 'desc')
|
|
$scope.data.reverse();
|
|
|
|
// Keep only what we need for the set
|
|
$scope.data = $scope.data.slice(0,$scope.panel.size * $scope.panel.pages)
|
|
|
|
} else {
|
|
return;
|
|
}
|
|
|
|
// This breaks, use $scope.data for this
|
|
$scope.all_fields = get_all_fields($scope.data);
|
|
broadcast_results();
|
|
|
|
// If we're not sorting in reverse chrono order, query every index for
|
|
// size*pages results
|
|
// Otherwise, only get size*pages results then stop querying
|
|
if(
|
|
($scope.data.length < $scope.panel.size*$scope.panel.pages ||
|
|
!(($scope.panel.sort[0] === $scope.time.field) && $scope.panel.sort[1] === 'desc')) &&
|
|
_segment+1 < $scope.panel.index.length
|
|
) {
|
|
$scope.get_data(_segment+1,$scope.query_id)
|
|
}
|
|
|
|
});
|
|
}
|
|
|
|
$scope.populate_modal = function(request) {
|
|
$scope.modal = {
|
|
title: "Table Inspector",
|
|
body : "<h5>Last Elasticsearch Query</h5><pre>"+
|
|
'curl -XGET '+config.elasticsearch+'/'+$scope.panel.index+"/_search?pretty -d'\n"+
|
|
angular.toJson(JSON.parse(request.toString()),true)+
|
|
"'</pre>",
|
|
}
|
|
}
|
|
|
|
$scope.without_kibana = function (row) {
|
|
row = _.clone(row)
|
|
delete row.kibana
|
|
return row
|
|
}
|
|
|
|
// Broadcast a list of all fields. Note that receivers of field array
|
|
// events should be able to receive from multiple sources, merge, dedupe
|
|
// and sort on the fly if needed.
|
|
function broadcast_results() {
|
|
eventBus.broadcast($scope.$id,$scope.panel.group,"fields", {
|
|
all : $scope.all_fields,
|
|
sort : $scope.panel.sort,
|
|
active: $scope.panel.fields
|
|
});
|
|
eventBus.broadcast($scope.$id,$scope.panel.group,"table_documents",
|
|
{query:$scope.panel.query,docs:$scope.data});
|
|
}
|
|
|
|
function set_time(time) {
|
|
$scope.time = time;
|
|
$scope.panel.index = _.isUndefined(time.index) ? $scope.panel.index : time.index
|
|
$scope.get_data();
|
|
}
|
|
|
|
}); |