Index

_ | A | B | C | D | E | F | G | J | K | L | M | N | O | P | Q | R | S | T | U | V | W

_

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

A

abort() (aiomas.local_queue.LocalQueueTransport method)
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.local_queue (module)
aiomas.rpc (module)
aiomas.subproc (module)
aiomas.util (module)
AiomasError
arrow_serializer() (in module aiomas.util)
async() (in module aiomas.util)
AsyncioClock (class in aiomas.clocks)

B

BaseClock (class in aiomas.clocks)

C

cafile (aiomas.agent.SSLCerts attribute)
call_at() (aiomas.clocks.BaseClock method)
call_in() (aiomas.clocks.BaseClock method)
can_write_eof() (aiomas.local_queue.LocalQueueTransport method)
cancel() (aiomas.clocks.TimerHandle method)
certfile (aiomas.agent.SSLCerts attribute)
channel (aiomas.rpc.RpcClient attribute)
Channel (class in aiomas.channel)
ChannelProtocol (class in aiomas.channel)
clear_queue_cache() (in module aiomas.local_queue)
clock (aiomas.agent.Container attribute)
close() (aiomas.channel.Channel method)
(aiomas.local_queue.LocalQueueServer method)
(aiomas.local_queue.LocalQueueTransport method)
(aiomas.rpc.RpcClient method)
codec (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)
create() (aiomas.agent.Container class method)
create_connection() (in module aiomas.local_queue)
create_server() (in module aiomas.local_queue)
create_task() (in module aiomas.util)

D

data_received() (aiomas.channel.ChannelProtocol method)
decode() (aiomas.codecs.Codec method)
DEFAULT_CODEC (in module aiomas.channel)
deserialize_obj() (aiomas.codecs.Codec method)
dict (aiomas.rpc.ServiceDict 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)
get_queue() (in module aiomas.local_queue)

J

JSON (class in aiomas.codecs)

K

keyfile (aiomas.agent.SSLCerts attribute)

L

LocalQueue (class in aiomas.local_queue)
LocalQueueServer (class in aiomas.local_queue)
LocalQueueTransport (class in aiomas.local_queue)
lq (aiomas.local_queue.LocalQueueServer attribute)

M

make_ssl_client_context() (in module aiomas.util)
make_ssl_server_context() (in module aiomas.util)
Manager (class in aiomas.subproc)
MsgPack (class in aiomas.codecs)
MsgPackBlosc (class in aiomas.codecs)

N

name (aiomas.rpc.Router attribute)
new_connection() (aiomas.local_queue.LocalQueue method)
(aiomas.local_queue.LocalQueueServer method)

O

obj (aiomas.rpc.Router attribute)
obj_from_str() (in module aiomas.util)
on_connection_reset() (aiomas.rpc.RpcClient method)
open_connection() (in module aiomas.channel)
(in module aiomas.rpc)
origin (aiomas.exceptions.RemoteException attribute)

P

parent (aiomas.rpc.Router attribute)
path (aiomas.rpc.Router attribute)
pause_writing() (aiomas.channel.ChannelProtocol method)
Proxy (class in aiomas.rpc)

Q

queue_id (aiomas.local_queue.LocalQueue attribute)

R

recv() (aiomas.channel.Channel method)
remote (aiomas.rpc.RpcClient attribute)
remote_traceback (aiomas.exceptions.RemoteException 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.ServiceDict attribute)
Router (class in aiomas.rpc)
rpc_service_process() (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)
SerializationError
serialize_obj() (aiomas.codecs.Codec method)
server (aiomas.local_queue.LocalQueue attribute)
service (aiomas.rpc.RpcClient attribute)
Service (class in aiomas.rpc)
ServiceDict (class in aiomas.rpc)
set_server() (aiomas.local_queue.LocalQueue method)
set_sub_router() (aiomas.rpc.Router method)
set_time() (aiomas.subproc.Manager method)
shutdown() (aiomas.agent.Container method)
sleep() (aiomas.clocks.BaseClock method)
sleep_until() (aiomas.clocks.BaseClock method)
spawn() (aiomas.subproc.Manager method)
SSLCerts (class in aiomas.agent)
start() (in module aiomas.subproc)
start_server() (in module aiomas.channel)
(in module aiomas.rpc)
stop() (aiomas.subproc.Manager method)

T

time() (aiomas.clocks.BaseClock method)
TimerHandle (class in aiomas.clocks)
transport (aiomas.channel.Channel attribute)

U

unset_server() (aiomas.local_queue.LocalQueue method)
utcnow() (aiomas.clocks.BaseClock method)

V

validate_aid() (aiomas.agent.Container method)

W

wait_closed() (aiomas.local_queue.LocalQueueServer method)
write() (aiomas.channel.ChannelProtocol method)
(aiomas.local_queue.LocalQueueTransport method)