angular.module('kibana.pie', []) .controller('pie', function($scope, eventBus) { // Set and populate defaults var _d = { query : { field:"_all", query:"*", goal: 1}, size : 10, exclude : [], donut : false, tilt : false, legend : true, labels : true, mode : "terms", group : "default", default_field : '_all' } _.defaults($scope.panel,_d) $scope.init = function() { eventBus.register($scope,'time', function(event,time){set_time(time)}); eventBus.register($scope,'query', function(event, query) { if($scope.panel.mode !== 'query') { $scope.panel.query.query = query; $scope.panel.query.query = _.isArray(query) ? query[0] : query; } else { if(_.isArray(query)) $scope.panel.query = _.map(query,function(q) { return {query: q, label: q}}) else $scope.panel.query[0] = {query: query, label: query} } $scope.get_data(); }); // Now that we're all setup, request the time from our group eventBus.broadcast($scope.$id,$scope.panel.group,'get_time') } $scope.remove_query = function(q) { if($scope.panel.mode !== 'query') return false; $scope.panel.query = _.without($scope.panel.query,q); $scope.get_data(); } $scope.add_query = function(label,query) { if($scope.panel.mode !== 'query') return false; $scope.panel.query.unshift({ query: query, label: label, }); $scope.get_data(); } $scope.set_mode = function(mode) { switch(mode) { case 'terms': $scope.panel.query = {query:"*",field:"_all"}; break; case 'query': $scope.panel.query = [{query:"*",label:"*"}]; break; case 'goal': $scope.panel.query = {query:"*",goal:100}; break; } } $scope.get_data = function() { // Make sure we have everything for the request to complete if(_.isUndefined($scope.panel.index) || _.isUndefined($scope.time)) return $scope.panel.loading = true; var request = $scope.ejs.Request().indices($scope.panel.index); // If we have an array, use query facet if($scope.panel.mode == "query") { if(!(_.isArray($scope.panel.query))) $scope.panel.query = [$scope.panel.query]; var queries = []; // Build the question part of the query _.each($scope.panel.query, function(v) { queries.push(ejs.FilteredQuery( ejs.QueryStringQuery(v.query || '*'), ejs.RangeFilter($scope.time.field) .from($scope.time.from) .to($scope.time.to)) ) }); // Then the insert into facet and make the request _.each(queries, function(v) { request = request.facet(ejs.QueryFacet(_.indexOf(queries,v)) .query(v) .facetFilter(ejs.QueryFilter(v)) ) }) var results = request.doSearch(); // Populate scope when we have results results.then(function(results) { $scope.panel.loading = false; $scope.hits = results.hits.total; $scope.data = []; _.each(results.facets, function(v, k) { var series = {}; var label = _.isUndefined($scope.panel.query[k].label) ? $scope.panel.query[k].query : $scope.panel.query[k].label var slice = { label : label, data : v.count }; if (!(_.isUndefined($scope.panel.query[k].color))) slice.color = $scope.panel.query[k].color; $scope.data.push(slice) }); $scope.$emit('render'); }); // If we don't have an array, assume its a term facet. } else if ($scope.panel.mode == "terms") { var results = request .facet(ejs.TermsFacet('pie') .field($scope.panel.query.field || $scope.panel.default_field) .size($scope.panel['size']) .exclude($scope.panel.exclude) .facetFilter(ejs.QueryFilter( ejs.FilteredQuery( ejs.QueryStringQuery($scope.panel.query.query || '*'), ejs.RangeFilter($scope.time.field) .from($scope.time.from) .to($scope.time.to) .cache(false) )))).size(0) .doSearch(); // Populate scope when we have results results.then(function(results) { $scope.panel.loading = false; $scope.hits = results.hits.total; $scope.data = []; var k = 0; _.each(results.facets.pie.terms, function(v) { var slice = { label : v.term, data : v.count }; $scope.data.push(); if(!(_.isUndefined($scope.panel.colors)) && _.isArray($scope.panel.colors) && $scope.panel.colors.length > 0) { slice.color = $scope.panel.colors[k%$scope.panel.colors.length]; } $scope.data.push(slice) k = k + 1; }); $scope.$emit('render'); }); } else { var results = request .query(ejs.QueryStringQuery($scope.panel.query.query || '*')) .filter(ejs.RangeFilter($scope.time.field) .from($scope.time.from) .to($scope.time.to) .cache(false)) .size(0) .doSearch(); results.then(function(results) { $scope.panel.loading = false; var complete = results.hits.total; var remaining = $scope.panel.query.goal - complete; $scope.data = [ { label : 'Complete', data : complete, color: '#51A351' }, { data : remaining, color: '#EEE'}] $scope.$emit('render'); }); } } function set_time(time) { $scope.time = time; $scope.panel.index = _.isUndefined(time.index) ? $scope.panel.index : time.index $scope.get_data(); } }) .directive('pie', function() { return { restrict: 'A', link: function(scope, elem, attrs) { elem.html('
