Struct WorkerBuilder 

pub struct WorkerBuilder { /* private fields */ }

Builder pattern for constructing and spawning a worker runtime.

A WorkerBuilder allows you to register multiple SharedObjects under a given name, and then spawn a worker that connects to an RPC broker and handles incoming requests.

Example

struct Calculator;

#[async_trait]
impl SharedObject for Calculator {
    async fn call(&self, method: &str, args: &Value) -> Value {
        match method {
            "add" => {
                let a = args["a"].as_i64().unwrap();
                let b = args["b"].as_i64().unwrap();
                Value::from(a + b)
            }
            _ => Value::Null,
        }
    }
}

WorkerBuilder::new()
    .add("Calculator", Calculator)
    .spawn()
    .await
    .unwrap();

Implementations

impl WorkerBuilder

pub fn new() -> Self

Create a new, empty worker builder.

pub fn add<T>(self, name: &str, obj: T) -> Self

where T: SharedObject + 'static,

Add a named object to the worker.

Arguments

• name - The name under which this object will be registered.
• obj - The object implementing SharedObject.

Returns

Updated WorkerBuilder so calls can be chained.

pub fn with_graceful_shutdown(self) -> (Self, Sender<bool>)

pub async fn spawn(self) -> Result<()>

Spawn the worker runtime with all registered objects.

This connects to the broker (via TCP, Unix socket, or Windows named pipe depending on platform and environment) and begins handling RPC requests.

Trait Implementations

impl Default for WorkerBuilder

fn default() -> Self

Returns the “default value” for a type.