MM1 comparison UX + Sweep analytics (global & per-server) + public Sweep + guided notebook

examples/builder_input/event_injection/lb_two_servers.py

@@ -37,8 +37,8 @@
 from asyncflow.workload import RqsGenerator
 
 # Runner + Analyzer
-from asyncflow.metrics.analyzer import ResultsAnalyzer
-from asyncflow.runtime.simulation_runner import SimulationRunner
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
+from asyncflow.runner.simulation import SimulationRunner
 
 
 def build_and_run() -> ResultsAnalyzer:

examples/builder_input/event_injection/single_server.py

@@ -45,8 +45,8 @@
 from asyncflow.workload import RqsGenerator
 
 # Runner + Analyzer
-from asyncflow.runtime.simulation_runner import SimulationRunner
-from asyncflow.metrics.analyzer import ResultsAnalyzer
+from asyncflow.runner.simulation import SimulationRunner
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
 
 
 def build_and_run() -> ResultsAnalyzer:

examples/builder_input/load_balancer/two_servers.py

@@ -51,8 +51,8 @@
 from asyncflow.workload import RqsGenerator
 
 # Runner + Analyzer
-from asyncflow.runtime.simulation_runner import SimulationRunner
-from asyncflow.metrics.analyzer import ResultsAnalyzer
+from asyncflow.runner.simulation import SimulationRunner
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
 
 
 def main() -> None:

examples/builder_input/single_server/single_server.py

@@ -40,8 +40,8 @@
 from asyncflow.workload import RqsGenerator
 
 # Runner + Analyzer
-from asyncflow.runtime.simulation_runner import SimulationRunner
-from asyncflow.metrics.analyzer import ResultsAnalyzer
+from asyncflow.runner.simulation import SimulationRunner
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
 
 
 def build_and_run() -> ResultsAnalyzer:

examples/yaml_input/event_injections/heavy_single_server.py

@@ -19,8 +19,8 @@
 import matplotlib.pyplot as plt
 import simpy
 
-from asyncflow.metrics.analyzer import ResultsAnalyzer
-from asyncflow.runtime.simulation_runner import SimulationRunner
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
+from asyncflow.runner.simulation import SimulationRunner
 
 
 def main() -> None:

examples/yaml_input/event_injections/lb_two_servers.py

@@ -15,8 +15,8 @@
 import matplotlib.pyplot as plt
 import simpy
 
-from asyncflow.metrics.analyzer import ResultsAnalyzer
-from asyncflow.runtime.simulation_runner import SimulationRunner
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
+from asyncflow.runner.simulation import SimulationRunner
 
 
 def main() -> None:

examples/yaml_input/event_injections/single_server.py

@@ -19,8 +19,8 @@
 import matplotlib.pyplot as plt
 import simpy
 
-from asyncflow.metrics.analyzer import ResultsAnalyzer
-from asyncflow.runtime.simulation_runner import SimulationRunner
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
+from asyncflow.runner.simulation import SimulationRunner
 
 
 def main() -> None:

examples/yaml_input/load_balancer/two_servers.py

@@ -23,8 +23,8 @@
 import simpy
 import matplotlib.pyplot as plt
 
-from asyncflow.runtime.simulation_runner import SimulationRunner
-from asyncflow.metrics.analyzer import ResultsAnalyzer
+from asyncflow.runner.simulation import SimulationRunner
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
 
 
 def main() -> None:

examples/yaml_input/single_server/single_server.py

@@ -44,8 +44,8 @@
 import matplotlib.pyplot as plt
 
 # The only imports a user needs to run a simulation
-from asyncflow.metrics.analyzer import ResultsAnalyzer
-from asyncflow.runtime.simulation_runner import SimulationRunner
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
+from asyncflow.runner.simulation import SimulationRunner
 
 # --- Basic Logging Setup ---
 logging.basicConfig(level=logging.INFO, format="%(levelname)s: %(message)s")

src/asyncflow/__init__.py

@@ -2,6 +2,7 @@
 from __future__ import annotations
 
 from asyncflow.builder.asyncflow_builder import AsyncFlow
-from asyncflow.runtime.simulation_runner import SimulationRunner
+from asyncflow.runner.simulation import SimulationRunner
+from asyncflow.runner.sweep import Sweep
 
-__all__ = ["AsyncFlow",  "SimulationRunner"]
+__all__ = ["AsyncFlow",  "SimulationRunner", "Sweep"]

src/asyncflow/analysis/__init__.py

@@ -1,5 +1,7 @@
 """Public module exposing the results analyzer"""
 
-from asyncflow.metrics.analyzer import ResultsAnalyzer
+from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
+from asyncflow.metrics.sweep_analyzer import SweepAnalyzer
+from asyncflow.queue_theory_analysis.mm1 import MM1
 
-__all__ = ["ResultsAnalyzer"]
+__all__ = ["MM1", "ResultsAnalyzer", "SweepAnalyzer"]

src/asyncflow/config/constants.py

@@ -213,7 +213,7 @@ class SamplePeriods(float, Enum):
 
   STANDARD_TIME = 0.01 # 10 MILLISECONDS
   MINIMUM_TIME = 0.001 # 1 MILLISECOND
-  MAXIMUM_TIME = 0.1   # 100 MILLISECONDS
+  MAXIMUM_TIME = 0.5   # 500 MILLISECONDS
 
 # ======================================================================
 # CONSTANTS FOR EVENT METRICS
@@ -227,7 +227,13 @@ class EventMetricName(StrEnum):
 
   # Mandatory
   RQS_CLOCK = "rqs_clock" # useful to collect starting and finishing time of rqs
-  # Not mandatory
+  RQS_SERVER_CLOCK = "rqs_server_clock" #useful for latency and throughput of the server
+  SERVICE_TIME = "service_time"
+  IO_TIME = "io_time"
+  WAITING_TIME = "waiting_time"
+
+
+  # Not mandatory now not implemented
   LLM_COST = "llm_cost"
 
 
@@ -240,6 +246,14 @@ class AggregatedMetricName(StrEnum):
 
   LATENCY_STATS = "latency_stats"
   THROUGHPUT = "throughput_rps"
+  SERVER_THROUGHPUT = "server_throughput"
+  SERVER_LATENCY_STATS = "server_latency_stats"
+  SERVICE_TIME_STATS = "service_time_stats"
+  IO_TIME_STATS = "io_time_stats"
+  WAITING_TIME_STATS = "waiting_time_stats"
+  UTILIZATION = "utilization"
+
+  # now not implemented
   LLM_STATS = "llm_stats"
 
 # ======================================================================

src/asyncflow/metrics/client.py

@@ -9,7 +9,9 @@
 class RqsClock(NamedTuple):
     """
     structure to register time of generation and
-    time of elaboration for each request
+    time of elaboration for each request during
+    all the cycle of elaboration starting and ending
+    with the client
     """
 
     start: float

src/asyncflow/metrics/server.py

@@ -1,9 +1,9 @@
 """
 initialization of the structure to gather the sampled metrics
-for the server of the system
+and event metrics for the server of the system
 """
-
 from collections.abc import Iterable
+from dataclasses import dataclass
 
 from asyncflow.config.constants import SampledMetricName
 
@@ -32,3 +32,14 @@ def build_server_metrics(
         metric: [] for metric in SERVER_METRICS
         if metric in enabled_sample_metrics
     }
+
+# For the client we choosed a named tuple, here we prefer
+# a dataclass because we need mutability since start and
+# are updated in two different steps
+@dataclass
+class ServerClock:
+    """Server-side request timing: start + finish."""
+
+    start: float
+    finish: float | None = None
+