Class RedisDistributedLock

java.lang.Object

com.iantapply.orchestra.adapter.redis.RedisDistributedLock

All Implemented Interfaces:

com.iantapply.orchestra.port.DistributedLock

public final class RedisDistributedLock
extends Object
implements com.iantapply.orchestra.port.DistributedLock

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

Nested Class Summary

Nested classes/interfaces inherited from interface com.iantapply.orchestra.port.DistributedLock

com.iantapply.orchestra.port.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<com.iantapply.orchestra.port.DistributedLock.Lease>	tryAcquire(String key, Duration duration)

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<com.iantapply.orchestra.port.DistributedLock.Lease> tryAcquire(String key,
 Duration duration)

Specified by:

tryAcquire in interface com.iantapply.orchestra.port.DistributedLock