Packages

delta_crdt

0.1.6
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 causal_dot_set.ex
Raw

lib/delta_crdt/causal_dot_set.ex 

defmodule DeltaCrdt.CausalDotSet do

  defstruct causal_context: DeltaCrdt.CausalContext.new(),

            state: MapSet.new()



  def new(dots \\ [])

  def new([]), do: %__MODULE__{}

  def new(dots), do: %__MODULE__{state: MapSet.new(dots)}

end



defimpl DeltaCrdt.DotStore, for: DeltaCrdt.CausalDotSet do

  def dots(%{state: state}), do: state

end



defimpl DeltaCrdt.SemiLattice, for: DeltaCrdt.CausalDotSet do

  defp convert_bottom(%{state: :bottom} = set) do

    set |> Map.put(:state, MapSet.new())

  end



  defp convert_bottom(set), do: set



  def minimum_delta(_state, delta), do: delta



  def join(set1, set2) do

    set1 = convert_bottom(set1)

    set2 = convert_bottom(set2)



    state =

      MapSet.intersection(set1.state, set2.state)

      |> MapSet.union(

        MapSet.difference(set1.state, DeltaCrdt.CausalContext.dots(set2.causal_context))

      )

      |> MapSet.union(

        MapSet.difference(set2.state, DeltaCrdt.CausalContext.dots(set1.causal_context))

      )



    %DeltaCrdt.CausalDotSet{

      state: state,

      causal_context: DeltaCrdt.CausalContext.join(set1.causal_context, set2.causal_context)

    }

  end



  def bottom?(%{state: dots}) do

    Enum.empty?(dots)

  end



  def compress(s), do: s

end