Index

A

accept_proposal (mango.messages.message.Performatives attribute) ACLMessage (class in mango.messages.acl_message_pb2) (class in mango.messages.message) activate() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) add_message_callback() (mango.modules.mqtt_module.MQTTModule method) (mango.modules.rabbit_module.RabbitModule method) (mango.modules.zero_module.ZeroModule method) add_role() (mango.agent.role.RoleAgent method) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) add_serializer() (mango.messages.codecs.Codec method) addr (mango.agent.core.AgentContext property) (mango.agent.core.AgentDelegates property) (mango.agent.role.RoleContext property) (mango.container.core.ContainerData attribute) Agent (class in mango.agent.core) AgentContext (class in mango.agent.core) AgentDelegates (class in mango.agent.core)

AgentProcessHandle (class in mango.container.core) agree (mango.messages.message.Performatives attribute) aid (mango.agent.role.RoleContext property) aids (mango.container.core.BaseContainerProcessManager property) AIDS (mango.container.core.IPCEventType attribute) aids (mango.container.core.MainContainerProcessManager property) AioDuplex (class in mango.util.multiprocessing) aioduplex() (in module mango.util.multiprocessing) aiopipe() (in module mango.util.multiprocessing) AioPipeReader (class in mango.util.multiprocessing) AioPipeStream (class in mango.util.multiprocessing) AioPipeWriter (class in mango.util.multiprocessing) as_agent_process() (mango.container.core.Container method) (mango.container.external_coupling.ExternalSchedulingContainer method) (mango.container.mqtt.MQTTContainer method) (mango.container.tcp.TCPContainer method) AsyncioClock (class in mango.util.clock) AwaitingProcessTask (class in mango.util.scheduling) AwaitingTask (class in mango.util.scheduling)

B

BaseContainerProcessManager (class in mango.container.core) BaseModule (class in mango.modules.base_module) bind() (mango.agent.role.Role method)

bind_callback() (mango.modules.mqtt_module.MQTTModule static method) (mango.modules.rabbit_module.RabbitModule method) (mango.modules.zero_module.ZeroModule method) broadcast() (mango.util.distributed_clock.DistributedClockManager method)

C

call_for_proposal (mango.messages.message.Performatives attribute) cancel (mango.messages.message.Performatives attribute) cancel_and_wait_for_task() (in module mango.container.core) cfp (mango.messages.message.Performatives attribute) Clock (class in mango.util.clock) clock (mango.container.core.ContainerData attribute) ClockAgent (class in mango.util.distributed_clock) close() (mango.util.multiprocessing.AioPipeStream method) (mango.util.multiprocessing.OwnershiplessConnection method) (mango.util.scheduling.AwaitingTask method) (mango.util.scheduling.ConditionalTask method) (mango.util.scheduling.InstantScheduledTask method) (mango.util.scheduling.ScheduledTask method) (mango.util.scheduling.TimestampScheduledTask method) Codec (class in mango.messages.codecs) codec (mango.container.core.ContainerData attribute) ConditionalProcessTask (class in mango.util.scheduling)

ConditionalTask (class in mango.util.scheduling) confirm (mango.messages.message.Performatives attribute) conn() (mango.modules.mqtt_module.MQTTModule method) connection_lost() (mango.container.protocol.ContainerProtocol method) connection_made() (mango.container.protocol.ContainerProtocol method) Container (class in mango.container.core) ContainerData (class in mango.container.core) ContainerMirrorData (class in mango.container.core) ContainerProtocol (class in mango.container.protocol) context (mango.agent.role.Role property) coro (mango.util.scheduling.Suspendable property) create() (in module mango.container.factory) create_agent_process() (mango.container.core.BaseContainerProcessManager method) (mango.container.core.MainContainerProcessManager method) create_agent_process_environment() (in module mango.container.core) current_timestamp (mango.agent.core.AgentContext property) (mango.agent.core.AgentDelegates property) (mango.agent.role.RoleContext property)

