Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Already on GitHub? Sign in to your account

Add cluster management. #71

Merged
merged 6 commits into from Apr 12, 2013
View
@@ -31,12 +31,10 @@ APPS = kernel stdlib sasl erts ssl tools os_mon runtime_tools crypto inets \
PLT = $(HOME)/.riak_control_dialyzer_plt
check_plt: compile
- dialyzer --check_plt --plt $(PLT) --apps $(APPS) \
- deps/*/ebin
+ dialyzer --check_plt --plt $(PLT) --apps $(APPS)
build_plt: compile
- dialyzer --build_plt --output_plt $(PLT) --apps $(APPS) \
- deps/*/ebin
+ dialyzer --build_plt --output_plt $(PLT) --apps $(APPS)
dialyzer: compile
@echo
@@ -53,3 +51,6 @@ cleanplt:
@echo
sleep 5
rm $(PLT)
+
+typer:
+ typer --annotate -I ../ --plt $(PLT) -r src
View
@@ -31,6 +31,27 @@
-type ring() :: riak_core_ring:riak_core_ring().
-type handoffs() :: [handoff()].
-type vnodes() :: [vnode()].
+-type plan() :: [] | legacy | ring_not_ready | unavailable.
+
+-type stage_error() :: nodedown
+ | already_leaving
+ | not_member
+ | only_member
+ | is_claimant
+ | invalid_replacement
+ | already_replacement
+ | not_reachable
+ | not_single_node
+ | self_join.
+
+-type action() :: leave
+ | remove
+ | {replace, node()}
+ | {force_replace, node()}.
+
+-type claim_percentage() :: number().
+
+-type change() :: {node(), action()}.
-record(partition_info,
{ index :: index(),
@@ -50,7 +71,9 @@
pending_pct :: float(),
mem_total :: integer(),
mem_used :: integer(),
- mem_erlang :: integer()
+ mem_erlang :: integer(),
+ action :: action(),
+ replacement :: node()
}).
-type partitions() :: [#partition_info{}].
Oops, something went wrong.