Struct TargetPluginRegistry 

pub struct TargetPluginRegistry<E>
where
    E: PluginEvent,
{ /* private fields */ }

Implementations

impl<E> TargetPluginRegistry<E>

where E: PluginEvent,

pub fn new() -> Self

pub fn register( &mut self, plugin: TargetPluginDescriptor<E>, ) -> Option<TargetPluginDescriptor<E>>

pub fn register_all<I>(&mut self, plugins: I)

where I: IntoIterator<Item = TargetPluginDescriptor<E>>,

pub fn supports_target_type(&self, target_type: &str) -> bool

pub fn registered_target_types(&self) -> Vec<String>

pub fn create_target( &self, target_type: &str, id: String, config: &KVS, ) -> Result<Box<dyn Target<E> + Send + Sync>, TargetError>

pub async fn create_targets_from_config( &self, config: &Config, route_prefix: &str, ) -> Result<Vec<Box<dyn Target<E> + Send + Sync>>, TargetError>

Creates every enabled target instance found in config.

Creation is fault-isolated per instance: one broken target must not prevent the remaining targets from activating, so failures are logged and summarized instead of aborting the whole activation.

pub async fn create_dormant_targets_from_config( &self, config: &Config, route_prefix: &str, ) -> Result<(Vec<Box<dyn Target<E> + Send + Sync>>, Vec<String>), TargetError>

Creates targets while deferring queue-store open until runtime handoff. Unlike the compatibility activation API, lifecycle preparation reports any invalid or unconstructable configured instance so the originating Admin request cannot report a false success.

pub async fn create_activation_from_config<A>( &self, config: &Config, route_prefix: &str, adapter: &A, ) -> Result<RuntimeActivation<E>, TargetError>

where A: PluginRuntimeAdapter<E> + ?Sized,

Trait Implementations

impl<E> Default for TargetPluginRegistry<E>

where E: PluginEvent,

fn default() -> Self

Returns the “default value” for a type.