Packages
eventstore
0.12.0
1.4.8
1.4.7
1.4.6
1.4.4
1.4.3
1.4.2
1.4.1
1.4.0
1.3.2
1.3.1
1.3.0
1.2.3
1.2.2
1.2.1
1.2.0
1.1.0
1.0.3
1.0.2
1.0.1
1.0.0
1.0.0-rc.0
0.17.0
0.16.2
0.16.1
0.16.0
0.15.1
0.15.0
0.14.0
0.14.0-rc.0
0.13.2
0.13.1
0.13.0
0.12.1
0.12.0
0.11.0
0.11.0-rc.0
0.10.1
0.10.0
0.9.0
0.8.1
0.8.0
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.2
0.6.1
0.6.0
0.5.2
0.5.1
0.5.0
0.4.3
0.4.2
0.4.1
0.4.0
0.3.0
0.2.1
0.2.0
0.1.0
0.0.5
0.0.4
0.0.3
0.0.2
0.0.1
Event store using PostgreSQL for persistence.
Current section
Files
Jump to
Current section
Files
lib/event_store/registration/local_registry.ex
defmodule EventStore.Registration.LocalRegistry do
@moduledoc """
Local process registration, restricted to a single node, using Elixir's [Registry](https://hexdocs.pm/elixir/Registry.html)
"""
@behaviour EventStore.Registration
alias EventStore.Publisher
@doc """
Return the local supervisor child spec
"""
@spec child_spec() :: [:supervisor.child_spec()]
@impl EventStore.Registration
def child_spec do
[
Supervisor.child_spec({Registry, [keys: :unique, name: EventStore.Registration.LocalRegistry]}, id: :event_store_local_registry),
]
end
@doc """
Starts a uniquely named child process of a supervisor using the given module and args.
Registers the pid with the given name.
"""
@spec start_child(name :: term(), supervisor :: module(), args :: [any()]) :: {:ok, pid()} | {:error, reason :: term()}
@impl EventStore.Registration
def start_child(name, supervisor, args) do
case whereis_name(name) do
:undefined ->
via_name = {:via, Registry, {EventStore.Registration.LocalRegistry, name}}
Supervisor.start_child(supervisor, args ++ [[name: via_name]])
pid ->
{:ok, pid}
end
end
@doc """
Get the pid of a registered name.
"""
@spec whereis_name(name :: term) :: pid | :undefined
@impl EventStore.Registration
def whereis_name(name), do: Registry.whereis_name({EventStore.Registration.LocalRegistry, name})
@doc """
Return a `:via` tuple to route a message to a process by its registered name
"""
@spec via_tuple(name :: term()) :: {:via, module(), name :: term()}
@impl EventStore.Registration
def via_tuple(name), do: {:via, Registry, {EventStore.Registration.LocalRegistry, name}}
@doc """
Publish events to the `EventStore.Publisher` process
"""
@callback publish_events(stream_uuid :: term, events :: list(EventStore.RecordedEvent.t)) :: :ok
@impl EventStore.Registration
def publish_events(stream_uuid, events) do
Publisher.notify_events(Publisher, stream_uuid, events)
end
end