Repository navigation
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Ganesh #2
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Uh oh!
There was an error while loading. Please reload this page.
Ganesh #2
Changes from all commits
ba6771d503d7d2e4371ebFile filter
Filter by extension
Conversations
Uh oh!
There was an error while loading. Please reload this page.
Jump to
Uh oh!
There was an error while loading. Please reload this page.
There are no files selected for viewing
My Project
Horizon — Autonomous Enterprise Infrastructure Recovery Platform
📌 Executive Summary & Problem Statement
When an enterprise's foundational databases, caches, queues, or microservices fail, recovery operations often devolve into manual chaos. Cross-functional engineering teams scramble in emergency War Rooms, manually restarting systems out of sequence.
The Outage Dilemma
The Horizon Solution
Horizon is an Autonomous Enterprise Infrastructure Recovery Platform that observes distributed clusters in real time, isolates root-cause failures via anti-flapping sliding windows, sequences bottom-up recovery using Kahn’s Topological Sorting algorithm$\mathcal{O}(V+E)$ , diagnoses incidents with Sarvam AI, enforces EIP-712 cryptographic multi-signature gates on the MST Blockchain, and anchors immutable Merkle root audit proofs on-chain.
📐 System Architecture & 7-Stage Autonomous Pipeline
Horizon organizes autonomous resilience into 7 discrete, verifiable pipelines. Every single stage generates a deterministic SHA-256 cryptographic checksum (
0x...) logged to console and aggregated into a final on-chain Merkle root.flowchart TD subgraph P1["Stage 1: APM Telemetry Ingestion"] A1["Datadog Synthetic Probes<br/>Dynatrace OneAgent Probes"] --> A2["Latency, CPU, Jitter Wave Stream"] end subgraph P2["Stage 2: Anomaly Detection & Flapping Guard"] A2 --> B1{"3-Consecutive-Miss<br/>Sliding Window?"} B1 -- "< 3 misses" --> B2["Transient Warning (Nominal)"] B1 -- ">= 3 misses" --> B3["Trip P1 Critical Incident<br/>Dispatch PagerDuty Audio Alert"] end subgraph P3["Stage 3: Kahn DAG Dependency Sequencing"] B3 --> C1["Extract Directed Acyclic Graph (DAG)"] C1 --> C2["Kahn Algorithm O(V+E)<br/>Cycle & Deadlock Detection"] C2 --> C3["Calculate BFS Blast Radius<br/>Synthesize Bottom-Up Tiers"] end subgraph P4["Stage 4: Real AI SRE Reasoning"] C3 --> D1["Sarvam AI SRE Copilot Ingestion"] D1 --> D2{"Cloud API vs Local Heuristic"} D2 -- "HTTP 200" --> D3["Original Sarvam Cloud LLM<br/>Model: sarvam-2b"] D2 -- "Fallback" --> D4["Deterministic SRE Guardrail Engine<br/>Multilingual Heuristic Engine"] end subgraph P5["Stage 5: High-Risk EIP-712 Governance Gate"] D3 & D4 --> E1{"Is High-Risk Step?<br/>(DB Promotion / Backup)"} E1 -- "Yes" --> E2["Pause Recovery Pipeline"] E2 --> E3["EIP-712 Typed Cryptographic Signature<br/>BridgeKey Wallet on MST Chain (91562037)"] E3 --> E4["Gate Approved & Unblocked"] E1 -- "No" --> E4 end subgraph P6["Stage 6: Autonomous Playbook Execution"] E4 --> F1["Tier 0: Database Standby Promotion & PITR"] F1 --> F2["Tier 1: Redis Cache Warm & Kafka Rebalance"] F2 --> F3["Tier 2: Ingress Routing Traffic Cutover"] end subgraph P7["Stage 7: Blockchain Merkle Proof Anchoring"] F3 --> G1["Aggregate Pipeline 1-6 SHA-256 Hashes"] G1 --> G2["Derive Merkle Root Audit Digest"] G2 --> G3["Anchor Transaction to MST Blockchain<br/>Smart Contract: 0x3EDad..."] G3 --> G4["Auto-Resolve PagerDuty P1 Alert<br/>Update Rolling MTTR Stopwatch"] end📂 Repository Structure & Source Code Organization
Horizon is structured as a monorepo adhering strictly to clean architectural boundaries:
🛡️ The 7-Stage Cryptographic Pipeline & Checksum Manifest
To eliminate black-box ambiguity, every autonomous remediation cycle computes and logs a deterministic SHA-256 hash for each stage:
telemetry-apmtelemetry-apmkahn-dagsarvam-cloud-llm/sre-heuristic-guardraileip712-gatesystemsystemReal-Time Console Output
Whenever an incident is remediated, the structured logger outputs clean audit logs to the browser console:
🤖 Real AI Engine & Provenance Verification
Horizon features an integrated Sarvam AI SRE Copilot that runs in two distinct, verifiable modes:
sarvam-ai-cloud):https://api.sarvam.ai/v1/chat/completions) using modelsarvam-2b.ORIGINAL SARVAM AI CLOUD (HTTP 200)badge and exact latency in milliseconds.sre-heuristic-guardrail):⚡ Model Context Protocol (MCP) Server
Horizon exposes an enterprise-grade MCP server for seamless integration with AI coding assistants (Claude Desktop, Cursor IDE, Google Antigravity CLI).
12-Tool MCP Catalogue
horizon_get_topology: Retrieves cluster microservices and directed dependency edges.horizon_probe_health: Evaluates node health using the 3-consecutive-miss threshold.horizon_simulate_failure: Injects simulated infrastructure outages on target nodes.horizon_trigger_recovery: Initiates Kahn DAG recovery (supportsautomatic,database_failover,service_restart, andrestore_from_backup).horizon_submit_gate_approval: Submits cryptographic ECDSA signature to unblock paused recovery.horizon_get_incident_timeline: Retrieves live RTO stopwatch, milestones, and rolling MTTR metrics.horizon_broadcast_incident: Dispatches War Room alerts to Slack, Discord, and HTTP webhooks.horizon_sign_approval_gate: Signs high-risk approval requests via EIP-712.horizon_verify_audit_proof: Verifies Merkle audit roots against the MST Blockchain.horizon_synthesize_yaml: Compiles cluster topology into valid Kubernetes / Docker Compose manifests.horizon_diagnose_cluster: Runs natural language diagnostic analysis on cluster state.horizon_get_audit_logs: Fetches immutable historical audit records.Inbound Alertmanager Webhook
Accepts Datadog and Prometheus Alertmanager alert webhooks at:
🚀 Quick Start & Installation
Prerequisites
1. Clone & Install Frontend
2. Configure Environment Variables
Copy
.env.exampleinapps/web/:Ensure the following keys are populated:
3. Start Development Server
# Start frontend dev server on http://localhost:5173 bun run dev4. Run the Full Test Suite
5. Setup & Run MCP Server (Optional)
🎬 60-Second Hackathon Demo Guide
http://localhost:5173/observability(or click Platformdb-primary) and click "Simulate Breach".📄 License & Compliance
Licensed under the MIT License. Developed for enterprise resilience, high-reliability autonomous operations, and hackathon presentation.
Uh oh!
There was an error while loading. Please reload this page.