Struct RequestQueue 

pub struct RequestQueue { /* private fields */ }

Manages pending requests and completed results for a mesh

Implementations

impl RequestQueue

pub fn new() -> Self

Create a new request queue

pub fn with_max_results(max_results: usize) -> Self

Create with a maximum result buffer size

pub fn submit(&self, target: &str, payload: String) -> String

Submit a new request, returns the request ID

pub fn complete(&self, request_id: &str, response: String)

Mark a request as completed with a response

pub fn fail(&self, request_id: &str, error: String)

Mark a request as failed

pub fn get_pending(&self) -> Vec<MeshRequest>

Get all pending requests

pub fn get_stale(&self, older_than: Duration) -> Vec<MeshRequest>

Get pending requests older than the specified duration

pub fn has_pending(&self) -> bool

Check if there are any pending requests

pub fn pending_count(&self) -> usize

Get number of pending requests

pub fn increment_reminder(&self, request_id: &str)

Increment reminder count for a request

pub fn take_results(&self) -> Vec<MeshResult>

Get available results (removes them from the queue)

pub fn peek_results(&self) -> Vec<MeshResult>

Peek at results without removing them

pub fn take_result(&self, request_id: &str) -> Option<MeshResult>

Get result for a specific request (removes it if found)

pub async fn wait_next(&self, timeout: Duration) -> Option<MeshResult>

Wait for the next result to become available

pub async fn wait_for( &self, request_id: &str, timeout: Duration, ) -> Option<MeshResult>

Wait for a specific result

Trait Implementations

impl Default for RequestQueue

fn default() -> Self

Returns the “default value” for a type.