Holon

Holon Queue Pipeline

Pull-based atomic dispatch queue -- workers claim holons, module locking, Caveman compression, swarm heartbeats.

Holon Queue Pipeline (v2026-09-30T110941Z-5e473105f4) 2026-09-30 | Pull-based atomic dispatch queue -- workers claim holons, module locking, Caveman compression, swarm heartbeats. 1 - QUEUE ROUTER - Handles API requests and dispatches holons queue_router.py GET /api/holons/ POST /api/holons/drop GET /api/holons/dlq holon_mailbox.py holons table holon_claims table holon_results table holon request 2 - CAVEMAN COMPRESSION - Compresses holon bodies queue_router.py _compress_claimed caveman:output_compressed caveman_holon_hook compress_holon_body initialize_caveman holon body 3 - LEDGER - Records holon transitions holon_ledger.py record history recent holon_ledger.py holon_transitions table holon_ledger_meta table transition det… 1. Receive holon request 2. Claim holon from mailbox 3. Compress holon body 4. Record transition in ledger 5. Return holon to requester Holon request payload { "id": "holon123" "sender": "workerA" "role_required": "admin" "body": "data" "metadata": {} } Compression metadata { "caveman_available": true "savings_pct": 50.0 "cost_usd_saved": 0.01 } The holon mailbox ensures atomicity and recovery guarantees for holon distribution. The ledger records all transitions for observability and quota enforcement. Legend actor = initiates work · process = code path · store = state on disk · bus = durable queue · dashed = separate process cyan = request flow · pink = state read/write · dashed green = pull / return path · red = refusal As of 2026-09-30 11:09 UTC, from commit 5e47310

Provenance

This drawing is generated, not drawn. It is rebuilt from the source files below, so when they change the picture changes — a diagram here cannot quietly describe a system that no longer works this way.

Owner
Holon
Slug
holon-queue-pipeline
Rendered
2026-09-30T110941Z
From commit
5e473105f4
Updated
30 Sep 2026, 11:09 UTC
Sources at
5e47310
Watches
4 paths
  • daemon/src/holon_domain/queue_router.py
  • daemon/src/holon_mailbox.py
  • daemon/src/holon_executor.py
  • daemon/src/holon_ledger.py