| OLD | NEW |
| 1 # Copyright 2015 The Chromium Authors. All rights reserved. | 1 # Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
| 3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
| 4 | 4 |
| 5 import functools | 5 import functools |
| 6 import operator | 6 import operator |
| 7 import time | 7 import time |
| 8 import unittest | 8 import unittest |
| 9 | 9 |
| 10 import mock | 10 import mock |
| (...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 120 self.assertEquals(24, self.store.get('foo', fields1, target_fields1)) | 120 self.assertEquals(24, self.store.get('foo', fields1, target_fields1)) |
| 121 self.assertEquals(34, self.store.get('foo', fields2, target_fields2)) | 121 self.assertEquals(34, self.store.get('foo', fields2, target_fields2)) |
| 122 | 122 |
| 123 self.assertIsNone(self.store.get('foo', fields3, None)) | 123 self.assertIsNone(self.store.get('foo', fields3, None)) |
| 124 self.assertIsNone(self.store.get('foo', (), None)) | 124 self.assertIsNone(self.store.get('foo', (), None)) |
| 125 self.assertIsNone(self.store.get('foo', fields1, target_fields2)) | 125 self.assertIsNone(self.store.get('foo', fields1, target_fields2)) |
| 126 self.assertEquals(44, self.store.get('foo', fields3, None, default=44)) | 126 self.assertEquals(44, self.store.get('foo', fields3, None, default=44)) |
| 127 | 127 |
| 128 self.assertIsNone(self.store.get('bar', (), None)) | 128 self.assertIsNone(self.store.get('bar', (), None)) |
| 129 | 129 |
| 130 def test_iter_field_values(self): |
| 131 fields1 = (('field', 'value'),) |
| 132 fields2 = (('field', 'value2'),) |
| 133 target_fields1 = {'region': 'rrr'} |
| 134 |
| 135 self.store.set('foo', fields1, None, 42) |
| 136 self.store.set('foo', fields2, None, 43) |
| 137 self.store.set('foo', fields2, target_fields1, 44) |
| 138 |
| 139 field_values = list(self.store.iter_field_values('foo')) |
| 140 self.assertEquals([ |
| 141 ((('field', 'value'),), 42), |
| 142 ((('field', 'value2'),), 43), |
| 143 ((('field', 'value2'),), 44), |
| 144 ], sorted(field_values)) |
| 145 |
| 130 def test_set_enforce_ge(self): | 146 def test_set_enforce_ge(self): |
| 131 self.store.set('foo', (('field', 'value'),), None, 42, enforce_ge=True) | 147 self.store.set('foo', (('field', 'value'),), None, 42, enforce_ge=True) |
| 132 self.store.set('foo', (('field', 'value'),), None, 43, enforce_ge=True) | 148 self.store.set('foo', (('field', 'value'),), None, 43, enforce_ge=True) |
| 133 | 149 |
| 134 with self.assertRaises(errors.MonitoringDecreasingValueError): | 150 with self.assertRaises(errors.MonitoringDecreasingValueError): |
| 135 self.store.set('foo', (('field', 'value'),), None, 42, enforce_ge=True) | 151 self.store.set('foo', (('field', 'value'),), None, 42, enforce_ge=True) |
| 136 | 152 |
| 137 def test_incr(self): | 153 def test_incr(self): |
| 138 self.store.set('foo', (('field', 'value'),), None, 42) | 154 self.store.set('foo', (('field', 'value'),), None, 42) |
| 139 self.store.incr('foo', (('field', 'value'),), None, 4) | 155 self.store.incr('foo', (('field', 'value'),), None, 4) |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 172 fields = (('field', 'value'),) | 188 fields = (('field', 'value'),) |
| 173 self.store.set('foo', fields, None, 42) # Registered in setUp(). | 189 self.store.set('foo', fields, None, 42) # Registered in setUp(). |
| 174 self.store.set('bar', fields, None, 24) # Unregistered. | 190 self.store.set('bar', fields, None, 24) # Unregistered. |
| 175 all_metrics = list(self.store.get_all()) | 191 all_metrics = list(self.store.get_all()) |
| 176 self.assertEqual(1, len(all_metrics)) | 192 self.assertEqual(1, len(all_metrics)) |
| 177 self.assertEqual('foo', all_metrics[0][1].name) | 193 self.assertEqual('foo', all_metrics[0][1].name) |
| 178 | 194 |
| 179 | 195 |
| 180 class InProcessMetricStoreTest(MetricStoreTestBase, unittest.TestCase): | 196 class InProcessMetricStoreTest(MetricStoreTestBase, unittest.TestCase): |
| 181 METRIC_STORE_CLASS = metric_store.InProcessMetricStore | 197 METRIC_STORE_CLASS = metric_store.InProcessMetricStore |
| OLD | NEW |