Echo Communication System

✅ Healthy vunknown 👤 Platform Team

Overview

Echo is VALINA's communication backbone, enabling real-time messaging, notifications, and event propagation across the ecosystem.

Handles all inter-service communication, user notifications, real-time updates, and event streaming. Ensures reliable message delivery with exactly-once semantics.

📦 Source Repository

Key Features

Real-time WebSocket messaging
Event-driven architecture
Notification routing and delivery
Pub/Sub message patterns
Message persistence and replay
Cross-service event propagation

Architecture

Event-driven messaging system: - Message Bus: Central event router - WebSocket Gateway: Real-time client connections - Notification Engine: Multi-channel delivery - Event Store: Persistent message log

System Overview

%%{init: {
  'theme': 'dark',
  'themeVariables': {
    'primaryColor': '#db41f6',
    'primaryBorderColor': '#e066f7',
    'primaryTextColor': '#ffffff',
    'secondaryColor': '#1a0f2e',
    'tertiaryColor': '#0f0a1a',
    'lineColor': '#22c55e',
    'fontSize': '14px'
  }
}}%%
flowchart TB
    subgraph EXTERNAL["🌐 External"]
        CLIENT[/"👤 Clients"/]
        INGRESS["🚪 Ingress"]
    end

    subgraph NS["valina-echo Namespace"]
        direction TB
        subgraph SVC["📦 Echo Communication System"]
            DEPLOY["⚙️ Deployment<br/>1 replicas"]
            subgraph PODS["Pods"]
                POD0["Pod 1"]
            end
        end
    end

    subgraph DATA["💾 Data Layer"]
        DB0["🐘 PostgreSQL (ECHO_DB_HOST)"]
        DB1["🐘 PostgreSQL (pgvector)"]
    end

    subgraph EXT["🔗 External Services"]
        EXT0["☁️ OpenAI Embeddings API"]
    end

    CLIENT --> INGRESS --> DEPLOY
    DEPLOY --> DATA
    DEPLOY --> EXT

Component Architecture

%%{init: {
  'theme': 'dark',
  'themeVariables': {
    'primaryColor': '#db41f6',
    'primaryBorderColor': '#e066f7',
    'primaryTextColor': '#ffffff',
    'secondaryColor': '#1a0f2e',
    'tertiaryColor': '#0f0a1a',
    'lineColor': '#22c55e',
    'fontSize': '14px'
  }
}}%%
flowchart TB
    subgraph ARCH_CLIENT["🧑 Client Layer"]
        ARCH_USER[/"User Interaction"/]
    end

    subgraph ARCH_CORE["💎 Echo Communication System Core"]
        direction TB
        subgraph ARCH_FEATURES["✨ Features"]
            ARCH_F0["Real-time WebSocket messaging"]
            ARCH_F1["Event-driven architecture"]
            ARCH_F2["Notification routing and de..."]
            ARCH_F3["Pub/Sub message patterns"]
            ARCH_F4["Message persistence and replay"]
        end

        subgraph ARCH_PROCESS["⚙️ Processing"]
            ARCH_HANDLER["Request Handler"]
            ARCH_LOGIC["Business Logic"]
        end
    end

    subgraph ARCH_DATA["💾 Data Layer"]
        ARCH_DB0["PostgreSQL (ECHO_DB_HOST)"]
        ARCH_DB1["PostgreSQL (pgvector)"]
    end

    ARCH_USER --> ARCH_CORE
    ARCH_HANDLER --> ARCH_LOGIC
    ARCH_LOGIC --> ARCH_DATA

Container Details

Property	Value
Image	`valina/echo-system:v1.3.2-ns-202601110146`
Replicas	1 / 1 ready
CPU Request	100m
CPU Limit	500m
Memory Request	256Mi
Memory Limit	512Mi

Volume Mounts

Volume	Mount Path
config → /app/config
tmp → /tmp
cache → /app/.cache

Flows and Processes

Process Flow

