Bridge between event stores and evoq routing infrastructure.

Creates a single $all subscription to a reckon-db store, receiving ALL events in global store order. Events are filtered locally by checking against registered event types in the type registry.

This preserves causal ordering across event types within a store, which is critical when projections for related events must execute in the order they were appended (e.g., license_initiated before license_published).

How It Works

1. Replays all historical events from the store (catch-up phase) 2. Subscribes to the store's $all stream (by_stream, selector $all) 3. Receives ALL new events in store-global order 4. For each event, checks if any handler is registered for its type 5. Routes matching events to evoq_event_router and evoq_pm_router 6. Skips events with no registered handlers (zero cost)

Usage

Start one instance per event store:

  %% In your application supervisor or startup:
  evoq_store_subscription:start_link(plugins_store)
  evoq_store_subscription:start_link(settings_store, #{})

All modules implementing evoq behaviours that have registered with evoq_event_type_registry will automatically receive matching events.