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
- All
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( ... ) @native() @IntrinsicCandidate()
-
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: Any): Boolean
- Definition Classes
- AnyRef → Any
- def get(name: String, remove: Boolean = true): StopwatchTimer
- def getAll(): Map[String, StopwatchTimer]
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- 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
- @native() @IntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- 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( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
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
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.