--- 20260319_120039_kagenti_native_rabbitmq_architecture ---
Title: kagenti-native RabbitMQ Architecture
Keywords: 
CID: bafka8d9c50c5c2e321a00401623ef5e0206
Witness: a8d9c50c5c2e321a00401623ef5e0206694e325c011e9f37cbacc3b2743e8b80
IPFS: QmPq3ngb6iS9rxHb8juFowEncJSV68hLpjxj3QDmVo37cj
DASL: 0xda5131a28090c5c2
Reply-To: 

```
kagenti-native RabbitMQ Architecture
=====================================

                          ┌─────────────────────┐
                          │   RabbitMQ Broker    │
                          │  localhost:5672      │
                          │  vhost: /monster     │
                          │  user: kagenti       │
                          │                     │
                          │  ┌───────────────┐  │
                          │  │   Exchange     │  │
                          │  │ kagenti.events │  │
                          │  │  (fanout)      │  │
                          │  └───────┬───────┘  │
                          │          │ bind     │
                          │  ┌───────▼────────┐ │
                          │  │     Queue       │ │
                          │  │ kagenti.agent   │ │
                          │  │   .events       │ │
                          │  └───────┬────────┘ │
                          └──────────┼──────────┘
                                     │
              ┌──────────────────────┼──────────────────────┐
              │                      │                      │
     publish  │             subscribe│              publish  │
              │                      │                      │
   ┌──────────▼──┐          ┌────────▼────────┐    ┌────────▼──────┐
   │ API Server  │          │   Reconciler    │    │  CLI / TUI    │
   │ (axum)      │          │   (daemon)      │    │  (Go client)  │
   │ :8480       │          │                 │    │               │
   │             │          │ on AgentEvent:  │    │ POST /deploy  │
   │ POST /deploy│─publish─▶│  Created → nix  │    │ POST /start   │
   │ POST /start │          │    build +      │    │ POST /stop    │
   │ POST /stop  │          │    systemd      │    │ GET  /status  │
   │ GET /status │          │    install+start│    │               │
   │ GET /agents │          │  Updated →      │    │ GET /agents   │
   │             │          │    restart unit  │    │               │
   └─────────────┘          │  Deleted →      │    └───────────────┘
                            │    stop+remove  │
                            └────────┬────────┘
                                     │
                    ┌────────────────┼────────────────┐
                    │                │                │
           ┌───────▼──────┐ ┌───────▼──────┐ ┌──────▼───────┐
           │ systemd       │ │ nix build    │ │ systemd      │
           │ --user        │ │              │ │ --user       │
           │               │ │ flake.nix    │ │              │
           │ kagenti-agent │ │ → /nix/store │ │ kagenti-agent│
           │ -hello.service│ │   /...-agent │ │ -git.service │
           └───────────────┘ └──────────────┘ └──────────────┘

Message Flow:
─────────────
1. Client POSTs AgentRuntime to API server
2. API server publishes AgentEvent::Created to RabbitMQ
3. Reconciler receives event via subscribe (mpsc channel)
4. Reconciler calls kagenti-nix::build_agent() → nix build
5. Reconciler calls kagenti-daemon::systemd::install() + start()
6. Agent runs as systemd --user service

AgentEvent (JSON, serde tagged):
────────────────────────────────
  {"kind":"Created", "name":"...", "namespace":"...", ...}
  {"kind":"Updated", "name":"...", "namespace":"...", ...}
  {"kind":"Deleted", "name":"...", "namespace":"..."}

Crate Mapping:
──────────────
  kagenti-api   → types + axum routes (k8s-compatible REST)
  kagenti-rmq   → EventBus (lapin v2, fanout exchange)
  kagenti-nix   → generate_flake() + build_agent()
  kagenti-daemon→ systemd.rs + main.rs (API + reconciler)
```


<div typeof="erdfa:SheafSection dasl:Type3" about="#bafkda513250f1595dc8">
  <meta property="erdfa:shard" content="66,3,16" />
  <meta property="erdfa:encoding" content="raw" />
  <meta property="erdfa:prime" content="1" />
  <meta property="dasl:addr" content="0xda51301071595dc8" />
  <meta property="dasl:type" content="3" />
  <meta property="dasl:eigenspace" content="Earth" />
  <meta property="dasl:bott" content="2 (H)" />
  <meta property="dasl:hecke" content="T_1" />
  <meta property="sheaf:orbifold" content="(66 mod 71, 3 mod 59, 16 mod 47)" />
  <link property="sheaf:subgroupIndex" href="erdfa:H/raw" />
</div>