Struct MultiNodeSpec 

pub struct MultiNodeSpec { /* private fields */ }

Multi-node test specification.

Implementations

impl MultiNodeSpec

pub fn new(name: impl Into<String>, node_count: usize) -> Self

pub fn name(&self) -> &str

pub fn node_count(&self) -> usize

pub fn node_address(&self, i: usize) -> String

Synthesize a per-node identity. Real cross-process tests can derive a TCP address from this string.

pub async fn boot(&self) -> Result<Vec<ActorSystem>, MultiNodeError>

Boot node_count distinct in-process ActorSystems. Each gets a name "<spec>-N". The reference config is used because per-node config knobs come into play in Phase 6.

pub async fn barrier( &self, label: &str, timeout: Duration, ) -> Result<(), MultiNodeError>

Each node calls barrier(label, timeout) with the same label; the future resolves once all node_count callers have arrived or timeout elapses (whichever is first).

Backed by tokio::sync::Barrier per label; this avoids the Notify::notify_waiters race where late waiters miss an already-fired notification.

pub async fn shutdown(&self, nodes: Vec<ActorSystem>)

Convenience: terminate every node booted by Self::boot.