Initial UI for Metrics in Observatory

runtime/bin/vmservice/observatory/lib/src/app/page.dart

 // Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 part of app;
 
 /// A [Page] controls the user interface of Observatory. At any given time
 /// one page will be the current page. Pages are registered at startup.
 /// When the user navigates within the application, each page is asked if it
 /// can handle the current location, the first page to say yes, wins.
@@ skipping 123 matching lines @@
     assert(element != null);
   }
 
   void _visit(String url) {
     assert(element != null);
     assert(canVisit(url));
   }
 
   bool canVisit(String url) => url.startsWith('vm-connect/');
 }
+
+class MetricsPage extends Page {
+  static RegExp _matcher = new RegExp(r'isolates/.*/metrics');
+  static RegExp _isolateMatcher = new RegExp(r'isolates/.*/');
+
+  // Page state, retained as long as ObservatoryApplication.
+  String selectedMetricId;
+
+  final Map<int, MetricPoller> pollers = new Map<int, MetricPoller>();
+
+  // 8 seconds, 4 seconds, 2 seconds, 1 second, and one hundred milliseconds.
+  static final List<int> POLL_PERIODS = [8000,
+                                         4000,
+                                         2000,
+                                         1000,
+                                         100];
+
+  MetricsPage(app) : super(app) {
+    for (var i = 0; i < POLL_PERIODS.length; i++) {
+      pollers[POLL_PERIODS[i]] = new MetricPoller(POLL_PERIODS[i]);
+    }
+  }
+
+  void onInstall() {
+    if (element == null) {
+      element = new Element.tag('metrics-page');
+      (element as MetricsPageElement).page = this;
+    }
+    assert(element != null);
+  }
+
+  void setRefreshPeriod(int refreshPeriod, ServiceMetric metric) {
+    if (metric.poller != null) {
+      if (metric.poller.pollPeriod.inMilliseconds == refreshPeriod) {
+        return;
+      }
+      // Remove from current poller.
+      metric.poller.metrics.remove(metric);
+      metric.poller = null;
+    }
+    if (refreshPeriod == 0) {
+      return;
+    }
+    var poller = pollers[refreshPeriod];
+    if (poller != null) {
+      poller.metrics.add(metric);
+      metric.poller = poller;
+      return;
+    }
+    throw new FallThroughError();
+  }
+
+  String _isolateId(String url) {
+    // Grab isolate prefix.
+    String isolateId = _isolateMatcher.stringMatch(url);
+    // Remove the trailing slash.
+    return isolateId.substring(0, isolateId.length - 1);
+  }
+
+  void _visit(String url) {
+    assert(element != null);
+    assert(canVisit(url));
+    app.vm.get(_isolateId(url)).then((i) {
+      (element as MetricsPageElement).isolate = i;
+    });
+  }
+
+  bool canVisit(String url) => _matcher.hasMatch(url);
+}