use TIPS_INGRESS_WRITER_ name

Author: wlawt

.env.example

@@ -38,8 +38,8 @@ TIPS_UI_S3_ACCESS_KEY_ID=minioadmin
 TIPS_UI_S3_SECRET_ACCESS_KEY=minioadmin
 
 # Ingress Writer
-TIPS_WRITER_DATABASE_URL=postgresql://postgres:postgres@localhost:5432/postgres
-TIPS_WRITER_KAFKA_BROKERS=localhost:9092
-TIPS_WRITER_KAFKA_TOPIC=tips-ingress-rpc
-TIPS_WRITER_KAFKA_GROUP_ID=local-writer
-TIPS_WRITER_LOG_LEVEL=info
+TIPS_INGRESS_WRITER_DATABASE_URL=postgresql://postgres:postgres@localhost:5432/postgres
+TIPS_INGRESS_WRITER_KAFKA_BROKERS=localhost:9092
+TIPS_INGRESS_WRITER_KAFKA_TOPIC=tips-ingress-rpc
+TIPS_INGRESS_WRITER_KAFKA_GROUP_ID=local-writer
+TIPS_INGRESS_WRITER_LOG_LEVEL=info

README.md

@@ -19,13 +19,13 @@ Event streaming and archival system that:
 - Archives bundle history to S3 for long-term storage
 - See [S3 Storage Format](docs/AUDIT_S3_FORMAT.md) for data structure details
 
-### 🔌 Ingress (`crates/ingress`)
+### 🔌 Ingress RPC (`crates/ingress-rpc`)
 The main entry point that provides a JSON-RPC API for receiving transactions and bundles.
 
 ### 🔨 Maintenance (`crates/maintenance`)
 A service that maintains the health of the TIPS DataStore, by removing stale or included bundles.
 
-### ✍️ Writer (`crates/writer`)
+### ✍️ Ingress Writer (`crates/ingress-writer`)
 A service that consumes bundles from Kafka and persists them to the datastore.
 
 ### 🖥️ UI (`ui`)

crates/ingress-writer/src/main.rs

@@ -17,23 +17,23 @@ use uuid::Uuid;
 #[derive(Parser)]
 #[command(author, version, about, long_about = None)]
 struct Args {
-    #[arg(long, env = "TIPS_WRITER_DATABASE_URL")]
+    #[arg(long, env = "TIPS_INGRESS_WRITER_DATABASE_URL")]
     database_url: String,
 
-    #[arg(long, env = "TIPS_WRITER_KAFKA_BROKERS")]
+    #[arg(long, env = "TIPS_INGRESS_WRITER_KAFKA_BROKERS")]
     kafka_brokers: String,
 
     #[arg(
         long,
-        env = "TIPS_WRITER_KAFKA_TOPIC",
+        env = "TIPS_INGRESS_WRITER_KAFKA_TOPIC",
         default_value = "tips-ingress-rpc"
     )]
     kafka_topic: String,
 
-    #[arg(long, env = "TIPS_WRITER_KAFKA_GROUP_ID")]
+    #[arg(long, env = "TIPS_INGRESS_WRITER_KAFKA_GROUP_ID")]
     kafka_group_id: String,
 
-    #[arg(long, env = "TIPS_WRITER_LOG_LEVEL", default_value = "info")]
+    #[arg(long, env = "TIPS_INGRESS_WRITER_LOG_LEVEL", default_value = "info")]
     log_level: String,
 }