Struct WorkerHandle 

pub struct WorkerHandle { /* private fields */ }

Handle to a worker process.

Provides methods to send commands, receive responses, and kill the process.

Implementations

impl WorkerHandle

pub fn spawn() -> Result<Self>

Spawn a new worker process.

Looks for the venus-worker binary in the following order:

1. VENUS_WORKER_PATH environment variable
2. Same directory as the current executable
3. System PATH

pub fn send_command(&mut self, cmd: &WorkerCommand) -> Result<()>

Send a command to the worker.

pub fn recv_response(&mut self) -> Result<WorkerResponse>

Receive a response from the worker.

pub fn load_cell( &mut self, dylib_path: PathBuf, dep_count: usize, entry_symbol: String, name: String, ) -> Result<()>

Load a cell in the worker.

pub fn execute(&mut self, inputs: Vec<Vec<u8>>) -> Result<Vec<u8>>

Execute the loaded cell with given inputs.

Returns the raw output bytes on success.

pub fn execute_with_widgets( &mut self, inputs: Vec<Vec<u8>>, widget_values_json: Vec<u8>, ) -> Result<(Vec<u8>, Vec<u8>)>

Execute the loaded cell with given inputs and widget values.

Returns the raw output bytes and widget definitions JSON on success.

pub fn kill(&mut self) -> Result<()>

Kill the worker process immediately.

This is the key feature for interruption - we can terminate the worker mid-computation without any cooperation from the cell.

pub fn is_alive(&mut self) -> bool

Check if the worker process is still running.

pub fn pid(&self) -> u32

Get the process ID of the worker.

pub fn shutdown(self) -> Result<()>

Graceful shutdown - ask worker to exit cleanly.

Trait Implementations

impl Drop for WorkerHandle

fn drop(&mut self)

Executes the destructor for this type.