Struct WsRemoteExecutor 

pub struct WsRemoteExecutor { /* private fields */ }

A remote executor that dispatches work to workers via WebSocket.

Workers are registered by address + optional token. When execute_remote is called, it finds a matching worker, connects via WS, sends the plan, and waits for the result.

Implementations

impl WsRemoteExecutor

pub fn new() -> Self

pub fn add_worker( &self, address: impl Into<String>, token: Option<String>, tags: Vec<String>, )

Register a worker endpoint.

pub fn has_workers(&self) -> bool

Trait Implementations

impl Default for WsRemoteExecutor

fn default() -> Self

Returns the “default value” for a type.

impl RemoteExecutor for WsRemoteExecutor

fn execute_remote( &self, node_id: &str, target: &RemoteTarget, input: Option<&Value>, ) -> Result<Value>

Execute a sub-plan remotely and return the output value.