Packages

delta_crdt

0.1.8
0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.10 0.5.9 0.5.8 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.1 0.3.0 0.3.0-rc2 0.3.0-rc1 0.2.1 0.2.0 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

Implementations of δ-CRDTs

HexDocs

Current section

Files

Jump to
Readme
39 Versions
0 Dependencies
Dependants
Files
Activity
delta_crdt lib delta_crdt aw_lww_map.ex
Raw

lib/delta_crdt/aw_lww_map.ex 

defmodule DeltaCrdt.AWLWWMap do

  alias DeltaCrdt.{CausalDotMap, AWSet, ORMap}



  def start_link(notify_pid \\ nil, opts \\ []) do

    DeltaCrdt.CausalCrdt.start_link(new(), notify_pid, opts)

  end



  def new(), do: %CausalDotMap{}



  def add(key, val, i, map) do

    {AWSet, :add, [{val, System.system_time(:nanosecond)}]}

    |> ORMap.apply(key, i, map)

  end



  def remove(key, i, map), do: ORMap.remove(key, i, map)



  def clear(i, map), do: ORMap.clear(i, map)



  def read(%{state: map}) do

    Map.new(map, fn {key, values} ->

      {val, _ts} = Enum.max_by(Map.keys(values.state), fn {_val, ts} -> ts end)

      {key, val}

    end)

  end

end