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 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)