allows non-local actors to subscribe on the local addresses of a supervisor. More...
#include <foreigners_support.h>
Public Member Functions | |
const std::type_index & | identity () const noexcept override |
returns pointer, which uniquely identifiess plugin type | |
void | activate (actor_base_t *actor) noexcept override |
invoked by actor upon initialization. | |
void | deactivate () noexcept override |
deactivates plugin from an actor | |
virtual void | on_call (message::handler_call_t &message) noexcept |
handler for message call | |
virtual void | on_unsubscription (message::commit_unsubscription_t &message) noexcept |
unsubscription message handler | |
virtual void | on_subscription_external (message::external_subscription_t &message) noexcept |
external unsubscription message handler | |
plugin_base_t ()=default | |
default plugin ctor | |
plugin_base_t (const plugin_base_t &)=delete | |
copy ctor is not allowed | |
Public Member Functions inherited from rotor::plugin::plugin_base_t | |
plugin_base_t ()=default | |
default plugin ctor | |
plugin_base_t (const plugin_base_t &)=delete | |
copy ctor is not allowed | |
virtual bool | handle_init (message::init_request_t *message) noexcept |
polls plugin, whether it is done with initialization | |
virtual bool | handle_shutdown (message::shutdown_request_t *message) noexcept |
polls plugin, whether it is done with shutdown | |
virtual void | handle_start (message::start_trigger_t *message) noexcept |
polls plugin, whether it is done with start | |
virtual bool | handle_subscription (message::subscription_t &message) noexcept |
polls plugin, whether it is done with subscription | |
virtual bool | handle_unsubscription (const subscription_point_t &point, bool external) noexcept |
polls plugin, whether it is done with unsubscription | |
virtual bool | forget_subscription (const subscription_point_t &point) noexcept |
remove subscription point from internal storage | |
virtual void | forget_subscription (const subscription_info_ptr_t &info) noexcept |
commits unsubscription via supervisor | |
template<typename Plugin , typename Fn > | |
void | with_casted (Fn &&fn, config_phase_t desired_phase=config_phase_t::INITIALIZING) noexcept |
invokes the callback if plugin type and phase mach | |
reaction_underlying_t | get_reaction () const noexcept |
returns the current set of plugin reactions | |
void | reaction_on (reaction_t value) noexcept |
turns on the specified reaction of the plugin | |
void | reaction_off (reaction_t value) noexcept |
turns off the specified reaction of the plugin | |
template<typename T > | |
auto & | access () noexcept |
generic non-public fields accessor | |
Static Public Attributes | |
static const std::type_index | class_identity |
Static Public Attributes inherited from rotor::plugin::plugin_base_t | |
static constexpr reaction_underlying_t | REACTION_MASK = 0b00001111 |
the bit mask for all reactions enabled | |
Additional Inherited Members | |
Public Types inherited from rotor::plugin::plugin_base_t | |
enum | reaction_t : unsigned { INIT = 0b00000001 , SHUTDOWN = 0b00000010 , SUBSCRIPTION = 0b00000100 , START = 0b00001000 } |
possible plugin's reactions on actor lifetime events | |
using | reaction_underlying_t = std::underlying_type_t< reaction_t > |
the underlying type of reaction_t | |
Protected Member Functions inherited from rotor::plugin::plugin_base_t | |
template<typename Handler > | |
subscription_info_ptr_t | subscribe (Handler &&handler, const address_ptr_t &address) noexcept |
subscribes plugin to the custom plugin handler on the specified address | |
template<typename Handler > | |
subscription_info_ptr_t | subscribe (Handler &&handler) noexcept |
subscribes plugin to the custom plugin handler on the main actor address | |
extended_error_ptr_t | make_error (const std::error_code &ec, const extended_error_ptr_t &next={}, const message_ptr_t &request={}) noexcept |
makes an error within the context of actor | |
Protected Attributes inherited from rotor::plugin::plugin_base_t | |
actor_base_t * | actor |
non-owning actor pointer | |
allows non-local actors to subscribe on the local addresses of a supervisor.
|
overridevirtualnoexcept |
invoked by actor upon initialization.
It it responsible for setting up reactions and further installation, e.g. messages subscriptions and may calling back actor's configuration (which can be postponed).
Before the activate is invoked, the plugin is in PREINIT
phase, after the activate is called, the plugin is in INITIALIZING
phase. This might be useful for early/late (double) plugin configuration in actor.
Reimplemented from rotor::plugin::plugin_base_t.
|
overridevirtualnoexcept |
deactivates plugin from an actor
The method can be intercepted by descendants to do not deactivate too early, and called when needed.
The plugin_base_t
implementation unsubscribes from all plugin subscriptions and when no subscription left commits deactivation to an actor.
Reimplemented from rotor::plugin::plugin_base_t.
|
overridevirtualnoexcept |
returns pointer, which uniquely identifiess plugin type
Implements rotor::plugin::plugin_base_t.
|
static |
The plugin unique identity to allow further static_cast'ing