Struct TargetRuntimeManager 

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

Shared runtime container for managing instantiated targets.

This intentionally focuses on low-risk shared lifecycle primitives first: add/remove/close/list/snapshot. Replay workers and reload orchestration can be layered on top in later phases.

Implementations

impl<E> TargetRuntimeManager<E>

where E: PluginEvent,

pub fn new() -> Self

pub fn add_arc(&mut self, target: SharedTarget<E>) -> Option<SharedTarget<E>>

pub fn add_boxed( &mut self, target: Box<dyn Target<E> + Send + Sync>, ) -> Option<SharedTarget<E>>

pub fn get(&self, key: &str) -> Option<SharedTarget<E>>

pub fn get_by_target_id(&self, target_id: &TargetID) -> Option<SharedTarget<E>>

pub fn remove(&mut self, key: &str) -> Option<SharedTarget<E>>

pub fn remove_by_target_id( &mut self, target_id: &TargetID, ) -> Option<SharedTarget<E>>

pub fn clear(&mut self)

pub async fn remove_and_close(&mut self, key: &str) -> Option<SharedTarget<E>>

pub async fn remove_by_target_id_and_close( &mut self, target_id: &TargetID, ) -> Option<SharedTarget<E>>

pub async fn clear_and_close(&mut self) -> Vec<(String, TargetError)>

Closes and removes every target, returning the id and error of each target whose close failed. Surfacing them lets a caller fail an explicit shutdown while still tearing down the rest of the runtime.

pub fn target_ids(&self) -> Vec<TargetID>

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

pub fn values(&self) -> Vec<SharedTarget<E>>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn snapshots(&self) -> Vec<RuntimeTargetSnapshot>

pub fn status_snapshot( &self, replay_workers: &ReplayWorkerManager, ) -> RuntimeStatusSnapshot

pub async fn health_snapshots(&self) -> Vec<RuntimeTargetHealthSnapshot>

Trait Implementations

impl<E> Debug for TargetRuntimeManager<E>

where E: PluginEvent,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<E> Default for TargetRuntimeManager<E>

where E: PluginEvent,

fn default() -> Self

Returns the “default value” for a type.