A riak_core application
make release
rebar3 ct
make console
1> tanodb:ping().
{pong,753586781748746817198774991869333432010090217472}
2> q().
Build 3 releases that can run on the same machine:
make devrel
Start them in different consoles:
make dev1-console make dev2-console make dev3-console
join 2 nodes to the first one:
make devrel-join
check the status of the cluster:
make devrel-status
you should see something like this:
================================= Membership ================================== Status Ring Pending Node ------------------------------------------------------------------------------- joining 0.0% -- 'tanodb2@127.0.0.1' joining 0.0% -- 'tanodb3@127.0.0.1' valid 100.0% -- 'tanodb1@127.0.0.1' ------------------------------------------------------------------------------- Valid:1 / Leaving:0 / Exiting:0 / Joining:2 / Down:0
it should say that 3 nodes are joining, now check the cluster plan:
make devrel-cluster-plan
it should display the cluster plan, now we can commit the plan:
make devrel-cluster-commit
check the status of the cluster again:
make devrel-status
you could see the vnodes transfering:
================================= Membership ================================== Status Ring Pending Node ------------------------------------------------------------------------------- valid 75.0% 25.0% 'tanodb1@127.0.0.1' valid 9.4% 25.0% 'tanodb2@127.0.0.1' valid 7.8% 25.0% 'tanodb3@127.0.0.1' ------------------------------------------------------------------------------- Valid:3 / Leaving:0 / Exiting:0 / Joining:0 / Down:0
at some point you should see something like this:
================================= Membership ================================== Status Ring Pending Node ------------------------------------------------------------------------------- valid 33.3% -- 'tanodb1@127.0.0.1' valid 33.3% -- 'tanodb2@127.0.0.1' valid 33.3% -- 'tanodb3@127.0.0.1' ------------------------------------------------------------------------------- Valid:3 / Leaving:0 / Exiting:0 / Joining:0 / Down:0
when you are bored you can stop them:
make devrel-stop
Create some variables in all nodes you are going to run the calls:
FullPrefix = {<<"tanodb">>, <<"config">>}.
Key1 = key_1.
Val1 = <<"value 1">>.Run each line on any node:
riak_core_metadata:get(FullPrefix, Key1).
% undefined
riak_core_metadata:get(FullPrefix, Key1, [{default, default_value_here}]).
% default_value_here
riak_core_metadata:put(FullPrefix, Key1, Val1).
% ok
riak_core_metadata:get(FullPrefix, Key1).
% <<"value 1">>
riak_core_metadata:to_list(FullPrefix).
% [{key_1,[<<"value 1">>]}]
riak_core_metadata:delete(FullPrefix, Key1).
% ok
riak_core_metadata:to_list(FullPrefix).
% [{key_1,['$deleted']}]Trace Metadata Calls:
ReturnTrace = fun(_) -> return_trace() end.
% at most 1000 calls per second
Rate = {1000, 1000}.
recon_trace:calls([{riak_core_broadcast, '_',
fun ([A, _]) when A /= lazy_tick -> return_trace() end},
{riak_core_metadata_hashtree, '_', ReturnTrace},
{riak_core_metadata_object, '_', ReturnTrace},
{riak_core_metadata_manager, '_', ReturnTrace},
{riak_core_metadata_exchange_fsm, '_', ReturnTrace},
{riak_core_metadata, '_', ReturnTrace}], Rate).Clear the trace:
recon_trace:clear().- define license and create LICENSE file
TODO