package snapshot
- Alphabetic
- Public
- All
Type Members
-
sealed
trait
ConnectionSnapshot extends AnyRef
Not for user extension
Not for user extension
- Annotations
- @DoNotInherit() @ApiMayChange()
-
trait
HideImpl extends AnyRef
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
sealed
trait
InterpreterSnapshot extends AnyRef
A snapshot of one interpreter - contains a set of logics running in the same underlying actor.
A snapshot of one interpreter - contains a set of logics running in the same underlying actor. Note that multiple interpreters may be running in the same actor (because of submaterialization)
Not for user extension
- Annotations
- @DoNotInherit() @ApiMayChange()
-
sealed
trait
LogicSnapshot extends AnyRef
Not for user extension
Not for user extension
- Annotations
- @DoNotInherit() @ApiMayChange()
-
sealed
trait
RunningInterpreter extends InterpreterSnapshot
A stream interpreter that is running/has been started
A stream interpreter that is running/has been started
- Annotations
- @DoNotInherit() @ApiMayChange()
-
sealed
trait
StreamSnapshot extends AnyRef
A snapshot of one running stream
A snapshot of one running stream
Not for user extension
- Annotations
- @DoNotInherit() @ApiMayChange()
-
sealed
trait
UninitializedInterpreter extends InterpreterSnapshot
A stream interpreter that was not yet initialized when the snapshot was taken
A stream interpreter that was not yet initialized when the snapshot was taken
Not for user extension
- Annotations
- @DoNotInherit() @ApiMayChange()
Value Members
-
object
ConnectionSnapshot
- Annotations
- @ApiMayChange()
-
object
MaterializerState
Debug utility to dump the running streams of a materializers in a structure describing the graph layout and "waits-on" relationships.
Debug utility to dump the running streams of a materializers in a structure describing the graph layout and "waits-on" relationships.
Some of the data extracted may be off unless the stream has settled, for example in when deadlocked, but the structure should be valid regardless. Extracting the information often will have an impact on the performance of the running streams.