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 |