Struct MaelstromDeployment 

pub struct MaelstromDeployment {
    pub node_count: usize,
    pub maelstrom_path: PathBuf,
    pub workload: String,
    pub time_limit: Option<u64>,
    pub rate: Option<u64>,
    pub availability: Option<String>,
    pub nemesis: Option<String>,
    pub extra_args: Vec<String>,
    /* private fields */
}

Available on crate feature maelstrom only.

The Maelstrom deployment environment.

This holds configuration for the Maelstrom run and accumulates compilation artifacts during deployment.

Fields

node_count: usize

Number of nodes in the cluster.

maelstrom_path: PathBuf

Path to the maelstrom binary.

workload: String

Workload to run (e.g., “echo”, “broadcast”, “g-counter”).

time_limit: Option<u64>

Time limit in seconds.

rate: Option<u64>

Rate of requests per second.

availability: Option<String>

The availability of nodes.

nemesis: Option<String>

Nemesis to run during tests.

extra_args: Vec<String>

Additional maelstrom arguments.

Implementations

impl MaelstromDeployment

pub fn new(workload: impl Into<String>) -> Self

Available on crate feature deploy only.

Create a new Maelstrom deployment with the given node count.

pub fn node_count(self, count: usize) -> Self

Available on crate feature deploy only.

Set the node count.

pub fn maelstrom_path(self, path: impl Into<PathBuf>) -> Self

Available on crate feature deploy only.

Set the path to the maelstrom binary.

pub fn time_limit(self, seconds: u64) -> Self

Available on crate feature deploy only.

Set the time limit in seconds.

pub fn rate(self, rate: u64) -> Self

Available on crate feature deploy only.

Set the request rate per second.

pub fn availability(self, availability: impl Into<String>) -> Self

Available on crate feature deploy only.

Set the availability for the test.

pub fn nemesis(self, nemesis: impl Into<String>) -> Self

Available on crate feature deploy only.

Set the nemesis for the test.

pub fn extra_args( self, args: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Available on crate feature deploy only.

Add extra arguments to pass to maelstrom.

pub fn build(&self) -> Result<PathBuf, Error>

Available on crate feature deploy only.

Build the compiled binary in dev mode. Returns the path to the compiled binary.

pub fn run(self) -> Result<(), Error>

Available on crate feature deploy only.

Run Maelstrom with the compiled binary, return Ok(()) if all checks pass.

This will block until Maelstrom completes.

pub fn binary_path(&self) -> Option<PathBuf>

Available on crate feature deploy only.

Get the path to the compiled binary (after building).