events: NATS JetStream ingress + normalized event schema #21

Closed
opened 2026-04-13 14:23:20 +00:00 by alvis · 1 comment
Owner

Define NormalizedEvent in shared-types. Set up JetStream streams for signals.* and feedback.*. Integrations publish; recommender + ml pipelines subscribe.

Define `NormalizedEvent` in `shared-types`. Set up JetStream streams for `signals.*` and `feedback.*`. Integrations publish; recommender + ml pipelines subscribe.
alvis added this to the M1 — Real signal milestone 2026-04-13 14:23:20 +00:00
alvis added the backend label 2026-04-13 14:23:20 +00:00
alvis modified the milestone from M1 — Real signal to M2 — AI tips + multi-source signals 2026-04-16 15:23:27 +00:00
Author
Owner

Shipped in 2a73809 and verified in deployment 2026-04-18: NATS bridge connects, signals/feedback streams created, scheduler emits signals.task.synced on the 15-min tick. Smoke test passed; closing. Follow-up: ml/serving consumer tracked in #98.

Shipped in 2a73809 and verified in deployment 2026-04-18: NATS bridge connects, signals/feedback streams created, scheduler emits signals.task.synced on the 15-min tick. Smoke test passed; closing. Follow-up: ml/serving consumer tracked in #98.
alvis closed this issue 2026-04-18 07:55:03 +00:00
Sign in to join this conversation.
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: alvis/oO#21