make version of ts_mon compatible with appengine

infra_libs/ts_mon/common/metrics.py

 # Copyright 2015 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 """Classes representing individual metrics that can be sent."""
 
 
 import copy
 import threading
 import time
 
-from monacq.proto import metrics_pb2
-
-from infra_libs.ts_mon import distribution
-from infra_libs.ts_mon import errors
-from infra_libs.ts_mon import interface
+try:
+  from infra_libs.ts_mon import interface
+  from infra_libs.ts_mon.common import distribution
+  from infra_libs.ts_mon.common import errors
+  from monacq.proto import metrics_pb2
+except ImportError: # pragma: no cover
+  import interface
+  from common import distribution
+  from common import errors
+  from monacq.proto import metrics_pb2
 
 
 MICROSECONDS_PER_SECOND = 1000000
 
 
 class Metric(object):
   """Abstract base class for a metric.
 
   A Metric is an attribute that may be monitored across many targets. Examples
   include disk usage or the number of requests a server has received. A single
@@ skipping 35 matching lines @@
     self._target = target
     fields = fields or {}
     if len(fields) > 7:
       raise errors.MonitoringTooManyFieldsError(self._name, fields)
     self._fields = fields
     self._normalized_fields = self._normalize_fields(self._fields)
     self._thread_lock = threading.Lock()
 
     interface.register(self)
 
+
+  def __eq__(self, other):
+    name = self._name == other._name
+    target = self._target == other._target
+    field = self._fields == other._fields
+    instance_type = type(self) == type(other)
+    return name and target and field and instance_type
+
   def unregister(self):
     interface.unregister(self)
 
   def serialize_to(self, collection_pb, default_target=None, loop_action=None):
     """Generate metrics_pb2.MetricsData messages for this metric.
 
     Args:
       collection_pb (metrics_pb2.MetricsCollection): protocol buffer into which
         to add the current metric values.
       default_target (Target): a Target to use if self._target is not set.
@@ skipping 343 matching lines @@
 
   def __init__(
       self, name, bucketer=None, target=None, fields=None, time_fn=time.time):
     super(NonCumulativeDistributionMetric, self).__init__(
         name,
         is_cumulative=False,
         bucketer=bucketer,
         target=target,
         fields=fields,
         time_fn=time_fn)