orsim.core package

Submodules

orsim.core.orsim_agent module

class orsim.core.orsim_agent.ORSimAgent(unique_id, run_id, reference_time, init_time_step, scheduler, behavior)[source]

Bases: ABC

add_step_log(message)[source]

agent_failed = False

bootstrap_step(time_step)[source]

abstract estimate_next_event_time()[source]

get_current_time_str()[source]

get_transition_probability(condition, default)[source]

handle_heartbeat_failure()[source]

handle_orsim_agent_message(payload)[source]

is_active()[source]

abstract logout()[source]: process any logout processes needed in the agent.

messenger = None

on_receive_message(client, userdata, message)[source]

payload_cache = None

abstract process_payload(payload)[source]

register_message_handler(topic, method)[source]

reset_step_log()[source]

shutdown()[source]

start_listening()[source]

step_log = {}

stop_listening()[source]

take_first_step(dummy_payload)[source]

orsim.core.orsim_env module

class orsim.core.orsim_env.ORSimEnv[source]

Bases: object

messenger_settings = None

classmethod set_backend(settings)[source]

classmethod validate_orsim_settings(settings)[source]

orsim.core.orsim_scheduler module

class orsim.core.orsim_scheduler.ORSimScheduler(run_id, scheduler_id, orsim_settings, init_failure_handler='soft')[source]

Bases: ABC

add_agent(spec, project_path, agent_class)[source]

async confirm_responses()[source]

on_receive_message(client, userdata, message)[source]

remove_agent(unique_id)[source]

async step()[source]

step_timeout_handler(e)[source]

orsim.core.orsim_scheduler.random() → x in the interval [0, 1).

Module contents