Struct TestCluster 

pub struct TestCluster { /* private fields */ }

Implementations

impl TestCluster

pub fn builder() -> TestClusterBuilder

pub async fn ping( &mut self, node_id: &str, echo: &str, ) -> Result<PingResponse, Box<dyn Error>>

Ping a node to verify it’s alive.

pub async fn get_node_info( &mut self, node_id: &str, ) -> Result<NodeInfoResponse, Box<dyn Error>>

Get node info.

pub async fn inject_fault( &mut self, node_id: &str, fault_type: &str, target: &str, duration_ms: u64, count: u32, ) -> Result<(), Box<dyn Error>>

Inject a fault on a node.

pub async fn clear_faults( &mut self, node_id: &str, ) -> Result<(), Box<dyn Error>>

Clear all faults on a node.

pub async fn subscribe_events( &mut self, node_id: &str, event_types: &[&str], ) -> Result<EventStream, Box<dyn Error>>

Subscribe to events from a node.

pub async fn custom( &mut self, node_id: &str, command_type: &str, payload: &[u8], ) -> Result<Vec<u8>, Box<dyn Error>>

Send a custom command.

pub async fn spawn_actor( &mut self, node_id: &str, actor_type: &str, actor_name: &str, args: &[u8], ) -> Result<SpawnActorResponse, Box<dyn Error>>

Spawn an actor on a node.

pub async fn tell_actor( &mut self, node_id: &str, actor_name: &str, message_type: &str, payload: &[u8], ) -> Result<TellActorResponse, Box<dyn Error>>

Send a fire-and-forget message to an actor on a node.

pub async fn ask_actor( &mut self, node_id: &str, actor_name: &str, message_type: &str, payload: &[u8], ) -> Result<AskActorResponse, Box<dyn Error>>

Send a request-reply message to an actor on a node.

pub async fn ask_actor_with_timeout( &mut self, node_id: &str, actor_name: &str, message_type: &str, payload: &[u8], timeout_ms: u64, ) -> Result<AskActorResponse, Box<dyn Error>>

Send a request-reply message to an actor on a node with a timeout. If timeout_ms > 0, the ask is cancelled after that many milliseconds.

pub async fn stop_actor( &mut self, node_id: &str, actor_name: &str, ) -> Result<StopActorResponse, Box<dyn Error>>

Stop an actor on a node.

pub async fn watch_actor( &mut self, node_id: &str, watcher_name: &str, target_name: &str, ) -> Result<WatchActorResponse, Box<dyn Error>>

Register a watch: when target_name stops, watcher_name is notified.

pub async fn shutdown_node( &mut self, node_id: &str, ) -> Result<(), Box<dyn Error>>

Graceful shutdown of a specific node.

pub async fn shutdown(&mut self)

Shutdown all nodes.

Trait Implementations

impl Drop for TestCluster

fn drop(&mut self)

Executes the destructor for this type.