Struct RedisTaskBackend 

pub struct RedisTaskBackend { /* private fields */ }

Available on crate feature tasks and non-WebAssembly only.

Redis-based task backend

Stores tasks in Redis with status tracking.

Examples

use reinhardt_tasks::RedisTaskBackend;

let backend = RedisTaskBackend::new("redis://127.0.0.1/").await?;

Implementations

impl RedisTaskBackend

pub async fn new(redis_url: &str) -> Result<RedisTaskBackend, RedisError>

Available on crate feature redis-backend only.

Create a new Redis backend

Arguments

• redis_url - Redis connection URL (e.g., “redis://127.0.0.1/”)

Examples

use reinhardt_tasks::RedisTaskBackend;

let backend = RedisTaskBackend::new("redis://localhost/").await?;

pub async fn with_prefix( redis_url: &str, key_prefix: String, ) -> Result<RedisTaskBackend, RedisError>

Available on crate feature redis-backend only.

Create a new Redis backend with custom key prefix

Arguments

• redis_url - Redis connection URL
• key_prefix - Custom key prefix for Redis keys

Examples

use reinhardt_tasks::RedisTaskBackend;

let backend = RedisTaskBackend::with_prefix(
    "redis://localhost/",
    "myapp:tasks:".to_string()
).await?;

Trait Implementations

impl TaskBackend for RedisTaskBackend

fn enqueue<'life0, 'async_trait>( &'life0 self, task: Box<dyn Task>, ) -> Pin<Box<dyn Future<Output = Result<TaskId, TaskExecutionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RedisTaskBackend: 'async_trait,

Enqueues a task and returns its assigned ID.

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

where 'life0: 'async_trait, RedisTaskBackend: 'async_trait,

Dequeues the next available task ID, if any.

fn get_status<'life0, 'async_trait>( &'life0 self, task_id: TaskId, ) -> Pin<Box<dyn Future<Output = Result<TaskStatus, TaskExecutionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RedisTaskBackend: 'async_trait,

Retrieves the current status of a task by its ID.

fn update_status<'life0, 'async_trait>( &'life0 self, task_id: TaskId, status: TaskStatus, ) -> Pin<Box<dyn Future<Output = Result<(), TaskExecutionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RedisTaskBackend: 'async_trait,

Updates the status of a task.

fn get_task_data<'life0, 'async_trait>( &'life0 self, task_id: TaskId, ) -> Pin<Box<dyn Future<Output = Result<Option<SerializedTask>, TaskExecutionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RedisTaskBackend: 'async_trait,

Get serialized task data by task ID

fn backend_name(&self) -> &str

Returns the name of this backend implementation.