timeSeries.js 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120
  1. define([
  2. 'lodash',
  3. 'kbn'
  4. ],
  5. function (_, kbn) {
  6. 'use strict';
  7. function TimeSeries(opts) {
  8. this.datapoints = opts.datapoints;
  9. this.info = opts.info;
  10. this.label = opts.info.alias;
  11. }
  12. function matchSeriesOverride(aliasOrRegex, seriesAlias) {
  13. if (!aliasOrRegex) { return false; }
  14. if (aliasOrRegex[0] === '/') {
  15. var regex = kbn.stringToJsRegex(aliasOrRegex);
  16. return seriesAlias.match(regex) != null;
  17. }
  18. return aliasOrRegex === seriesAlias;
  19. }
  20. function translateFillOption(fill) {
  21. return fill === 0 ? 0.001 : fill/10;
  22. }
  23. TimeSeries.prototype.applySeriesOverrides = function(overrides) {
  24. this.lines = {};
  25. this.points = {};
  26. this.bars = {};
  27. this.info.yaxis = 1;
  28. this.zindex = 0;
  29. delete this.stack;
  30. for (var i = 0; i < overrides.length; i++) {
  31. var override = overrides[i];
  32. if (!matchSeriesOverride(override.alias, this.info.alias)) {
  33. continue;
  34. }
  35. if (override.lines !== void 0) { this.lines.show = override.lines; }
  36. if (override.points !== void 0) { this.points.show = override.points; }
  37. if (override.bars !== void 0) { this.bars.show = override.bars; }
  38. if (override.fill !== void 0) { this.lines.fill = translateFillOption(override.fill); }
  39. if (override.stack !== void 0) { this.stack = override.stack; }
  40. if (override.linewidth !== void 0) { this.lines.lineWidth = override.linewidth; }
  41. if (override.pointradius !== void 0) { this.points.radius = override.pointradius; }
  42. if (override.steppedLine !== void 0) { this.lines.steps = override.steppedLine; }
  43. if (override.zindex !== void 0) { this.zindex = override.zindex; }
  44. if (override.yaxis !== void 0) {
  45. this.info.yaxis = override.yaxis;
  46. }
  47. }
  48. };
  49. TimeSeries.prototype.getFlotPairs = function (fillStyle) {
  50. var result = [];
  51. this.color = this.info.color;
  52. this.yaxis = this.info.yaxis;
  53. this.info.total = 0;
  54. this.info.max = -212312321312;
  55. this.info.min = 212312321312;
  56. var ignoreNulls = fillStyle === 'connected';
  57. var nullAsZero = fillStyle === 'null as zero';
  58. var currentTime;
  59. var currentValue;
  60. for (var i = 0; i < this.datapoints.length; i++) {
  61. currentValue = this.datapoints[i][0];
  62. currentTime = this.datapoints[i][1];
  63. if (currentValue === null) {
  64. if (ignoreNulls) { continue; }
  65. if (nullAsZero) {
  66. currentValue = 0;
  67. }
  68. }
  69. if (_.isNumber(currentValue)) {
  70. this.info.total += currentValue;
  71. }
  72. if (currentValue > this.info.max) {
  73. this.info.max = currentValue;
  74. }
  75. if (currentValue < this.info.min) {
  76. this.info.min = currentValue;
  77. }
  78. result.push([currentTime * 1000, currentValue]);
  79. }
  80. if (result.length > 2) {
  81. this.info.timeStep = result[1][0] - result[0][0];
  82. }
  83. if (result.length) {
  84. this.info.avg = (this.info.total / result.length);
  85. this.info.current = result[result.length-1][1];
  86. }
  87. return result;
  88. };
  89. TimeSeries.prototype.updateLegendValues = function(formater, decimals, scaledDecimals) {
  90. this.info.avg = this.info.avg != null ? formater(this.info.avg, decimals, scaledDecimals) : null;
  91. this.info.current = this.info.current != null ? formater(this.info.current, decimals, scaledDecimals) : null;
  92. this.info.min = this.info.min != null ? formater(this.info.min, decimals, scaledDecimals) : null;
  93. this.info.max = this.info.max != null ? formater(this.info.max, decimals, scaledDecimals) : null;
  94. this.info.total = this.info.total != null ? formater(this.info.total, decimals, scaledDecimals) : null;
  95. };
  96. return TimeSeries;
  97. });