1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.metrics;
20
21 import org.apache.hadoop.metrics2.lib.MutableCounterLong;
22 import org.apache.hadoop.metrics2.lib.MutableFastCounter;
23 import org.apache.hadoop.metrics2.lib.MutableGaugeLong;
24 import org.junit.BeforeClass;
25 import org.junit.Test;
26
27 import static org.junit.Assert.assertEquals;
28 import static org.junit.Assert.assertNull;
29
30
31
32
33 public class TestBaseSourceImpl {
34
35 private static BaseSourceImpl bmsi;
36
37 @BeforeClass
38 public static void setUp() throws Exception {
39 bmsi = new BaseSourceImpl("TestName", "test description", "testcontext", "TestContext");
40 }
41
42 @Test
43 public void testSetGauge() throws Exception {
44 bmsi.setGauge("testset", 100);
45 assertEquals(100, ((MutableGaugeLong) bmsi.metricsRegistry.get("testset")).value());
46 bmsi.setGauge("testset", 300);
47 assertEquals(300, ((MutableGaugeLong) bmsi.metricsRegistry.get("testset")).value());
48
49 }
50
51 @Test
52 public void testIncGauge() throws Exception {
53 bmsi.incGauge("testincgauge", 100);
54 assertEquals(100, ((MutableGaugeLong) bmsi.metricsRegistry.get("testincgauge")).value());
55 bmsi.incGauge("testincgauge", 100);
56 assertEquals(200, ((MutableGaugeLong) bmsi.metricsRegistry.get("testincgauge")).value());
57
58 }
59
60 @Test
61 public void testDecGauge() throws Exception {
62 bmsi.decGauge("testdec", 100);
63 assertEquals(-100, ((MutableGaugeLong) bmsi.metricsRegistry.get("testdec")).value());
64 bmsi.decGauge("testdec", 100);
65 assertEquals(-200, ((MutableGaugeLong) bmsi.metricsRegistry.get("testdec")).value());
66
67 }
68
69 @Test
70 public void testIncCounters() throws Exception {
71 bmsi.incCounters("testinccounter", 100);
72 assertEquals(100, ((MutableFastCounter) bmsi.metricsRegistry.get("testinccounter")).value());
73 bmsi.incCounters("testinccounter", 100);
74 assertEquals(200, ((MutableFastCounter) bmsi.metricsRegistry.get("testinccounter")).value());
75
76 }
77
78 @Test
79 public void testRemoveMetric() throws Exception {
80 bmsi.setGauge("testrmgauge", 100);
81 bmsi.removeMetric("testrmgauge");
82 assertNull(bmsi.metricsRegistry.get("testrmgauge"));
83 }
84
85 }