Stopwatch

Stopwatch provides a timer that follows asynchronous flows. A Stopwatch can be started in one actor (or Akka Stream operator, or Scala Future) and then flow through to others via message sends or asynchronous callbacks. You can use it to gather time metrics for “hot paths” within flows that cross multiple asynchronous boundaries. Intervals are marked programmatically with start and stop points within the application using an Akka extension Stopwatch API.

If you need to measure a synchronous block of code in nanoseconds use the Custom metric timer utility instead.

Enabling Stopwatch

Stopwatch is disabled by default, and needs to be enabled

copycinnamon.stopwatch {
  enabled = true
}

Stopwatch API

Time intervals are marked programmatically within your code using the Stopwatch API. It’s possible to have multiple Stopwatches active in the same message flow.

Accessing Stopwatch

The import for Stopwatch is:

Scala

copyimport com.lightbend.cinnamon.akka.Stopwatch

Java

copyimport com.lightbend.cinnamon.akka.Stopwatch;

Stopwatch is an Akka extension and is accessed via the actor system. Within an actor, you can access the system via the context.

Scala

copyStopwatch(context.system)

Java

copyStopwatch.get(getContext().system());

Accessing Stopwatch from Akka Typed

For Akka Typed, there is a separate extension that can be used with typed actor systems or actor contexts.

First add the Cinnamon Akka Typed module dependency to your build file:

sbt

copylibraryDependencies += Cinnamon.library.cinnamonAkkaTyped

Maven

copy<dependency>
  <groupId>com.lightbend.cinnamon</groupId>
  <artifactId>cinnamon-akka-typed_2.13</artifactId>
  <version>2.20.4</version>
</dependency>

Gradle

copydependencies {
  implementation group: 'com.lightbend.cinnamon', name: 'cinnamon-akka-typed_2.13', version: '2.20.4'
}

Then import the typed extension for Stopwatch:

Scala

copyimport com.lightbend.cinnamon.akka.typed.Stopwatch

Java

copyimport com.lightbend.cinnamon.akka.typed.Stopwatch;

Stopwatch start

Use the start method to name a Stopwatch, and to wrap message sends that will be included in the flow of the time interval measurement.

Scala

copyStopwatch(context.system).start("my-stopwatch-name") {
  actor ! "message"
}

Java

copyStopwatch.get(getContext().system())
    .start("my-stopwatch-name", () -> actor.tell("message", getSelf()));

Stopwatch stop

Use the stop method to stop measuring elapsed time, marking the end of the interval. This can be at any point in the message flow that originates at the start marker. The start and stop names for the Stopwatch must be the same.

Scala

copyStopwatch(context.system).stop("my-stopwatch-name")

Java

copyStopwatch.get(getContext().system()).stop("my-stopwatch-name");

Time interval metrics will now be reported for the specified Stopwatch.

Stopwatch example

Here’s an example of starting a Stopwatch in ActorA and then stopping the Stopwatch in ActorB, after some work has been completed:

copyimport akka.actor.{ Actor, Props }
import com.lightbend.cinnamon.akka.Stopwatch

class ActorA extends Actor {
  val actorB = context.actorOf(Props(new ActorB), "b")
  def receive = {
    case "Begin" =>
      Stopwatch(context.system).start("my-stopwatch-name") {
        actorB.forward("DoWork")
      }
  }
}

class ActorB extends Actor {
  def receive = {
    case "DoWork" =>
      doSomeWork()
      Stopwatch(context.system).stop("my-stopwatch-name")
  }

  def doSomeWork(): Unit = ???
}

A metric recorder will be used to measure the distribution of interval times between the start and stop points.

Active time

A stopwatch records the total elapsed time between the start and stop endpoints of a flow, and can also record the active time during the flow—the time spent actively in actor message processing, stream operators, or future callbacks, as compared with the time in actor mailboxes or waiting to be scheduled. Active time measurements are on by default, and can be disabled using this setting:

copycinnamon.stopwatch {
  active-time = off
}

Remote Stopwatch

