View Source shards_partition (shards v1.1.1)

Partition Owner.

The partition owner is a gen_server that creates and holds the ETS table associated with the partition.

Summary

Functions

apply_ets_fun(Pid, EtsFun, Args)

compute(Key, Meta)

handle_call(Request, From, State)

handle_cast(Request, State)

handle_info(Reason, State)

init(_)

pid(Tab, Partition)

retrieve_tab(Pid)

start_link(Tab, PartitionedTablePid, PartitionIndex, Options)

stop(Pid)

Equivalent to stop(Server, 5000).

stop(Pid, Timeout)

tid(Tab, Partition)

tid(Tab, Key, Meta)

Functions

apply_ets_fun(Pid, EtsFun, Args)

-spec apply_ets_fun(Pid :: pid(), EtsFun :: atom(), Args :: [term()]) -> term().

compute(Key, Meta)

-spec compute(Key :: term(), Meta :: shards_meta:t()) -> non_neg_integer().

handle_call(Request, From, State)

handle_cast(Request, State)

handle_info(Reason, State)

init(_)

pid(Tab, Partition)

-spec pid(Tab :: shards:tab(), Partition :: non_neg_integer()) -> pid().

retrieve_tab(Pid)

-spec retrieve_tab(Pid :: pid()) -> atom() | ets:tid().

start_link(Tab, PartitionedTablePid, PartitionIndex, Options)

-spec start_link(Tab :: atom() | ets:tid(),
                 PartitionedTablePid :: pid(),
                 PartitionIndex :: non_neg_integer(),
                 Options :: [term()]) ->
                    {ok, pid()} | ignore | {error, term()}.

stop(Pid)

Equivalent to stop(Server, 5000).

stop(Pid, Timeout)

-spec stop(Pid :: pid(), Timeout :: timeout()) -> ok.

tid(Tab, Partition)

-spec tid(Tab :: shards:tab(), Partition :: non_neg_integer()) -> ets:tid().

tid(Tab, Key, Meta)

-spec tid(Tab :: shards:tab(), Key :: term(), Meta :: shards_meta:t()) -> ets:tid().