Struct zng::task::ipc::Worker

pub struct Worker<I, O>
where
    I: IpcValue,
    O: IpcValue,
{ /* private fields */ }

Represents a running worker process.

Implementations

impl<I, O> Worker<I, O>

where I: IpcValue, O: IpcValue,

pub async fn start(worker_name: impl Into<Txt>) -> Result<Worker<I, O>, Error>

Start a worker process implemented in the current executable.

Note that the current process must call run_worker at startup to actually work. You can use zng_env::on_process_start! to inject startup code.

pub async fn start_with( worker_name: impl Into<Txt>, env_vars: &[(&str, &str)], args: &[&str], ) -> Result<Worker<I, O>, Error>

Start a worker process implemented in the current executable with custom env vars and args.

pub async fn start_other( worker_name: impl Into<Txt>, worker_exe: impl Into<PathBuf>, env_vars: &[(&str, &str)], args: &[&str], ) -> Result<Worker<I, O>, Error>

Start a worker process implemented in another executable with custom env vars and args.

pub async fn start_duct( worker_name: impl Into<Txt>, worker: Expression, ) -> Result<Worker<I, O>, Error>

Start a worker process from a custom configured duct process.

Note that the worker executable must call run_worker at startup to actually work. You can use zng_env::on_process_start! to inject startup code.

pub async fn shutdown(self) -> Result<(), Error>

Awaits current tasks and kills the worker process.

pub fn run( &mut self, input: I, ) -> impl Future<Output = Result<O, RunError>> + Send + 'static

Run a task in a free worker thread.

pub fn crash_error(&mut self) -> Option<&WorkerCrashError>

Crash error.

The worker cannot be used if this is set, run requests will immediately disconnect.

Trait Implementations

impl<I, O> Drop for Worker<I, O>

where I: IpcValue, O: IpcValue,

fn drop(&mut self)

Executes the destructor for this type.