Skip to main content

create_plugin_runtime

ad_core::plugin::runtime

Function create_plugin_runtime 

Source 
pub fn create_plugin_runtime<P: NDPluginProcess>(
    port_name: &str,
    processor: P,
    pool: Arc<NDArrayPool>,
    queue_size: usize,
    ndarray_port: &str,
    wiring: Arc<WiringRegistry>,
) -> (PluginRuntimeHandle, JoinHandle<()>)
Expand description

Create a plugin runtime with control plane (PortActor) and data plane (processing thread).

Returns:

  • PluginRuntimeHandle for wiring and control
  • PortRuntimeHandle for param I/O
  • JoinHandle for the data processing thread