gramps 78f7b79494 Task 11: cluster protocol — subscribe(), ping/pong health, 9 message types ...

- amqp.py: subscribe() creates exclusive queues bound to routing keys,
  _rebind_subscriptions() recreates them after reconnect
- cluster.py: CLUSTER_NODES, CLUSTER_EVENTS (bounded 1000),
  CLUSTER_COORDINATOR with auto-promotion, all 6 handlers
  (register, deregister, pong, event, coordinator_query),
  ping_node() with 5s timeout + auto-deregister on failure
- routers/cluster.py: GET /api/cluster
- Wired into app.py lifespan after amqp_connect()
- 13 tests covering all handlers, boundaries, and API shape
- No passive heartbeats — workers assumed present until ping
  timeout at work-routing time

2026-07-06 19:22:31 -07:00

..

__init__.py

refactor(arch): modular package structure — split monolithic app.py into config/db/auth/memory/search/rag/gpu + routers/

2026-06-16 08:17:46 -07:00

chat.py

v1.9.0 -> v1.10.0: file upload UI + attachment management

2026-07-03 12:18:06 -07:00

cluster.py

Task 11: cluster protocol — subscribe(), ping/pong health, 9 message types

2026-07-06 19:22:31 -07:00

completions.py

fix: resolve all critical runtime errors and bugs from audit

2026-06-27 15:12:18 -07:00

conversations.py

v1.9.0 -> v1.10.0: file upload UI + attachment management

2026-07-03 12:18:06 -07:00

hardware.py

v0.11.0 -> v0.12.0: startup hardware self-assessment (Roadmap J)

2026-07-03 12:53:34 -07:00

ingest.py

refactor: extract eviction engine into eviction.py (rag.py 303→109 lines)

2026-07-06 08:00:26 -07:00

memories.py

refactor(arch): modular package structure — split monolithic app.py into config/db/auth/memory/search/rag/gpu + routers/

2026-06-16 08:17:46 -07:00

models.py

fix: resolve all critical runtime errors and bugs from audit

2026-06-27 15:12:18 -07:00

presets.py

refactor(arch): modular package structure — split monolithic app.py into config/db/auth/memory/search/rag/gpu + routers/

2026-06-16 08:17:46 -07:00

profile.py

refactor(arch): modular package structure — split monolithic app.py into config/db/auth/memory/search/rag/gpu + routers/

2026-06-16 08:17:46 -07:00

rag_admin.py

fix: address three gaps in Task 8 spec compliance

2026-07-06 08:05:14 -07:00

search_route.py

fix: resolve all critical runtime errors and bugs from audit

2026-06-27 15:12:18 -07:00

settings.py

refactor(arch): modular package structure — split monolithic app.py into config/db/auth/memory/search/rag/gpu + routers/

2026-06-16 08:17:46 -07:00

skills.py

refactor(arch): modular package structure — split monolithic app.py into config/db/auth/memory/search/rag/gpu + routers/

2026-06-16 08:17:46 -07:00

upload.py

refactor: extract eviction engine into eviction.py (rag.py 303→109 lines)

2026-07-06 08:00:26 -07:00