Added Cargo.lock

Author: milindsrivastava1997

Cargo.lock

@@ -14,7 +14,7 @@ This quickstart simulates a typical monitoring deployment with components you mi
 
 Then it adds ASAPQuery's components on top:
 - **Query Engine** - Prometheus-compatible API with sketch-based acceleration
-- **[Arroyo](https://github.com/ProjectASAP/arroyo) + asap-sketch-ingest** - Streaming engine with pipelines configured for building sketches
+- **[Arroyo](https://github.com/ProjectASAP/arroyo) + asap-summary-ingest** - Streaming engine with pipelines configured for building sketches
 - **Kafka** - Message broker for streaming data from Arroyo to the Query Engine
 - **asap-planner** - Automatically configures sketches from PromQL queries
 

asap-quickstart/README.md

@@ -1,4 +1,4 @@
-# SketchDB Configuration for Pattern-based Demo
+# ASAP Configuration for Pattern-based Demo
 # Uses deterministic time-based patterns for visual comparison
 
 query_groups:

asap-quickstart/config/controller-config.yaml

@@ -137,7 +137,7 @@ services:
       timeout: 5s
       retries: 5
     depends_on:
-      asap-sketch-ingest:
+      asap-summary-ingest:
         condition: service_completed_successfully
     restart: no
 
@@ -187,10 +187,10 @@ services:
       - asap-planner-output:/asap-planner-output
     restart: "no"
 
-  asap-sketch-ingest:
+  asap-summary-ingest:
     image: ghcr.io/projectasap/asap-arroyosketch:v0.1.0
-    container_name: asap-sketch-ingest
-    hostname: asap-sketch-ingest
+    container_name: asap-summary-ingest
+    hostname: asap-summary-ingest
     networks:
       - asap-network
     command:
@@ -203,12 +203,12 @@ services:
       - "--output_kafka_topic=flink_output"
       - "--output_format=json"
       - "--pipeline_name=asap-demo"
-      - "--output_dir=/asap-sketch-ingest-output"
+      - "--output_dir=/asap-summary-ingest-output"
       - "--arroyo_url=http://arroyo:5115/api/v1"
       - "--bootstrap_servers=kafka:9092"
     volumes:
       - asap-planner-output:/asap-planner-output:ro
-      - ./output/asap-sketch-ingest:/asap-sketch-ingest-output
+      - ./output/asap-summary-ingest:/asap-summary-ingest-output
     depends_on:
       asap-planner:
         condition: service_completed_successfully
@@ -251,7 +251,7 @@ services:
       - "--decompress-json"
       - "--forward-unsupported-queries"
     depends_on:
-      asap-sketch-ingest:
+      asap-summary-ingest:
         condition: service_completed_successfully
       kafka:
         condition: service_healthy

asap-quickstart/docker-compose.yml

@@ -583,7 +583,7 @@ pub async fn generate_arroyosketch_compose(
     let code_dir = project_root.to_string_lossy();
 
     // Paths
-    let arroyosketch_dir = format!("{}/asap-sketch-ingest", code_dir);
+    let arroyosketch_dir = format!("{}/asap-summary-ingest", code_dir);
     let template_path = format!("{}/arroyosketch-cli-compose.yml.j2", arroyosketch_dir);
     let helper_script = format!("{}/asap-tools/experiments/generate_arroyosketch_compose.py", code_dir);
     let compose_output_path = format!("{}/asap-tools/docker/generated_compose_files/arroyosketch-compose.yml", code_dir);

asap-tools/asap-cli/src/docker_util.rs

@@ -9,7 +9,7 @@ asap-common
 asap-query-engine
 asap-planner
 #prometheus-kafka-adapter
-asap-sketch-ingest
+asap-summary-ingest
 asap-quickstart
 asap-tools/data-sources/prometheus-exporters
 asap-tools/queriers/prometheus-client

asap-tools/components.conf

@@ -8,7 +8,7 @@ services:
     ports:
       - "5115:5115"
     volumes:
-      - ../../asap-sketch-ingest/config.yaml:/config.yaml
+      - ../../asap-summary-ingest/config.yaml:/config.yaml
     command: ["--config", "/config.yaml", "cluster"]
     environment:
       - ARROYO__API__RUN_HTTP_PORT=5115

asap-tools/docker/arroyo-cli-compose.yml

@@ -66,7 +66,7 @@ The script executes these phases in order:
   - asap-query-engine (Rust binary + Docker image)
   - asap-planner (Docker image)
   - Arroyo (Node.js frontend + Rust binary + Docker image)
-  - asap-sketch-ingest (Python scripts)
+  - asap-summary-ingest (Python scripts)
   - asap-tools/queriers/prometheus-client, asap-tools/data-sources/prometheus-exporters, asap-tools/execution-utilities, asap-tools/prometheus-benchmark
 
 ### Directory Structure Created
@@ -77,7 +77,7 @@ The script executes these phases in order:
 │   ├── asap-tools/
 │   ├── asap-query-engine/
 │   ├── asap-planner/
-│   ├── asap-sketch-ingest/
+│   ├── asap-summary-ingest/
 │   ├── arroyo/
 │   ├── asap-common/
 │   └── asap-tools/prometheus-benchmark/
@@ -148,7 +148,7 @@ asap-common
 sketchlib-rust
 asap-query-engine
 asap-planner
-asap-sketch-ingest
+asap-summary-ingest
 asap-quickstart
 asap-tools/data-sources/prometheus-exporters
 asap-tools/queriers/prometheus-client
@@ -296,11 +296,11 @@ cargo install refinery_cli
 - Web console (Node.js/React frontend)
 - Controller and workers (Rust binaries)
 
-#### 5. asap-sketch-ingest
-**What:** Python scripts for deploying asap-sketch-ingest pipelines
+#### 5. asap-summary-ingest
+**What:** Python scripts for deploying asap-summary-ingest pipelines
 **Build Process:**
 ```bash
-cd asap-sketch-ingest
+cd asap-summary-ingest
 pip install -r requirements.txt  # jinja2 for templating
 ```
 **Deployment:** Python scripts, no Docker image

asap-tools/docs/deployment.md

@@ -94,7 +94,7 @@ Kafka has three places where message size limits need to be configured (see [PR
 2. **Kafka topic configuration** (`asap-tools/experiments/experiment_utils/services/kafka.py`):
    - Update `max.message.bytes` in the topic creation command
 
-3. **Arroyo connection profile** (`asap-sketch-ingest/templates/json/connection_profile.j2`):
+3. **Arroyo connection profile** (`asap-summary-ingest/templates/json/connection_profile.j2`):
    - Add connection properties with `message.max.bytes` and `batch.size`
 
 **Example values:**

asap-tools/docs/troubleshooting.md

@@ -66,7 +66,7 @@ def stop_all_jobs(self) -> None:
         """Stop all running Arroyo jobs."""
         cmd = "python3 delete_pipeline.py --all_pipelines"
         cmd_dir = os.path.join(
-            self.provider.get_home_dir(), "code", "asap-sketch-ingest"
+            self.provider.get_home_dir(), "code", "asap-summary-ingest"
         )
         self.provider.execute_command(
             node_idx=self.node_offset,
@@ -160,7 +160,7 @@ def run_arroyosketch(
             if enable_optimized_remote_write:
                 cmd += " --prometheus_remote_write_source optimized"
         cmd_dir = os.path.join(
-            constants.CLOUDLAB_HOME_DIR, "code", "asap-sketch-ingest"
+            constants.CLOUDLAB_HOME_DIR, "code", "asap-summary-ingest"
         )
 
         if avoid_long_ssh:
@@ -216,7 +216,7 @@ def stop_arroyosketch(self, pipeline_id: str) -> None:
         """
         cmd = "python3 delete_pipeline.py --pipeline_id {}".format(pipeline_id)
         cmd_dir = os.path.join(
-            constants.CLOUDLAB_HOME_DIR, "code", "asap-sketch-ingest"
+            constants.CLOUDLAB_HOME_DIR, "code", "asap-summary-ingest"
         )
         self.provider.execute_command(
             node_idx=self.node_offset,
@@ -309,7 +309,7 @@ def is_healthy(self) -> bool:
     def _start_bare_metal(self, experiment_output_dir: str, **kwargs) -> None:
         """Start Arroyo cluster using bare metal deployment (original implementation)."""
         arroyo_config_file_path = os.path.join(
-            constants.CLOUDLAB_HOME_DIR, "code", "asap-sketch-ingest", "config.yaml"
+            constants.CLOUDLAB_HOME_DIR, "code", "asap-summary-ingest", "config.yaml"
         )
         arroyo_bin_path = os.path.join(
             constants.CLOUDLAB_HOME_DIR, "code", "arroyo", "target", "release", "arroyo"
@@ -332,7 +332,7 @@ def _start_bare_metal(self, experiment_output_dir: str, **kwargs) -> None:
     def _start_containerized(self, experiment_output_dir: str, **kwargs) -> None:
         """Start Arroyo cluster using Docker container deployment."""
         arroyo_config_file_path = os.path.join(
-            constants.CLOUDLAB_HOME_DIR, "code", "asap-sketch-ingest", "config.yaml"
+            constants.CLOUDLAB_HOME_DIR, "code", "asap-summary-ingest", "config.yaml"
         )
         arroyo_output_file = os.path.join(experiment_output_dir, "arroyo_cluster.out")