Struct BuiltinPluginRuntimeAdapter 

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

Built-in in-process runtime adapter that preserves the current replay and activation behavior while presenting a stable runtime contract to callers.

Implementations

impl<E> BuiltinPluginRuntimeAdapter<E>

where E: PluginEvent,

pub fn new( replay_hook: Arc<dyn Fn(ReplayEvent<E>) -> Pin<Box<dyn Future<Output = ()> + Send>> + Send + Sync>, replay_start_observer: Arc<dyn Fn(&str, bool) + Send + Sync>, replay_semaphore: Option<Arc<Semaphore>>, batch_timeout: Duration, idle_sleep: Duration, stop_log_prefix: impl Into<Arc<str>>, ) -> Self

pub async fn prepare_targets( &self, targets: Vec<Box<dyn Target<E> + Send + Sync>>, ) -> PreparedActivation<E>

pub async fn prepare_targets_cancellable( &self, targets: Vec<Box<dyn Target<E> + Send + Sync>>, cancellation: &CancellationToken, ) -> PreparedActivation<E>

pub fn open_prepared_stores( &self, prepared: PreparedActivation<E>, ) -> (OpenedActivation<E>, PreparedActivation<E>)

Opens queue stores only after the previous runtime generation has been quiesced. Targets whose stores cannot be opened retain the established fault-isolation behavior and are returned for lock-free shutdown.

pub fn try_activate_prepared( &self, opened: OpenedActivation<E>, ) -> (RuntimeActivation<E>, PreparedActivation<E>)

pub async fn close_prepared( &self, prepared: PreparedActivation<E>, ) -> Result<(), TargetError>

Trait Implementations

impl<E> Clone for BuiltinPluginRuntimeAdapter<E>

where E: PluginEvent + Clone,

fn clone(&self) -> BuiltinPluginRuntimeAdapter<E>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E> PluginRuntimeAdapter<E> for BuiltinPluginRuntimeAdapter<E>

where E: PluginEvent,

fn activate_with_replay<'life0, 'async_trait>( &'life0 self, targets: Vec<Box<dyn Target<E> + Send + Sync>>, ) -> Pin<Box<dyn Future<Output = RuntimeActivation<E>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn replace_runtime_targets<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, runtime: &'life1 mut TargetRuntimeManager<E>, replay_workers: &'life2 mut ReplayWorkerManager, activation: RuntimeActivation<E>, ) -> Pin<Box<dyn Future<Output = Result<(), TargetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn stop_replay_workers<'life0, 'life1, 'async_trait>( &'life0 self, replay_workers: &'life1 mut ReplayWorkerManager, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn snapshot_runtime_status( &self, runtime: &TargetRuntimeManager<E>, replay_workers: &ReplayWorkerManager, ) -> RuntimeStatusSnapshot

fn snapshot_runtime_health<'life0, 'life1, 'async_trait>( &'life0 self, runtime: &'life1 TargetRuntimeManager<E>, ) -> Pin<Box<dyn Future<Output = Vec<RuntimeTargetHealthSnapshot>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn shutdown<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, runtime: &'life1 mut TargetRuntimeManager<E>, replay_workers: &'life2 mut ReplayWorkerManager, ) -> Pin<Box<dyn Future<Output = Result<(), TargetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,