abstract class Timekeeper extends StopwatchBlocks
Default implementation of a Stopwatch. Subclasses need to extend this to transport the stopwatches across async boundaries and get notified when a stopwatch is stopped.
- Alphabetic
- By Inheritance
- Timekeeper
- StopwatchBlocks
- Stopwatch
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Timekeeper(recordActiveTime: Boolean, isEnabled: Boolean)
Abstract Value Members
- abstract def stopped(name: String, elapsed: Long, active: Long): Unit
INTERNAL API
INTERNAL API
A stopwatch stopped.
- name
the name of the stopwatch
- elapsed
the recorded time for this stopwatch in nanoseconds
- active
the recorded active time for this stopwatch in nanoseconds
- Attributes
- protected
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def activate(name: String): Unit
Start a stopwatch where subsequent operations in the current asynchronous scope will propagate the stopwatch; such as within the scope of an Akka Stream operator.
Start a stopwatch where subsequent operations in the current asynchronous scope will propagate the stopwatch; such as within the scope of an Akka Stream operator. The matching stopwatch stop operation will create a user defined time interval. A user defined stopwatch may start and stop in any location in the asynchronous flow, i.e. it may span over several actors, futures, or streams.
- name
name of the stopwatch
- Definition Classes
- StopwatchBlocks → Stopwatch
- def add(name: String, startTime: Long, sampling: Long, recordActiveTime: Boolean): Unit
- def add(name: String, startTime: Long, recordActiveTime: Boolean): Unit
- def add(name: String, startTime: Long, sampling: Long): Unit
- def add(name: String, startTime: Long): Unit
- def add(name: String): Unit
- Definition Classes
- Timekeeper → StopwatchBlocks
- def addEmpty(name: String): Unit
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def data: Map[String, StopwatchTimer]
- Attributes
- protected
- final def data_=(value: Map[String, StopwatchTimer]): Unit
- Attributes
- protected
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def get(name: String, remove: Boolean = true): StopwatchTimer
- def getAll(): Map[String, StopwatchTimer]
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def isActive(name: String): Boolean
- val isEnabled: Boolean
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def mergeStopwatches(first: Stopwatches, second: Stopwatches): Stopwatches
INTERNAL API
INTERNAL API
Merge suspended stopwatches for context joining.
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- val recordActiveTime: Boolean
- val remote: RemoteTimekeeper
- def remove(name: String): Unit
- Definition Classes
- Timekeeper → StopwatchBlocks
- def resumeEmptyStopwatches(): Unit
INTERNAL API
INTERNAL API
Resume empty stopwatches after an async boundary jump.
- def resumeStopwatches(suspended: Stopwatches, resumeTime: Long): Unit
INTERNAL API
INTERNAL API
Resume suspended stopwatches after an async boundary jump.
- def resumeStopwatches(suspended: Stopwatches): Unit
INTERNAL API
INTERNAL API
Resume suspended stopwatches after an async boundary jump.
- def start(name: String, runnable: Runnable): Unit
Start a stopwatch where the operations in the runnable will propagate the stopwatch.
Start a stopwatch where the operations in the runnable will propagate the stopwatch. The matching stopwatch stop operation will create a user defined time interval. A user defined stopwatch may start and stop in any location in the asynchronous flow, i.e. it may span over several actors, futures, or streams.
- name
name of the stopwatch
- runnable
runnable to run within the stopwatch start scope
- Definition Classes
- StopwatchBlocks → Stopwatch
- def start[T](name: String)(body: => T): T
Start a stopwatch where the operations in the block will propagate the stopwatch.
Start a stopwatch where the operations in the block will propagate the stopwatch. The matching stopwatch stop operation will create a user defined time interval. A user defined stopwatch may start and stop in any location in the asynchronous flow, i.e. it may span over several actors, futures, or streams.
- name
name of the stopwatch
- returns
result of block
- Definition Classes
- StopwatchBlocks → Stopwatch
- def startTime(name: String, remove: Boolean = true): Long
- def stop(name: String, stopTime: Long): Unit
- def stop(name: String): Unit
Stop an active stopwatch with the specified name creating a user defined time interval.
Stop an active stopwatch with the specified name creating a user defined time interval. A user defined stopwatch may start and stop in any location in the asynchronous flow, i.e. it may span over several actors, futures, or streams.
- name
name of the stopwatch to stop
- Definition Classes
- Timekeeper → Stopwatch
- def stopped(name: String, stopwatch: StopwatchTimer, stopTime: Long): Unit
INTERNAL API
INTERNAL API
A stopwatch stopped.
- Attributes
- protected
- def suspendStopwatches(suspendTime: Long): Stopwatches
INTERNAL API
INTERNAL API
Suspend the active stopwatches to transport them across an async boundary.
- def suspendStopwatches: Stopwatches
INTERNAL API
INTERNAL API
Suspend the active stopwatches to transport them across an async boundary.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def wrap(name: String, runnable: Runnable): Unit
Run the runnable within a stopwatch start and end, to create a user defined time interval.
Run the runnable within a stopwatch start and end, to create a user defined time interval.
- name
name of the stopwatch
- runnable
runnable to run within the time interval
- Definition Classes
- StopwatchBlocks → Stopwatch
- def wrap[T](name: String)(body: => T): T
Run the block within a stopwatch start and stop, to create a user defined time interval.
Run the block within a stopwatch start and stop, to create a user defined time interval.
- name
name of the stopwatch
- returns
result of block
- Definition Classes
- StopwatchBlocks → Stopwatch
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
This is the public API for Cinnamon.
The com.lightbend.cinnamon package contains the public Cinnamon API.
See the complete list of Cinnamon packages on the right.
Cinnamon Events and Metrics
For the custom events API see
CinnamonEvents
.For the custom metrics API see
CinnamonMetrics
.Stopwatch
For the Stopwatch API see
Stopwatch
.Coda Hale Metrics
For creating custom Coda Hale Metrics reporters see the com.lightbend.cinnamon.chmetrics.reporter package.