Update documentation: remove airliner references

- Update MICROSERVICES_ARCHITECTURE.md: 'Airliner Administration' → 'EventStreamMonitor'
- Update all endpoint URLs in documentation to use eventstreammonitor
- Update MICROSERVICES_SETUP.md endpoint examples
- Update LOAD_TEST_RESULTS.md and LOG_MONITORING_QUICKSTART.md endpoints
- Update docs/redis_integration.md endpoint examples

Author: Kamal Sai Devarapalli

LOAD_TEST_RESULTS.md

@@ -18,7 +18,7 @@
 ## Performance Results
 
 ### User Management Service
-**Endpoint:** `/api/v1/airliner/getUser/1000`
+**Endpoint:** `/api/v1/eventstreammonitor/users/1000`
 
 | Metric | Value |
 |--------|-------|

LOG_MONITORING_QUICKSTART.md

@@ -1 +1 @@
-# Real-Time Log Monitoring - Quick Start ## Quick Start ### 1. Start Services ```bash # Start all services including log monitor docker-compose up -d # Verify log monitor is running docker-compose ps logmonitor-service ``` ### 2. Access Dashboard Open your browser: **http://localhost:5004** The dashboard will automatically: - Show error statistics - Display recent errors - Auto-refresh every 5 seconds ### 3. Generate Test Errors ```bash # Trigger an error in a service curl -X POST http://localhost:5001/api/v1/airliner/registerUser \ -H "Content-Type: application/json" \ -d '{"invalid": "data"}' # Check dashboard - error should appear within 5 seconds ``` ## API Endpoints ### Get All Errors ```bash curl http://localhost:5004/api/v1/logs/errors?limit=50 ``` ### Get Statistics ```bash curl http://localhost:5004/api/v1/logs/stats ``` ### Get Errors by Service ```bash curl http://localhost:5004/api/v1/logs/errors/usermanagement ``` ## Verify Kafka Topics ```bash # List topics docker-compose exec kafka kafka-topics --list --bootstrap-server localhost:9092 # Should see: # - application-logs # - application-logs-errors # Consume logs docker-compose exec kafka kafka-console-consumer \ --bootstrap-server localhost:9092 \ --topic application-logs-errors \ --from-beginning ``` ## Grafana Setup 1. Install Grafana (or use Docker): ```bash docker run -d -p 3000:3000 grafana/grafana ``` 2. Add Data Source: - Type: JSON API - URL: http://localhost:5004/api/v1/grafana - Access: Server 3. Create Dashboard: - Add panel with query: `error_count` - Add panel with query: `error_by_service` - Add panel with query: `error_by_level` ## Features - Real-time error monitoring - Multi-service log collection - Automatic error filtering - Beautiful dashboard - Grafana integration - REST API for automation ## Why This Shines 1. **DevOps Skills**: Shows understanding of monitoring and observability 2. **Real-Time Processing**: Demonstrates event-driven architecture 3. **Production Ready**: Error handling, resilience, scalability 4. **Modern Stack**: Kafka, Python, Grafana - industry standard tools ## Next Steps 1. View dashboard: http://localhost:5004 2. Check API: http://localhost:5004/api/v1/logs/stats 3. Set up Grafana dashboards 4. Add alerting for critical errors For detailed documentation, see `docs/log_monitoring_system.md` 
+# Real-Time Log Monitoring - Quick Start ## Quick Start ### 1. Start Services ```bash # Start all services including log monitor docker-compose up -d # Verify log monitor is running docker-compose ps logmonitor-service ``` ### 2. Access Dashboard Open your browser: **http://localhost:5004** The dashboard will automatically: - Show error statistics - Display recent errors - Auto-refresh every 5 seconds ### 3. Generate Test Errors ```bash # Trigger an error in a service curl -X POST http://localhost:5001/api/v1/eventstreammonitor/users/register \ -H "Content-Type: application/json" \ -d '{"invalid": "data"}' # Check dashboard - error should appear within 5 seconds ``` ## API Endpoints ### Get All Errors ```bash curl http://localhost:5004/api/v1/logs/errors?limit=50 ``` ### Get Statistics ```bash curl http://localhost:5004/api/v1/logs/stats ``` ### Get Errors by Service ```bash curl http://localhost:5004/api/v1/logs/errors/usermanagement ``` ## Verify Kafka Topics ```bash # List topics docker-compose exec kafka kafka-topics --list --bootstrap-server localhost:9092 # Should see: # - application-logs # - application-logs-errors # Consume logs docker-compose exec kafka kafka-console-consumer \ --bootstrap-server localhost:9092 \ --topic application-logs-errors \ --from-beginning ``` ## Grafana Setup 1. Install Grafana (or use Docker): ```bash docker run -d -p 3000:3000 grafana/grafana ``` 2. Add Data Source: - Type: JSON API - URL: http://localhost:5004/api/v1/grafana - Access: Server 3. Create Dashboard: - Add panel with query: `error_count` - Add panel with query: `error_by_service` - Add panel with query: `error_by_level` ## Features - Real-time error monitoring - Multi-service log collection - Automatic error filtering - Beautiful dashboard - Grafana integration - REST API for automation ## Why This Shines 1. **DevOps Skills**: Shows understanding of monitoring and observability 2. **Real-Time Processing**: Demonstrates event-driven architecture 3. **Production Ready**: Error handling, resilience, scalability 4. **Modern Stack**: Kafka, Python, Grafana - industry standard tools ## Next Steps 1. View dashboard: http://localhost:5004 2. Check API: http://localhost:5004/api/v1/logs/stats 3. Set up Grafana dashboards 4. Add alerting for critical errors For detailed documentation, see `docs/log_monitoring_system.md` 