D

data (mango.agent.role.RoleContext property) (mango.container.core.IPCEvent attribute) data_received() (mango.container.protocol.ContainerProtocol method) DataContainer (class in mango.agent.role) deactivate() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) decode() (mango.messages.codecs.Codec method) (mango.messages.codecs.FastJSON method) (mango.messages.codecs.JSON method) (mango.messages.codecs.PROTOBUF method) decode_mqtt_message() (mango.container.mqtt.MQTTContainer method) DecodeError deregister_agent() (mango.agent.core.AgentContext method) (mango.container.core.Container method) (mango.container.mqtt.MQTTContainer method)

DESCRIPTOR (mango.messages.acl_message_pb2.ACLMessage attribute) (mango.messages.other_proto_msgs_pb2.GenericMsg attribute) deserialize_obj() (mango.messages.codecs.Codec method) detach() (mango.util.multiprocessing.AioDuplex method) (mango.util.multiprocessing.AioPipeStream method) disconfirm (mango.messages.message.Performatives attribute) DISPATCH (mango.container.core.IPCEventType attribute) dispatch_to_agent_process() (mango.container.core.BaseContainerProcessManager method) (mango.container.core.Container method) (mango.container.core.MainContainerProcessManager method) distribute_time() (mango.util.distributed_clock.DistributedClockManager method) DistributedClockAgent (class in mango.util.distributed_clock) DistributedClockManager (class in mango.util.distributed_clock) drain() (mango.util.multiprocessing.ObjectStreamWriter method) duration (mango.container.external_coupling.ExternalSchedulingContainerOutput attribute)

E

emit_event() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) encode() (mango.messages.codecs.Codec method) (mango.messages.codecs.FastJSON method) (mango.messages.codecs.JSON method) (mango.messages.codecs.PROTOBUF method) end_mq_thread() (mango.modules.mqtt_module.MQTTModule method) (mango.modules.rabbit_module.RabbitModule method) (mango.modules.zero_module.ZeroModule method)

enum_serializer() (in module mango.messages.message) eof_received() (mango.container.protocol.ContainerProtocol method) event_pipe (mango.container.core.ContainerMirrorData attribute) ext_mirror_container_creator() (in module mango.container.external_coupling) ExternalAgentMessage (class in mango.container.external_coupling) ExternalClock (class in mango.util.clock) ExternalSchedulingContainer (class in mango.container.external_coupling) ExternalSchedulingContainerOutput (class in mango.container.external_coupling) extract_meta() (mango.messages.message.ACLMessage method)

F

failure (mango.messages.message.Performatives attribute)

FastJSON (class in mango.messages.codecs) frameworks (mango.modules.base_module.BaseModule attribute)

G

GenericMsg (class in mango.messages.other_proto_msgs_pb2) get() (mango.agent.role.DataContainer method) get_next_activity() (mango.util.clock.ExternalClock method)

get_next_event() (mango.util.distributed_clock.DistributedClockManager method) get_or_create_model() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method)

H

handle_message() (mango.agent.core.Agent method) (mango.agent.role.RoleAgent method) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.util.distributed_clock.DistributedClockAgent method) (mango.util.distributed_clock.DistributedClockManager method)

handle_message_in_sp() (mango.container.core.BaseContainerProcessManager method) (mango.container.core.MainContainerProcessManager method)

I

inbox_length() (mango.agent.role.RoleContext method) inform (mango.messages.message.Performatives attribute) inform_if (mango.messages.message.Performatives attribute) init (mango.container.core.AgentProcessHandle attribute) init_process() (mango.util.scheduling.ScheduledProcessControl method)

InstantScheduledProcessTask (class in mango.util.scheduling) InstantScheduledTask (class in mango.util.scheduling) IPCEvent (class in mango.container.core) IPCEventType (class in mango.container.core) is_aid_available() (mango.container.core.Container method) is_suspended() (mango.util.scheduling.Suspendable method)