%%{init: {
  'theme': 'dark',
  'themeVariables': {
    'primaryColor': '#db41f6',
    'primaryBorderColor': '#e066f7',
    'primaryTextColor': '#ffffff',
    'secondaryColor': '#1a0f2e',
    'tertiaryColor': '#0f0a1a',
    'lineColor': '#22c55e',
    'fontSize': '14px'
  }
}}%%
flowchart LR
    subgraph FLOW_IN["📥 Input"]
        GEN_REQ["📥 Request"]
        GEN_CONFIG["⚙️ Config"]
        GEN_CONTEXT["📋 Context"]
    end

    subgraph FLOW_PROC["⚙️ Processing"]
        GEN_RECEIVE["📨 Receive"]
        GEN_PROCESS["⚙️ Echo Communication System"]
        GEN_RESPOND["📤 Prepare Response"]
    end

    subgraph FLOW_OUT["📤 Output"]
        GEN_RES["📦 Response"]
        GEN_LOG["📝 Log"]
        GEN_METRICS["📊 Metrics"]
    end

    GEN_REQ --> GEN_RECEIVE
    GEN_CONFIG --> GEN_PROCESS
    GEN_CONTEXT --> GEN_PROCESS
    GEN_RECEIVE --> GEN_PROCESS --> GEN_RESPOND
    GEN_RESPOND --> GEN_RES
    GEN_RESPOND --> GEN_LOG
    GEN_PROCESS --> GEN_METRICS

Request Lifecycle

%%{init: {
  'theme': 'dark',
  'themeVariables': {
    'primaryColor': '#db41f6',
    'primaryBorderColor': '#e066f7',
    'primaryTextColor': '#ffffff',
    'secondaryColor': '#1a0f2e',
    'tertiaryColor': '#0f0a1a',
    'lineColor': '#22c55e',
    'fontSize': '14px'
  }
}}%%
sequenceDiagram
    autonumber
    participant C as 👤 Client
    participant I as 🚪 Ingress
    participant S as ⚙️ Echo Communication System
    participant D as 💾 Database

    C->>+I: HTTP Request
    I->>+S: Route to Service
    Note over S: Health Check ✓
        S->>+D: Query Data
        D-->>-S: Return Result
    S-->>-I: Response
    I-->>-C: HTTP Response

Custom Flows

Memory Storage
Semantic Retrieval
Context Building
Memory Consolidation
Embedding Update

Integration and APIs

Exposed Ports

Port	Service
http:8500	echo-system

Health Check

/api/echo/health:8500

Dependencies

Service	Purpose
RabbitMQ	Dependency
Redis (pub/sub)	Dependency
PostgreSQL (event store)	Dependency

Data Stores

PostgreSQL (ECHO_DB_HOST)
PostgreSQL (pgvector)

External Services

OpenAI Embeddings API

Security and Compliance

Security Context

Setting	Value
Security Level	Hardened
Run as Non-Root	✅ Yes
Read-Only Root FS	✅ Yes

Dropped Capabilities

ALL

Security Best Practices

Hardened Security

This service follows security best practices:

✅ Runs as non-root user
✅ Read-only root filesystem
✅ All capabilities dropped

Monitoring and Operations

Health Probes

Readiness Probe

Setting	Value
Endpoint	`/api/echo/health:8500`
Initial Delay	10s
Period	10s
Timeout	1s

Liveness Probe

Setting	Value
Endpoint	`/api/echo/health:8500`
Initial Delay	30s
Period	30s
Timeout	1s

No Prometheus metrics configured. Add prometheus.io/scrape: "true" annotation.

Operations Commands

# Check deployment status
kubectl get deployment echo-system -n valina-echo

# View logs
kubectl logs -l app.kubernetes.io/name=echo-system -n valina-echo -f

# Scale replicas
kubectl scale deployment/echo-system -n valina-echo --replicas=3

# Restart deployment
kubectl rollout restart deployment/echo-system -n valina-echo

🔧 AI-Powered Diagnostics

🔧 Diagnostics

✅ No issues detected

📊 SLO Dashboard

SLO	Target	Current	Error Budget	Status
🟢 Availability	99.9%	99.95%	85% remaining	✅ Meeting
⚡ Latency P99	< 200ms	142ms	92% remaining	✅ Meeting
🔴 Error Rate	< 0.1%	0.02%	98% remaining	✅ Meeting

📈 Live Metrics

CPU Usage

0%

▁▂▃▂▃▄▃▂▃▂

Memory

0MB

▂▂▃▃▃▄▄▃▃▃

Request Rate

0.0k/s

▃▄▅▆▅▆▇▆▅▆

Error Rate

0.00%

▁▁▁▂▁▁▁▁▁▁

🔒 Security Scan

0

Critical

0

High

2

Medium

5

Low

Security Status: Passing

Last scanned: 2026-01-12 10:00 UTC Scanner: Trivy v0.50.0

👥 RBAC & Permissions

Resource	Permissions	Scope
ServiceAccount	`default`	Namespace
ClusterRole	`view`	Cluster-wide (read)

Pod Security Standards

Policy	Status
Privileged	❌ Denied
Run as Root	❌ Blocked
Host Network	❌ Blocked
Host PID	❌ Blocked

📖 API Documentation

No OpenAPI Spec

Add API documentation via annotation: valina.ai/openapi-url: "https://..."

