Mads
Multi-Agent Distributed System
Loading...
Searching...
No Matches
Mads::Bridge Member List

This is the complete list of members for Mads::Bridge, including all inherited members.

_agent_idMads::Agentprotected
_announce_clock_offset(const Mads::ClockOffsetResult &r)Mads::Agentprotected
_apply_socket_options()Mads::Agentprotected
_attachment_pathMads::Agentprotected
_clock_agent_identity() constMads::Agentprotected
_clock_announce_msMads::Agentprotected
_clock_consensusMads::Agentprotected
_clock_correctionMads::Agentprotected
_clock_interval_msMads::Agentprotected
_clock_mtxMads::Agentmutableprotected
_clock_seqMads::Agentprotected
_clock_sourceMads::Agentprotected
_clock_sync_responderMads::Agentprotected
_clock_threadMads::Agentprotected
_clock_wants_sync() constMads::Agentprotected
_clocksync_last_replyMads::Agentprotected
_clocksync_mtxMads::Agentmutableprotected
_clocksync_pongsMads::Agentprotected
_clocksync_probe_sent_atMads::Agentprotected
_clocksync_probe_seqMads::Agentprotected
_compressionMads::Agentprotected
_configMads::Agentprotected
_configure_clock_sync()Mads::Agentprotected
_conflateMads::Agentprotected
_connectedMads::Agentprotected
_contextMads::Agentprotected
_crossMads::Agentprotected
_cryptoMads::Agentprotected
_curve_authMads::Agentprotected
_dropped_messagesMads::Agentprotected
_event_cvMads::Agentprotected
_event_mtxMads::Agentprotected
_handle_clocksync_message(const nlohmann::json &msg)Mads::Agentprotected
_high_res_loopMads::Agentprotected
_hostnameMads::Agentprotected
_init_doneMads::Agentprotected
_io_reads_subscriberMads::Agentprotected
_io_threadMads::Agentprotected
_key_dirMads::Agentprotected
_last_blobMads::Agentprotected
_last_messageMads::Agentprotected
_last_value_onlyMads::Agentprotected
_latest_messageMads::Agentprotected
_message_state_mutexMads::Agentmutableprotected
_nameMads::Agentprotected
_own_clock_measurementMads::Agentprotected
_pub_endpointMads::Agentprotected
_pub_monitorMads::Agentprotected
_pub_topicMads::Agentprotected
_publish_mutexMads::Agentprotected
_publisherMads::Agentprotected
_raw_settingsMads::Agentprotected
_rc_owns_socketMads::Agentprotected
_receive_timeoutMads::Agentprotected
_remote_controlledMads::Agentprotected
_restartMads::Agentprotected
_run_peer_measurement()Mads::Agentprotected
_runtimeMads::Agentprotected
_settings_fetchedMads::Agentprotected
_settings_jsonMads::Agentprotected
_settings_timeoutMads::Agentprotected
_settings_uriMads::Agentprotected
_shutdown_doneMads::Agentprotected
_spin_marginMads::Agentprotected
_stamp_clock_result(Mads::ClockOffsetResult r, Mads::ClockSource source, uint8_t hops)Mads::Agentprotected
_start_clock_thread()Mads::Agentprotected
_start_io_thread()Mads::Agentprotected
_startup_event_threadMads::Agentprotected
_statusMads::Agentprotected
_stoppingMads::Agentprotected
_sub_endpointMads::Agentprotected
_sub_monitorMads::Agentprotected
_sub_topicMads::Agentprotected
_subscriberMads::Agentprotected
_time_stepMads::Agentprotected
_timecode_offsetMads::Agentprotected
_topic_matches_subscription(const std::string &topic) constMads::Agentprotected
_watchdog_stopMads::Agentprotected
_watchdog_threadMads::Agentprotected
_wildcard_sub_topicMads::Agentprotected
_wire_formatMads::Agentprotected
Agent(std::string name, std::string settings_uri)Mads::Agent
attachment_path()Mads::Agent
auth_verboseMads::Agent
Bridge(std::string name, std::string settings_path)Mads::Bridgeinline
broadcast_clock_probe(std::chrono::milliseconds window=std::chrono::milliseconds(300))Mads::Agent
client_key_nameMads::Agent
clock_domain() constMads::Agent
clock_offset() constMads::Agent
compression() constMads::Agent
conflate()Mads::Agent
connect(std::chrono::milliseconds delay=std::chrono::milliseconds(250))Mads::Agent
connect_pub(std::chrono::milliseconds delay=std::chrono::milliseconds(0))Mads::Agentprotected
connect_sub()Mads::Agentprotected
curve_auth()Mads::Agent
delivery() constMads::Agent
disconnect()Mads::Agent
dropped_messages() constMads::Agent
dummyMads::Agent
enable_high_res_loop(bool on=true, std::chrono::nanoseconds spin_margin=std::chrono::microseconds(200))Mads::Agent
enable_remote_control(bool threaded=false)Mads::Agent
enable_threaded_remote_control()Mads::Agentinline
fetch_settings(bool crypto=false)Mads::Agent
get_agent_id()Mads::Agent
get_settings()Mads::Agent
high_res_loop() constMads::Agent
high_watermark()Mads::Agent
info(std::ostream &out=std::cout)Mads::Agentvirtual
init(std::string name, std::string settings_uri, bool crypto=false, std::filesystem::path const &key_dir="", bool install_watchdog=true)Mads::Agent
init(bool crypto=false, bool install_watchdog=true)Mads::Agent
install_loop_watchdog(uint8_t max_count=3)Mads::Agent
install_signal_handlers()Mads::Agentstatic
is_connected()Mads::Agent
is_crypto()Mads::Agent
keep_running() constMads::Agentinlineprotected
key_dir()Mads::Agent
last_blob()Mads::Agent
last_blob_view() constMads::Agent
last_json()Mads::Agent
last_message()Mads::Agent
last_topic()Mads::Agent
link_state() constMads::Agent
loop(loop_fun_t const &lambda, std::chrono::nanoseconds duration)Mads::Agent
loop(loop_fun_t const &lambda)Mads::Agent
loop_fun_t typedefMads::Agent
measure_clock_offset(size_t samples=5, int timeout_ms=1000)Mads::Agent
name()Mads::Agent
pub_endpoint() constMads::Agentinline
pub_topic() constMads::Agentinline
publish(nlohmann::json payload, std::string topic="")Mads::Agent
publish(const char *payload, size_t len, nlohmann::json meta=nlohmann::json{{"format", "raw"}}, std::string topic="")Mads::Agent
publish(const std::vector< unsigned char > &payload, nlohmann::json meta=nlohmann::json{{"format", "raw"}}, std::string topic="")Mads::Agent
publish_raw_message(const std::string &topic, const std::vector< std::string > &parts)Mads::Agent
receive(bool dont_block=false)Mads::Agent
receive_raw(zmq::multipart_t &message, bool dont_block=false)Mads::Agentprotected
receive_raw_message(std::string &topic, std::vector< std::string > &parts, bool dont_block=false)Mads::Agent
receive_timeout()Mads::Agent
register_event(const event_type event=event_type::marker, const nlohmann::json &info=nlohmann::json(), const std::string &info_name="info")Mads::Agent
remote_control(std::string payload_str)Mads::Agent
restart()Mads::Agent
route()Mads::Bridgeinline
running() constMads::Agentinline
runtime() constMads::Agentinline
save_settings(const std::string path=SETTINGS_PATH)Mads::Agent
server_key_nameMads::Agent
set_agent_id(std::string id)Mads::Agent
set_compression(Compression c)Mads::Agent
set_conflate(bool conflate)Mads::Agent
set_cross(bool cross)Mads::Agent
set_delivery(Delivery d)Mads::Agent
set_high_watermark(int i=1000)Mads::Agent
set_key_dir(const std::filesystem::path &path)Mads::Agent
set_pub_endpoint(std::string endpoint)Mads::Agentinline
set_pub_topic(std::string topic)Mads::Agent
set_receive_timeout(int to)Mads::Agent
set_receive_timeout(std::chrono::milliseconds to)Mads::Agent
set_runtime(std::shared_ptr< Mads::Runtime > runtime)Mads::Agent
set_settings_timeout(int to)Mads::Agent
set_settings_timeout(std::chrono::milliseconds to)Mads::Agent
set_sub_endpoint(std::string endpoint)Mads::Agentinline
set_sub_topic(std::vector< std::string > topics)Mads::Agentinline
set_wire_format(WireFormat fmt)Mads::Agent
settings_are_local() constMads::Agent
settings_timeout()Mads::Agent
settings_uri()Mads::Agent
setup_crypto(Mads::auth_verbose verbose=auth_verbose::off)Mads::Agent
shutdown()Mads::Agent
split_URL(const std::string &url)Mads::Agentprotectedstatic
status()Mads::Agent
sub_endpoint() constMads::Agentinline
sub_topic() constMads::Agentinline
timecode_fpsMads::Agent
wait_for_connection(std::chrono::milliseconds timeout)Mads::Agent
wire_format() constMads::Agent
~Agent()Mads::Agentvirtual