trait BacklogStatusTelemetry extends AnyRef
Observing backlog status. Supported as an extension of Telemetry. Implementing this trait allows tracking whether projections are keeping up with their source.
- Annotations
- @InternalStableApi()
- Source
- BacklogStatus.scala
- Alphabetic
- By Inheritance
- BacklogStatusTelemetry
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def backlogStatusCheckIntervalSeconds(): Int
Define how frequently backlog status should be checked.
Define how frequently backlog status should be checked. Return 0 to disable backlog status checking.
- returns
backlog status check interval in seconds
- abstract def reportTimestampBacklogStatus(latestSourceTimestamp: Long, latestOffsetTimestamp: Long): Unit
Observe a reported backlog status, based on the latest source and offset timestamps.
Observe a reported backlog status, based on the latest source and offset timestamps.
Timestamps are in milliseconds since epoch. Timestamps will be 0 when not present.
The offset timestamp may be ahead of the source timestamp at the time of checking. If only the source timestamp is present, then the projection has not yet processed the first envelope. If only the offset timestamp is present, then the source may have been cleaned and the projection is up-to-date. If neither timestamp is present, then there has been no activity and the projection is up-to-date.
Called periodically, based on backlogStatusCheckIntervalSeconds, with the backlog status of the projection.
- latestSourceTimestamp
latest millisecond-based timestamp for the projection source (0 if not present)
- latestOffsetTimestamp
latest millisecond-based timestamp for projection offsets (0 if not present)
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
- 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 eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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()
- 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])