Struct RedisResultBackend 

pub struct RedisResultBackend { /* private fields */ }

Redis-backed result storage.

Results are stored as JSON strings with a configurable TTL (default 24 hours). Group operations (complete_group_member) use a Lua script to atomically increment the completed count and push the result, preventing races when multiple workers finish group members concurrently.

Implementations

impl RedisResultBackend

pub async fn new(config: RedisConfig) -> Result<RedisResultBackend, KojinError>

Create a new Redis result backend.

Builds a deadpool_redis connection pool from the given config and verifies connectivity by acquiring one connection. The default result TTL is 24 hours; override with with_ttl.

pub fn with_ttl(self, ttl: Duration) -> RedisResultBackend

Override the result TTL (time-to-live).

Results older than this duration are automatically expired by Redis. Defaults to 24 hours if not called.

Trait Implementations

impl ResultBackend for RedisResultBackend

fn store<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 TaskId, result: &'life2 Value, ) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, RedisResultBackend: 'async_trait,

Store a task result.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RedisResultBackend: 'async_trait,

Get a stored result.

fn wait<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<Value, KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RedisResultBackend: 'async_trait,

Wait for a result to be available, with timeout.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RedisResultBackend: 'async_trait,

Delete a stored result.

fn init_group<'life0, 'life1, 'async_trait>( &'life0 self, group_id: &'life1 str, total: u32, ) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RedisResultBackend: 'async_trait,

Initialize a group with the expected total count.

fn complete_group_member<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, group_id: &'life1 str, _task_id: &'life2 TaskId, result: &'life3 Value, ) -> Pin<Box<dyn Future<Output = Result<u32, KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, RedisResultBackend: 'async_trait,

Mark a group member as complete and return the number of completed members.

fn get_group_results<'life0, 'life1, 'async_trait>( &'life0 self, group_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Value>, KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RedisResultBackend: 'async_trait,

Get all results for a group.