Packages

delta_crdt

0.1.0
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
5 Dependants
Files
Activity
delta_crdt lib delta_crdt or_map.ex
Raw

lib/delta_crdt/or_map.ex 

defmodule DeltaCrdt.ORMap do

  alias DeltaCrdt.{CausalDotMap, DummyCausalCrdt, CausalContext, DotStore}



  def apply({m, f, a} = op, key, i, %CausalDotMap{} = map) do

    val = Map.get(map.state, key, DummyCausalCrdt.new())

    delta_op = apply(m, f, a ++ [i, %{val | causal_context: map.causal_context}])



    %CausalDotMap{

      state: %{key => Map.put(delta_op, :causal_context, nil)},

      causal_context: delta_op.causal_context,

      keys: MapSet.new([key])

    }

  end



  def remove(key, i, %CausalDotMap{} = map) do

    val = Map.get(map.state, key, DummyCausalCrdt.new())



    %CausalDotMap{

      state: :bottom,

      causal_context: DotStore.dots(val) |> CausalContext.new(),

      keys: MapSet.new([key])

    }

  end



  def clear(i, %CausalDotMap{} = map) do

    %CausalDotMap{

      state: :bottom,

      causal_context: DotStore.dots(map) |> CausalContext.new(),

      keys: map.keys

    }

  end

end