Struct RemoteRunner 

pub struct RemoteRunner { /* private fields */ }

A Runner that delegates execution to a remote worker via Transport.

Implementations

impl RemoteRunner

pub fn new(transport: impl Transport + 'static) -> Self

pub fn transport(&self) -> &dyn Transport

Access the underlying transport (for strategy methods).

Trait Implementations

impl Runner for RemoteRunner

fn fit( &self, plan: &ExecutionPlan, filters: &FilterLibrary, _cache: &dyn CacheStore, _event_bus: &Arc<EventBus>, input: &Value, y: Option<&Value>, ) -> Result<(Value, HashMap<String, Value>)>

Train: fit each filter, forward to propagate outputs. Returns (last output, all node outputs).

fn forward( &self, plan: &ExecutionPlan, filters: &FilterLibrary, _cache: &dyn CacheStore, _event_bus: &Arc<EventBus>, input: &Value, ) -> Result<Value>

Inference: forward data through the compiled plan.