Packages
eventstore
0.11.0-rc.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/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.Registration.LocalRegistry.Supervisor
def child_spec do
[
Supervisor.child_spec([]),
]
end
@doc """
Starts a process using the given module/function/args parameters, and registers the pid with the given name.
"""
@spec register_name(name :: term, module :: atom, function :: atom, args :: [term]) :: {:ok, pid} | {:error, term}
@impl EventStore.Registration
def register_name(name, module, fun, [supervisor, args]) do
name = {:via, Registry, {EventStore.Registration.LocalRegistry, name}}
apply(module, fun, [supervisor, args ++ [[name: name]]])
end
@doc """
Get the pid of a registered name.
"""
@spec whereis_name(name :: term) :: pid | :undefined
@impl EventStore.Registration
def whereis_name(name)
def whereis_name(name), do: Registry.whereis_name({EventStore.Registration.LocalRegistry, name})
@doc """
Publish events
"""
@callback publish_events(stream_uuid :: term, events :: list(EventStore.RecordedEvent.t)) :: :ok
@impl EventStore.Registration
def publish_events(stream_uuid, events) do
send(EventStore.Publisher, {:notify_events, stream_uuid, events})
end
defmacro __using__(_opts) do
quote location: :keep do
def via_tuple(name), do: {:via, Registry, {EventStore.Registration.LocalRegistry, name}}
end
end
end