A Stopwatch can flow across remote actors, and can start and stop on different remote nodes. Stopwatches started using the Stopwatch API will be automatically transferred across remote message sends.

Stopwatch and Akka Streams

The Stopwatch API can be used with Akka Streams.

Because subsequent stream operations cannot be wrapped, use the activate method to start stopwatches within the scope of an Akka Stream operator, rather than the start method. For example:

copyval flow = source
  .map { value =>
    Stopwatch(system).activate("my-stopwatch-name")
    transform(value)
  }
  .mapAsync(4)(asyncTransform)
  .map { value =>
    val result = transform(value)
    Stopwatch(system).stop("my-stopwatch-name")
    result
  }

Stopwatch and Futures

The Stopwatch API can be used with Scala Futures or Java CompletableFutures.

For example, when using the ask pattern, the query to the actor can be wrapped in a Stopwatch start:

Scala

copyval future = Stopwatch(system).start("my-stopwatch-name") {
  actor ? message
}

Java

copyCompletionStage future =
    Stopwatch.get(system)
        .start("my-stopwatch-name", () -> Patterns.ask(actor, message, timeout));

And then the Stopwatch can be stopped when the Future holding the response is completed:

Scala

copyfuture.onComplete { _ =>
  Stopwatch(system).stop("my-stopwatch-name")
}

Java

copyCompletionStage completed =
    future.thenRun(() -> Stopwatch.get(system).stop("my-stopwatch-name"));

Stopwatch and Akka Scheduler

The Stopwatch API can be used with Akka Scheduler.

For example, when using scheduleOnce to defer sending a message to an actor, it can be wrapped in a Stopwatch start:

Scala

copyStopwatch(system).start("my-stopwatch-name") {
  system.scheduler.scheduleOnce(delay) {
    actor ! "DoWork"
  }
}

Java

copyStopwatch.get(system)
    .start(
        "my-stopwatch-name",
        () ->
            system
                .getScheduler()
                .scheduleOnce(delay, () -> actor.tell("DoWork", sender), system.dispatcher()));

And then the Stopwatch can be stopped when the message is received and some work is done:

Scala

copyclass WorkerActor extends Actor {
  override def receive: Receive = {
    case "DoWork" =>
      doSomeWork()
      Stopwatch(system).stop("my-stopwatch-name")
      sender() ! "Done"
  }
  def doSomeWork(): Unit = {
    // do some work
  }
}

Java

copystatic class WorkerActor extends AbstractActor {

  @Override
  public Receive createReceive() {
    return ReceiveBuilder.create()
        .matchEquals(
            "DoWork",
            msg -> {
              doSomeWork();
              Stopwatch.get(getContext().getSystem()).stop("my-stopwatch-name");
              sender().tell("Done", getSelf());
            })
        .build();
  }

  private void doSomeWork() {
    // do some work
  }

}

Stopwatch interval thresholds

Time interval thresholds can be configured for Stopwatches. An event will be reported whenever the given threshold is exceeded for a recorded interval.

Interval thresholds for Stopwatches are configured under cinnamon.stopwatch.thresholds keyed by Stopwatch name.

To generate threshold events if the “hot path” in the example above takes longer than 5 seconds, we can do so by defining the following setting:

copycinnamon.stopwatch {
  thresholds {
    "my-stopwatch-name" = 5s
  }
}

Stopwatch custom Recorder

It’s possible to configure a Stopwatch to use a custom recorder:

copycinnamon.akka.meta.descriptor.stopwatch.stopwatch-time {
  hints = [ custom-recorder ]
}

cinnamon.akka.meta.descriptor.stopwatch.stopwatch-active-time {
  hints = [ custom-recorder ]
}

This allows you to configure the Stopwatch recorder depending on the backend:

• In Coda Hale it can be configured to use a custom histogram. See the Coda Hale Metric hints

• In Prometheus it can be configured to use a custom Summary or even a Histogram instead of a Summary. The last is useful when you need to aggregate metrics because a Summary is in general not aggregatable. See the Prometheus Histogram duration buckets.