本文整理了Java中com.spotify.helios.servicescommon.statistics.ZooKeeperMetrics
类的一些代码示例,展示了ZooKeeperMetrics
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperMetrics
类的具体详情如下:
包路径:com.spotify.helios.servicescommon.statistics.ZooKeeperMetrics
类名称:ZooKeeperMetrics
[英]This interface lets us report ZooKeeper metrics.
[中]这个界面允许我们报告ZooKeeper指标。
代码示例来源:origin: spotify/helios
public void checkException(Exception ex, String... tags) {
Throwable th = ex;
while (th != null && !(th instanceof KeeperException)) {
th = th.getCause();
}
if (th == null) {
return;
}
final KeeperException k = (KeeperException) th;
final String message = exceptionMap.get(k.getClass());
if (message == null) {
return;
}
final List<String> tagList = Lists.newArrayList("zookeeper", "error", message);
tagList.addAll(Lists.newArrayList(tags));
metrics.zookeeperTransientError();
}
代码示例来源:origin: spotify/helios
public void connectionStateChanged(final ConnectionState newState) {
metrics.connectionStateChanged(newState);
}
代码示例来源:origin: spotify/helios
public <T> T time(final String tag, final String name, ZooKeeperCallable<T> callable)
throws KeeperException {
final long startTime = clock.getTick();
try {
return callable.call();
} catch (KeeperException e) {
checkException(e, tag, name);
throw e;
} catch (Exception e) {
Throwables.throwIfUnchecked(e);
throw new RuntimeException(e);
} finally {
metrics.updateTimer(name, clock.getTick() - startTime, TimeUnit.NANOSECONDS);
}
}
代码示例来源:origin: at.molindo/helios-services
public void checkException(Exception e, String... tags) {
Throwable t = e;
while (t != null && !(t instanceof KeeperException)) {
t = t.getCause();
}
if (t == null) {
return;
}
final KeeperException k = (KeeperException) t;
final String message = exceptionMap.get(k.getClass());
if (message == null) {
return;
}
final List<String> tagList = Lists.newArrayList("zookeeper", "error", message);
tagList.addAll(Lists.newArrayList(tags));
riemannFacade.event()
.tags(tagList)
.send();
metrics.zookeeperTransientError();
}
内容来源于网络,如有侵权,请联系作者删除!