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

Registry.clock介绍

[英]The clock used by the registry for timing events.
[中]注册表用于计时事件的时钟。

代码示例

代码示例来源：origin: Netflix/servo

LazyTimer(Registry registry, Id id) {
 super(registry.clock());
 this.registry = registry;
 this.id = id;
}

代码示例来源：origin: spinnaker/kayenta

private List<InfluxDbResult> queryInfluxdb(InfluxDbRemoteService remoteService, String metricSetName, String query) {
 long startTime = registry.clock().monotonicTime();
 List<InfluxDbResult> influxDbResults;
 try {
  influxDbResults = remoteService.query(metricSetName, query);
 } finally {
  long endTime = registry.clock().monotonicTime();
  Id influxDbFetchTimerId = registry.createId("influxdb.fetchTime");
  registry.timer(influxDbFetchTimerId).record(endTime - startTime, TimeUnit.NANOSECONDS);
 }
 return influxDbResults;
}

代码示例来源：origin: spinnaker/kayenta

long startTime = registry.clock().monotonicTime();
List<PrometheusResults> prometheusResultsList;
                               canaryScope.getStep());
} finally {
 long endTime = registry.clock().monotonicTime();

代码示例来源：origin: Netflix/spectator

/** Create a new instance. */
private LongTaskTimer(Registry registry, Id id) {
 this.clock = registry.clock();
 this.id = id;
}

代码示例来源：origin: spinnaker/kayenta

long startTime = registry.clock().monotonicTime();
ListTimeSeriesResponse response;
 response = list.execute();
} finally {
 long endTime = registry.clock().monotonicTime();
 Id stackdriverFetchTimerId = registry.createId("stackdriver.fetchTime").withTag("project", projectId);

代码示例来源：origin: com.netflix.spectator/spectator-api

/** Create a new instance. */
private LongTaskTimer(Registry registry, Id id) {
 this.clock = registry.clock();
 this.id = id;
}

代码示例来源：origin: apache/servicecomb-java-chassis

public void onInvocationFinish(InvocationFinishEvent event) {
 lastUpdated = registry.clock().wallTime();
 InvocationStageTrace stageTrace = event.getInvocation().getInvocationStageTrace();
 totalTimer.record((long) stageTrace.calcTotalTime());
 handlersRequestTimer.record((long) stageTrace.calcHandlersRequestTime());
 handlersResponseTimer.record((long) stageTrace.calcHandlersResponseTime());
 prepareTimer.record((long) stageTrace.calcInvocationPrepareTime());
}

代码示例来源：origin: spinnaker/kayenta

String isoStep = Duration.of(atlasCanaryScope.getStep(), SECONDS) + "";
long start = registry.clock().monotonicTime();
List <AtlasResults> atlasResultsList;
try {
 MAX_RETRIES, RETRY_BACKOFF);
} finally {
 long end = registry.clock().monotonicTime();
 registry.timer("atlas.fetchTime").record(end - start, TimeUnit.NANOSECONDS);

代码示例来源：origin: com.netflix.spectator/spectator-api

@Override public void record(Runnable f) {
 final long s = registry.clock().monotonicTime();
 try {
  f.run();
 } finally {
  final long e = registry.clock().monotonicTime();
  record(e - s, TimeUnit.NANOSECONDS);
 }
}

代码示例来源：origin: Netflix/spectator

@Override public void record(Runnable f) {
 final long s = registry.clock().monotonicTime();
 try {
  f.run();
 } finally {
  final long e = registry.clock().monotonicTime();
  record(e - s, TimeUnit.NANOSECONDS);
 }
}

代码示例来源：origin: Netflix/spectator

@Override public <T> T record(Callable<T> f) throws Exception {
 final long s = registry.clock().monotonicTime();
 try {
  return f.call();
 } finally {
  final long e = registry.clock().monotonicTime();
  record(e - s, TimeUnit.NANOSECONDS);
 }
}

代码示例来源：origin: com.netflix.spectator/spectator-api

@Override public <T> T record(Callable<T> rf) throws Exception {
 final Clock clock = registry.clock();
 final long s = clock.monotonicTime();
 try {
  return rf.call();
 } finally {
  final long e = clock.monotonicTime();
  record(e - s, TimeUnit.NANOSECONDS);
 }
}

代码示例来源：origin: com.netflix.spectator/spectator-api

@Override public void record(Runnable rf) {
 final Clock clock = registry.clock();
 final long s = clock.monotonicTime();
 try {
  rf.run();
 } finally {
  final long e = clock.monotonicTime();
  record(e - s, TimeUnit.NANOSECONDS);
 }
}

代码示例来源：origin: Netflix/spectator

@Override public <T> T record(Callable<T> rf) throws Exception {
 final Clock clock = registry.clock();
 final long s = clock.monotonicTime();
 try {
  return rf.call();
 } finally {
  final long e = clock.monotonicTime();
  record(e - s, TimeUnit.NANOSECONDS);
 }
}

代码示例来源：origin: Netflix/spectator

@Override public void record(Runnable rf) {
 final Clock clock = registry.clock();
 final long s = clock.monotonicTime();
 try {
  rf.run();
 } finally {
  final long e = clock.monotonicTime();
  record(e - s, TimeUnit.NANOSECONDS);
 }
}

代码示例来源：origin: Netflix/spectator

@Override public void record(Runnable rf) {
 final Clock clock = registry.clock();
 final long s = clock.monotonicTime();
 try {
  rf.run();
 } finally {
  final long e = clock.monotonicTime();
  record(e - s, TimeUnit.NANOSECONDS);
 }
}

代码示例来源：origin: com.netflix.spectator/spectator-api

@Override public <T> T record(Callable<T> rf) throws Exception {
 final Clock clock = registry.clock();
 final long s = clock.monotonicTime();
 try {
  return rf.call();
 } finally {
  final long e = clock.monotonicTime();
  record(e - s, TimeUnit.NANOSECONDS);
 }
}

代码示例来源：origin: Netflix/metacat

void recordTime(final SNSMessage<?> message, final String timeName) {
  final Timer timer = this.registry.timer(
    timeName,
    Metrics.TagEventsType.getMetricName(),
    message.getClass().getName()
  );
  timer.record(this.registry.clock().wallTime() - message.getTimestamp(), TimeUnit.MILLISECONDS);
}

代码示例来源：origin: com.netflix.spectator/spectator-api

/**
 * Create a new IntervalCounter using the given registry and base id.
 */
IntervalCounter(Registry registry, Id id) {
 this.clock = registry.clock();
 this.id = id;
 this.counter = registry.counter(id.withTag(Statistic.count));
 this.lastUpdated = PolledMeter.using(registry)
   .withId(id)
   .withTag(Statistic.duration)
   .monitorValue(new AtomicLong(0L), Functions.age(clock));
}

代码示例来源：origin: Netflix/spectator

@Test
public void testGaugeHelpersWithCustomFunction2() {
 AtomicLong al1 = new AtomicLong(1L);
 Registry r = new DefaultRegistry(new ManualClock(40, 0));
 ToDoubleFunction<AtomicLong> f = (obj) -> (r.clock().wallTime() - obj.doubleValue()) / 1000.0;
 AtomicLong v1 = r.gauge("foo", al1, f);
 Assertions.assertSame(v1, al1);
 Id id1 = r.createId("foo");
 assertGaugeValue(r, id1, 39.0 / 1000.0);
}