Index

C I P R S T
All Classes and Interfaces|All Packages

C

close() - Method in class com.iantapply.orchestra.adapter.redis.RedisTransport

com.iantapply.orchestra.adapter.redis - package com.iantapply.orchestra.adapter.redis

Minimal RESP transport and ownership-token distributed leases for Redis.

I

isReachable() - Method in class com.iantapply.orchestra.adapter.redis.RedisTransport

Checks whether Redis accepts a short authenticated PING request.

P

publish(String, byte[]) - Method in class com.iantapply.orchestra.adapter.redis.RedisTransport

R

RedisDistributedLock - Class in com.iantapply.orchestra.adapter.redis

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

RedisDistributedLock(URI, String) - Constructor for class com.iantapply.orchestra.adapter.redis.RedisDistributedLock

Creates a Redis-backed lease provider.

RedisTransport - Class in com.iantapply.orchestra.adapter.redis

Redis Pub/Sub transport with daemon subscription threads and reconnect handling.

RedisTransport(URI, String) - Constructor for class com.iantapply.orchestra.adapter.redis.RedisTransport

Creates a Redis Pub/Sub transport.

RedisTransport(URI, String, Consumer) - Constructor for class com.iantapply.orchestra.adapter.redis.RedisTransport

Creates a Redis transport with an operational failure counter sink.

S

subscribe(String, Consumer) - Method in class com.iantapply.orchestra.adapter.redis.RedisTransport

T

tryAcquire(String, Duration) - Method in class com.iantapply.orchestra.adapter.redis.RedisDistributedLock

C I P R S T
All Classes and Interfaces|All Packages