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

Timer.record介绍

[英]Updates the statistics kept by the counter with the specified amount.
[中]用指定的金额更新计数器保存的统计信息。

代码示例

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

public static void recordQueueWaitTime(String taskType, long queueWaitTime) {
  getTimer(classQualifier, "task_queue_wait", "taskType", taskType).record(queueWaitTime, TimeUnit.MILLISECONDS);
}

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

public static void recordWorkflowCompletion(String workflowType, long duration, String ownerApp) {
  getTimer(classQualifier, "workflow_execution", "workflowName", workflowType, "ownerApp", ""+ownerApp).record(duration, TimeUnit.MILLISECONDS);
}

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

@Override public void record(long amount, TimeUnit unit) {
 get().record(amount, unit);
}

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

private void endConnEstablishTimer(Timing timing)
{
  timing.end();
  connEstablishTimer.record(timing.getDuration(), TimeUnit.NANOSECONDS);
}

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

@Override
public void stop() {
  super.stop();
  long duration = getDuration(TimeUnit.MILLISECONDS);
  sm.record(duration, TimeUnit.MILLISECONDS);
}

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

public static void recordTaskExecutionTime(String taskType, long duration, boolean includesRetries, Task.Status status) {
  getTimer(classQualifier, "task_execution", "taskType", taskType, "includeRetries", "" + includesRetries, "status", status.name()).record(duration, TimeUnit.MILLISECONDS);
}

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

private void endConnEstablishTimer(Timing timing)
{
  timing.end();
  connEstablishTimer.record(timing.getDuration(), TimeUnit.NANOSECONDS);
}

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

stopwatch.stop();
WorkflowTaskMetrics.getExecutionTimer(worker.getTaskDefName())
    .record(stopwatch.elapsed(TimeUnit.MILLISECONDS), TimeUnit.MILLISECONDS);

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

.record(() -> taskClient.batchPollTasksInDomain(taskType, domain, worker.getIdentity(), realPollCount, worker.getLongPollTimeoutInMS()));
incrementTaskPollCount(taskType, tasks.size());
logger.debug("Polled {}, domain {}, received {} tasks in worker - {}", worker.getTaskDefName(), domain, tasks.size(), worker.getIdentity());

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

registry.timer(id).record(
 getNanoTime() - ((Long) request.getAttribute(TIMER_ATTRIBUTE)), TimeUnit.NANOSECONDS
);

代码示例来源：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

registry.timer(prometheusFetchTimerId).record(endTime - startTime, TimeUnit.NANOSECONDS);

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

registry.timer(stackdriverFetchTimerId).record(endTime - startTime, TimeUnit.NANOSECONDS);

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

} finally {
 long end = registry.clock().monotonicTime();
 registry.timer("atlas.fetchTime").record(end - start, TimeUnit.NANOSECONDS);

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

@Test
public void empty() {
 Timer t = new CompositeTimer(NoopId.INSTANCE, clock, Collections.emptyList());
 assertCountEquals(t, 0L);
 assertTotalEquals(t, 0L);
 t.record(1L, TimeUnit.SECONDS);
 assertCountEquals(t, 0L);
 assertTotalEquals(t, 0L);
}

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

@Test
public void timerRecordCallable() throws Exception {
 Timer t = registry.timer("foo");
 t.record(() -> clock.add(42, TimeUnit.SECONDS));
 Assertions.assertEquals(1, t.count());
 Assertions.assertEquals(TimeUnit.SECONDS.toNanos(42), t.totalTime());
}

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

@Test
public void resurrectUsingCachedRefInitTimer() {
 ManualClock clock = new ManualClock();
 ExpiringRegistry registry = new ExpiringRegistry(clock);
 Timer t = registry.timer("test");
 clock.setWallTime(60000 * 30);
 registry.removeExpiredMeters();
 Assertions.assertEquals(0, registry.timers().count());
 t.record(42, TimeUnit.NANOSECONDS);
 Assertions.assertEquals(1, registry.timers().count());
}

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

@Test
public void testRecordZero() {
 Timer t = new DefaultTimer(clock, NoopId.INSTANCE);
 t.record(0, TimeUnit.MILLISECONDS);
 Assertions.assertEquals(t.count(), 1L);
 Assertions.assertEquals(t.totalTime(), 0L);
}

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

@Test
public void testRecordNegative() {
 Timer timer = factory.timer(factory.createId("testRecordNegative"));
 timer.record(-42, TimeUnit.MILLISECONDS);
 Assertions.assertEquals(timer.count(), 0L);
 Assertions.assertEquals(0L, timer.totalTime());
}

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

@Test
public void testRecordCallable() throws Exception {
 Timer t = new DefaultTimer(clock, NoopId.INSTANCE);
 clock.setMonotonicTime(100L);
 int v = t.record(() -> {
  clock.setMonotonicTime(500L);
  return 42;
 });
 Assertions.assertEquals(v, 42);
 Assertions.assertEquals(t.count(), 1L);
 Assertions.assertEquals(t.totalTime(), 400L);
}