Packages
ex_esdb
0.1.5
0.11.0
0.10.0
0.9.0
0.8.0
0.7.8
0.7.7
0.7.6
0.7.5
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.1
0.6.0
0.5.1
0.5.0
0.4.8
0.4.7
0.4.6
0.4.5
0.4.4
0.4.3
0.4.2
0.4.1
0.4.0
0.3.3
0.3.2
0.3.1
0.3.0
0.2.5
0.2.4
0.2.3
0.2.2
0.2.1
0.2.0
0.1.7
0.1.6
0.1.5
0.1.4
0.1.3
0.1.2
0.1.1
0.1.0
0.0.20
0.0.19
0.0.18
0.0.17
0.0.16
0.0.15
0.0.14-alpha
0.0.13-alpha
0.0.12-alpha
0.0.11-alpha
0.0.10-alpha
0.0.9-alpha
0.0.8-alpha
0.0.6-alpha
0.0.5-alpha
0.0.4-alpha
0.0.3-alpha
0.0.2-alfa
0.0.1-alfa
ExESDB is a reincarnation of rabbitmq/khepri, specialized for use as a BEAM-native event store.
Current section
Files
Jump to
Current section
Files
lib/ex_esdb/event_projector.ex
defmodule ExESDB.EventProjector do
@moduledoc """
This module contains the event projector functionality
"""
use GenServer
alias ExESDB.Themes, as: Themes
alias Phoenix.PubSub, as: PubSub
require Logger
@impl true
def handle_info({:event, event}, state) do
Logger.info("#{Themes.projector(self(), "Received event: #{inspect(event, pretty: true)}")}")
{:noreply, state}
end
@impl true
def handle_info({:DOWN, _ref, :process, _pid, _reason}, state) do
Logger.info("#{Themes.projector(self(), "Projector DOWN")}")
{:noreply, state}
end
@impl true
def handle_info(msg, state) do
Logger.info("#{Themes.projector(self(), "Unknown message: #{inspect(msg, pretty: true)}")}")
{:noreply, state}
end
##### PLUMBING #####
@impl true
def init(opts) do
Process.flag(:trap_exit, true)
Logger.info("#{Themes.projector(self(), "is UP.")}")
opts[:pub_sub]
|> PubSub.subscribe(to_string(opts[:store_id]))
{:ok, opts}
end
@impl true
def terminate(reason, state) do
Logger.info("#{Themes.projector(self(), "⚠️ Shutting down gracefully. Reason: #{inspect(reason)}")}")
# Unsubscribe from PubSub
state[:pub_sub]
|> PubSub.unsubscribe(to_string(state[:store_id]))
:ok
end
def start_link(opts) do
GenServer.start_link(
__MODULE__,
opts,
name: __MODULE__
)
end
def child_spec(opts) do
%{
id: __MODULE__,
start: {__MODULE__, :start_link, [opts]},
type: :worker,
restart: :permanent,
shutdown: 5000,
}
end
end