« Changelog History


eventstore v0.9.0 Release Notes

  • ✨ Enhancements

    • Adds causation_id alongside correlation_id for events (#48).

    To migrate an existing event store database execute [v0.9.0.sql](priv/event_store/migrations/v0.9.0.sql) script.

    • 👍 Allow single stream, and all streams, subscriptions to provide a mapper function that maps every received event before sending to the subscriber.
      EventStore.subscribe_to_stream(stream_uuid, "subscription", subscriber, mapper: fn event -> event.data end)
    • Subscribers now receive an {:events, events} tuple and should acknowledge receipt by: EventStore.ack(subscription, events)