Crates.io | maelstrom_rs |
lib.rs | maelstrom_rs |
version | 0.1.0 |
source | src |
created_at | 2022-01-23 19:22:35.505265 |
updated_at | 2022-01-23 19:22:35.505265 |
description | A Rust crate to write toy distributed systems with Maelstrom as Actors |
homepage | https://github.com/PierreZ/maelstrom-rs |
repository | https://github.com/PierreZ/maelstrom-rs |
max_upload_size | |
id | 519827 |
size | 29,631 |
A crate that is providing an Actor model to develop toy distributed systems using 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.
Examples following the official documentations can be found in the examples folder.
The crate exposes:
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!(),
}
}
}