metrics.js 4.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. const debug_1 = require("debug");
  4. const featureManager_1 = require("../featureManager");
  5. const eventLoopMetrics_1 = require("../metrics/eventLoopMetrics");
  6. const network_1 = require("../metrics/network");
  7. const httpMetrics_1 = require("../metrics/httpMetrics");
  8. const v8_1 = require("../metrics/v8");
  9. const runtime_1 = require("../metrics/runtime");
  10. exports.defaultMetricConf = {
  11. eventLoop: true,
  12. network: false,
  13. http: true,
  14. runtime: true,
  15. v8: true
  16. };
  17. class MetricConfig {
  18. }
  19. exports.MetricConfig = MetricConfig;
  20. class AvailableMetric {
  21. }
  22. const availableMetrics = [
  23. {
  24. name: 'eventloop',
  25. module: eventLoopMetrics_1.default,
  26. optionsPath: 'eventLoop'
  27. },
  28. {
  29. name: 'http',
  30. module: httpMetrics_1.default,
  31. optionsPath: 'http'
  32. },
  33. {
  34. name: 'network',
  35. module: network_1.default,
  36. optionsPath: 'network'
  37. },
  38. {
  39. name: 'v8',
  40. module: v8_1.default,
  41. optionsPath: 'v8'
  42. },
  43. {
  44. name: 'runtime',
  45. module: runtime_1.default,
  46. optionsPath: 'runtime'
  47. }
  48. ];
  49. class MetricsFeature {
  50. constructor() {
  51. this.logger = debug_1.default('axm:features:metrics');
  52. }
  53. init(options) {
  54. if (typeof options !== 'object')
  55. options = {};
  56. this.logger('init');
  57. for (let availableMetric of availableMetrics) {
  58. const metric = new availableMetric.module();
  59. let config = undefined;
  60. if (typeof availableMetric.optionsPath !== 'string') {
  61. config = {};
  62. }
  63. else if (availableMetric.optionsPath === '.') {
  64. config = options;
  65. }
  66. else {
  67. config = featureManager_1.getObjectAtPath(options, availableMetric.optionsPath);
  68. }
  69. metric.init(config);
  70. availableMetric.instance = metric;
  71. }
  72. }
  73. get(name) {
  74. const metric = availableMetrics.find(metric => metric.name === name);
  75. if (metric === undefined)
  76. return undefined;
  77. return metric.instance;
  78. }
  79. destroy() {
  80. this.logger('destroy');
  81. for (let availableMetric of availableMetrics) {
  82. if (availableMetric.instance === undefined)
  83. continue;
  84. availableMetric.instance.destroy();
  85. }
  86. }
  87. }
  88. exports.MetricsFeature = MetricsFeature;
  89. //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibWV0cmljcy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uL3NyYy9mZWF0dXJlcy9tZXRyaWNzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsaUNBQXlCO0FBQ3pCLHNEQUE0RDtBQUM1RCxrRUFBbUc7QUFDbkcsZ0RBQXdFO0FBQ3hFLHdEQUF1RTtBQUN2RSxzQ0FBeUQ7QUFDekQsZ0RBQTBFO0FBRTdELFFBQUEsaUJBQWlCLEdBQWlCO0lBQzdDLFNBQVMsRUFBRSxJQUFJO0lBQ2YsT0FBTyxFQUFFLEtBQUs7SUFDZCxJQUFJLEVBQUUsSUFBSTtJQUNWLE9BQU8sRUFBRSxJQUFJO0lBQ2IsRUFBRSxFQUFFLElBQUk7Q0FDVCxDQUFBO0FBRUQsTUFBYSxZQUFZO0NBdUJ4QjtBQXZCRCxvQ0F1QkM7QUFFRCxNQUFNLGVBQWU7Q0FxQnBCO0FBRUQsTUFBTSxnQkFBZ0IsR0FBc0I7SUFDMUM7UUFDRSxJQUFJLEVBQUUsV0FBVztRQUNqQixNQUFNLEVBQUUsMEJBQThCO1FBQ3RDLFdBQVcsRUFBRSxXQUFXO0tBQ3pCO0lBQ0Q7UUFDRSxJQUFJLEVBQUUsTUFBTTtRQUNaLE1BQU0sRUFBRSxxQkFBVztRQUNuQixXQUFXLEVBQUUsTUFBTTtLQUNwQjtJQUNEO1FBQ0UsSUFBSSxFQUFFLFNBQVM7UUFDZixNQUFNLEVBQUUsaUJBQWE7UUFDckIsV0FBVyxFQUFFLFNBQVM7S0FDdkI7SUFDRDtRQUNFLElBQUksRUFBRSxJQUFJO1FBQ1YsTUFBTSxFQUFFLFlBQVE7UUFDaEIsV0FBVyxFQUFFLElBQUk7S0FDbEI7SUFDRDtRQUNFLElBQUksRUFBRSxTQUFTO1FBQ2YsTUFBTSxFQUFFLGlCQUFjO1FBQ3RCLFdBQVcsRUFBRSxTQUFTO0tBQ3ZCO0NBQ0YsQ0FBQTtBQU9ELE1BQWEsY0FBYztJQUEzQjtRQUVVLFdBQU0sR0FBYSxlQUFLLENBQUMsc0JBQXNCLENBQUMsQ0FBQTtJQXFDMUQsQ0FBQztJQW5DQyxJQUFJLENBQUUsT0FBZ0I7UUFDcEIsSUFBSSxPQUFPLE9BQU8sS0FBSyxRQUFRO1lBQUUsT0FBTyxHQUFHLEVBQUUsQ0FBQTtRQUM3QyxJQUFJLENBQUMsTUFBTSxDQUFDLE1BQU0sQ0FBQyxDQUFBO1FBRW5CLEtBQUssSUFBSSxlQUFlLElBQUksZ0JBQWdCLEVBQUU7WUFDNUMsTUFBTSxNQUFNLEdBQUcsSUFBSSxlQUFlLENBQUMsTUFBTSxFQUFFLENBQUE7WUFDM0MsSUFBSSxNQUFNLEdBQVEsU0FBUyxDQUFBO1lBQzNCLElBQUksT0FBTyxlQUFlLENBQUMsV0FBVyxLQUFLLFFBQVEsRUFBRTtnQkFDbkQsTUFBTSxHQUFHLEVBQUUsQ0FBQTthQUNaO2lCQUFNLElBQUksZUFBZSxDQUFDLFdBQVcsS0FBSyxHQUFHLEVBQUU7Z0JBQzlDLE1BQU0sR0FBRyxPQUFPLENBQUE7YUFDakI7aUJBQU07Z0JBQ0wsTUFBTSxHQUFHLGdDQUFlLENBQUMsT0FBTyxFQUFFLGVBQWUsQ0FBQyxXQUFXLENBQUMsQ0FBQTthQUMvRDtZQUlELE1BQU0sQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLENBQUE7WUFDbkIsZUFBZSxDQUFDLFFBQVEsR0FBRyxNQUFNLENBQUE7U0FDbEM7SUFDSCxDQUFDO0lBRUQsR0FBRyxDQUFFLElBQVk7UUFDZixNQUFNLE1BQU0sR0FBRyxnQkFBZ0IsQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLEVBQUUsQ0FBQyxNQUFNLENBQUMsSUFBSSxLQUFLLElBQUksQ0FBQyxDQUFBO1FBQ3BFLElBQUksTUFBTSxLQUFLLFNBQVM7WUFBRSxPQUFPLFNBQVMsQ0FBQTtRQUMxQyxPQUFPLE1BQU0sQ0FBQyxRQUFRLENBQUE7SUFDeEIsQ0FBQztJQUVELE9BQU87UUFDTCxJQUFJLENBQUMsTUFBTSxDQUFDLFNBQVMsQ0FBQyxDQUFBO1FBQ3RCLEtBQUssSUFBSSxlQUFlLElBQUksZ0JBQWdCLEVBQUU7WUFDNUMsSUFBSSxlQUFlLENBQUMsUUFBUSxLQUFLLFNBQVM7Z0JBQUUsU0FBUTtZQUNwRCxlQUFlLENBQUMsUUFBUSxDQUFDLE9BQU8sRUFBRSxDQUFBO1NBQ25DO0lBQ0gsQ0FBQztDQUNGO0FBdkNELHdDQXVDQyJ9