Struct EnterpriseRedisBackend 

pub struct EnterpriseRedisBackend { /* private fields */ }

Enterprise Redis backend

Implementations

impl EnterpriseRedisBackend

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

Create a new enterprise Redis backend

pub async fn acquire_lock( &self, resource: &str, ttl: Duration, ) -> StateResult<RedlockGuard>

Acquire distributed lock using Redlock algorithm

pub async fn try_acquire_lock( &self, resource: &str, ttl: Duration, ) -> StateResult<Option<RedlockGuard>>

Try to acquire lock without blocking

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

Batch get with pipeline

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

Batch put with pipeline

pub async fn stats(&self) -> BackendStats

Get backend statistics

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

Health check

pub fn metrics(&self) -> Option<Arc<RedisMetrics>>

Get metrics registry for Prometheus export

Trait Implementations

impl Clone for EnterpriseRedisBackend

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StateBackend for EnterpriseRedisBackend

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