Struct TimeoutManager 

pub struct TimeoutManager { /* private fields */ }

Timeout manager for commands and acknowledgments

Tracks command expiration (TTL) and acknowledgment timeouts. Provides efficient lookup of expired commands via BTreeMap.

Implementations

impl TimeoutManager

pub fn new() -> Self

Create a new timeout manager

pub async fn register_expiration( &self, command: &HierarchicalCommand, ) -> Result<()>

Register a command for expiration tracking

If the command has an expires_at field, it will be tracked for automatic expiration.

pub async fn process_expired(&self) -> Vec<String>

Check and process expired commands

Returns a list of command IDs that have expired. This should be called periodically by a background task.

pub async fn unregister_expiration(&self, command_id: &str) -> Result<()>

Unregister a command from expiration tracking

Called when a command completes before expiring.

pub async fn register_ack_timeout( &self, command_id: String, expected_acks: Vec<String>, timeout: Duration, ) -> Result<()>

Register an acknowledgment timeout

Tracks expected acknowledgments for a command with a timeout.

pub async fn record_ack(&self, command_id: &str, node_id: &str) -> bool

Record a received acknowledgment

Updates the tracking for a command’s acknowledgments. Returns true if all expected acks have been received.

pub async fn check_ack_timeouts(&self) -> Vec<String>

Check for acknowledgment timeouts

Returns list of command IDs that have timed out waiting for acks. A command has timed out if:

1. The timeout period has elapsed
2. Not all expected acknowledgments have been received

pub async fn get_ack_status(&self, command_id: &str) -> Option<AckTimeout>

Get acknowledgment status for a command

Returns the acknowledgment tracking info if it exists.

pub async fn unregister_ack_timeout(&self, command_id: &str) -> Result<()>

Remove acknowledgment timeout tracking

Called when a command completes or is cancelled.

pub async fn expiration_count(&self) -> usize

Get count of commands being tracked for expiration

pub async fn ack_timeout_count(&self) -> usize

Get count of commands being tracked for ack timeout

Trait Implementations

impl Default for TimeoutManager

fn default() -> Self

Returns the “default value” for a type.