Index

_

__call__() (aiomas.rpc.Proxy method) __getattr__() (aiomas.rpc.Proxy method)

__weakref__ (aiomas.rpc.Proxy attribute)

A

add() (aiomas.rpc.Router method) add_serializer() (aiomas.codecs.Codec method) addr (aiomas.agent.Agent attribute) Agent (class in aiomas.agent) aiomas (module) aiomas.agent (module) aiomas.channel (module)

aiomas.clocks (module) aiomas.codecs (module) aiomas.exceptions (module) aiomas.rpc (module) aiomas.util (module) async() (in module aiomas.util) AsyncioClock (class in aiomas.clocks)

B

BaseClock (class in aiomas.clocks)

C

call_at() (aiomas.clocks.BaseClock method) call_in() (aiomas.clocks.BaseClock method) channel (aiomas.rpc.RpcClient attribute) Channel (class in aiomas.channel) ChannelProtocol (class in aiomas.channel) clock (aiomas.agent.Container attribute) close() (aiomas.channel.Channel method) (aiomas.rpc.RpcClient method) codec (aiomas.agent.Container attribute) (aiomas.channel.Channel attribute)

Codec (class in aiomas.codecs) connect() (aiomas.agent.Container method) connection_lost() (aiomas.channel.ChannelProtocol method) connection_made() (aiomas.channel.ChannelProtocol method) container (aiomas.agent.Agent attribute) Container (class in aiomas.agent) content (aiomas.channel.Request attribute)

D

data_received() (aiomas.channel.ChannelProtocol method) decode() (aiomas.codecs.Codec method)

deserialize_obj() (aiomas.codecs.Codec method) dict (aiomas.rpc.RoutingDict attribute)

E

encode() (aiomas.codecs.Codec method) eof_received() (aiomas.channel.ChannelProtocol method)

expose() (aiomas.rpc.Router static method) (aiomas.rpc.Service static method) (in module aiomas.rpc) ExternalClock (class in aiomas.clocks)

F

fail() (aiomas.channel.Request method)

G

get_extra_info() (aiomas.channel.Channel method)

J

JSON (class in aiomas.codecs)

M

MsgPack (class in aiomas.codecs)

MsgPackBlosc (class in aiomas.codecs)

N

name (aiomas.rpc.Router attribute)

O

obj (aiomas.rpc.Router attribute)

open_connection() (in module aiomas.channel) (in module aiomas.rpc)

P

parent (aiomas.rpc.Router attribute) path (aiomas.rpc.Router attribute)

pause_writing() (aiomas.channel.ChannelProtocol method) Proxy (class in aiomas.rpc)

R

recv() (aiomas.channel.Channel method) remote (aiomas.rpc.RpcClient attribute) RemoteException reply() (aiomas.channel.Request method) Request (class in aiomas.channel) resolve() (aiomas.rpc.Router method) resume_writing() (aiomas.channel.ChannelProtocol method)

router (aiomas.agent.Agent attribute) (aiomas.rpc.RoutingDict attribute) Router (class in aiomas.rpc) RoutingDict (class in aiomas.rpc) rpc_service() (in module aiomas.rpc) RpcClient (class in aiomas.rpc) run() (in module aiomas.util)

S

send() (aiomas.channel.Channel method) serializable() (in module aiomas.codecs) serialize_obj() (aiomas.codecs.Codec method) service (aiomas.rpc.RpcClient attribute) Service (class in aiomas.rpc) set_sub_router() (aiomas.rpc.Router method)

shutdown() (aiomas.agent.Container method) sleep() (aiomas.clocks.BaseClock method) sleep_until() (aiomas.clocks.BaseClock method) spawn() (aiomas.agent.Container method) start_server() (in module aiomas.channel) (in module aiomas.rpc)

T

time() (aiomas.clocks.BaseClock method)

transport (aiomas.channel.Channel attribute)

U

utcnow() (aiomas.clocks.BaseClock method)

V

validate_aid() (aiomas.agent.Container method)

W

write() (aiomas.channel.ChannelProtocol method)