Path: internal/event
- Event type constants:
records.*(row writes) andmetadata.*(mapped toschema.*on the bus). - EventBus:
EmitEventpublishesrecords.*andschema.*. - Implementations:
memory— single process (EVENT_BUS=memory, default)redis— Redis Stream (EVENT_BUS=redis+REDIS_URL) for multi-instance consumers
- Webhooks:
POST /v1/admin/webhooks; dispatcher POSTs matching events. HeaderX-Webhook-Signature: sha256=...when a secret is set.
This service does not persist an event log. External systems record via webhook (or a bus consumer).