Module ImportFrom alias ImportFrom alias ImportFrom alias alias ImportFrom alias Assign NameStore ListLoad Str Str Str Str Str Assign NameStore Dict FunctionDef arguments args NameParam NameParam defaults NameLoad body If Call NameLoad NameLoad NameLoad body Return NameLoad orelse If Call NameLoad NameLoad Str body Return Call NameLoad AttributeLoad NameLoad attr orelse If NameLoad body Return NameLoad orelse Raise Call NameLoad BinOpMod Str NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return IfExp Call NameLoad NameLoad Str AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr If UnaryOpNot NameLoad body Raise Call NameLoad NameLoad Return NameLoad decorator_list ClassDef bases body Expr Str FunctionDef arguments args NameParam NameParam defaults NameLoad body Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr FunctionDef arguments args NameParam NameParam NameParam defaults body Return Call NameLoad NameLoad NameLoad NameLoad decorator_list Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Assign NameStore Call NameLoad If Call NameLoad NameLoad NameLoad body Assert CompareIs NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr orelse Assign AttributeStore NameLoad attr NameLoad Expr Call NameLoad NameLoad keyword NameLoad Return NameLoad decorator_list ClassDef bases body Expr Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call NameLoad NameLoad Str NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list Assign NameStore NameLoad FunctionDef arguments args NameParam defaults body Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call NameLoad NameLoad NameLoad Return BoolOpAnd NameLoad CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Return UnaryOpNot Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad Call NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call NameLoad NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign AttributeStore NameLoad attr Call NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Return CompareGt BinOpSub Call NameLoad AttributeLoad NameLoad attr NameLoad orelse Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body If CompareIs AttributeLoad NameLoad attr NameLoad body Assign AttributeStore NameLoad attr Call NameLoad Return NameLoad orelse Assign NameStore BinOpSub Call NameLoad AttributeLoad NameLoad attr Return IfExp CompareGtE NameLoad NameLoad NameLoad NameLoad decorator_list decorator_list
N/A pulsar CommandNotFound pulsar.utils.pep default_timer futures Future chain_future consts * N/A __all__ N/A ActorProxy ActorProxyMonitor get_proxy command get_command N/A global_commands_table N/A get_proxy N/A N/A obj safe N/A False N/A N/A N/A isinstance obj ActorProxy N/A N/A obj N/A N/A N/A hasattr obj proxy N/A N/A N/A get_proxy N/A obj proxy N/A N/A safe N/A N/A None N/A N/A N/A ValueError N/A "%s" is not an actor or actor proxy. obj N/A actor_identity N/A N/A actor N/A N/A N/A N/A N/A hasattr actor aid N/A actor aid actor N/A get_command N/A N/A name N/A N/A N/A Get the command function *name* N/A command N/A N/A global_commands_table get N/A N/A name lower N/A N/A command N/A N/A N/A CommandNotFound name N/A command N/A command N/A N/A N/A Decorator for pulsar command functions.

    :parameter ack: ``True`` if the command acknowledge the sender with a
        response. Usually is set to ``True`` (which is also the default value).
     __init__ N/A N/A self ack N/A True N/A N/A N/A self ack ack N/A __call__ N/A N/A self f N/A N/A N/A N/A self name N/A N/A N/A f __name__ lower command_function N/A N/A request args kwargs N/A N/A N/A N/A f request args kwargs N/A N/A N/A command_function ack N/A self ack N/A N/A command_function __name__ N/A self name N/A N/A command_function __doc__ N/A f __doc__ N/A N/A global_commands_table N/A N/A self name command_function N/A command_function N/A N/A actor_proxy_future N/A N/A aid future N/A None N/A N/A self N/A Future N/A N/A isinstance aid ActorProxyMonitor N/A N/A N/A future None N/A N/A aid callback self N/A N/A self aid N/A aid aid N/A N/A N/A self aid aid N/A N/A chain_future future next self N/A self N/A ActorProxy N/A N/A N/A A proxy for a remote :class:`.Actor`.

    This is a lightweight class which delegates function calls to the
    underlying remote object.

    It is picklable and therefore can be send from actor to actor using
    :ref:`actor message passing <tutorials-messages>`.

    For example, lets say we have a proxy ``a``, to send a message to it::

        from pulsar import send

        send(a, 'echo', 'hello there!')

    will send the :ref:`command <actor_commands>` ``echo`` to actor ``a`` with
    parameter ``"hello there!"``.

    .. attribute:: aid

        Unique ID for the remote :class:`.Actor`

    .. attribute:: address

        the socket address of the underlying :attr:`.Actor.mailbox`.

     __init__ N/A N/A self impl N/A N/A N/A N/A self aid N/A impl aid N/A N/A self name N/A impl name N/A N/A self cfg N/A impl cfg N/A N/A self address N/A getattr impl address None N/A __repr__ N/A N/A self N/A N/A N/A N/A %s(%s) N/A N/A self name N/A self aid N/A N/A __str__ __repr__ proxy N/A N/A self N/A N/A N/A self N/A property __eq__ N/A N/A self o N/A N/A N/A o N/A get_proxy o True N/A N/A o N/A N/A self aid N/A o aid N/A __ne__ N/A N/A self o N/A N/A N/A N/A N/A N/A self __eq__ o N/A N/A ActorProxyMonitor N/A ActorProxy N/A N/A A specialised :class:`.ActorProxy` class.

    It contains additional information about the remote underlying
    :class:`.Actor`. Instances of this class serialise into
    :class:`.ActorProxy`.

    The :class:`.ActorProxyMonitor` is special since it lives in the
    :class:`.Arbiter` domain and it is used by the :class:`.Arbiter`
    (or a :class:`.Monitor`) to monitor the state of the spawned actor.

    .. attribute:: impl

        The :class:`.Concurrency` instance for the remote :class:`.Actor`. This
        dictionary is constantly updated by the remote actor by sending the
        :ref:`info message <actor_info_command>`.

    .. attribute:: info

        Dictionary of information regarding the remote :class:`.Actor`

    .. attribute:: mailbox

        This is the connection with the remote actor. It is available once the
        :ref:`actor handshake <handshake>` between the actor and the monitor
        has completed. The :attr:`mailbox` is a server-side
        :class:`.MailboxProtocol` instance and it is used
        by the :func:`.send` function to send messages to the remote actor.
     N/A monitor None __init__ N/A N/A self impl N/A N/A N/A N/A self impl impl N/A N/A self info N/A N/A N/A self mailbox None N/A N/A self callback None N/A N/A self spawning_start None N/A N/A self stopping_start None N/A N/A N/A N/A super __init__ impl N/A notified N/A N/A self N/A N/A N/A Last time this :class:`.ActorProxyMonitor` was notified by the
        remote actor. N/A N/A N/A N/A self info get last_notified N/A property proxy N/A N/A self N/A N/A N/A The :class:`.ActorProxy` for this monitor. N/A N/A ActorProxy self N/A property __reduce__ N/A N/A self N/A N/A N/A N/A N/A N/A self proxy __reduce__ N/A is_alive N/A N/A self N/A N/A N/A ``True`` if underlying actor is alive.
         N/A N/A N/A N/A self impl is_alive N/A terminate N/A N/A self N/A N/A N/A Terminate life of underlying actor.
         N/A N/A N/A N/A self impl terminate N/A join N/A N/A self timeout N/A None N/A N/A Wait until the underlying actor terminates.

        If ``timeout`` is provided, it raises an exception if the timeout
        is reached.
         N/A N/A N/A N/A self impl join timeout timeout N/A start N/A N/A self N/A N/A N/A Start the remote actor.
         N/A N/A self spawning_start N/A default_timer N/A N/A N/A N/A self impl start N/A should_be_alive N/A N/A self N/A N/A N/A N/A N/A self mailbox N/A N/A N/A N/A N/A default_timer N/A self spawning_start ACTOR_ACTION_TIMEOUT N/A N/A True N/A should_terminate N/A N/A self N/A N/A N/A N/A N/A self stopping_start None N/A N/A N/A self stopping_start N/A default_timer N/A False N/A N/A dt N/A N/A default_timer N/A self stopping_start N/A N/A N/A dt ACTOR_ACTION_TIMEOUT dt False N/A N/A