本文整理了Java中com.netflix.spectator.api.Registry.get
方法的一些代码示例,展示了Registry.get
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Registry.get
方法的具体详情如下:
包路径:com.netflix.spectator.api.Registry
类名称:Registry
方法名:get
[英]Returns the meter associated with a given id.
[中]返回与给定id关联的仪表。
代码示例来源:origin: org.springframework.metrics/spring-metrics
@Override
public Meter get(Id id) {
return composite.get(id);
}
代码示例来源:origin: Netflix/spectator
@Override public Meter get(Id id) {
return impl.get(id);
}
代码示例来源:origin: com.netflix.spectator/spectator-api
@Override public Meter get(Id id) {
return impl.get(id);
}
代码示例来源:origin: stackoverflow.com
private <T extends Box> void helperMethod(Class<T> clazz, Box box, Registry registry) {
registry.get( clazz ).parse( clazz.cast( box ) );
}
// then you use it like in the place you had before:
for ( Box box : boxes ) {
Class<? extends Box> clazz = box.getClass();
helperMethod(clazz, box, registry);
}
代码示例来源:origin: Netflix/spectator
@Override public Meter get(Id id) {
rlock.lock();
try {
for (Registry r : registries) {
Meter m = r.get(id);
if (m != null) {
if (m instanceof Counter) {
return counter(id);
} else if (m instanceof Timer) {
return timer(id);
} else if (m instanceof DistributionSummary) {
return distributionSummary(id);
} else if (m instanceof Gauge) {
return gauge(id);
} else {
return null;
}
}
}
return null;
} finally {
rlock.unlock();
}
}
代码示例来源:origin: com.netflix.spectator/spectator-api
@Override public Meter get(Id id) {
rlock.lock();
try {
for (Registry r : registries) {
Meter m = r.get(id);
if (m != null) {
if (m instanceof Counter) {
return counter(id);
} else if (m instanceof Timer) {
return timer(id);
} else if (m instanceof DistributionSummary) {
return distributionSummary(id);
} else if (m instanceof Gauge) {
return gauge(id);
} else {
return null;
}
}
}
return null;
} finally {
rlock.unlock();
}
}
代码示例来源:origin: Netflix/spectator
private long getValue(String name) {
Meter meter = registry.get(registry.createId(name));
if (meter != null) {
for (Measurement m : meter.measure()) {
return (long) m.value();
}
}
return Long.MAX_VALUE;
}
代码示例来源:origin: Netflix/spectator
private Meter getMeter(String meterName, String threadPoolName) {
ThreadPoolMonitor.attach(registry, latchedExecutor, threadPoolName);
PolledMeter.update(registry);
final Id id = registry.createId(meterName).withTag(ThreadPoolMonitor.ID_TAG_NAME,
(threadPoolName == null || threadPoolName.isEmpty()) ? ThreadPoolMonitor.DEFAULT_ID : threadPoolName);
return registry.get(id);
}
代码示例来源:origin: Netflix/spectator
@Test
public void testGet() {
Registry r = newRegistry(5, true);
Counter c = r.counter(r.createId("foo"));
c.increment(42);
Meter m = r.get(c.id());
Assertions.assertEquals(c.measure().iterator().next(), m.measure().iterator().next());
}
代码示例来源:origin: Netflix/spectator
@Test
public void methodValueUnknownNoPropagate() {
Registry r = newRegistry(false, 10000);
r.methodValue("queueSize", this, "unknownMethod");
Assertions.assertNull(r.get(r.createId("queueSize")));
}
代码示例来源:origin: Netflix/spectator
@Test
public void methodValueBadReturnTypeNoPropagate() {
Registry r = newRegistry(false, 10000);
r.methodValue("queueSize", this, "toString");
Assertions.assertNull(r.get(r.createId("queueSize")));
}
代码示例来源:origin: Netflix/spectator
@Disabled
public void staticGet() {
Id id = registry.createId("foo");
DoubleDistributionSummary t = DoubleDistributionSummary.get(registry, id);
Assertions.assertSame(t, DoubleDistributionSummary.get(registry, id));
Assertions.assertNotNull(registry.get(id));
}
代码示例来源:origin: Netflix/spectator
@Test
public void testRegisterBadTypeAccessNoThrow() {
Registry r = newRegistry(5, false);
Counter c = new DefaultCounter(clock, r.createId("foo"));
r.counter(c.id());
r.register(c);
Assertions.assertNotSame(r.get(c.id()), c);
}
代码示例来源:origin: Netflix/spectator
@Test
public void testRegister() {
Registry r = newRegistry(5, true);
Counter c = new DefaultCounter(clock, r.createId("foo"));
r.register(c);
c.increment();
Assertions.assertEquals(c.count(), 1L);
r.register(c);
PolledMeter.update(r);
Meter meter = r.get(c.id());
for (Measurement m : meter.measure()) {
Assertions.assertEquals(m.value(), 2.0, 1e-12);
}
}
代码示例来源:origin: Netflix/spectator
@Disabled
public void testRegister() {
DoubleDistributionSummary t = newInstance();
registry.register(t);
t.record(42.0);
clock.setWallTime(65000L);
for (Measurement m : registry.get(t.id()).measure()) {
Assertions.assertEquals(m.timestamp(), 65000L);
switch (get(m.id(), "statistic")) {
case "count":
Assertions.assertEquals(m.value(), 1.0 / 65.0, 1e-12);
break;
case "totalAmount":
Assertions.assertEquals(m.value(), 42.0 / 65.0, 1e-12);
break;
case "totalOfSquares":
Assertions.assertEquals(m.value(), 42.0 * 42.0 / 65.0, 1e-12);
break;
case "max":
Assertions.assertEquals(m.value(), 42.0, 1e-12);
break;
default:
Assertions.fail("unexpected id: " + m.id());
break;
}
}
}
内容来源于网络,如有侵权,请联系作者删除!