Package org.apache.pekko.stream.snapshot

Interface RunningInterpreter

All Superinterfaces:
InterpreterSnapshot
public interface RunningInterpreter extends InterpreterSnapshot
A stream interpreter that is running/has been started

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.collection.immutable.Seq<ConnectionSnapshot>
    connections()
    Each connection between logics in the interpreter
    scala.collection.immutable.Seq<LogicSnapshot>
    logics()
    Each of the materialized graph stage logics running inside the interpreter
    int
    runningLogicsCount()
    Total number of non-stopped logics in the interpreter
    scala.collection.immutable.Seq<LogicSnapshot>
    stoppedLogics()
    All logics that has completed and is no longer executing

  • Method Details

    • 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 interface InterpreterSnapshot

    • 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