Packages

fifo_dt

0.1.69
0.2.26 0.2.25 0.2.24 0.2.23 0.2.22 0.2.21 0.2.20 0.2.19 0.2.18 0.2.17 0.2.16 0.2.15 0.2.14 0.2.13 0.2.12 0.2.11 0.2.10 0.2.9 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.69 0.1.68 0.1.67 0.1.66 0.1.65

FiFo datatype collection

Current section

Files

Jump to
Readme
32 Versions
6 Dependencies
Dependants
Files
Activity
fifo_dt src ft_cmap.erl
Raw

src/ft_cmap.erl 

-module(ft_cmap).



-export([new/0, value/1, get/2, get/3, merge/2, inc/4, dec/4, remove/3, ctx/1]).



-define(T, riak_dt_emcntr).

-spec new() -> riak_dt_map:map().

new() ->

    riak_dt_map:new().



-spec merge(riak_dt_map:map(), riak_dt_map:map()) -> riak_dt_map:map().

merge(A, B) ->

    riak_dt_map:merge(A, B).



value(Map) ->

    V1 = riak_dt_map:value(Map),

    [{K, V} || {{K, ?T}, V} <- V1].



get(Key, Map) ->

    V1 = riak_dt_map:value(Map),

    case [{K, V} || {{K, ?T}, V} <- V1, K =:= Key] of

        [] ->

            undefined;

        [{_, V}] ->

            {ok, V}

    end.



get(Key, Dflt, Map) ->

    case ft_cmap:get(Key, Map) of

        {ok, V} ->

            V;

        _ ->

            Dflt

    end.



inc(Actor, Key, Value, Map) ->

    Update = {update, [{update, {Key, ?T}, {increment, Value}}]},

    riak_dt_map:update(Update, Actor, Map).



dec(Actor, Key, Value, Map) ->

    Update = {update, [{update, {Key, ?T}, {decrement, Value}}]},

    riak_dt_map:update(Update, Actor, Map).



remove(Actor, Key, Map) ->

    Update = {update, [{remove, {Key, ?T}}]},

    case riak_dt_map:update(Update, Actor, Map) of

        {error, {precondition, {not_present, {Key, ?T}}}} ->

            {ok, Map};

        Res ->

            Res

    end.



ctx(Map) ->

    riak_dt_map:precondition_context(Map).