Packages

nebulex

2.1.1
3.0.4 3.0.3 3.0.2 3.0.1 3.0.0 3.0.0-rc.2 3.0.0-rc.1 2.6.6 2.6.5 2.6.4 2.6.3 2.6.2 2.6.1 2.6.0 2.5.2 2.5.1 2.5.0 2.4.2 2.4.1 2.4.0 2.3.2 2.3.1 2.3.0 2.2.1 2.2.0 2.1.1 2.1.0 2.0.0 2.0.0-rc.2 2.0.0-rc.1 2.0.0-rc.0 1.2.2 1.2.1 1.2.0 1.1.1 1.1.0 1.0.1 1.0.0 1.0.0-rc.3 1.0.0-rc.2 1.0.0-rc.1

In-memory and distributed caching toolkit for Elixir

HexDocs

Current section

Files

Jump to
Readme
41 Versions
3 Dependencies
Dependants
Files
Activity
nebulex lib nebulex cache registry.ex
Raw

lib/nebulex/cache/registry.ex 

defmodule Nebulex.Cache.Registry do

  @moduledoc false



  use GenServer



  ## API



  @spec start_link(Keyword.t()) :: GenServer.on_start()

  def start_link(_opts) do

    GenServer.start_link(__MODULE__, :ok, name: __MODULE__)

  end



  @spec register(pid, term) :: :ok

  def register(pid, value) when is_pid(pid) do

    GenServer.call(__MODULE__, {:register, pid, value})

  end



  @spec lookup(atom | pid) :: term

  def lookup(name) when is_atom(name) do

    name

    |> GenServer.whereis()

    |> Kernel.||(raise Nebulex.RegistryLookupError, name: name)

    |> lookup()

  end



  def lookup(pid) when is_pid(pid) do

    {_ref, value} = :persistent_term.get({__MODULE__, pid})

    value

  end



  ## GenServer Callbacks



  @impl true

  def init(:ok) do

    {:ok, :ok}

  end



  @impl true

  def handle_call({:register, pid, value}, _from, state) do

    ref = Process.monitor(pid)

    :ok = :persistent_term.put({__MODULE__, pid}, {ref, value})

    {:reply, :ok, state}

  end



  @impl true

  def handle_info({:DOWN, ref, _type, pid, _reason}, state) do

    {^ref, _} = :persistent_term.get({__MODULE__, pid})

    _ = :persistent_term.erase({__MODULE__, pid})

    {:noreply, state}

  end

end