com.netflix.spectator.api.Registry.get()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.6k)|赞(0)|评价(0)|浏览(122)

本文整理了Java中com.netflix.spectator.api.Registry.get方法的一些代码示例,展示了Registry.get的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Registry.get方法的具体详情如下:
包路径:com.netflix.spectator.api.Registry
类名称:Registry
方法名:get

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;
  }
 }
}

相关文章