Struct Mesh

pub struct Mesh { /* private fields */ }

Represents a mesh::Node with the ability to spawn new processes that can communicate with any other process belonging to the same mesh.

Process creation

A Mesh instance can spawn new processes with an initial communication channel associated with the mesh. All processes originating from the same mesh can potentially communicate and exchange channels with each other.

Each spawned process can be configured differently via ProcessConfig. Processes are created with Mesh::launch_host.

let mesh = Mesh::new("remote_mesh".to_string()).unwrap();
let (send, recv) = mesh::channel();
mesh.launch_host(ProcessConfig::new("test"), recv).await.unwrap();
send.send(String::from("message for new process"));

Implementations

impl Mesh

pub fn new(mesh_name: String) -> Result<Self>

Creates a new mesh with the given name.

pub async fn launch_host<T: 'static + MeshField + Send>( &self, config: ProcessConfig, initial_message: T, ) -> Result<()>

Spawns a new host in the mesh with the provided configuration and initial message.

The initial message will be provided to the closure passed to try_run_mesh_host().

pub async fn shutdown(self)

Shutdown the mesh and wait for any spawned processes to exit.

The Mesh instance is no longer usable after shutdown.

pub fn crash(&self, pid: i32)

Crashes the child process with the given process ID.

Trait Implementations

impl Inspect for Mesh

fn inspect(&self, req: Request<'_>)

Inspects the object.