Behaviours: gen_server.
Authors: Ulf Wiger (ulf.wiger@erlang-consulting.com).
This module implements an extended process registry
For a detailed description, see erlang07-wiger.pdf.
context() = {scope(), type()} | type()
Local scope is the default
headpat() = {keypat(), pidpat(), ValPat}
key() = {type(), scope(), any()}
keypat() = {sel_type() | sel_var(), l | g | sel_var(), any()}
pidpat() = pid() | sel_var()
sel_var() = DollarVar | '_'.
scope() = l | g
l = local registration; g = global registration
sel_pattern() = [{headpat(), Guards, Prod}]
sel_type() = n | p | c | a | names | props | counters | aggr_counters
type() = n | p | c | a
n = name; p = property; c = counter; a = aggregate_counter
add_global_aggr_counter/1 | Registers a global (unique) aggregated counter. |
add_global_counter/2 | Registers a global (non-unique) counter. |
add_global_name/1 | Registers a global (unique) name. |
add_global_property/2 | Registers a global (non-unique) property. |
add_local_aggr_counter/1 | Registers a local (unique) aggregated counter. |
add_local_counter/2 | Registers a local (non-unique) counter. |
add_local_name/1 | Registers a local (unique) name. |
add_local_property/2 | Registers a local (non-unique) property. |
first/1 | Behaves as ets:first(Tab) for a given type of registration object. |
get_value/1 | Read the value stored with a key registered to the current process. |
info/1 | Similar to process_info(Pid) but with additional gproc info. |
info/2 | Similar to process_info(Pid, Item), but with additional gproc info. |
last/1 | Behaves as ets:last(Tab) for a given type of registration object. |
lookup_global_aggr_counter/1 | Lookup a global (unique) aggregated counter and returns its value. |
lookup_global_counters/1 | Look up all global (non-unique) instances of a given Counter. |
lookup_global_name/1 | Lookup a global unique name. |
lookup_global_properties/1 | Look up all global (non-unique) instances of a given Property. |
lookup_local_aggr_counter/1 | Lookup a local (unique) aggregated counter and returns its value. |
lookup_local_counters/1 | Look up all local (non-unique) instances of a given Counter. |
lookup_local_name/1 | Lookup a local unique name. |
lookup_local_properties/1 | Look up all local (non-unique) instances of a given Property. |
lookup_pid/1 | Lookup the Pid stored with a key. |
lookup_pids/1 | Returns a list of pids with the published key Key. |
lookup_values/1 | Retrieve the {Pid,Value} pairs corresponding to Key. |
mreg/3 | Register multiple {Key,Value} pairs of a given type and scope. |
next/2 | Behaves as ets:next(Tab,Key) for a given type of registration object. |
prev/2 | Behaves as ets:prev(Tab,Key) for a given type of registration object. |
reg/1 | Equivalent to reg(Key, undefined). |
reg/2 | Register a name or property for the current process. |
select/1 | Equivalent to select(all, Pat). |
select/2 | Perform a select operation on the process registry. |
select/3 | Like select/2 but returns Limit objects at a time. |
send/2 | Sends a message to the process, or processes, corresponding to Key. |
set_value/2 | Sets the value of the registeration entry given by Key. |
start_link/0 | Starts the gproc server. |
table/1 | Equivalent to table(Context, []). |
table/2 | QLC table generator for the gproc registry. |
unreg/1 | Unregister a name or property. |
update_counter/2 | Updates the counter registered as Key for the current process. |
where/1 | Returns the pid registered as Key. |
add_global_aggr_counter(Name) -> any()
Equivalent to reg({a, l, Name}).
Registers a global (unique) aggregated counter.
add_global_counter(Name, Initial) -> any()
Registers a global (non-unique) counter. @equiv reg({c,g,Name},Value)
add_global_name(Name) -> any()
Registers a global (unique) name. @equiv reg({n,g,Name})
add_global_property(Name, Value) -> any()
Registers a global (non-unique) property. @equiv reg({p,g,Name},Value)
add_local_aggr_counter(Name) -> any()
Equivalent to reg({a, l, Name}).
Registers a local (unique) aggregated counter.
add_local_counter(Name, Initial) -> any()
Registers a local (non-unique) counter. @equiv reg({c,l,Name},Value)
add_local_name(Name) -> any()
Registers a local (unique) name. @equiv reg({n,l,Name})
add_local_property(Name, Value) -> any()
Registers a local (non-unique) property. @equiv reg({p,l,Name},Value)
Behaves as ets:first(Tab) for a given type of registration object.
See http://www.erlang.org/doc/man/ets.html#first-1. The registry behaves as an ordered_set table.get_value(Key) -> Value
Read the value stored with a key registered to the current process.
If no such key is registered to the current process, this function exits.info(Pid::pid()) -> ProcessInfo
Similar to process_info(Pid)
but with additional gproc info.
gproc
information item, containing the {Key,Value}
pairs registered to the process.
info(Pid::pid(), Item::atom()) -> {Item, Info}
Similar to process_info(Pid, Item), but with additional gproc info.
ForItem = gproc
, this function returns a list of {Key, Value}
pairs
registered to the process Pid. For other values of Item, it returns the
same as http://www.erlang.org/doc/man/erlang.html#process_info-2.
Behaves as ets:last(Tab) for a given type of registration object.
See http://www.erlang.org/doc/man/ets.html#last-1. The registry behaves as an ordered_set table.lookup_global_aggr_counter(Name::any()) -> integer()
Equivalent to where({a, g, Name}).
Lookup a global (unique) aggregated counter and returns its value. Fails if there is no such object.
lookup_global_counters(Counter::any()) -> [{pid(), Value::integer()}]
Equivalent to lookup_values({c, l, Counter}).
Look up all global (non-unique) instances of a given Counter. Returns a list of {Pid, Value} tuples for all matching objects.
lookup_global_name(Name::any()) -> pid()
Equivalent to where({n, g, Name}).
Lookup a global unique name. Fails if there is no such name.
lookup_global_properties(Property::any()) -> [{pid(), Value}]
Equivalent to lookup_values({p, g, Property}).
Look up all global (non-unique) instances of a given Property. Returns a list of {Pid, Value} tuples for all matching objects.
lookup_local_aggr_counter(Name::any()) -> integer()
Equivalent to where({a, l, Name}).
Lookup a local (unique) aggregated counter and returns its value. Fails if there is no such object.
lookup_local_counters(Counter::any()) -> [{pid(), Value::integer()}]
Equivalent to lookup_values({c, l, Counter}).
Look up all local (non-unique) instances of a given Counter. Returns a list of {Pid, Value} tuples for all matching objects.
lookup_local_name(Name::any()) -> pid()
Equivalent to where({n, l, Name}).
Lookup a local unique name. Fails if there is no such name.
lookup_local_properties(Property::any()) -> [{pid(), Value}]
Equivalent to lookup_values({p, l, Property}).
Look up all local (non-unique) instances of a given Property. Returns a list of {Pid, Value} tuples for all matching objects.
lookup_pid(Key) -> Pid
Lookup the Pid stored with a key.
lookup_pids(Key::key()) -> [pid()]
Returns a list of pids with the published key Key
If the type of registration entry is either name or aggregated counter, this function will return either an empty list, or a list of one pid. For non-unique types, the return value can be a list of any length.lookup_values(Key::key()) -> [{pid(), Value}]
Retrieve the {Pid,Value}
pairs corresponding to Key.
Register multiple {Key,Value} pairs of a given type and scope.
This function is more efficient than callingreg/2
repeatedly.
Behaves as ets:next(Tab,Key) for a given type of registration object.
See http://www.erlang.org/doc/man/ets.html#next-2. The registry behaves as an ordered_set table.Behaves as ets:prev(Tab,Key) for a given type of registration object.
See http://www.erlang.org/doc/man/ets.html#prev-2. The registry behaves as an ordered_set table.reg(Key::key()) -> true
Equivalent to reg(Key, undefined).
reg(Key::key(), Value) -> true
Register a name or property for the current process
select(Pat::select_pattern()) -> list(sel_object())
Equivalent to select(all, Pat).
select(Type::sel_type(), Pat::sel_pattern()) -> [{Key, Pid, Value}]
Perform a select operation on the process registry.
The physical representation in the registry may differ from the above, but the select patterns are transformed appropriately.select(Type::sel_type(), Pat::sel_patten(), Limit::integer()) -> [{Key, Pid, Value}]
Like select/2
but returns Limit objects at a time.
send(Key::key(), Msg::any()) -> Msg
Sends a message to the process, or processes, corresponding to Key.
If Key belongs to a unique object (name or aggregated counter), this function will send a message to the corresponding process, or fail if there is no such process. If Key is for a non-unique object type (counter or property), Msg will be send to all processes that have such an object.set_value(Key::key(), Value) -> true
Sets the value of the registeration entry given by Key
Key is assumed to exist and belong to the calling process. If it doesn't, this function will exit.
Value can be any term, unless the object is a counter, in which case it must be an integer.start_link() -> {ok, pid()}
Starts the gproc server.
This function is intended to be called from gproc_sup, as part of starting the gproc application.table(Context::context()) -> any()
Equivalent to table(Context, []).
table(Context::context(), Opts) -> any()
QLC table generator for the gproc registry. Context specifies which subset of the registry should be queried. See http://www.erlang.org/doc/man/qlc.html.
unreg(Key::key()) -> true
Unregister a name or property.
update_counter(Key::key(), Incr::integer()) -> integer()
Updates the counter registered as Key for the current process.
This function works like ets:update_counter/3 (see http://www.erlang.org/doc/man/ets.html#update_counter-3), but will fail if the type of object referred to by Key is not a counter.where(Key::key()) -> pid()
Returns the pid registered as Key
The type of registration entry must be either name or aggregated counter. Otherwise this function will exit. Uselookup_pids/1
in these
cases.
Generated by EDoc, Sep 22 2009, 10:04:07.