Struct Runtime

pub struct Runtime<W, A, P: Process<W, A>>
where
    W: DeserializeOwned + Serialize,
    A: DeserializeOwned + Serialize,
{ /* private fields */ }

Node runtime

A runtime will create, initialize and run an instance of P.

Parameters

• W the workload body type, e.g. Echo
• A the application body type

Implementations

impl<W, A, P: Process<W, A>> Runtime<W, A, P>

where W: DeserializeOwned + Serialize, A: DeserializeOwned + Serialize,

pub async fn new(args: Vec<String>, process: P) -> Result<Self>

pub async fn run_process(&self) -> Status

Run the process

Run the runtime`s node process. The call will return

• on encountering a fatal error, or
• after Self::shutdown is called

pub async fn run_io_egress(&self)

Run IO egress until Self::shutdown is called

pub async fn run_io_ingress(&self)

Run IO ingress until Self::shutdown is called

pub fn shutdown(&self)

Shutdown the runtime