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( &mut self, path: &Path, config: &[u8], operator_id: FlowNodeId, ) -> FFIResult<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(FFIOperator) - Successfully loaded operator
• Err(FFIError) - Loading or initialization failed

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

Create an operator instance from an already loaded library by name

Arguments

• operator_name - 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_name: &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<(String, PathBuf, u32)>

List all loaded operators with their metadata

Returns a vector of tuples containing:

• Operator name
• Library path
• API version

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.