Initial backend for metrics in Observatory

runtime/lib/profiler.dart

Index: runtime/lib/profiler.dart
diff --git a/runtime/lib/profiler.dart b/runtime/lib/profiler.dart
index 2c60141a492552be8f36be050e44dc0d772f7422..8f6463b68eb1976583ac89a4a0fd400d3b145da6 100644
--- a/runtime/lib/profiler.dart
+++ b/runtime/lib/profiler.dart
@@ -3,6 +3,7 @@
 // BSD-style license that can be found in the LICENSE file.
 
 import "dart:_internal";
+import 'dart:convert';

[koda, 2014/07/29 19:44:13]

Inconsistent quotes.

[Cutch, 2014/07/30 00:01:24]

Done.

 
 patch class UserTag {
   /* patch */ factory UserTag(String label) {
@@ -22,3 +23,142 @@ patch UserTag getCurrentTag() => _getCurrentTag();
 UserTag _getCurrentTag() native "Profiler_getCurrentTag";
 
 UserTag _getDefaultTag() native "UserTag_defaultTag";
+
+/// Abstract [Metric] class. Metric names must be unique, are hierarchical,
+/// and use periods as separators. For example, 'a.b.c'. Uniqueness is only
+/// enforced when a Metric is registered.
+abstract class Metric {
+  /// [name] of this metric.
+  final String name;
+  /// [description] of this metric.
+  final String description;
+
+  Metric(this.name, this.description);
+
+  Map _toJSON();
+}
+
+/// A measured value with a min and max. Initial value is min. Value will
+/// be clamped to the interval [min, max].
+class Gauge extends Metric {
+  final double min;
+  final double max;
+
+  double _value;
+  double get value => _value;
+  set value(double v) {
+    if (v < min) {
+      v = min;
+    }
+    if (v > max) {

[koda, 2014/07/29 19:44:13]

else if

[Cutch, 2014/07/30 00:01:24]

Done.

+      v = max;
+    }
+    _value = v;
+  }
+
+  Gauge(String name, String description, this.min, this.max)
+      : super(name, description) {
+    if (min is! double) {
+      throw new ArgumentError('min must be a double');
+    }
+    if (max is! double) {
+      throw new ArgumentError('max must be a double');
+    }
+    if (!(min < max)) {
+      throw new ArgumentError('min must be less than max');
+    }
+    _value = min;
+  }
+
+  Map _toJSON() {
+    var map = {
+      'type': 'Gauge',
+      'id': 'metrics/$name',
+      'name': name,
+      'description': description,
+      'value': value,
+      'min': min,
+      'max': max,
+    };
+    return map;
+  }
+}
+
+
+/// A changing value. Initial value is 0.0.
+class Counter extends Metric {
+  Counter(String name, String description)
+      : super(name, description);
+
+  double _value = 0.0;
+  double get value => _value;
+  set value(double v) {
+    _value = v;
+  }
+
+  Map _toJSON() {
+    var map = {
+      'type': 'Counter',
+      'id': 'metrics/$name',

[koda, 2014/07/29 19:44:13]

I guess we should avoid having slashes in the name then? Maybe overkill to
verify it, though.

[Cutch, 2014/07/30 00:01:24]

We need to verify. Things will fall over when we parse the request url if the
name has a /. I now throw in the Metric constructor if the name contains a /.

+      'name': name,
+      'description': description,
+      'value': value,
+    };
+    return map;
+  }
+}
+
+/// Register [Metric]s to make them visible to Observatory.

[koda, 2014/07/29 19:44:13]

You use the term "register" here and above, but the method is called "add".
Consider renaming/rewording.

[Cutch, 2014/07/30 00:01:24]

Done.

+class Metrics {
+  static final List<Metric> _metrics = new List<Metric>();
+
+  static bool _nameExists(String name) {
+    for (var i = 0; i < _metrics.length; i++) {
+      if (_metrics[i].name == name) {
+        return true;
+      }
+    }
+    return false;
+  }
+
+  static void add(Metric metric) {
+    if (metric is! Metric) {
+      throw new ArgumentError('metric must be a Metric');
+    }
+    if (_nameExists(metric.name)) {
+      throw new ArgumentError('Register metrics have unique names');
+    }
+    _metrics.add(metric);
+  }
+
+  static void remove(Metric metric) {
+    if (metric is! Metric) {
+      throw new ArgumentError('metric must be a Metric');
+    }
+    _metrics.remove(metric);
+  }
+
+  static String _printMetric(String id) {
+    for (var i = 0; i < _metrics.length; i++) {
+      var m = _metrics[i];
+      if (m.name == id) {
+        return JSON.encode(m._toJSON());
+      }
+    }
+    return null;
+  }
+
+  static String _printMetrics() {
+    var members = [];
+    for (var i = 0; i < _metrics.length; i++) {
+      var m = _metrics[i];
+      members.add(m._toJSON());
+    }
+    var map = {
+      'type': 'MetricList',
+      'id': 'metrics',
+      'members': members,
+    };
+    return JSON.encode(map);
+  }
+}