Struct MemoryQueueManager 

pub struct MemoryQueueManager { /* private fields */ }

Memory-based queue manager for simple deployments

Implementations

impl MemoryQueueManager

pub fn new() -> Self

pub fn start_processing(&self)

Starts the background processing loop. Should be called once after setup.

Trait Implementations

impl Default for MemoryQueueManager

fn default() -> Self

Returns the “default value” for a type.

impl QueueInterface for MemoryQueueManager

fn add_to_queue<'life0, 'life1, 'async_trait>( &'life0 self, queue_name: &'life1 str, data: JobData, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn process_queue<'life0, 'life1, 'async_trait>( &'life0 self, queue_name: &'life1 str, callback: JobProcessorFnAsync, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

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

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

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

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