Interface RunningInterpreter

    • Method Detail

      • connections

        scala.collection.immutable.Seq<ConnectionSnapshot> connections()
        Each connection between logics in the interpreter that is not closed on both ends yet
      • logics

        scala.collection.immutable.Seq<LogicSnapshot> logics()
        Each of the materialized graph stage logics running inside the interpreter. Logics that already stopped are released by the interpreter and show up as a placeholder without name or attributes.
        Specified by:
        logics in interface InterpreterSnapshot
      • runningLogicsCount

        int runningLogicsCount()
        Total number of non-stopped logics in the interpreter
      • stoppedLogics

        scala.collection.immutable.Seq<LogicSnapshot> stoppedLogics()
        All logics that have completed and are no longer executing. Released by the interpreter, so they carry neither name nor attributes, see logics()