We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 02e75d0 commit b1da8e5Copy full SHA for b1da8e5
src/ra_kv.erl
@@ -76,7 +76,7 @@ start_cluster(System, ClusterName, #{members := ServerIds})
76
-spec add_member(System :: atom(),
77
NewMemberId :: ra_server_id(),
78
LeaderId :: ra_server_id()) ->
79
- ok | {error, term()}.
+ ok | {error, term()} | {timeout, ra_server_id()}.
80
add_member(System, {Name, _} = Id, LeaderId0) ->
81
{ok, Members, LeaderId1} = ra:members(LeaderId0),
82
?assert(not lists:member(Id, Members)),
@@ -105,7 +105,7 @@ add_member(System, {Name, _} = Id, LeaderId0) ->
105
-spec remove_member(System :: atom(),
106
107
108
109
remove_member(System, Id, LeaderId0) ->
110
{ok, Members, _} = ra:members(LeaderId0),
111
RemainingMembers = lists:delete(Id, Members),
src/ra_kv_harness.erl
@@ -923,7 +923,7 @@ validate_key_across_members(Key, ExpectedValue, Members) ->
923
false -> error
924
end.
925
926
-partitioned_node_name(#{partitioned_state := #{partitioned_node := {_, Node}}}) ->
+partitioned_node_name(#{partition_state := #{partitioned_node := {_, Node}}}) ->
927
Node;
928
partitioned_node_name(_State) ->
929
none.
0 commit comments