Struct InMemoryQueue 

pub struct InMemoryQueue { /* private fields */ }

Implementations

impl InMemoryQueue

pub fn new() -> Self

pub fn with_limit(max_queue_size: usize) -> Self

Trait Implementations

impl Default for InMemoryQueue

fn default() -> Self

Returns the “default value” for a type.

impl MessageQueue for InMemoryQueue

fn push<'life0, 'life1, 'async_trait>( &'life0 self, vtoken: &'life1 str, msg: WeixinMessage, ) -> Pin<Box<dyn Future<Output = Result<bool, HubError>> + Send + 'async_trait>>

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

fn push_shared<'life0, 'life1, 'async_trait>( &'life0 self, vtoken: &'life1 str, base: Arc<WeixinMessage>, context_token: Option<String>, hub_ext: Option<HubExt>, ) -> Pin<Box<dyn Future<Output = Result<bool, HubError>> + Send + 'async_trait>>

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

Optimised push for the broadcast path: the base message is shared via Arc<WeixinMessage> and only the per-recipient context_token and ilink_hub_ext are supplied separately. The base clone cost drops from O(N × msg_size) to O(msg_size) + N × cheap field clone, which matters when many backends are online and a message carries images / files.

fn drain<'life0, 'life1, 'async_trait>( &'life0 self, vtoken: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<WeixinMessage>, HubError>> + Send + 'async_trait>>

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

fn wait_notify<'life0, 'life1, 'async_trait>( &'life0 self, vtoken: &'life1 str, timeout_secs: u64, ) -> Pin<Box<dyn Future<Output = Result<bool, HubError>> + Send + 'async_trait>>

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

fn remove_client<'life0, 'life1, 'async_trait>( &'life0 self, vtoken: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), HubError>> + Send + 'async_trait>>

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

fn queue_sizes<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, usize>, HubError>> + Send + 'async_trait>>

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