Index

A

accept_proposal (mango.Performatives attribute) activate() (in module mango) (in module mango.express.api) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.RoleContext method) add_edge() (mango.Topology method) add_node() (mango.Topology method) add_note() (mango.SerializationError method) add_role() (mango.agent.role.RoleAgent method) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.RoleAgent method) (mango.RoleContext method) add_serializer() (mango.JSON method) (mango.messages.codecs.Codec method) (mango.PROTOBUF method) addr (mango.Agent property) (mango.agent.core.AgentContext property) (mango.agent.core.AgentDelegates property) (mango.RoleAgent property) (mango.RoleContext property) addr() (in module mango) (in module mango.express.api)

after_start() (mango.express.api.RunWithContainer method) (mango.express.api.RunWithMQTTManager method) Agent (class in mango) (class in mango.agent.core) agent_composed_of() (in module mango) (in module mango.express.api) AgentAddress (class in mango) AgentContext (class in mango.agent.core) AgentDelegates (class in mango.agent.core) agents (mango.Topology property) agree (mango.Performatives attribute) aid (mango.Agent property) (mango.agent.core.AgentDelegates property) (mango.AgentAddress attribute) (mango.RoleAgent property) (mango.RoleContext property) args (mango.SerializationError attribute) as_agent_process() (mango.container.core.Container method) as_agent_process_lazy() (mango.container.core.Container method) AsyncioClock (class in mango) (class in mango.util.clock) AwaitingProcessTask (class in mango.util.scheduling) AwaitingTask (class in mango.util.scheduling)

B

broadcast() (mango.DistributedClockManager method) (mango.util.distributed_clock.DistributedClockManager method)

BROKEN (mango.agent.core.State attribute)

C

call_for_proposal (mango.Performatives attribute) cancel (mango.Performatives attribute) cfp (mango.Performatives attribute) Clock (class in mango.util.clock) clock (mango.agent.core.AgentContext property) ClockAgent (class in mango.util.distributed_clock) close() (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) complete_topology() (in module mango) ComposedAgent (class in mango.express.api) ConditionalProcessTask (class in mango.util.scheduling) ConditionalTask (class in mango.util.scheduling) confirm (mango.Performatives attribute) Container (class in mango.container.core) ContainerActivationManager (class in mango.express.api) context (mango.agent.role.Role property) (mango.Role property)

coro (mango.util.scheduling.Suspendable property) create_acl() (in module mango) create_container_list() (mango.express.api.RunWithContainer method) (mango.express.api.RunWithMQTTManager method) (mango.express.api.RunWithTCPManager method) create_ec_container() (in module mango) create_external_coupling() (in module mango.container.factory) create_mqtt() (in module mango.container.factory) create_mqtt_container() (in module mango) create_tcp() (in module mango.container.factory) create_tcp_container() (in module mango) create_topology() (in module mango) current_timestamp (mango.Agent property) (mango.agent.core.AgentContext property) (mango.agent.core.AgentDelegates property) (mango.agent.role.RoleContext property) (mango.RoleAgent property) (mango.RoleContext property) custom_topology() (in module mango)

D

data (mango.agent.role.RoleContext property) (mango.RoleContext property) DataContainer (class in mango.agent.role) deactivate() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.RoleContext method) decode() (mango.JSON method) (mango.messages.codecs.Codec method) (mango.messages.codecs.JSON method) (mango.messages.codecs.PROTOBUF method) (mango.PROTOBUF method) decode_mqtt_message() (mango.container.mqtt.MQTTContainer method) DecodeError deregister() (mango.agent.core.AgentContext method) (mango.container.core.Container method) (mango.container.mqtt.MQTTContainer method)

deserialize_obj() (mango.JSON method) (mango.messages.codecs.Codec method) (mango.PROTOBUF method) disconfirm (mango.Performatives attribute) dispatch_to_agent_process() (mango.container.core.Container method) distribute_time() (mango.DistributedClockManager method) (mango.util.distributed_clock.DistributedClockManager method) DistributedClockAgent (class in mango) (class in mango.util.distributed_clock) DistributedClockManager (class in mango) (class in mango.util.distributed_clock) duration (mango.container.external_coupling.ExternalSchedulingContainerOutput attribute)

E

emit_event() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.RoleContext method) encode() (mango.JSON method) (mango.messages.codecs.Codec method) (mango.messages.codecs.JSON method) (mango.messages.codecs.PROTOBUF method) (mango.PROTOBUF method)

