Struct ProcessEngineRegistry 

pub struct ProcessEngineRegistry { /* private fields */ }

Implementations

impl ProcessEngineRegistry

pub fn new() -> Self

pub fn with_engine(self, engine: Arc<dyn ProcessEngine>) -> Self

pub fn try_with_engine( self, engine: Arc<dyn ProcessEngine>, ) -> Result<Self, PluginError>

Register an engine, rejecting a duplicate ProcessEngine::kind. This is the single enforcement point for unique engine kinds across everything registered on a runtime host, whether the engine was wired directly or contributed through the plugin contract.

pub fn get(&self, kind: &str) -> Option<Arc<dyn ProcessEngine>>

pub fn engines(&self) -> impl Iterator<Item = &Arc<dyn ProcessEngine>>

Iterate over every registered engine, used by the store-peer coherence validator to sweep engine durability tiers.

pub fn require(&self, kind: &str) -> Result<Arc<dyn ProcessEngine>, PluginError>

pub fn validate_input(&self, input: &ProcessInput) -> Result<(), PluginError>

Trait Implementations

impl Clone for ProcessEngineRegistry

fn clone(&self) -> ProcessEngineRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ProcessEngineRegistry

fn default() -> ProcessEngineRegistry

Returns the “default value” for a type.