New Api RqsGenerator ---> ArrivalsGenerator (#27)

* changing api per ArrivalsGenerator and implementing distrib for ArrivalRuntime

* Reafctoring API Arrival generator, tests integrations now working

* Api Arrival generator migration complete with tests

Author: GioeleB00

asyncflow_queue_limit/asyncflow_mm1.ipynb

@@ -20,33 +20,33 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 3,
+   "execution_count": null,
    "id": "b8a94d93",
    "metadata": {},
    "outputs": [],
    "source": [
     "import sys, importlib\n",
     "\n",
-    "# 1) Svuota tutto ciò che inizia con 'asyncflow' da sys.modules\n",
+    "\n",
     "for m in list(sys.modules):\n",
     "    if m.startswith(\"asyncflow\"):\n",
     "        del sys.modules[m]\n",
     "\n",
-    "# 2) Re-importa SOLO le facciate pubbliche (niente import profondi)\n",
+    "\n",
     "from asyncflow import AsyncFlow, SimulationRunner\n",
     "from asyncflow.analysis import MMc, ResultsAnalyzer\n",
     "from asyncflow.components import (\n",
-    "    Client, Server, Edge, Endpoint, LoadBalancer\n",
+    "    Client, Server, Edge, Endpoint, LoadBalancer, ArrivalsGenerator\n",
     ")\n",
     "from asyncflow.settings import SimulationSettings\n",
-    "from asyncflow.workload import RqsGenerator\n",
+    "\n",
     "import simpy\n",
     "\n"
    ]
   },
   {
    "cell_type": "code",
-   "execution_count": 4,
+   "execution_count": null,
    "id": "d1b7ad7d",
    "metadata": {},
    "outputs": [
@@ -64,10 +64,10 @@
     "\n",
     "# Public AsyncFlow API\n",
     "from asyncflow import AsyncFlow, SimulationRunner, Sweep\n",
-    "from asyncflow.components import Client, Server, Edge, Endpoint, LoadBalancer\n",
+    "from asyncflow.components import Client, Server, Edge, Endpoint, LoadBalancer, ArrivalsGenerator\n",
     "from asyncflow.settings import SimulationSettings\n",
-    "from asyncflow.workload import RqsGenerator\n",
-    "from asyncflow.analysis import MM1, ResultsAnalyzer, SweepAnalyzer, MMc\n",
+    "from asyncflow.analysis import  ResultsAnalyzer, SweepAnalyzer, MMc\n",
+    "from asyncflow.enums import Distribution\n",
     "\n",
     "print(\"Imports OK.\")"
    ]
@@ -128,17 +128,16 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 5,
+   "execution_count": null,
    "id": "ba93587a",
    "metadata": {},
    "outputs": [],
    "source": [
     "def build_payload():\n",
-    "    generator = RqsGenerator(\n",
+    "    generator = ArrivalsGenerator(\n",
     "        id=\"rqs-1\",\n",
-    "        avg_active_users={\"mean\": 120},\n",
-    "        avg_request_per_minute_per_user={\"mean\": 20},\n",
-    "        user_sampling_window=60,\n",
+    "        lambda_rps=30,\n",
+    "        model=Distribution.POISSON\n",
     "    )\n",
     "\n",
     "    client = Client(id=\"client-1\")\n",
@@ -189,7 +188,7 @@
     "\n",
     "    payload = (\n",
     "        AsyncFlow()\n",
-    "        .add_generator(generator)\n",
+    "        .add_arrivals_generator(generator)\n",
     "        .add_client(client)\n",
     "        .add_servers(srv1, srv2)\n",
     "        .add_load_balancer(lb)\n",