Struct FFIOperatorLoader 

pub struct FFIOperatorLoader { /* private fields */ }

FFI operator loader for dynamic libraries This is meant to be used as a singleton via get_global_loader()

Implementations

impl FFIOperatorLoader

pub fn load_operator_library(&mut self, path: &Path) -> FFIResult<bool>

pub fn register_operator( &mut self, path: &Path, ) -> FFIResult<Option<LoadedOperatorInfo>>

Register an operator library without instantiating it

This loads the library, validates it as an operator, and extracts metadata without creating an operator instance. Use this for discovery/registration.

Arguments

• path - Path to the shared library file

Returns

• Ok(Some(LoadedOperatorInfo)) - Successfully registered operator with full metadata
• Ok(None) - Library is not a valid FFI operator (silently skipped)
• Err(FFIError) - Loading or validation failed

pub fn load_operator( &mut self, path: &Path, config: &[u8], operator_id: FlowNodeId, ) -> FFIResult<Option<FFIOperator>>

Load an operator from a dynamic library

Arguments

• path - Path to the shared library file
• config - Operator configuration data
• operator_id - ID for this operator instance

Returns

• Ok(Some(FFIOperator)) - Successfully loaded operator
• Ok(None) - Library is not a valid FFI operator (silently skipped)
• Err(FFIError) - Loading or initialization failed

pub fn create_operator_by_name( &mut self, operator: &str, operator_id: FlowNodeId, config: &[u8], ) -> FFIResult<FFIOperator>

Create an operator instance from an already loaded library by name

Arguments

• operator - Name of the operator type
• operator_id - Node ID for this operator instance
• config - Configuration data for the operator

Returns

• Ok(FFIOperator) - Successfully created operator
• Err(FFIError) - Creation failed

pub fn has_operator(&self, operator: &str) -> bool

Check if an operator name is registered

pub fn unload_library(&mut self, path: &Path) -> FFIResult<()>

Unload a library

Arguments

• path - Path to the library to unload

Safety

This will invalidate any operators created from this library. Ensure all operators from this library are destroyed first.

pub fn loaded_count(&self) -> usize

Get the number of loaded libraries

pub fn is_loaded(&self, path: &Path) -> bool

Check if a library is loaded

pub fn list_loaded_operators(&self) -> Vec<LoadedOperatorInfo>

List all loaded operators with their metadata

Trait Implementations

impl Default for FFIOperatorLoader

fn default() -> Self

Returns the “default value” for a type.

impl Drop for FFIOperatorLoader

fn drop(&mut self)

Executes the destructor for this type.