Struct Loader 

pub struct Loader<I, O>
where
    I: Send + 'static,
    O: Send + 'static,
{ /* private fields */ }

Reconstructs runnables from definitions. Caller registers factories by name for each Lambda / Opaque kind they expect to load.

Implementations

impl<I, O> Loader<I, O>

where I: Send + 'static, O: Send + 'static,

pub fn new() -> Self

Empty loader.

pub fn register<F>(&mut self, name: impl Into<String>, factory: F)

where F: Fn(&Value) -> Arc<dyn Runnable<I, O>> + Send + Sync + 'static,

Register a factory for a named lambda or opaque kind. The factory receives the params payload (serde_json::Value::Null for lambdas) and must produce an Arc<dyn Runnable<I, O>>.

pub fn load(&self, def: &RunnableDefinition) -> Result<Arc<dyn Runnable<I, O>>>

Reconstruct a Runnable<I, O> from its definition.

Trait Implementations

impl<I, O> Default for Loader<I, O>

where I: Send + 'static, O: Send + 'static,

fn default() -> Self

Returns the “default value” for a type.