Package akka.stream.snapshot
Interface RunningInterpreter
-
- All Superinterfaces:
InterpreterSnapshot
public interface RunningInterpreter extends InterpreterSnapshot
A stream interpreter that is running/has been started
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description scala.collection.immutable.Seq<ConnectionSnapshot>
connections()
Each connection between logics in the interpreterscala.collection.immutable.Seq<LogicSnapshot>
logics()
Each of the materialized graph stage logics running inside the interpreterint
runningLogicsCount()
Total number of non-stopped logics in the interpreterscala.collection.immutable.Seq<LogicSnapshot>
stoppedLogics()
All logics that has completed and is no longer executing
-
-
-
Method Detail
-
connections
scala.collection.immutable.Seq<ConnectionSnapshot> connections()
Each connection between logics in the interpreter
-
logics
scala.collection.immutable.Seq<LogicSnapshot> logics()
Each of the materialized graph stage logics running inside the interpreter- Specified by:
logics
in interfaceInterpreterSnapshot
-
runningLogicsCount
int runningLogicsCount()
Total number of non-stopped logics in the interpreter
-
stoppedLogics
scala.collection.immutable.Seq<LogicSnapshot> stoppedLogics()
All logics that has completed and is no longer executing
-
-