Convenience library that makes it easier to use statebox with riak, extracted from best practices in our production code at Mochi Media.
Erlang
50
10 commits
updated Nov 20, 2013
Convenience library that makes it easier to use statebox with riak, extracted from best practices in our production code at Mochi Media.
Used in production at Mochi Media.
{ok, Pid} = riakc_pb_socket:start_link("127.0.0.1", 8087),
S = statebox_riak:new([{riakc_pb_socket, Pid}]),
statebox_riak:apply_bucket_ops(
<<"friends">>,
[{[<<"bob">>], statebox_orddict:f_union(following, [<<"alice">>])},
{[<<"alice">>], statebox_orddict:f_union(followers, [<<"bob">>])}],
S),
[<<"alice">>] = orddict:fetch(
following, statebox_riak:get_value(<<"friends">>, <<"bob">>, S)),
[<<"bob">>] = orddict:fetch(
followers, statebox_riak:get_value(<<"friends">>, <<"alice">>, S)).
Erlang
100.0%
Convenience library that makes it easier to use statebox with riak, extracted from best practices in our production code at Mochi Media.
Erlang
50
10 commits
updated Nov 20, 2013
Convenience library that makes it easier to use statebox with riak, extracted from best practices in our production code at Mochi Media.
Used in production at Mochi Media.
{ok, Pid} = riakc_pb_socket:start_link("127.0.0.1", 8087),
S = statebox_riak:new([{riakc_pb_socket, Pid}]),
statebox_riak:apply_bucket_ops(
<<"friends">>,
[{[<<"bob">>], statebox_orddict:f_union(following, [<<"alice">>])},
{[<<"alice">>], statebox_orddict:f_union(followers, [<<"bob">>])}],
S),
[<<"alice">>] = orddict:fetch(
following, statebox_riak:get_value(<<"friends">>, <<"bob">>, S)),
[<<"bob">>] = orddict:fetch(
followers, statebox_riak:get_value(<<"friends">>, <<"alice">>, S)).
Erlang
100.0%