Struct MemoryRequestQueue 

pub struct MemoryRequestQueue { /* private fields */ }

A thread-safe, lease-based request queue stored entirely in memory.

Implementations

impl MemoryRequestQueue

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

Creates an empty FIFO queue with the given name.

pub fn with_policy(name: impl Into<String>, policy: MemoryQueuePolicy) -> Self

Creates an empty queue using the selected frontier policy.

Trait Implementations

impl Debug for MemoryRequestQueue

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RequestQueue for MemoryRequestQueue

fn add<'life0, 'async_trait>( &'life0 self, request: Request, opts: AddOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<QueueOpInfo>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Adds a request and returns its deduplication status.

fn add_batch<'life0, 'async_trait>( &'life0 self, requests: Vec<RequestSource>, opts: AddOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<BatchAddHandle>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Adds multiple request sources and returns a handle for deferred completion.

fn fetch_next<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<Lease>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Hands temporary ownership of the next request to the caller as a lease.

fn mark_handled<'life0, 'async_trait>( &'life0 self, lease: Lease, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Marks a leased request as successful and consumes its lease.

fn reclaim<'life0, 'async_trait>( &'life0 self, lease: Lease, opts: ReclaimOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Re-queues a lease, incrementing retry count unless opts disables it.

fn renew<'life0, 'life1, 'async_trait>( &'life0 self, lease_id: &'life1 LeaseId, extend_by: Duration, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Extends an active lease deadline, returning LeaseNotFound if it is unknown or completed.

fn abandon<'life0, 'async_trait>( &'life0 self, lease: Lease, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Re-queues and consumes a lease without incrementing its request retry count.

fn is_empty<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns whether no requests are currently pending.

fn is_finished<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns whether no requests are pending or leased.

fn handled_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the number of successfully handled requests.

fn pending_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the number of pending requests.