Struct TransformRegistry 

pub struct TransformRegistry { /* private fields */ }

A registry of named async transform functions keyed by name.

Both sync and async callables can be registered:

• register — wraps a sync Fn in an async block.
• register_async — stores a native async fn directly.

A shared rhai::Engine is embedded for evaluating EdgeTransform::Script variants. The engine has conservative safety limits applied by default (max_operations = 50_000, max_call_levels = 32).

Implementations

impl TransformRegistry

pub fn new() -> Self

Create an empty registry with a sandboxed Rhai scripting engine.

The engine has the following safety limits:

• Maximum 50,000 operations per script evaluation.
• Maximum 32 nested function call levels.

pub fn register( &mut self, name: impl Into<String>, f: impl Fn(Vec<Value>) -> Value + Send + Sync + 'static, )

Register a synchronous transform function.

The function is wrapped in an async block so it integrates seamlessly with the rest of the async execution path.

pub fn register_async<F, Fut>(&mut self, name: impl Into<String>, f: F)

where F: Fn(Vec<Value>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Value> + Send + 'static,

Register a native async transform function.

Use this when your transform needs to await (e.g. database lookups, HTTP calls, inter-task channels).

pub fn get( &self, name: &str, ) -> Option<&Arc<dyn Fn(Vec<Value>) -> BoxFuture<Value> + Send + Sync>>

Retrieve a named transform function by name.

Trait Implementations

impl Clone for TransformRegistry

fn clone(&self) -> TransformRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for TransformRegistry

fn default() -> Self

Returns the “default value” for a type.