Struct OwnedExecutor 

pub struct OwnedExecutor<H: NodeHandler> { /* private fields */ }

Owned executor that can be reused across runs without leaking the plan.

Implementations

impl<H: NodeHandler> OwnedExecutor<H>

pub fn new(plan: Arc<RuntimePlan>, handler: H) -> Self

pub fn with_const_coercers(self, coercers: ConstCoercerMap) -> Self

Provide a shared constant coercer registry (used by dynamic plugins).

pub fn with_output_movers(self, movers: OutputMoverMap) -> Self

Provide a shared output mover registry (used by dynamic plugins).

pub fn with_state(self, state: StateStore) -> Self

pub fn without_gpu(self) -> Self

pub fn with_pool_size(self, size: Option<usize>) -> Self

pub fn with_host_bridges(self, mgr: HostBridgeManager) -> Self

pub fn reset(&mut self)

pub fn run_in_place(&mut self) -> Result<ExecutionTelemetry, ExecuteError>

pub fn run_parallel_in_place( &mut self, ) -> Result<ExecutionTelemetry, ExecuteError>

where H: Send + Sync + 'static,