J

JSON (class in mango.messages.codecs)

json_serializable() (in module mango.messages.codecs)

K

kill_process() (mango.util.scheduling.ScheduledProcessControl method)

kill_process_event (mango.util.scheduling.ScheduledProcessControl attribute) kwargs (mango.container.core.ContainerData attribute)

L

log() (mango.modules.mqtt_module.MQTTModule method)

M

main_queue (mango.container.core.ContainerMirrorData attribute) MainContainerProcessManager (class in mango.container.core) mango.agent.core module mango.agent.role module mango.container.core module mango.container.external_coupling module mango.container.factory module mango.container.mqtt module mango.container.protocol module mango.container.tcp module mango.messages.acl_message_pb2 module mango.messages.codecs module mango.messages.message module mango.messages.other_proto_msgs_pb2 module mango.modules.base_module module mango.modules.mqtt_module module mango.modules.rabbit_module module mango.modules.zero_module module mango.util.clock module mango.util.distributed_clock module

mango.util.multiprocessing module mango.util.scheduling module mango.util.termination_detection module message (mango.container.external_coupling.ExternalAgentMessage attribute) message_dict (mango.messages.message.ACLMessage property) message_pipe (mango.container.core.ContainerMirrorData attribute) messages (mango.container.external_coupling.ExternalSchedulingContainerOutput attribute) MirrorContainerProcessManager (class in mango.container.core) module mango.agent.core mango.agent.role mango.container.core mango.container.external_coupling mango.container.factory mango.container.mqtt mango.container.protocol mango.container.tcp mango.messages.acl_message_pb2 mango.messages.codecs mango.messages.message mango.messages.other_proto_msgs_pb2 mango.modules.base_module mango.modules.mqtt_module mango.modules.rabbit_module mango.modules.zero_module mango.util.clock mango.util.distributed_clock mango.util.multiprocessing mango.util.scheduling mango.util.termination_detection mqtt_mirror_container_creator() (in module mango.container.mqtt) MQTTContainer (class in mango.container.mqtt) MQTTModule (class in mango.modules.mqtt_module)

N

next_activity (mango.container.external_coupling.ExternalSchedulingContainerOutput attribute) not_understood (mango.messages.message.Performatives attribute)

notify_running() (mango.util.scheduling.ScheduledTask method) notify_sleeping() (mango.util.scheduling.ScheduledTask method)

O

ObjectStreamReader (class in mango.util.multiprocessing) ObjectStreamWriter (class in mango.util.multiprocessing) obtain_connection() (mango.container.tcp.TCPConnectionPool method) on_change_model() (mango.agent.role.Role method) on_deactivation() (mango.agent.role.Role method) on_disconnect() (mango.modules.mqtt_module.MQTTModule method) on_mqtt_msg() (mango.modules.mqtt_module.MQTTModule method)

on_stop() (mango.agent.role.Role method) (mango.agent.role.RoleHandler method) (mango.util.scheduling.ScheduledTask method) open() (mango.util.multiprocessing.AioDuplex method) (mango.util.multiprocessing.AioPipeStream method) open_readonly() (mango.util.multiprocessing.AioDuplex method) open_writeonly() (mango.util.multiprocessing.AioDuplex method) OwnershiplessConnection (class in mango.util.multiprocessing)

P

Performatives (class in mango.messages.message) PeriodicScheduledProcessTask (class in mango.util.scheduling) PeriodicScheduledTask (class in mango.util.scheduling) pid (mango.container.core.AgentProcessHandle attribute) (mango.container.core.IPCEvent attribute) PipeToWriteQueue (class in mango.util.multiprocessing) pre_hook_reserve_aid() (mango.container.core.BaseContainerProcessManager method) (mango.container.core.MirrorContainerProcessManager method) pre_hook_send_internal_message() (mango.container.core.BaseContainerProcessManager method) (mango.container.core.MainContainerProcessManager method) (mango.container.core.MirrorContainerProcessManager method)

