Provides a clean interface for publishing and subscribing to events.

Configuration

In your config.exs:

config :sorcery, :pub_sub,
  pub_sub: Sorcery.PubSub.PostgresStore,
  pub_sub_opts: [
    repo: MyApp.Repo,
    table_name: "events"
  ]

Or for in-memory storage:

config :sorcery, :pub_sub,
  pub_sub: Sorcery.PubSub.MemoryStore

Usage

# Publish an event
event = Sorcery.Event.new(%{
  type: "user_registered",
  data: %{user_id: "123"},
  domain: "users",
  instance_id: "instance_1",
  domain_sequence_number: 1
})

Sorcery.PubSub.publish(event)

# Subscribe to events
{:ok, events, pagination} = Sorcery.PubSub.subscribe()

# Query specific events
{:ok, events, pagination} = Sorcery.PubSub.subscribe_by_domain("users")
{:ok, events, pagination} = Sorcery.PubSub.subscribe_by_type("user_registered")