📜 Version History

Added pgvector support

Improved search relevance

⚡ Latency Heatmap

P50

45ms

P90

98ms

P99
142ms

Max

285ms

SLO (200ms)

🟡 95.0%

Good

24-Hour Latency Heatmap

Hourly P99 🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢🟢

🟢 <50% 🟡 50-75% 🟠 75-100% 🔴 >SLO

🔔 Active Alerts

✅ All Clear 0 active alerts

🌐 Traffic Flow

📥 Inbound Traffic

nginx-ingress → 1.2k rps | 45ms | 0.02% err

api-gateway → 850.0 rps | 12ms | 0.00% err

📤 Outbound Traffic

No outbound traffic detected

💰 Cost Attribution

Monthly Cost $5.85

Efficiency Score 72%

Resource Breakdown

CPU

Memory

Storage

Net

💻 CPU: $3.00 🧠 Memory: $2.40 💾 Storage: $0.30 🌐 Network: $0.15

📚 Runbooks

🔥 High CPU Usage

Steps to diagnose and mitigate high CPU consumption

cpuperformance

⚡ High Latency

Troubleshooting guide for latency spikes

latencynetworking

🔄 Pod Restarts

Investigation steps for frequent pod restarts

restartsoom

📞 On-Call

📞 Platform Team Platform Team Escalation 📅 View Schedule

Primary

OE

On-Call Engineer

📧 Email 💬 @oncall

🕐 Shift ends: 7h

Secondary

BE

Backup Engineer

📧 Email 💬 @oncall-backup

📅 Change Timeline

📅 Deployment History 1 changes 📊 View in ArgoCD

🚀

Deployment 2026-01-14 06:44 UTC

Current deployment

👤 CI/CD

🐤 Canary Status

🐤 No active canary deployment

🔴 Error Drill-down

✅ No errors in the last 24 hours 📋 View Logs

⚡ Quick Actions

Future Enhancements

Multi-modal memory
Long-term consolidation
Memory graphs

Configuration Reference

Labels

Label	Value
`app`	`echo`
`component`	`swarm`

Environment Variables

Variable	Value
`ECHO_CONFIG`	`/app/config/echo_config.yaml`
`ECHO_DB_HOST`	`pgbouncer.valina-db.svc.cluster.local`
`ECHO_DB_NAME`	`echo_db`
`ECHO_DB_PORT`	`6432`
`VAL_API_URL`	`http://valina-rust-backend.valina.svc.cluster.local:80`

Annotations

Annotation	Value
`valina.ai/architecture`	`Vector database integration with pgvector for similarity sea…`
`valina.ai/changelog`	`Added pgvector support,Improved search relevance`
`valina.ai/databases`	`PostgreSQL (pgvector)`
`valina.ai/dependencies`	`postgresql`
`valina.ai/dependents`	`valina-rust-backend`
`valina.ai/external-services`	`OpenAI Embeddings API`
`valina.ai/features`	`Vector Storage,Semantic Search,Context Windows,Memory Consol…`
`valina.ai/flows`	`Memory Storage,Semantic Retrieval,Context Building,Memory Co…`
`valina.ai/openapi-url`	`https://echo.valina.ai/api/docs`
`valina.ai/owner`	`@3xzyle`
`valina.ai/purpose`	`Memory and context management system for VALINA AI with vect…`
`valina.ai/repository`	`https://github.com/3xzyle/VALINA-AI`
`valina.ai/roadmap`	`Multi-modal memory,Long-term consolidation,Memory graphs`

📋 Service Index

View all documented services
📊 System Status

Live health dashboard
🏷️ Communication

Other services in this category

Auto-Generated Documentation

This documentation was auto-generated from Kubernetes deployment metadata.

Enhance this doc by adding annotations:

annotations:
  valina.ai/description: "Detailed service description"
  valina.ai/purpose: "Service purpose statement"
  valina.ai/features: "Feature 1, Feature 2, Feature 3"
  valina.ai/flows: "Auth Flow, Data Processing Flow"
  valina.ai/dependencies: "redis, postgres, auth-service"
  valina.ai/api-endpoints: "/api/v1/resource, /health"
  valina.ai/economics: "Ties to GRAT treasury via..."
  valina.ai/owner: "Platform Team"
  valina.ai/repository: "https://github.com/org/repo"
  valina.ai/changelog: "v1.2.0 Added feature X, v1.1.0 Initial release"
  valina.ai/roadmap: "SSO integration, Multi-region support"
  valina.ai/notices: "Requires v2.0 by Q2 2026"

Created: 2026-01-11T06:37:52Z | Generated: 2026-01-14T06:44:05.710233270+00:00