Struct taskline::backends::redis::RedisBackend

pub struct RedisBackend { /* private fields */ }

Redis backend. It implements both DequeuBackend and EnqueuBackend traits. You can use score to sort tasks in queue. Usually it is unix timestamp.

Implementations

impl RedisBackend

pub fn new( client: Client, queue_key: String, read_batch_size: usize, autodelete: bool ) -> Self

Create new instance of RedisBackend.

It requires redis::Client instance, redis key used to store tasks and number of tasks to read in one batch. It also creates lua script used to pop tasks from redis.

• client - redis client.
• queue_key - redis key is used to store tasks.
• read_batch_size - number of tasks to read in one batch.
• autodelete - if true, tasks will be deleted from queue after reading. If false, tasks should be deleted explicitly from queue after reading with RedisBackend::delete. New in version 0.5.0.

pub async fn read(&self, score: &f64) -> Result<Vec<String>, RedisError>

Calls lua script to pop tasks from redis. If there are no tasks in queue it returns empty vector. If there are no tasks with score less than score, returns empty vector.

pub async fn write(&self, task: &String, score: &f64) -> Result<(), RedisError>

Adds a task to redis. It uses score to sort tasks in queue. Usually it is unix timestamp.

pub async fn delete(&self, task: &String) -> Result<(), RedisError>

Delete a task from queue.

New in version 0.5.0.

pub async fn is_redis_version_ok(&self) -> Result<bool, RedisError>

Check redis version.

New in version 0.6.0.

Trait Implementations

impl Clone for RedisBackend

fn clone(&self) -> RedisBackend

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CommitBackend<String, RedisError> for RedisBackend

fn commit<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 String ) -> Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a task from queue.

New in version 0.5.1.

impl DequeuBackend<String, f64, RedisError> for RedisBackend

fn dequeue<'life0, 'life1, 'async_trait>( &'life0 self, score: &'life1 f64 ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, RedisError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Calls lua script to pop tasks from redis. If there are no tasks in queue it returns empty vector. If there are no tasks with score less than score, returns empty vector.

impl EnqueuBackend<String, f64, RedisError> for RedisBackend

fn enqueue<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task: &'life1 String, score: &'life2 f64 ) -> Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Adds a task to redis. It uses score to sort tasks in queue. Usually it is unix timestamp.