access() noexcept | rotor::supervisor_t | |
access(Args... args) noexcept | rotor::supervisor_t | |
rotor::actor_base_t::access() const noexcept | rotor::actor_base_t | |
rotor::actor_base_t::access(Args... args) const noexcept | rotor::actor_base_t | |
activate_plugins() noexcept | rotor::actor_base_t | |
activating_plugins | rotor::actor_base_t | protected |
active_requests | rotor::actor_base_t | protected |
rotor::actor_base_t::actor_base_t(config_t &cfg) | rotor::actor_base_t | |
address | rotor::actor_base_t | protected |
address_maker | rotor::actor_base_t | protected |
assign_shutdown_reason(extended_error_ptr_t reason) noexcept | rotor::actor_base_t | protected |
AUTOSHUTDOWN_SUPERVISOR | rotor::actor_base_t | static |
cancel_timer(request_id_t request_id) noexcept | rotor::actor_base_t | |
commit_plugin_activation(plugin::plugin_base_t &plugin, bool success) noexcept | rotor::actor_base_t | |
commit_plugin_deactivation(plugin::plugin_base_t &plugin) noexcept | rotor::actor_base_t | |
commit_unsubscription(const subscription_info_ptr_t &info) noexcept | rotor::supervisor_t | virtual |
config_builder_t typedef | rotor::supervisor_t | |
config_t typedef | rotor::supervisor_t | |
configure(plugin::plugin_base_t &plugin) noexcept | rotor::actor_base_t | virtual |
context | rotor::supervisor_t | protected |
continuation_mask | rotor::actor_base_t | protected |
create_actor() | rotor::supervisor_t | inline |
create_address() noexcept | rotor::actor_base_t | |
deactivate_plugins() noexcept | rotor::actor_base_t | |
deactivating_plugins | rotor::actor_base_t | protected |
delivery | rotor::supervisor_t | protected |
do_cancel_timer(request_id_t timer_id) noexcept override | rotor::thread::supervisor_thread_t | virtual |
do_initialize(system_context_t *ctx) noexcept override | rotor::supervisor_t | virtual |
do_process() noexcept | rotor::supervisor_t | inline |
do_request(actor_base_t &actor, const address_ptr_t &dest_addr, const address_ptr_t &reply_to, Args &&...args) noexcept | rotor::supervisor_t | inline |
do_shutdown(const extended_error_ptr_t &reason={}) noexcept override | rotor::supervisor_t | virtual |
do_start_timer(const pt::time_duration &interval, timer_handler_base_t &handler) noexcept override | rotor::thread::supervisor_thread_t | virtual |
enqueue(message_ptr_t message) noexcept override | rotor::thread::supervisor_thread_t | virtual |
ESCALATE_FALIURE | rotor::actor_base_t | static |
get_address() const noexcept | rotor::actor_base_t | inline |
get_identity() const noexcept | rotor::actor_base_t | inline |
get_plugin(const std::type_index &) const noexcept | rotor::actor_base_t | protected |
get_registry_address() const noexcept | rotor::supervisor_t | inline |
get_shutdown_reason() const noexcept | rotor::actor_base_t | inline |
get_supervisor() const noexcept | rotor::actor_base_t | inline |
identity | rotor::actor_base_t | protected |
inbound_queue | rotor::supervisor_t | protected |
inbound_queue_size | rotor::supervisor_t | protected |
inbound_queue_t typedef | rotor::supervisor_t | |
init_continue() noexcept | rotor::actor_base_t | |
init_finish() noexcept | rotor::actor_base_t | virtual |
init_request | rotor::actor_base_t | protected |
init_start() noexcept | rotor::actor_base_t | virtual |
init_timeout | rotor::actor_base_t | protected |
instantiate_address(const void *locality) noexcept | rotor::supervisor_t | protectedvirtual |
intercept(message_ptr_t &message, const void *tag, const continuation_t &continuation) noexcept override | rotor::thread::supervisor_thread_t | virtual |
is_handler typedef | rotor::actor_base_t | |
last_req_id | rotor::supervisor_t | protected |
lifetime | rotor::actor_base_t | protected |
link_server | rotor::actor_base_t | protected |
locality_leader | rotor::supervisor_t | protected |
make_address() noexcept | rotor::supervisor_t | virtual |
make_error(const std::error_code &ec, const extended_error_ptr_t &next={}, const message_ptr_t &request={}) const noexcept | rotor::actor_base_t | protected |
make_response(Request &message, Args &&...args) | rotor::actor_base_t | |
make_response(Request &message, const extended_error_ptr_t &ec) | rotor::actor_base_t | |
manager | rotor::supervisor_t | protected |
on_child_init(actor_base_t *actor, const extended_error_ptr_t &ec) noexcept | rotor::supervisor_t | virtual |
on_child_shutdown(actor_base_t *actor) noexcept | rotor::supervisor_t | virtual |
on_request_trigger(request_id_t timer_id, bool cancelled) noexcept | rotor::supervisor_t | protected |
on_start() noexcept override | rotor::supervisor_t | virtual |
on_subscription(message::subscription_t &message) noexcept | rotor::actor_base_t | |
on_timer_trigger(request_id_t request_id, bool cancelled) noexcept | rotor::actor_base_t | protected |
on_unlink(const address_ptr_t &server_addr) noexcept | rotor::actor_base_t | protectedvirtual |
on_unsubscription(message::unsubscription_t &message) noexcept | rotor::actor_base_t | |
on_unsubscription_external(message::unsubscription_external_t &message) noexcept | rotor::actor_base_t | |
parent | rotor::supervisor_t | protected |
plugins | rotor::actor_base_t | protected |
plugins_list_t typedef | rotor::supervisor_t | |
plugins_storage | rotor::actor_base_t | protected |
poll_duration | rotor::supervisor_t | protected |
PROGRESS_INIT | rotor::actor_base_t | static |
PROGRESS_SHUTDOWN | rotor::actor_base_t | static |
put(message_ptr_t message) | rotor::supervisor_t | inline |
queue | rotor::supervisor_t | protected |
reply_to(Request &message, Args &&...args) | rotor::actor_base_t | |
reply_with_error(Request &message, const extended_error_ptr_t &ec) | rotor::actor_base_t | |
request(const address_ptr_t &dest_addr, Args &&...args) | rotor::actor_base_t | |
request(const address_ptr_t &dest_addr, Args &&...args) | rotor::actor_base_t | |
request_map | rotor::supervisor_t | protected |
request_map_t typedef | rotor::supervisor_t | protected |
request_via(const address_ptr_t &dest_addr, const address_ptr_t &reply_addr, Args &&...args) | rotor::actor_base_t | |
request_via(const address_ptr_t &dest_addr, const address_ptr_t &reply_addr, Args &&...args) | rotor::actor_base_t | |
requests_t typedef | rotor::actor_base_t | protected |
resources | rotor::actor_base_t | protected |
send(const address_ptr_t &addr, Args &&...args) | rotor::actor_base_t | |
should_restart() const noexcept | rotor::actor_base_t | virtual |
shutdown() noexcept override | rotor::thread::supervisor_thread_t | virtual |
shutdown_continue() noexcept | rotor::actor_base_t | |
shutdown_finish() noexcept override | rotor::supervisor_t | virtual |
shutdown_flag | rotor::supervisor_t | protected |
shutdown_poll_frequency | rotor::supervisor_t | protected |
shutdown_reason | rotor::actor_base_t | protected |
shutdown_request | rotor::actor_base_t | protected |
shutdown_start() noexcept | rotor::actor_base_t | virtual |
shutdown_timeout | rotor::actor_base_t | protected |
spawn(factory_t) noexcept | rotor::supervisor_t | |
spawner_address | rotor::actor_base_t | protected |
start() noexcept override | rotor::thread::supervisor_thread_t | virtual |
start_timer(const pt::time_duration &interval, Delegate &delegate, Method method) noexcept | rotor::actor_base_t | |
start_timer(request_id_t request_id, const pt::time_duration &interval, Delegate &delegate, Method method) noexcept | rotor::actor_base_t | protected |
state | rotor::actor_base_t | protected |
subscribe(actor_base_t &actor, Handler &&handler) | rotor::supervisor_t | inline |
subscribe(const handler_ptr_t &handler, const address_ptr_t &addr, const actor_base_t *owner_ptr, owner_tag_t owner_tag) noexcept | rotor::supervisor_t | |
subscribe(Handler &&h, const address_ptr_t &addr) noexcept | rotor::supervisor_t | |
subscribe(Handler &&h) noexcept | rotor::supervisor_t | |
subscription_map | rotor::supervisor_t | protected |
supervisor | rotor::actor_base_t | protected |
supervisor_t(supervisor_config_t &config) | rotor::supervisor_t | |
supervisor_t(const supervisor_t &)=delete (defined in rotor::supervisor_t) | rotor::supervisor_t | |
supervisor_t(supervisor_t &&)=delete (defined in rotor::supervisor_t) | rotor::supervisor_t | |
supervisor_thread_t(supervisor_config_t &cfg) | rotor::thread::supervisor_thread_t | inline |
timers_map | rotor::actor_base_t | protected |
timers_map_t typedef | rotor::actor_base_t | protected |
unsubscribe(Handler &&h, address_ptr_t &addr) noexcept | rotor::actor_base_t | |
unsubscribe(Handler &&h) noexcept | rotor::actor_base_t | |
unsubscribe(const handler_ptr_t &h) noexcept | rotor::actor_base_t | inline |
unsubscribe_actor(const address_ptr_t &addr, Handler &&handler) noexcept | rotor::supervisor_t | inline |
update_time() noexcept | rotor::thread::supervisor_thread_t | |
~actor_base_t() (defined in rotor::actor_base_t) | rotor::actor_base_t | virtual |
~supervisor_t() (defined in rotor::supervisor_t) | rotor::supervisor_t | |