marina_pool (marina v0.4.3)

View Source

Summary

Functions

init()

-spec init() -> ok.

node()

-spec node() -> {ok, atom()} | {error, marina_pool_not_started}.

node(RoutingKey)

-spec node(binary() | undefined) -> {ok, atom()} | {error, marina_pool_not_started}.

node_id(_)

-spec node_id(binary()) -> atom().

start(Strategy, Nodes)

-spec start(random | token_aware, [{binary(), binary()}]) -> ok.

stop(N)

-spec stop(non_neg_integer()) -> ok.

sync(Strategy, NewNodes, OldNodes)

-spec sync(random | token_aware, [{binary(), binary()}], [{binary(), binary()}]) -> ok.