Struct qm_redis::work_queue::WorkQueue

pub struct WorkQueue { /* private fields */ }

Implementations

impl WorkQueue

pub fn new(name: KeyPrefix) -> WorkQueue

pub async fn recover<C: AsyncCommands>(&self, db: &mut C) -> RedisResult<()>

pub fn add_item_to_pipeline(&self, pipeline: &mut Pipeline, item: &Item)

pub async fn add_item<C: AsyncCommands>( &self, db: &mut C, item: &Item ) -> RedisResult<()>

pub fn queue_len<'a, C: AsyncCommands>( &'a self, db: &'a mut C ) -> impl Future<Output = RedisResult<usize>> + 'a

pub fn processing<'a, C: AsyncCommands>( &'a self, db: &'a mut C ) -> impl Future<Output = RedisResult<usize>> + 'a

pub async fn lease<C: AsyncCommands>( &self, db: &mut C, timeout: Option<Duration>, lease_duration: Duration ) -> RedisResult<Option<Item>>

pub async fn complete<C: AsyncCommands>( &self, db: &mut C, item: &Item ) -> RedisResult<bool>