Struct RedisStateBackend 

pub struct RedisStateBackend { /* private fields */ }

Redis state backend with connection pooling and advanced features

Implementations

impl RedisStateBackend

pub async fn new(config: RedisConfig) -> StateResult<Self>

Create a new Redis state backend

Arguments

• config - Redis configuration

Returns

A new RedisStateBackend instance

Errors

Returns error if connection to Redis fails

pub async fn stats(&self) -> RedisStats

Get current statistics

pub async fn health_check(&self) -> StateResult<bool>

Check connection health

pub async fn server_info(&self) -> StateResult<String>

Get Redis server info

pub async fn put_with_ttl( &self, key: &[u8], value: &[u8], ttl: Duration, ) -> StateResult<()>

Put with custom TTL

pub async fn batch_get( &self, keys: &[&[u8]], ) -> StateResult<Vec<Option<Vec<u8>>>>

Batch get multiple keys

pub async fn batch_put(&self, pairs: &[(&[u8], &[u8])]) -> StateResult<()>

Batch put multiple key-value pairs

pub async fn batch_delete(&self, keys: &[&[u8]]) -> StateResult<usize>

Batch delete multiple keys

pub async fn get_and_delete(&self, key: &[u8]) -> StateResult<Option<Vec<u8>>>

Atomic get and delete operation

pub async fn set_if_not_exists( &self, key: &[u8], value: &[u8], ttl: Duration, ) -> StateResult<bool>

Set key only if it doesn’t exist (with TTL)

pub async fn ttl(&self, key: &[u8]) -> StateResult<Option<Duration>>

Get remaining TTL for a key

pub async fn checkpoint(&self) -> StateResult<Vec<(Vec<u8>, Vec<u8>)>>

Create a checkpoint (snapshot) of all state

pub async fn restore( &self, checkpoint: Vec<(Vec<u8>, Vec<u8>)>, ) -> StateResult<()>

Restore state from a checkpoint

pub async fn memory_usage(&self) -> StateResult<u64>

Get memory usage statistics from Redis

Trait Implementations

impl StateBackend for RedisStateBackend

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<Option<Vec<u8>>>> + Send + 'async_trait>>

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

Retrieve a value for the given key

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 [u8], value: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

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

Store a value for the given key

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

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

Delete a key and its associated value

fn list_keys<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<Vec<Vec<u8>>>> + Send + 'async_trait>>

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

List all keys with the given prefix

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

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

Clear all state from the backend

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

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

Get the number of keys in the backend

fn contains<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<bool>> + Send + 'async_trait>>

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

Check if a key exists