com.worxbend.cobalt.ConsumerSupervisor.Snapshot
See theSnapshot companion object
final case class Snapshot(state: RunState, since: Instant, generation: Int, restarts: Int, lastError: Option[String], handle: Option[ConsumerHandle])
The supervisor's whole mutable state, as one immutable value behind one reference.
One AtomicReference to a case class rather than five references: a reader of ConsumerSupervisor.status gets a consistent view, where five separate atomics would let it observe state = running alongside the previous generation's error.
Attributes
- Companion
- object
- Graph
-
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass Objecttrait Matchableclass Any
Members list
In this article