maelstrom_rs

Crates.iomaelstrom_rs
lib.rsmaelstrom_rs
version0.1.0
sourcesrc
created_at2022-01-23 19:22:35.505265
updated_at2022-01-23 19:22:35.505265
descriptionA Rust crate to write toy distributed systems with Maelstrom as Actors
homepagehttps://github.com/PierreZ/maelstrom-rs
repositoryhttps://github.com/PierreZ/maelstrom-rs
max_upload_size
id519827
size29,631
Pierre Zemb (PierreZ)

documentation

https://docs.rs/maelstrom_rs

README

maelstrom-rs

A crate that is providing an Actor model to develop toy distributed systems using Maelstrom.

What is Maelstrom?

Maelstrom is a workbench for learning distributed systems by writing your own. It uses the Jepsen testing library to test toy implementations of distributed systems.

Getting started

Examples following the official documentations can be found in the examples folder.

The crate exposes:

  • an Actor trait that you can implement:
  • a Runtime, that will run it.

Examples

use maelstrom_rs::actor::Actor;
use maelstrom_rs::message::{Request, Response};
use maelstrom_rs::error::Error;
use maelstrom_rs::runtime::Runtime;

fn main() {
   let node = EchoActor { node_id: None };
   let mut runtime = Runtime::new(Box::new(node));
   // runtime.start();
}

struct EchoActor {
    node_id: Option<String>,
}

impl Actor for EchoActor {
  fn init(&mut self, node_id: &str, _node_ids: Vec<String>) -> Result<(), Error> {
       self.node_id = Some(String::from(node_id));
       eprintln!("node {} initiated", node_id);
       Ok(())
   }

   fn receive(&mut self, message: &Request) -> Result<Vec<Response>, Error> {
       match message.message_type.as_str() {
           "echo" => unimplemented!(),
           _ => unimplemented!(),
        }
   }
}
Commit count: 11

cargo fmt