zzstoatzz.io
prefect server in zig
update CLAUDE.md files for recent changes
- broker: document heap allocation and ephemeral group cleanup
- db: document events module functions including backfill query
🤖 Generated with [Claude Code](https://claude.com/claude-code)
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
+7
src/broker/CLAUDE.md
+7
src/broker/CLAUDE.md
···
32
32
33
33
uses growable Queue (ArrayList-backed) per topic.
34
34
broadcasts to all subscribers (simulates fan-out).
35
+
StoredMessage uses heap allocation (no size limits).
36
+
37
+
## ephemeral groups
38
+
39
+
ephemeral consumer groups (e.g., ws-{timestamp}) are destroyed on unsubscribe.
40
+
redis: XGROUP DESTROY cleans up the consumer group.
41
+
memory: no cleanup needed (in-process only).
+7
src/db/CLAUDE.md
+7
src/db/CLAUDE.md
···
27
27
- `PREFECT_DATABASE_PATH`: sqlite path (default: prefect.db)
28
28
- `PREFECT_DATABASE_URL`: postgres connection string
29
29
30
+
## events module
31
+
32
+
- `insertDeduped`: INSERT OR IGNORE for event deduplication
33
+
- `queryRecent`: backfill query for /events/out (uses std.json.Stringify.valueAlloc)
34
+
- `trim`: delete events older than cutoff
35
+
- `count`: count total events
36
+
30
37
## testing
31
38
32
39
```bash