propagate (mango.messages.message.Performatives attribute) propose (mango.messages.message.Performatives attribute) PROTOBUF (class in mango.messages.codecs) proxy (mango.messages.message.Performatives attribute) publish_mq_message() (mango.modules.mqtt_module.MQTTModule method) (mango.modules.rabbit_module.RabbitModule method) (mango.modules.zero_module.ZeroModule method) put() (mango.util.multiprocessing.PipeToWriteQueue method) put_nowait() (mango.util.multiprocessing.PipeToWriteQueue method)

Q

query_if (mango.messages.message.Performatives attribute)

query_ref (mango.messages.message.Performatives attribute)

R

RabbitModule (class in mango.modules.rabbit_module) raise_exceptions() (mango.agent.core.Agent method) (mango.modules.base_module.BaseModule method) read_bytes() (mango.util.multiprocessing.ObjectStreamReader method) read_connection (mango.util.multiprocessing.AioDuplex property) read_object() (mango.util.multiprocessing.ObjectStreamReader method) receiver (mango.container.external_coupling.ExternalAgentMessage attribute) RecurrentScheduledProcessTask (class in mango.util.scheduling) RecurrentScheduledTask (class in mango.util.scheduling) recv() (mango.util.multiprocessing.OwnershiplessConnection method) refuse (mango.messages.message.Performatives attribute) register_agent() (mango.agent.core.AgentContext method) (mango.container.core.Container method) register_proto_type() (mango.messages.codecs.PROTOBUF method) reject_proposal (mango.messages.message.Performatives attribute) release_connection() (mango.container.tcp.TCPConnectionPool method) remove_role() (mango.agent.role.RoleAgent method) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) request (mango.messages.message.Performatives attribute) request_when (mango.messages.message.Performatives attribute)

request_whenever (mango.messages.message.Performatives attribute) resume() (mango.util.scheduling.Scheduler method) (mango.util.scheduling.Suspendable method) resume_task() (mango.util.scheduling.ScheduledProcessControl method) Role (class in mango.agent.role) RoleAgent (class in mango.agent.role) RoleContext (class in mango.agent.role) RoleHandler (class in mango.agent.role) roles (mango.agent.role.RoleAgent property) (mango.agent.role.RoleHandler property) run() (mango.util.scheduling.AwaitingProcessTask method) (mango.util.scheduling.AwaitingTask method) (mango.util.scheduling.ConditionalProcessTask method) (mango.util.scheduling.ConditionalTask method) (mango.util.scheduling.PeriodicScheduledTask method) (mango.util.scheduling.RecurrentScheduledTask method) (mango.util.scheduling.ScheduledTask method) (mango.util.scheduling.TimestampScheduledProcessTask method) (mango.util.scheduling.TimestampScheduledTask method) run_mq() (mango.modules.rabbit_module.RabbitModule method) (mango.modules.zero_module.ZeroModule method) run_task_event (mango.util.scheduling.ScheduledProcessControl attribute)

S

schedule_awaiting_task() (mango.util.scheduling.Scheduler method) schedule_conditional_process_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_conditional_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_instant_acl_message() (mango.agent.core.AgentDelegates method) schedule_instant_message() (mango.agent.core.AgentDelegates method) schedule_instant_process_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_instant_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_periodic_process_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_periodic_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_process_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_recurrent_process_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_recurrent_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_timestamp_process_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) schedule_timestamp_task() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) ScheduledProcessControl (class in mango.util.scheduling) ScheduledProcessTask (class in mango.util.scheduling) ScheduledTask (class in mango.util.scheduling) Scheduler (class in mango.util.scheduling) send() (mango.util.multiprocessing.OwnershiplessConnection method) send_acl_message() (mango.agent.core.AgentContext method) (mango.agent.core.AgentDelegates method) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.container.core.Container method) send_current_time() (mango.util.distributed_clock.DistributedClockManager method) send_message() (mango.agent.core.AgentContext method) (mango.agent.core.AgentDelegates method) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.container.core.Container method) (mango.container.external_coupling.ExternalSchedulingContainer method) (mango.container.mqtt.MQTTContainer method) (mango.container.tcp.TCPContainer method)

