This document describes cell 0.0. For development docs, go here.
cell.presence¶
cell.presence
-
class
cell.presence.
AwareActorMixin
¶ -
lookup
(value)¶
-
meta_lookup_section
= None¶
-
send_to_able
(method, args={}, to=None, **kwargs)¶
-
wakeup_all_agents
()¶
-
-
class
cell.presence.
AwareAgent
(connection, id=None, actors=None)¶ -
get_default_scatter_limit
(actor)¶
-
lookup_agent
(pred, *sections)¶
-
lookup_agents
(pred, *sections)¶
-
on_awake
()¶
-
on_presence_ready
()¶
-
on_run
()¶
-
presence
¶
-
-
class
cell.presence.
Event
¶
-
class
cell.presence.
Presence
(agent, interval=None, on_awake=None)¶ -
class
Event
¶
-
class
Presence.
State
(presence)¶ -
agents
¶
-
agents_by_meta
(predicate, *sections)¶
-
can
(actor)¶
-
expire_agents
()¶
-
first_agent_by_meta
(predicate, *sections)¶
-
logger_name
= 'cell.presence.state'¶
-
meta_for
(actor)¶
-
neighbors
()¶
-
on_message
(body, message)¶
-
update_agent
(agent=None, **kw)¶
-
update_meta_for
(agent, meta)¶
-
when_heartbeat
(agent=None, **kw)¶
-
when_offline
(agent=None, **kw)¶
-
when_online
(agent=None, **kw)¶
-
when_wakeup
(**kw)¶
-
-
Presence.
announce
(event, **retry_policy)¶
-
Presence.
can
(actor)¶
-
Presence.
create_event
(type)¶
-
Presence.
exchange
= <unbound Exchange cl.agents(topic)>¶
-
Presence.
extra_context
(*args, **kwds)¶
-
Presence.
g
= None¶
-
Presence.
get_consumers
(Consumer, channel)¶
-
Presence.
get_queue
()¶
-
Presence.
interval
= 10¶
-
Presence.
logger_name
¶
-
Presence.
meta
()¶
-
Presence.
send_heartbeat
()¶
-
Presence.
send_offline
()¶
-
Presence.
send_online
()¶
-
Presence.
should_stop
¶
-
Presence.
start
()¶
-
Presence.
wakeup
()¶
-
class
-
class
cell.presence.
State
(presence)¶ -
agents
¶
-
agents_by_meta
(predicate, *sections)¶
-
can
(actor)¶
-
expire_agents
()¶
-
first_agent_by_meta
(predicate, *sections)¶
-
logger_name
= 'cell.presence.state'¶
-
meta_for
(actor)¶
-
neighbors
()¶
-
on_message
(body, message)¶
-
update_agent
(agent=None, **kw)¶
-
update_meta_for
(agent, meta)¶
-
when_heartbeat
(agent=None, **kw)¶
-
when_offline
(agent=None, **kw)¶
-
when_online
(agent=None, **kw)¶
-
when_wakeup
(**kw)¶
-
-
cell.presence.
announce_after
(fun)¶