ext_mirror_container_creator() (in module mango.container.external_coupling) ExternalAgentMessage (class in mango.container.external_coupling) ExternalClock (class in mango) (class in mango.util.clock) ExternalSchedulingContainer (class in mango.container.external_coupling) ExternalSchedulingContainerOutput (class in mango.container.external_coupling)

F

failure (mango.Performatives attribute)

G

get() (mango.agent.role.DataContainer method) get_next_activity() (mango.ExternalClock method) (mango.util.clock.ExternalClock method) get_next_event() (mango.DistributedClockManager method) (mango.util.distributed_clock.DistributedClockManager method)

get_or_create_model() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.RoleContext method) get_role() (mango.agent.role.RoleContext method) (mango.RoleContext method)

H

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

I

INACTIVE (mango.agent.core.State attribute) inbox_length() (mango.agent.role.RoleContext method) (mango.RoleContext method) inform (mango.Performatives attribute) inform_if (mango.Performatives attribute)

init_process() (mango.util.scheduling.ScheduledProcessControl method) inject() (mango.Topology method) InstantScheduledProcessTask (class in mango.util.scheduling) InstantScheduledTask (class in mango.util.scheduling) is_aid_available() (mango.container.core.Container method) is_suspended() (mango.util.scheduling.Suspendable method)

J

JSON (class in mango) (class in mango.messages.codecs)

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

K

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

kill_process_event (mango.util.scheduling.ScheduledProcessControl attribute)

M

make_type_id() (mango.JSON method) (mango.messages.codecs.Codec method) (mango.PROTOBUF method) mango module 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.tcp module mango.express.api module mango.messages.codecs module mango.util.clock module

mango.util.distributed_clock module mango.util.scheduling module mango.util.termination_detection module message (mango.container.external_coupling.ExternalAgentMessage attribute) messages (mango.container.external_coupling.ExternalSchedulingContainerOutput attribute) module mango mango.agent.core mango.agent.role mango.container.core mango.container.external_coupling mango.container.factory mango.container.mqtt mango.container.tcp mango.express.api mango.messages.codecs mango.util.clock mango.util.distributed_clock mango.util.scheduling mango.util.termination_detection mqtt_mirror_container_creator() (in module mango.container.mqtt) MQTTContainer (class in mango.container.mqtt)

N

neighbors() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.agent.core.TopologyService method) (mango.RoleAgent method) (mango.RoleContext method)

next_activity (mango.container.external_coupling.ExternalSchedulingContainerOutput attribute) NORMAL (mango.agent.core.State attribute) not_understood (mango.Performatives attribute) notify_running() (mango.util.scheduling.ScheduledTask method) notify_sleeping() (mango.util.scheduling.ScheduledTask method)

O

observable_tasks (mango.Agent property) (mango.agent.core.Agent property) (mango.RoleAgent property) obtain_connection() (mango.container.tcp.TCPConnectionPool method) on_change_model() (mango.agent.role.Role method) (mango.Role method) on_deactivation() (mango.agent.role.Role method) (mango.Role method) on_ready() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.agent.role.Role method) (mango.agent.role.RoleAgent method) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.container.core.Container method) (mango.DistributedClockManager method) (mango.Role method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.distributed_clock.DistributedClockManager method)

on_register() (mango.Agent method) (mango.agent.core.Agent method) (mango.agent.role.RoleAgent method) (mango.RoleAgent method) on_start() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.agent.role.Role method) (mango.agent.role.RoleAgent method) (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.Role method) (mango.RoleAgent method) (mango.RoleContext method) on_stop() (mango.agent.role.Role method) (mango.agent.role.RoleHandler method) (mango.Role method) (mango.util.scheduling.ScheduledTask method)

P

per_node() (in module mango) Performatives (class in mango) PeriodicScheduledProcessTask (class in mango.util.scheduling) PeriodicScheduledTask (class in mango.util.scheduling) PrintingAgent (class in mango) (class in mango.express.api)

propagate (mango.Performatives attribute) propose (mango.Performatives attribute) PROTOBUF (class in mango) (class in mango.messages.codecs) protocol_addr (mango.AgentAddress attribute) proxy (mango.Performatives attribute)

Q

query_if (mango.Performatives attribute)

query_ref (mango.Performatives attribute)

R

receiver (mango.container.external_coupling.ExternalAgentMessage attribute) RecurrentScheduledProcessTask (class in mango.util.scheduling) RecurrentScheduledTask (class in mango.util.scheduling) refuse (mango.Performatives attribute) register() (mango.agent.core.AgentContext method) (mango.container.core.Container method) register_proto_type() (mango.messages.codecs.PROTOBUF method) (mango.PROTOBUF method) reject_proposal (mango.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) (mango.RoleAgent method) (mango.RoleContext method) request (mango.Performatives attribute) request_when (mango.Performatives attribute) request_whenever (mango.Performatives attribute) resume() (mango.util.scheduling.Scheduler method) (mango.util.scheduling.Suspendable method) resume_task() (mango.util.scheduling.ScheduledProcessControl method) Role (class in mango) (class in mango.agent.role) RoleAgent (class in mango) (class in mango.agent.role)

