Packages
gen_server_proxy
0.1.18
0.1.72
0.1.71
0.1.70
0.1.68
0.1.67
0.1.66
0.1.65
0.1.64
0.1.63
0.1.62
0.1.61
0.1.60
0.1.59
0.1.58
0.1.57
0.1.56
0.1.55
0.1.54
0.1.53
0.1.52
0.1.51
0.1.50
0.1.49
0.1.48
0.1.47
0.1.46
0.1.45
0.1.44
0.1.43
0.1.42
0.1.40
0.1.39
0.1.38
0.1.37
0.1.36
0.1.35
0.1.34
0.1.33
0.1.32
0.1.31
0.1.30
0.1.29
0.1.28
0.1.27
0.1.26
0.1.25
0.1.24
0.1.23
0.1.22
0.1.21
0.1.20
0.1.19
0.1.18
0.1.17
0.1.16
0.1.15
0.1.14
0.1.13
0.1.12
0.1.11
0.1.10
0.1.9
0.1.8
0.1.7
0.1.6
0.1.5
0.1.4
0.1.3
0.1.2
0.1.1
0.1.0
Invokes call, cast or stop with a GenServer registered via a server ID. Will wait a bit if the GenServer is not yet registered on restarts.
Current section
Files
Jump to
Current section
Files
lib/gen_server/proxy.ex
defmodule GenServer.Proxy do
@moduledoc """
Makes a GenServer call to a registered server.
Will wait a bit if the server is not yet registered on restarts.
Also supports GenServer cast and GenServer stop.
"""
@doc """
Converts a `server ID` into a server name like a `via tuple`.
## Examples
@impl GenServer.Proxy
def server_name(game_name),
do: {:via, Registry, {:registry, game_name}}
@impl GenServer.Proxy
def server_name(game_name),
do: {:global, {GameServer, game_name}}
"""
@callback server_name(server_id :: term) :: GenServer.name()
@doc ~S'''
Called when the server remains unregistered despite waiting a bit.
## Examples
@impl GenServer.Proxy
def server_unregistered(game_name),
do: IO.puts("Game #{game_name} not started.")
'''
@callback server_unregistered(server_id :: term) :: term
defmacro __using__(options) do
alias = options[:alias]
if alias do
quote do
alias unquote(__MODULE__), as: unquote(alias)
require unquote(alias)
end
else
quote do
import unquote(__MODULE__)
end
end
end
@doc ~S'''
Makes a GenServer call to a registered server given its `server ID`.
Will wait a bit if the server is not yet registered on restarts.
The given `module` (or by default `<caller's_module>.Proxy`) must
implement the 2 callbacks of `GenServer.Proxy` (this module).
## Examples
# Assuming the following callback module:
defmodule Game.Engine.Proxy do
@behaviour GenServer.Proxy
@impl GenServer.Proxy
def server_name(game_name),
do: {:via, Registry, {:registry, game_name}}
@impl GenServer.Proxy
def server_unregistered(game_name),
do: IO.puts("Game #{game_name} not started.")
end
# We could use the call macro like so:
defmodule Game.Engine do
use GenServer.Proxy
def summary(game_name), do: call(:summary, game_name)
...
end
'''
defmacro call(request, server_id, module \\ nil) do
if module do
quote bind_quoted: [request: request, id: server_id, module: module] do
GenServer.Proxy.Caller.call(request, id, module)
end
else
quote bind_quoted: [request: request, id: server_id] do
GenServer.Proxy.Caller.call(request, id, __MODULE__.Proxy)
end
end
end
defmacro cast(request, server_id, module \\ nil) do
if module do
quote bind_quoted: [request: request, id: server_id, module: module] do
GenServer.Proxy.Caster.cast(request, id, module)
end
else
quote bind_quoted: [request: request, id: server_id] do
GenServer.Proxy.Caster.cast(request, id, __MODULE__.Proxy)
end
end
end
defmacro stop(reason, server_id, module \\ nil) do
if module do
quote bind_quoted: [reason: reason, id: server_id, module: module] do
GenServer.Proxy.Stopper.stop(reason, id, module)
end
else
quote bind_quoted: [reason: reason, id: server_id] do
GenServer.Proxy.Stopper.stop(reason, id, __MODULE__.Proxy)
end
end
end
end