Struct RedisDistributedLock 

pub struct RedisDistributedLock { /* private fields */ }

Redis-based distributed lock implementation

Uses Redis atomic operations and LUA scripts to implement distributed locking with proper ownership semantics and automatic expiration.

Implementations

impl RedisDistributedLock

pub async fn new(redis_url: &str) -> StateResult<Self>

Create a new Redis distributed lock

Arguments

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

Returns

• Ok(RedisDistributedLock) - Lock instance created
• Err(StateError) - Failed to connect to Redis

pub async fn with_config( redis_url: &str, prefix: &str, retry_config: RetryConfig, ) -> StateResult<Self>

Create a new Redis distributed lock with custom configuration

Arguments

• redis_url - Redis connection URL
• prefix - Key prefix for locks (e.g., “app:lock:”)
• retry_config - Retry configuration for lock acquisition

Trait Implementations

impl Debug for RedisDistributedLock

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl DistributedLock for RedisDistributedLock

fn acquire<'life0, 'life1, 'async_trait>( &'life0 self, resource: &'life1 str, ttl: Duration, ) -> Pin<Box<dyn Future<Output = StateResult<LockGuard>> + Send + 'async_trait>>

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

Acquire a lock for the given resource

fn try_acquire<'life0, 'life1, 'async_trait>( &'life0 self, resource: &'life1 str, ttl: Duration, ) -> Pin<Box<dyn Future<Output = StateResult<Option<LockGuard>>> + Send + 'async_trait>>

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

Try to acquire a lock without blocking

fn release_internal<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, resource: &'life1 str, token: &'life2 LockToken, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

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

Internal release method (used by Drop)

fn is_locked<'life0, 'life1, 'async_trait>( &'life0 self, resource: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateResult<bool>> + Send + 'async_trait>>

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

Check if a resource is currently locked

fn extend<'life0, 'life1, 'async_trait>( &'life0 self, guard: &'life1 mut LockGuard, ttl: Duration, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

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

Extend the TTL of an existing lock

fn get_lock_info<'life0, 'life1, 'async_trait>( &'life0 self, resource: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateResult<Option<LockToken>>> + Send + 'async_trait>>

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

Get information about who holds a lock

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

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

Release a lock