RoleContext (class in mango) (class in mango.agent.role) RoleHandler (class in mango.agent.role) roles (mango.agent.role.RoleAgent property) (mango.agent.role.RoleHandler property) (mango.RoleAgent 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_task_event (mango.util.scheduling.ScheduledProcessControl attribute) run_with_mqtt() (in module mango) (in module mango.express.api) run_with_tcp() (in module mango) (in module mango.express.api) RunWithContainer (class in mango.express.api) RunWithMQTTManager (class in mango.express.api) RunWithTCPManager (class in mango.express.api)

S

schedule_awaiting_task() (mango.util.scheduling.Scheduler method) schedule_conditional_process_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_conditional_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_instant_message() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) schedule_instant_process_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_instant_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_periodic_process_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_periodic_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_process_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_recurrent_process_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_recurrent_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_timestamp_process_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) (mango.util.scheduling.Scheduler method) schedule_timestamp_task() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext 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_current_time() (mango.DistributedClockManager method) (mango.util.distributed_clock.DistributedClockManager method) send_message() (mango.Agent method) (mango.agent.core.AgentContext method) (mango.agent.core.AgentDelegates method) (mango.agent.role.RoleContext method) (mango.container.core.Container method) (mango.container.external_coupling.ExternalSchedulingContainer method) (mango.container.mqtt.MQTTContainer method) (mango.container.tcp.TCPContainer method) (mango.RoleAgent method) (mango.RoleContext method)

sender_addr() (in module mango) (in module mango.express.api) SerializationError, [1] serialize_obj() (mango.JSON method) (mango.messages.codecs.Codec method) (mango.messages.codecs.PROTOBUF method) (mango.PROTOBUF method) service_of_type() (mango.Agent method) (mango.agent.core.AgentContext method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext method) set_edge_state() (mango.Topology method) set_time() (mango.ExternalClock method) (mango.util.clock.ExternalClock method) setup() (mango.agent.role.Role method) (mango.Role method) shutdown() (mango.Agent method) (mango.agent.core.Agent method) (mango.agent.role.RoleAgent method) (mango.container.core.Container method) (mango.container.mqtt.MQTTContainer method) (mango.container.tcp.TCPConnectionPool method) (mango.container.tcp.TCPContainer method) (mango.DistributedClockManager method) (mango.RoleAgent method) (mango.util.distributed_clock.DistributedClockManager method) (mango.util.scheduling.Scheduler method) sleep() (mango.AsyncioClock method) (mango.ExternalClock method) (mango.util.clock.AsyncioClock method) (mango.util.clock.Clock method) (mango.util.clock.ExternalClock method) (mango.util.scheduling.Scheduler method) start() (mango.container.core.Container method) (mango.container.mqtt.MQTTContainer method) (mango.container.tcp.TCPContainer method) State (class in mango.agent.core) state_to_neighbors (mango.agent.core.TopologyService attribute) step() (mango.container.external_coupling.ExternalSchedulingContainer method) stop() (mango.util.scheduling.Scheduler method) stop_tasks() (mango.util.scheduling.Scheduler method) subscribe (mango.Performatives attribute) subscribe() (mango.agent.role.RoleHandler method) subscribe_event() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.RoleContext method) subscribe_for_agent() (mango.container.mqtt.MQTTContainer method) subscribe_message() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.RoleContext method) subscribe_model() (mango.agent.role.RoleContext method) (mango.RoleContext method) subscribe_send() (mango.agent.role.RoleContext method) (mango.agent.role.RoleHandler method) (mango.RoleContext 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) suspendable_tasks (mango.Agent property) (mango.agent.core.Agent property) (mango.RoleAgent property)

T

tasks_complete() (mango.Agent method) (mango.agent.core.AgentDelegates method) (mango.RoleAgent method) (mango.RoleContext 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)

time (mango.AsyncioClock property) (mango.container.external_coupling.ExternalAgentMessage attribute) (mango.ExternalClock property) (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) Topology (class in mango) TopologyService (class in mango.agent.core)

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) (mango.RoleContext method)

W

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

wait_for_futures() (mango.DistributedClockManager method) (mango.util.distributed_clock.DistributedClockManager method) with_traceback() (mango.SerializationError method)