SerializationError serialize_obj() (mango.messages.codecs.Codec method) (mango.messages.codecs.PROTOBUF method) set_time() (mango.util.clock.ExternalClock method) setup() (mango.agent.role.Role method) (mango.container.tcp.TCPContainer method) shutdown() (mango.agent.core.Agent method) (mango.agent.role.RoleAgent method) (mango.container.core.BaseContainerProcessManager method) (mango.container.core.Container method) (mango.container.core.MainContainerProcessManager method) (mango.container.core.MirrorContainerProcessManager method) (mango.container.external_coupling.ExternalSchedulingContainer method) (mango.container.mqtt.MQTTContainer method) (mango.container.protocol.ContainerProtocol method) (mango.container.tcp.TCPConnectionPool method) (mango.container.tcp.TCPContainer method) (mango.util.distributed_clock.DistributedClockManager method) (mango.util.scheduling.Scheduler method) sleep() (mango.util.clock.AsyncioClock method) (mango.util.clock.Clock method) (mango.util.clock.ExternalClock method) (mango.util.scheduling.Scheduler method) split_content_and_meta() (mango.messages.message.ACLMessage method) start_mq_thread() (mango.modules.mqtt_module.MQTTModule method) (mango.modules.rabbit_module.RabbitModule method) (mango.modules.zero_module.ZeroModule method) step() (mango.container.external_coupling.ExternalSchedulingContainer method) stop() (mango.util.scheduling.Scheduler method) subscribe (mango.messages.message.Performatives attribute) subscribe() (mango.agent.role.RoleHandler method) subscribe_event() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) subscribe_for_agent() (mango.container.mqtt.MQTTContainer method) subscribe_message() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) subscribe_model() (mango.agent.role.RoleContext method) subscribe_send() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) suspend() (mango.util.scheduling.Scheduler method) (mango.util.scheduling.Suspendable method) suspend_task() (mango.util.scheduling.ScheduledProcessControl method) Suspendable (class in mango.util.scheduling)

T

tasks_complete() (mango.agent.core.AgentDelegates method) (mango.util.scheduling.Scheduler method) tasks_complete_or_sleeping() (in module mango.util.termination_detection) (mango.util.scheduling.Scheduler method) tcp_mirror_container_creator() (in module mango.container.tcp) TCPConnectionPool (class in mango.container.tcp) TCPContainer (class in mango.container.tcp)

terminate_event (mango.container.core.ContainerMirrorData attribute) time (mango.container.external_coupling.ExternalAgentMessage attribute) (mango.util.clock.AsyncioClock property) (mango.util.clock.Clock property) (mango.util.clock.ExternalClock property) TimestampScheduledProcessTask (class in mango.util.scheduling) TimestampScheduledTask (class in mango.util.scheduling) type (mango.container.core.IPCEvent attribute)

U

unfinished_task_count() (in module mango.util.termination_detection) update() (mango.agent.role.DataContainer method) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method)

W

wait_all_done() (mango.util.distributed_clock.ClockAgent method) wait_all_online() (mango.util.distributed_clock.DistributedClockManager method) wait_for_futures() (mango.util.distributed_clock.DistributedClockManager method)

write() (mango.container.protocol.ContainerProtocol method) write_bytes() (mango.util.multiprocessing.ObjectStreamWriter method) write_connection (mango.util.multiprocessing.AioDuplex property) write_object() (mango.util.multiprocessing.ObjectStreamWriter method)

Z

ZeroModule (class in mango.modules.zero_module)