angular.module('kibana.histogram', []) .controller('histogram', function($scope, eventBus) { var _id = _.uniqueId(); // Set and populate defaults var _d = { query : [ {query: "*", label:"Query"} ], interval: secondsToHms(calculate_interval($scope.from,$scope.to,40,0)/1000), show : ['bars'], fill : false, group : "default", } _.defaults($scope.panel,_d) $scope.init = function() { eventBus.register($scope,'time', function(event,time){set_time(time)}); eventBus.register($scope,'query', function(event, query) { $scope.panel.query[0].query = query; $scope.get_data(); }); // Now that we're all setup, request the time from our group if we don't // have it yet if(_.isUndefined($scope.time)) eventBus.broadcast($scope.$id,$scope.panel.group,'get_time') } $scope.remove_query = function(q) { $scope.panel.query = _.without($scope.panel.query,q); $scope.get_data(); } $scope.add_query = function(label,query) { if(!(_.isArray($scope.panel.query))) $scope.panel.query = new Array(); $scope.panel.query.unshift({ query: query, label: label, }); $scope.get_data(); } $scope.get_data = function() { // Make sure we have everything for the request to complete if(_.isUndefined($scope.panel.index) || _.isUndefined($scope.panel.time)) return var request = $scope.ejs.Request().indices($scope.panel.index); // Build the question part of the query var queries = []; _.each($scope.panel.query, function(v) { queries.push($scope.ejs.FilteredQuery( ejs.QueryStringQuery(v.query || '*'), ejs.RangeFilter($scope.panel.time.field) .from($scope.panel.time.from) .to($scope.panel.time.to)) ) }); // Build the facet part _.each(queries, function(v) { request = request .facet($scope.ejs.DateHistogramFacet(_.indexOf(queries,v)) .field($scope.panel.time.field) .interval($scope.panel.interval) .facetFilter($scope.ejs.QueryFilter(v)) ).size(0) }) // Then run it var results = request.doSearch(); // Populate scope when we have results results.then(function(results) { $scope.hits = results.hits.total; $scope.data = []; _.each(results.facets, function(v, k) { // Null values at each end of the time range ensure we see entire range var data = [[$scope.panel.time.from.getTime(), null]]; _.each(v.entries, function(v, k) { data.push([v['time'],v['count']]) }); data.push([$scope.panel.time.to.getTime(), null]) var series = { data: { label: $scope.panel.query[k].label || k, data: data, }}; if (!(_.isUndefined($scope.panel.query[k].color))) series.data.color = $scope.panel.query[k].color; $scope.data.push(series.data) }); $scope.$emit('render') }); } function set_time(time) { $scope.panel.time = time; $scope.panel.index = _.isUndefined(time.index) ? $scope.panel.index : time.index $scope.panel.interval = secondsToHms( calculate_interval(time.from,time.to,50,0)/1000), $scope.get_data(); } // Ready, init $scope.init(); }) .directive('histogram', function() { return { restrict: 'A', link: function(scope, elem, attrs, ctrl) { // Receive render events scope.$on('render',function(){ render_panel(); }); // Re-render if the window is resized angular.element(window).bind('resize', function(){ render_panel(); }); // Function for rendering panel function render_panel() { // Determine format var show = _.isUndefined(scope.panel.show) ? { bars: true, lines: false, points: false } : { lines: _.indexOf(scope.panel.show,'lines') < 0 ? false : true, bars: _.indexOf(scope.panel.show,'bars') < 0 ? false : true, points: _.indexOf(scope.panel.show,'points') < 0 ? false : true, stack: _.indexOf(scope.panel.show,'stack') < 0 ? null : true, } // Set barwidth based on specified interval var barwidth = interval_to_seconds(scope.panel.interval)*1000 var scripts = $LAB.script("common/lib/panels/jquery.flot.js") .script("common/lib/panels/jquery.flot.time.js") .script("common/lib/panels/jquery.flot.stack.js") // Populate element. Note that jvectormap appends, does not replace. scripts.wait(function(){ // Populate element $.plot(elem, scope.data, { legend: { position: "nw", labelFormatter: function(label, series) { return '' + label + ' / ' + scope.panel.interval + ''; } }, series: { stack: show.stack, lines: { show: show.lines, fill: scope.panel.fill }, bars: { show: show.bars, fill: 1, barWidth: barwidth/1.8 }, points: { show: show.points }, shadowSize: 1 }, yaxis: { min: 0, color: "#000" }, xaxis: { mode: "time", timeformat: "%H:%M:%S
%m-%d", label: "Datetime", color: "#000", }, grid: { backgroundColor: '#fff', borderWidth: 0, borderColor: '#eee', color: "#eee", hoverable: true, } }) }) function tt(x, y, contents) { var tooltip = $('#pie-tooltip').length ? $('#pie-tooltip') : $('
'); //var tooltip = $('#pie-tooltip') tooltip.text(contents).css({ position: 'absolute', top : y + 5, left : x + 5, color : "#FFF", border : '1px solid #FFF', padding : '2px', 'font-size': '8pt', 'background-color': '#000', }).appendTo("body"); } elem.bind("plothover", function (event, pos, item) { if (item) { var percent = parseFloat(item.series.percent).toFixed(1) + "%"; tt(pos.pageX, pos.pageY, item.datapoint[1].toFixed(1) + " @ " + new Date(item.datapoint[0]).format(config.timeformat)); } else { $("#pie-tooltip").remove(); } }); } } }; })