Class RedisDistributedLock

java.lang.Object

com.iantapply.orchestra.adapter.redis.RedisDistributedLock

All Implemented Interfaces:

DistributedLock

public final class RedisDistributedLock
extends Object
implements DistributedLock

Redis lease provider using atomic NX/PX acquisition and token-checked release.

Nested Class Summary

Nested classes/interfaces inherited from interface DistributedLock

DistributedLock.Lease

Constructor Summary

Constructors

Constructor	Description
RedisDistributedLock(URI uri, String namespace)	Creates a Redis-backed lease provider.

Method Summary

Modifier and Type	Method	Description
Optional<DistributedLock.Lease>	tryAcquire(String key, Duration duration)	Attempts to claim a key for a bounded duration without waiting.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RedisDistributedLock

public RedisDistributedLock(URI uri,
 String namespace)

Creates a Redis-backed lease provider.

Parameters:

uri - Redis URI, optionally containing credentials and database number

namespace - prefix used to isolate Orchestra keys

Method Details

tryAcquire

public Optional<DistributedLock.Lease> tryAcquire(String key,
 Duration duration)

Description copied from interface: DistributedLock

Attempts to claim a key for a bounded duration without waiting.

Specified by:

tryAcquire in interface DistributedLock

Parameters:

key - globally meaningful lock key

duration - lease lifetime

Returns:

owned lease, or empty when another node owns the key