MICROSERVICES_ARCHITECTURE.md

@@ -1,7 +1,7 @@
 # Microservices Architecture
 
 ## Overview
-This document describes the microservices architecture for the Airliner Administration system.
+This document describes the microservices architecture for the EventStreamMonitor system.
 
 ## Services
 
@@ -10,8 +10,7 @@ This document describes the microservices architecture for the Airliner Administ
 - **Port**: 5001 (9091 internal)
 - **Database**: `REGISTRATIONS` (PostgreSQL)
 - **Endpoints**:
-  - `POST /api/v1/airliner/registerUser` - Register new user
-  - (Note: Other endpoints may use different URL patterns - check service code for current routes)
+  - `POST /api/v1/eventstreammonitor/users/register` - Register new user
 - **gRPC**: User validation for token generation
 - **Kafka**: Publishes user registration events
 
@@ -20,8 +19,8 @@ This document describes the microservices architecture for the Airliner Administ
 - **Port**: TBD
 - **Database**: Separate PostgreSQL database
 - **Endpoints**:
-  - `POST /api/v1/airliner/login` - User login (check service code for current routes)
-  - `POST /api/v1/airliner/generateToken` - Generate JWT token (check service code for current routes)
+  - `POST /api/v1/eventstreammonitor/auth/login` - User login (check service code for current routes)
+  - `POST /api/v1/eventstreammonitor/auth/generateToken` - Generate JWT token (check service code for current routes)
 - **gRPC**: Token validation service
 
 ### 3. Task Processing Service

MICROSERVICES_SETUP.md

@@ -1,15 +1,15 @@
 # Microservices Setup Guide
 
 ## Overview
-This guide explains how to set up and run all microservices in the Airliner Administration system.
+This guide explains how to set up and run all microservices in the EventStreamMonitor system.
 
 ## Services Architecture
 
 ### 1. User Management Service
 - **Port**: 5001 (external), 9091 (internal)
 - **Database**: `REGISTRATIONS` (PostgreSQL on port 3304)
 - **Endpoints**:
-  - `POST /api/v1/airliner/registerUser` - Register new user
+  - `POST /api/v1/eventstreammonitor/users/register` - Register new user
 - **Kafka**: Publishes to `user-registration-events` topic
 
 ### 2. Task Processing Service (formerly Booking Service)
@@ -83,7 +83,7 @@ docker-compose logs -f notification-service
 
 ### Test User Registration
 ```bash
-curl -X POST http://localhost:5001/api/v1/airliner/registerUser \
+curl -X POST http://localhost:5001/api/v1/eventstreammonitor/users/register \
   -H "Content-Type: application/json" \
   -H "Accept: application/json" \
   -H "Host: localhost:5001" \

docs/redis_integration.md

@@ -258,7 +258,7 @@ from app.redis_helper import UserManagementRedisHelper
 
 redis_helper = UserManagementRedisHelper()
 
-@app.route('/api/v1/airliner/registerUser', methods=['POST'])
+@app.route('/api/v1/eventstreammonitor/users/register', methods=['POST'])
 def register_user():
     # Get client IP or user ID for rate limiting
     client_id = request.remote_addr  # or user_id if authenticated

services/usermanagement/README.md

@@ -11,9 +11,9 @@ Microservice responsible for user registration, user data management, and user v
 - Kafka producer for user events
 
 ## API Endpoints
-- `POST /api/v1/airliner/registerUser` - Register new user
-- `GET /api/v1/airliner/getUser/<id>` - Get user information
-- `DELETE /api/v1/airliner/deleteUser/<id>` - Delete user
+- `POST /api/v1/eventstreammonitor/users/register` - Register new user
+- `GET /api/v1/eventstreammonitor/users/<id>` - Get user information
+- `DELETE /api/v1/eventstreammonitor/users/<id>` - Delete user
 
 ## Configuration
 Copy `.env.example` to `.env` and update with your configuration.