本文整理了Java中io.micrometer.core.instrument.Timer.record()
方法的一些代码示例,展示了Timer.record()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Timer.record()
方法的具体详情如下:
包路径:io.micrometer.core.instrument.Timer
类名称:Timer
方法名:record
暂无
代码示例来源:origin: com.zaxxer/HikariCP
/** {@inheritDoc} */
@Override
public void recordConnectionAcquiredNanos(final long elapsedAcquiredNanos)
{
connectionObtainTimer.record(elapsedAcquiredNanos, TimeUnit.NANOSECONDS);
}
代码示例来源:origin: com.zaxxer/HikariCP
/** {@inheritDoc} */
@Override
public void recordConnectionUsageMillis(final long elapsedBorrowedMillis)
{
connectionUsage.record(elapsedBorrowedMillis, TimeUnit.MILLISECONDS);
}
代码示例来源:origin: com.zaxxer/HikariCP
@Override
public void recordConnectionCreatedMillis(long connectionCreatedMillis)
{
connectionCreation.record(connectionCreatedMillis, TimeUnit.MILLISECONDS);
}
}
代码示例来源:origin: relayrides/pushy
private void recordEndTimeForNotification(final long notificationId) {
final long endTime = System.nanoTime();
final Long startTime = this.notificationStartTimes.remove(notificationId);
if (startTime != null) {
this.notificationTimer.record(endTime - startTime, TimeUnit.NANOSECONDS);
}
}
代码示例来源:origin: alibaba/nacos
public static void logNotifyEvent(String dataId, String group, String tenant, String requestIpAppName, long ts,
String handleIp, String type, long delayed, String targetIp) {
if (!LogUtil.traceLog.isInfoEnabled()) {
return;
}
MetricsMonitor.getNotifyRtTimer().record(delayed, TimeUnit.MILLISECONDS);
// 方便tlog切分
if (StringUtils.isBlank(tenant)) {
tenant = null;
}
//localIp | dataid | group | tenant | requestIpAppName | ts | handleIp | event | type | [delayed] | ext
// (targetIp)
LogUtil.traceLog.info("{}|{}|{}|{}|{}|{}|{}|{}|{}|{}|{}", LOCAL_IP, dataId, group, tenant,
requestIpAppName, ts, handleIp, "notify", type, delayed, targetIp);
}
代码示例来源:origin: alibaba/nacos
@Override
public HttpResult httpDelete(String path, List<String> headers, List<String> paramValues, String encoding, long readTimeoutMs) throws IOException {
long start = System.currentTimeMillis();
long end = 0;
HttpResult result = null;
try {
result = httpAgent.httpDelete(path, headers, paramValues, encoding, readTimeoutMs);
} catch (IOException e) {
end = System.currentTimeMillis();
MetricsMonitor.getConfigRequestMonitor("DELETE", path, "NA").record(end - start, TimeUnit.MILLISECONDS);
throw e;
}
end = System.currentTimeMillis();
MetricsMonitor.getConfigRequestMonitor("DELETE", path, String.valueOf(result.code)).record(end - start, TimeUnit.MILLISECONDS);
return result;
}
代码示例来源:origin: micrometer-metrics/micrometer
@Benchmark
public int sumTimedWithSupplier() {
return timer.record(this::sum);
}
代码示例来源:origin: alibaba/nacos
@Override
public HttpResult httpGet(String path, List<String> headers, List<String> paramValues, String encoding, long readTimeoutMs) throws IOException {
long start = System.currentTimeMillis();
long end = 0;
HttpResult result = null;
try {
result = httpAgent.httpGet(path, headers, paramValues, encoding, readTimeoutMs);
} catch (IOException e) {
end = System.currentTimeMillis();
MetricsMonitor.getConfigRequestMonitor("GET", path, "NA").record(end - start, TimeUnit.MILLISECONDS);
throw e;
}
end = System.currentTimeMillis();
MetricsMonitor.getConfigRequestMonitor("GET", path, String.valueOf(result.code)).record(end - start, TimeUnit.MILLISECONDS);
return result;
}
代码示例来源:origin: alibaba/nacos
@Override
public HttpResult httpPost(String path, List<String> headers, List<String> paramValues, String encoding, long readTimeoutMs) throws IOException {
long start = System.currentTimeMillis();
long end = 0;
HttpResult result = null;
try {
result = httpAgent.httpPost(path, headers, paramValues, encoding, readTimeoutMs);
} catch (IOException e) {
end = System.currentTimeMillis();
MetricsMonitor.getConfigRequestMonitor("POST", path, "NA").record(end - start, TimeUnit.MILLISECONDS);
throw e;
}
end = System.currentTimeMillis();
MetricsMonitor.getConfigRequestMonitor("POST", path, String.valueOf(result.code)).record(end - start, TimeUnit.MILLISECONDS);
return result;
}
代码示例来源:origin: micrometer-metrics/micrometer
@Benchmark
public int sumTimedWithRegistryLookup() {
return registry.timer("timer").record(this::sum);
}
代码示例来源:origin: alibaba/nacos
ConfigTraceService.NOTIFY_EVENT_OK, delayed, serverIp);
MetricsMonitor.getNotifyRtTimer().record(delayed, TimeUnit.MILLISECONDS);
代码示例来源:origin: alibaba/nacos
public String callServer(String api, Map<String, String> params, String curServer, String method)
throws NacosException {
long start = System.currentTimeMillis();
long end = 0;
List<String> headers = Arrays.asList("Client-Version", UtilAndComs.VERSION,
"Accept-Encoding", "gzip,deflate,sdch",
"Connection", "Keep-Alive",
"RequestId", UuidUtils.generateUuid());
String url;
if (!curServer.contains(UtilAndComs.SERVER_ADDR_IP_SPLITER)) {
curServer = curServer + UtilAndComs.SERVER_ADDR_IP_SPLITER + DEFAULT_SERVER_PORT;
}
url = HttpClient.getPrefix() + curServer + api;
HttpClient.HttpResult result = HttpClient.request(url, headers, params, UtilAndComs.ENCODING, method);
end = System.currentTimeMillis();
MetricsMonitor.getNamingRequestMonitor(method, url, String.valueOf(result.code))
.record(end - start, TimeUnit.MILLISECONDS);
if (HttpURLConnection.HTTP_OK == result.code) {
return result.content;
}
if (HttpURLConnection.HTTP_NOT_MODIFIED == result.code) {
return StringUtils.EMPTY;
}
LogUtils.LOG.error("CALL-SERVER", "failed to req API:" + HttpClient.getPrefix() + curServer
+ api + ". code:"
+ result.code + " msg: " + result.content);
throw new NacosException(NacosException.SERVER_ERROR, "failed to req API:" + HttpClient.getPrefix() + curServer
+ api + ". code:"
+ result.code + " msg: " + result.content);
}
代码示例来源:origin: reactor/reactor-core
@Override
public void onNext(T t) {
if (done) {
this.malformedSourceCounter.increment();
Operators.onNextDropped(t, actual.currentContext());
return;
}
//record the delay since previous onNext/onSubscribe. This also records the count.
long last = this.lastNextEventNanos;
this.lastNextEventNanos = clock.monotonicTime();
this.onNextIntervalTimer.record(lastNextEventNanos - last, TimeUnit.NANOSECONDS);
actual.onNext(t);
}
代码示例来源:origin: reactor/reactor-core
@Override
@Nullable
public T poll() {
if (qs == null) {
return null;
}
try {
T v = qs.poll();
if (v == null && fusionMode == SYNC) {
//this is also a complete event
this.subscribeToTerminateSample.stop(subscribeToCompleteTimer);
}
if (v != null) {
//this is an onNext event
//record the delay since previous onNext/onSubscribe. This also records the count.
long last = this.lastNextEventNanos;
this.lastNextEventNanos = clock.monotonicTime();
this.onNextIntervalTimer.record(lastNextEventNanos - last, TimeUnit.NANOSECONDS);
}
return v;
} catch (Throwable e) {
//register a timer for that particular exception
Timer timer = subscribeToErrorTimerFactory.apply(e);
//record error termination
this.subscribeToTerminateSample.stop(timer);
throw e;
}
}
代码示例来源:origin: reactor/reactor-core
@Override
public void onNext(T t) {
if (this.fusionMode == Fuseable.ASYNC) {
actual.onNext(null);
return;
}
if (done) {
this.malformedSourceCounter.increment();
Operators.onNextDropped(t, actual.currentContext());
return;
}
//record the delay since previous onNext/onSubscribe. This also records the count.
long last = this.lastNextEventNanos;
this.lastNextEventNanos = clock.monotonicTime();
this.onNextIntervalTimer.record(lastNextEventNanos - last, TimeUnit.NANOSECONDS);
actual.onNext(t);
}
代码示例来源:origin: spring-projects/spring-integration
@Override
public void record(long time, TimeUnit unit) {
this.timer.record(time, unit);
}
代码示例来源:origin: line/armeria
private static void onResponse(RequestLog log, MeterIdPrefixFunction meterIdPrefixFunction,
ActiveRequestMetrics activeRequestMetrics) {
final RequestContext ctx = log.context();
final MeterRegistry registry = ctx.meterRegistry();
final MeterIdPrefix idPrefix = meterIdPrefixFunction.apply(registry, log);
final RequestMetrics metrics = MicrometerUtil.register(
registry, idPrefix, RequestMetrics.class, DefaultRequestMetrics::new);
if (log.requestCause() != null) {
metrics.failure().increment();
return;
}
metrics.requestDuration().record(log.requestDurationNanos(), TimeUnit.NANOSECONDS);
metrics.requestLength().record(log.requestLength());
metrics.responseDuration().record(log.responseDurationNanos(), TimeUnit.NANOSECONDS);
metrics.responseLength().record(log.responseLength());
metrics.totalDuration().record(log.totalDurationNanos(), TimeUnit.NANOSECONDS);
if (isSuccess(log)) {
metrics.success().increment();
} else {
metrics.failure().increment();
}
activeRequestMetrics.decrement();
}
代码示例来源:origin: org.springframework.boot/spring-boot-actuator
private void success(ServerWebExchange exchange, long start) {
Iterable<Tag> tags = this.tagsProvider.httpRequestTags(exchange, null);
this.registry.timer(this.metricName, tags).record(System.nanoTime() - start,
TimeUnit.NANOSECONDS);
}
代码示例来源:origin: org.springframework.boot/spring-boot-actuator
private void error(ServerWebExchange exchange, long start, Throwable cause) {
Iterable<Tag> tags = this.tagsProvider.httpRequestTags(exchange, cause);
this.registry.timer(this.metricName, tags).record(System.nanoTime() - start,
TimeUnit.NANOSECONDS);
}
代码示例来源:origin: org.springframework.boot/spring-boot-actuator
@Override
public ClientHttpResponse intercept(HttpRequest request, byte[] body,
ClientHttpRequestExecution execution) throws IOException {
long startTime = System.nanoTime();
ClientHttpResponse response = null;
try {
response = execution.execute(request, body);
return response;
}
finally {
getTimeBuilder(request, response).register(this.meterRegistry)
.record(System.nanoTime() - startTime, TimeUnit.NANOSECONDS);
urlTemplate.remove();
}
}
内容来源于网络,如有侵权,请联系作者删除!