Packages

exd

0.1.11
0.2.1 0.2.0 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.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

A few sentences (a paragraph) describing the project.

HexDocs

Current section

Files

Jump to
Readme
38 Versions
7 Dependencies
Dependants
Files
Activity
exd lib exd store memory.ex
Raw

lib/exd/store/memory.ex 

defmodule Exd.Store.Memory do

  @moduledoc """

  Uses an in-memory ETS table as store

  """

  use Exd.Store

  use GenServer



  @typedoc "Runtime options for in-memory store"

  @type options :: [{:name, term() | binary()}]



  ## Client



  @spec start_link(options()) :: GenServer.on_start()

  def start_link(opts \\ []) do

    GenServer.start_link(__MODULE__, opts)

  end



  @impl true

  def all(name) do

    entries = for {key, value} <- :ets.match_object(name, {:"$1", :"_"}), do: value

    {:ok, entries}

  end



  @impl true

  def get(name, key) do

    case :ets.lookup(name, key) do

      [{key, value}] ->

        {:ok, value}

      [] ->

        :not_found

      _ ->

        :error

    end

  end



  @impl true

  def put(name, key, value) do

    record = {key, value}

    case :ets.insert(name, record) do

      true ->

        :ok

      _ ->

        :error

    end

  end



  ## Server



  @impl true

  def init(opts) do

    setup_table(opts)

    {:ok, %{}}

  end



  ## Helpers



  defp setup_table(opts) do

    table_name = Keyword.fetch!(opts, :name)

    table_opts = [:set, :named_table, :public, read_concurrency: true]

    :ets.new(table_name, table_opts)



    initial_state = Keyword.get(opts, :initial_state)

    if initial_state do

      for doc <- initial_state do

        put(table_name, doc[opts[:primary_key]], doc)

      end

    end

  end



end