Index

A B C D E F G H I K L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Serialized Form

A

acquireAsync(LockKey, Duration, Duration) - Method in interface com.cotani.redis.lock.DistributedLockService
Attempts to acquire a distributed lock, retrying asynchronously until the wait timeout expires.
addOrUpdateScoreAsync(RedisKey, String, double) - Method in interface com.cotani.redis.leaderboard.RedisSortedSetStore
Adds or updates the score of a member in the sorted set.
allowed() - Method in record class com.cotani.redis.ratelimit.RateLimitResult
Returns the value of the allowed record component.

B

build() - Method in class com.cotani.redis.config.RedisConfig.Builder
 
build() - Method in class com.cotani.redis.CotaniRedisBuilder
 
builder() - Static method in record class com.cotani.redis.config.RedisConfig
 
builder() - Static method in interface com.cotani.redis.CotaniRedis
Creates a new fluent builder for configuring and instantiating CotaniRedis.
builder() - Static method in class com.cotani.redis.CotaniRedises
Creates a new fluent builder for configuring and instantiating CotaniRedis.
Builder() - Constructor for class com.cotani.redis.config.RedisConfig.Builder
 
byteArray() - Static method in interface com.cotani.redis.codec.RedisCodec
Pass-through codec for raw byte arrays.
ByteArrayRedisCodec - Class in com.cotani.redis.codec
Direct byte array pass-through Redis codec.

C

channel() - Method in record class com.cotani.redis.channel.ChannelMessage
Returns the value of the channel record component.
channel(ChannelId) - Method in interface com.cotani.redis.CotaniRedis
Resolves a string-based Pub/Sub channel.
channel(ChannelId, RedisCodec) - Method in interface com.cotani.redis.CotaniRedis
Resolves a strongly typed Pub/Sub channel.
channelId() - Method in interface com.cotani.redis.channel.ChannelSubscription
Returns the subscribed channel identifier.
ChannelId - Record Class in com.cotani.redis.channel
Value object representing a unique Redis Pub/Sub channel identifier.
ChannelId(String) - Constructor for record class com.cotani.redis.channel.ChannelId
Creates an instance of a ChannelId record class.
ChannelMessage<T> - Record Class in com.cotani.redis.channel
Immutable wrapper around a typed message received from a Redis Pub/Sub channel.
ChannelMessage(ChannelId, T, Instant) - Constructor for record class com.cotani.redis.channel.ChannelMessage
Creates an instance of a ChannelMessage record class.
ChannelSubscription - Interface in com.cotani.redis.channel
Handle to an active Redis channel listener subscription.
checkAndStartAsync(CooldownKey, Duration) - Method in class com.cotani.redis.cooldown.RedisDistributedCooldownService
 
clear() - Method in class com.cotani.redis.event.RedisDistributedEventBus
 
clearAllAsync() - Method in class com.cotani.redis.cooldown.RedisDistributedCooldownService
 
clearExpiredAsync() - Method in class com.cotani.redis.cooldown.RedisDistributedCooldownService
 
clientName() - Method in record class com.cotani.redis.config.RedisConfig
Returns the value of the clientName record component.
clientName(String) - Method in class com.cotani.redis.config.RedisConfig.Builder
 
close() - Method in interface com.cotani.redis.channel.ChannelSubscription
 
close() - Method in interface com.cotani.redis.channel.RedisRpcChannel
 
close() - Method in class com.cotani.redis.cooldown.RedisDistributedCooldownService
 
close() - Method in interface com.cotani.redis.CotaniRedis
Begins closing this instance without blocking.
close() - Method in class com.cotani.redis.CotaniRedisModule
 
close() - Method in class com.cotani.redis.event.RedisDistributedEventBus
 
close() - Method in interface com.cotani.redis.lock.DistributedLock
Begins releasing this lock without blocking.
closeAsync() - Method in interface com.cotani.redis.channel.ChannelSubscription
 
closeAsync() - Method in interface com.cotani.redis.CotaniRedis
Asynchronously closes all connections, cancels subscriptions, and releases event loops.
closeAsync() - Method in class com.cotani.redis.CotaniRedisModule
 
closeAsync() - Method in interface com.cotani.redis.lock.DistributedLock
 
CLOSED - Enum constant in enum class com.cotani.redis.RedisState
 
CLOSING - Enum constant in enum class com.cotani.redis.RedisState
 
codec() - Method in interface com.cotani.redis.channel.RedisChannel
Returns the codec used to serialize and deserialize messages on this channel.
com.cotani.redis - package com.cotani.redis
 
com.cotani.redis.cache - package com.cotani.redis.cache
 
com.cotani.redis.channel - package com.cotani.redis.channel
 
com.cotani.redis.codec - package com.cotani.redis.codec
 
com.cotani.redis.config - package com.cotani.redis.config
 
com.cotani.redis.cooldown - package com.cotani.redis.cooldown
 
com.cotani.redis.event - package com.cotani.redis.event
 
com.cotani.redis.exception - package com.cotani.redis.exception
 
com.cotani.redis.leaderboard - package com.cotani.redis.leaderboard
 
com.cotani.redis.lock - package com.cotani.redis.lock
 
com.cotani.redis.ratelimit - package com.cotani.redis.ratelimit
 
com.cotani.redis.store - package com.cotani.redis.store
 
config(RedisConfig) - Method in class com.cotani.redis.CotaniRedisBuilder
 
CONNECTED - Enum constant in enum class com.cotani.redis.RedisState
 
connectTimeout() - Method in record class com.cotani.redis.config.RedisConfig
Returns the value of the connectTimeout record component.
connectTimeout(Duration) - Method in class com.cotani.redis.config.RedisConfig.Builder
 
CotaniRedis - Interface in com.cotani.redis
Primary Cotani Redis interface providing non-blocking asynchronous Pub/Sub channels, distributed mutual exclusion locks, and key-value operations.
CotaniRedisBuilder - Class in com.cotani.redis
Fluent builder for creating CotaniRedis instances.
CotaniRedisBuilder() - Constructor for class com.cotani.redis.CotaniRedisBuilder
 
CotaniRedises - Class in com.cotani.redis
Entrypoint factory for the cotani-redis module.
CotaniRedisModule - Class in com.cotani.redis
Lifecycle bridge for registering CotaniRedis with Cotani.forPlugin(plugin).
create(Plugin, RedisConfig) - Static method in interface com.cotani.redis.CotaniRedis
Creates a CotaniRedis instance for a plugin using the given configuration.
create(Plugin, RedisConfig) - Static method in class com.cotani.redis.CotaniRedises
Creates a CotaniRedis instance for a plugin using the given configuration.
create(Plugin, RedisConfig) - Static method in class com.cotani.redis.CotaniRedisModule
 
create(Plugin, RedisConfig, PaperTaskScheduler) - Static method in interface com.cotani.redis.CotaniRedis
Creates a CotaniRedis instance for a plugin using the given configuration and scheduler.
create(Plugin, RedisConfig, PaperTaskScheduler) - Static method in class com.cotani.redis.CotaniRedises
Creates a CotaniRedis instance for a plugin using the given configuration and scheduler.
create(Plugin, RedisConfig, PaperTaskScheduler) - Static method in class com.cotani.redis.CotaniRedisModule
 
currentRequests() - Method in record class com.cotani.redis.ratelimit.RateLimitResult
Returns the value of the currentRequests record component.

D

database() - Method in record class com.cotani.redis.config.RedisConfig
Returns the value of the database record component.
database(int) - Method in class com.cotani.redis.config.RedisConfig.Builder
 
decode(byte[]) - Method in class com.cotani.redis.codec.ByteArrayRedisCodec
 
decode(byte[]) - Method in interface com.cotani.redis.codec.RedisCodec
Deserializes a byte array into a domain object.
decode(byte[]) - Method in class com.cotani.redis.codec.StringRedisCodec
 
decrementAndGetAsync(RedisKey, long) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Atomically decrements the numeric value at key by delta.
delete(K) - Method in class com.cotani.redis.cache.RedisCacheRepository
 
deleteAsync(RedisKey) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Deletes a key from Redis.
DistributedLock - Interface in com.cotani.redis.lock
Handle representing an acquired distributed lock.
DistributedLockService - Interface in com.cotani.redis.lock
Service for acquiring and executing work under distributed mutual exclusion locks across server clusters.

E

encode(byte[]) - Method in class com.cotani.redis.codec.ByteArrayRedisCodec
 
encode(String) - Method in class com.cotani.redis.codec.StringRedisCodec
 
encode(T) - Method in interface com.cotani.redis.codec.RedisCodec
Serializes a message object to a byte array.
equals(Object) - Method in record class com.cotani.redis.channel.ChannelId
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.cotani.redis.channel.ChannelMessage
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.cotani.redis.config.RedisConfig
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.cotani.redis.leaderboard.RankEntry
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.cotani.redis.lock.LockKey
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.cotani.redis.lock.LockToken
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.cotani.redis.ratelimit.RateLimitResult
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.cotani.redis.store.RedisKey
Indicates whether some other object is "equal to" this one.
existsAsync(RedisKey) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Checks if a key exists in Redis.
expireAsync(RedisKey, Duration) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Sets or updates expiration on an existing key.

F

FAILED - Enum constant in enum class com.cotani.redis.RedisState
 
find(K) - Method in class com.cotani.redis.cache.RedisCacheRepository
 
findAsync(CooldownKey) - Method in class com.cotani.redis.cooldown.RedisDistributedCooldownService
 

G

getAsync(RedisKey) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Retrieves a string value by key.
getAsync(RedisKey, RedisCodec) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Retrieves a strongly typed object deserialized using the specified codec.
getBinaryAsync(RedisKey) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Retrieves raw binary bytes by key.
getRangeAsync(RedisKey, long, long) - Method in interface com.cotani.redis.leaderboard.RedisSortedSetStore
Retrieves a range of ranked entries between start and stop rank (0-based inclusive, ordered by score descending).
getRankAsync(RedisKey, String) - Method in interface com.cotani.redis.leaderboard.RedisSortedSetStore
Retrieves the 1-based rank of a member ordered by score descending (highest score = rank 1).
getScoreAsync(RedisKey, String) - Method in interface com.cotani.redis.leaderboard.RedisSortedSetStore
Retrieves the score of a member.
getTopAsync(RedisKey, int) - Method in interface com.cotani.redis.leaderboard.RedisSortedSetStore
Retrieves the top ranked entries ordered by score descending (highest score first).

H

hashCode() - Method in record class com.cotani.redis.channel.ChannelId
Returns a hash code value for this object.
hashCode() - Method in record class com.cotani.redis.channel.ChannelMessage
Returns a hash code value for this object.
hashCode() - Method in record class com.cotani.redis.config.RedisConfig
Returns a hash code value for this object.
hashCode() - Method in record class com.cotani.redis.leaderboard.RankEntry
Returns a hash code value for this object.
hashCode() - Method in record class com.cotani.redis.lock.LockKey
Returns a hash code value for this object.
hashCode() - Method in record class com.cotani.redis.lock.LockToken
Returns a hash code value for this object.
hashCode() - Method in record class com.cotani.redis.ratelimit.RateLimitResult
Returns a hash code value for this object.
hashCode() - Method in record class com.cotani.redis.store.RedisKey
Returns a hash code value for this object.
hdelAsync(RedisKey, String...) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Deletes one or more fields from a hash.
hexistsAsync(RedisKey, String) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Checks if a field exists within a hash.
hgetAllAsync(RedisKey) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Retrieves all fields and values of a hash.
hgetAsync(RedisKey, String) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Retrieves the value of a field within a hash at key.
hgetAsync(RedisKey, String, RedisCodec) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Retrieves and decodes a typed object from a field within a hash.
hgetBinaryAsync(RedisKey, byte[]) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Retrieves raw binary bytes of a field within a hash at key.
hincrByAsync(RedisKey, String, long) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Atomically increments the numeric value of a hash field by delta.
hkeysAsync(RedisKey) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Retrieves all field names within a hash.
hlenAsync(RedisKey) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Returns the number of fields within a hash.
host() - Method in record class com.cotani.redis.config.RedisConfig
Returns the value of the host record component.
host(String) - Method in class com.cotani.redis.config.RedisConfig.Builder
 
hsetAsync(RedisKey, String, String) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Sets a field and value within a hash at key.
hsetAsync(RedisKey, String, T, RedisCodec) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Sets a typed object encoded using the specified codec within a hash field.
hsetBinaryAsync(RedisKey, byte[], byte[]) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Sets a field and raw binary value within a hash at key.

I

id() - Method in interface com.cotani.redis.channel.RedisChannel
Returns the channel identifier.
incrementAndGetAsync(RedisKey, long) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Atomically increments the numeric value at key by delta.
incrementScoreAsync(RedisKey, String, double) - Method in interface com.cotani.redis.leaderboard.RedisSortedSetStore
Atomically increments the score of a member by delta.
INSTANCE - Static variable in class com.cotani.redis.codec.ByteArrayRedisCodec
 
INSTANCE - Static variable in class com.cotani.redis.codec.StringRedisCodec
 
isActive() - Method in interface com.cotani.redis.channel.ChannelSubscription
Checks if this subscription is actively receiving messages.
isHeld() - Method in interface com.cotani.redis.lock.DistributedLock
Checks if this handle believes it currently holds the lock.

K

key() - Method in exception class com.cotani.redis.exception.LockAcquisitionException
 
key() - Method in interface com.cotani.redis.lock.DistributedLock
Returns the locked key.
keysAsync(String) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Finds keys matching a pattern using the blocking KEYS command.

L

leaseTime() - Method in interface com.cotani.redis.lock.DistributedLock
Returns the lease duration granted upon lock acquisition.
localhost() - Static method in record class com.cotani.redis.config.RedisConfig
 
LockAcquisitionException - Exception Class in com.cotani.redis.exception
Thrown when acquiring a distributed lock fails due to timeout, conflict or connection issues.
LockAcquisitionException(LockKey, String) - Constructor for exception class com.cotani.redis.exception.LockAcquisitionException
 
LockAcquisitionException(LockKey, String, Throwable) - Constructor for exception class com.cotani.redis.exception.LockAcquisitionException
 
LockKey - Record Class in com.cotani.redis.lock
Value object identifying a distributed mutual exclusion lock.
LockKey(String) - Constructor for record class com.cotani.redis.lock.LockKey
Creates an instance of a LockKey record class.
locks() - Method in interface com.cotani.redis.CotaniRedis
Returns the distributed lock service.
LockToken - Record Class in com.cotani.redis.lock
Value object representing an ownership lease token for a distributed lock.
LockToken(String) - Constructor for record class com.cotani.redis.lock.LockToken
Creates an instance of a LockToken record class.

M

maxRequests() - Method in record class com.cotani.redis.ratelimit.RateLimitResult
Returns the value of the maxRequests record component.
member() - Method in record class com.cotani.redis.leaderboard.RankEntry
Returns the value of the member record component.

N

NEW - Enum constant in enum class com.cotani.redis.RedisState
 

O

of(ChannelId, T) - Static method in record class com.cotani.redis.channel.ChannelMessage
 
of(CotaniRedis) - Static method in class com.cotani.redis.CotaniRedisModule
 
of(CotaniRedis, ChannelId, RedisCodec) - Static method in class com.cotani.redis.cache.RedisCacheInvalidationBus
 
of(RedisKeyValueStore, Function, RedisCodec) - Static method in class com.cotani.redis.cache.RedisCacheRepository
 
of(String) - Static method in record class com.cotani.redis.channel.ChannelId
 
of(String) - Static method in record class com.cotani.redis.lock.LockKey
 
of(String) - Static method in record class com.cotani.redis.lock.LockToken
 
of(String) - Static method in record class com.cotani.redis.store.RedisKey
 
of(Function, Function) - Static method in interface com.cotani.redis.codec.RedisCodec
Creates a codec from custom functional encoder and decoder mappings.
ofPrefix(RedisKeyValueStore, String, RedisCodec) - Static method in class com.cotani.redis.cache.RedisCacheRepository
 

P

password() - Method in record class com.cotani.redis.config.RedisConfig
Returns the value of the password record component.
password(String) - Method in class com.cotani.redis.config.RedisConfig.Builder
 
payload() - Method in record class com.cotani.redis.channel.ChannelMessage
Returns the value of the payload record component.
pingAsync() - Method in interface com.cotani.redis.CotaniRedis
Sends a ping command to verify Redis connectivity and measure latency.
plugin(Plugin) - Method in class com.cotani.redis.CotaniRedisBuilder
 
port() - Method in record class com.cotani.redis.config.RedisConfig
Returns the value of the port record component.
port(int) - Method in class com.cotani.redis.config.RedisConfig.Builder
 
publish(CacheInvalidation) - Method in class com.cotani.redis.cache.RedisCacheInvalidationBus
 
publish(T) - Method in class com.cotani.redis.event.RedisDistributedEventBus
 
publishAsync(T) - Method in interface com.cotani.redis.channel.RedisChannel
Asynchronously publishes a message to this channel.
publishAsync(T) - Method in class com.cotani.redis.event.RedisDistributedEventBus
 

R

random() - Static method in record class com.cotani.redis.lock.LockToken
 
rank() - Method in record class com.cotani.redis.leaderboard.RankEntry
Returns the value of the rank record component.
RankEntry - Record Class in com.cotani.redis.leaderboard
Represents a member entry in a sorted set leaderboard with score and rank.
RankEntry(String, double, long) - Constructor for record class com.cotani.redis.leaderboard.RankEntry
Creates an instance of a RankEntry record class.
rateLimiter() - Method in interface com.cotani.redis.CotaniRedis
Returns the distributed rate limiter service.
RateLimitResult - Record Class in com.cotani.redis.ratelimit
Result of a rate limit check against a sliding window.
RateLimitResult(boolean, long, long, Duration) - Constructor for record class com.cotani.redis.ratelimit.RateLimitResult
Creates an instance of a RateLimitResult record class.
RECONNECTING - Enum constant in enum class com.cotani.redis.RedisState
 
redis() - Method in class com.cotani.redis.CotaniRedisModule
 
RedisCacheInvalidationBus<K> - Class in com.cotani.redis.cache
Distributed cache invalidation bus backed by Redis Pub/Sub.
RedisCacheInvalidationBus(CotaniRedis, ChannelId, RedisCodec) - Constructor for class com.cotani.redis.cache.RedisCacheInvalidationBus
 
RedisCacheRepository<K,V> - Class in com.cotani.redis.cache
Adapter integrating RedisKeyValueStore as a persistent backing store for CacheRepository.
RedisChannel<T> - Interface in com.cotani.redis.channel
Strongly typed Redis Pub/Sub message channel.
RedisCodec<T> - Interface in com.cotani.redis.codec
Strategy interface for encoding domain messages to bytes and decoding raw bytes back to domain objects.
RedisConfig - Record Class in com.cotani.redis.config
Immutable configuration for connecting to a Redis standalone or cluster instance.
RedisConfig(String, int, String, String, int, boolean, String, Duration, Duration) - Constructor for record class com.cotani.redis.config.RedisConfig
Creates an instance of a RedisConfig record class.
RedisConfig.Builder - Class in com.cotani.redis.config
 
RedisConnectionException - Exception Class in com.cotani.redis.exception
Thrown when connecting to the Redis cluster or server fails or drops unexpectedly.
RedisConnectionException(String) - Constructor for exception class com.cotani.redis.exception.RedisConnectionException
 
RedisConnectionException(String, Throwable) - Constructor for exception class com.cotani.redis.exception.RedisConnectionException
 
RedisDistributedCooldownService - Class in com.cotani.redis.cooldown
High-performance distributed cooldown service backed by Redis.
RedisDistributedCooldownService(CotaniRedis) - Constructor for class com.cotani.redis.cooldown.RedisDistributedCooldownService
 
RedisDistributedCooldownService(CotaniRedis, Clock, String) - Constructor for class com.cotani.redis.cooldown.RedisDistributedCooldownService
 
RedisDistributedEventBus - Class in com.cotani.redis.event
Distributed event bus bridging local EventBus listeners with Redis Pub/Sub across a server cluster.
RedisDistributedEventBus(EventBus, CotaniRedis, ChannelId) - Constructor for class com.cotani.redis.event.RedisDistributedEventBus
 
RedisException - Exception Class in com.cotani.redis.exception
Base runtime exception for all Redis-related errors in Cotani.
RedisException(String) - Constructor for exception class com.cotani.redis.exception.RedisException
 
RedisException(String, Throwable) - Constructor for exception class com.cotani.redis.exception.RedisException
 
RedisKey - Record Class in com.cotani.redis.store
Value object representing a key in Redis storage.
RedisKey(String) - Constructor for record class com.cotani.redis.store.RedisKey
Creates an instance of a RedisKey record class.
RedisKeyValueStore - Interface in com.cotani.redis.store
High-performance non-blocking Redis key-value operations and atomic counters.
RedisRateLimiter - Interface in com.cotani.redis.ratelimit
Distributed rate limiter backed by Redis atomic sliding window Lua scripts.
RedisRpcChannel<Q,R> - Interface in com.cotani.redis.channel
Asynchronous cross-server Request-Response (RPC) communication channel over Redis Pub/Sub.
RedisSortedSetStore - Interface in com.cotani.redis.leaderboard
Non-blocking Redis Sorted Set (ZSET) operations for real-time leaderboards, ranked statistics, and priority scoring.
RedisState - Enum Class in com.cotani.redis
State machine representing the lifecycle of a CotaniRedis client instance.
RedisTimeoutException - Exception Class in com.cotani.redis.exception
Thrown when a Redis command or transaction exceeds its allocated deadline.
RedisTimeoutException(String) - Constructor for exception class com.cotani.redis.exception.RedisTimeoutException
 
RedisTimeoutException(String, Throwable) - Constructor for exception class com.cotani.redis.exception.RedisTimeoutException
 
registerCodec(Class, RedisCodec) - Method in class com.cotani.redis.event.RedisDistributedEventBus
 
releaseAsync() - Method in interface com.cotani.redis.lock.DistributedLock
Asynchronously releases this lock using atomic Lua evaluation to ensure that only the owning token can delete the lock key.
removeAsync(CooldownKey) - Method in class com.cotani.redis.cooldown.RedisDistributedCooldownService
 
removeAsync(RedisKey, String) - Method in interface com.cotani.redis.leaderboard.RedisSortedSetStore
Removes a member from the sorted set.
requestAsync(Q, Duration) - Method in interface com.cotani.redis.channel.RedisRpcChannel
Sends a request across the network and asynchronously waits for a response with a timeout.
resetAfter() - Method in record class com.cotani.redis.ratelimit.RateLimitResult
Returns the value of the resetAfter record component.
resetAsync(String) - Method in interface com.cotani.redis.ratelimit.RedisRateLimiter
Resets/clears the rate limit history for a key immediately.
respond(Function) - Method in interface com.cotani.redis.channel.RedisRpcChannel
Registers a responder handler that processes incoming requests on this channel and computes a reply.
rpcChannel(ChannelId) - Method in interface com.cotani.redis.CotaniRedis
Resolves a string-based asynchronous cross-server Request-Response (RPC) communication channel.
rpcChannel(ChannelId, RedisCodec, RedisCodec) - Method in interface com.cotani.redis.CotaniRedis
Resolves an asynchronous cross-server Request-Response (RPC) communication channel.

S

save(K, V) - Method in class com.cotani.redis.cache.RedisCacheRepository
 
scanKeysAsync(String) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Asynchronously scans for keys matching a pattern using cursor-based non-blocking SCAN.
scheduler(PaperTaskScheduler) - Method in class com.cotani.redis.CotaniRedisBuilder
 
score() - Method in record class com.cotani.redis.leaderboard.RankEntry
Returns the value of the score record component.
setAsync(RedisKey, String) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Sets a string value with no expiration.
setAsync(RedisKey, String, Duration) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Sets a string value with a time-to-live expiration.
setAsync(RedisKey, T, RedisCodec) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Sets a typed object encoded using the specified codec with no expiration.
setAsync(RedisKey, T, RedisCodec, Duration) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Sets a typed object encoded using the specified codec with a time-to-live expiration.
setIfAbsentAsync(RedisKey, String, Duration) - Method in interface com.cotani.redis.store.RedisKeyValueStore
Sets a string value with a time-to-live expiration only if the key does not already exist (SET NX PX).
sizeAsync() - Method in class com.cotani.redis.cooldown.RedisDistributedCooldownService
 
sizeAsync(RedisKey) - Method in interface com.cotani.redis.leaderboard.RedisSortedSetStore
Returns the total cardinality (number of members) of the sorted set.
sortedSets() - Method in interface com.cotani.redis.CotaniRedis
Returns the distributed Sorted Set and Leaderboard operations service.
ssl() - Method in record class com.cotani.redis.config.RedisConfig
Returns the value of the ssl record component.
ssl(boolean) - Method in class com.cotani.redis.config.RedisConfig.Builder
 
startAsync() - Method in interface com.cotani.redis.CotaniRedis
Connects to the Redis cluster and prepares connection pools asynchronously.
STARTING - Enum constant in enum class com.cotani.redis.RedisState
 
state() - Method in interface com.cotani.redis.CotaniRedis
Returns the current connection and lifecycle state.
store() - Method in interface com.cotani.redis.CotaniRedis
Returns the key-value storage and counter operations.
string() - Static method in interface com.cotani.redis.codec.RedisCodec
Codec for plain UTF-8 strings.
StringRedisCodec - Class in com.cotani.redis.codec
UTF-8 String Redis codec.
subscribe(Class, EventListener) - Method in class com.cotani.redis.event.RedisDistributedEventBus
 
subscribe(Class, EventPriority, boolean, EventListener) - Method in class com.cotani.redis.event.RedisDistributedEventBus
 
subscribe(Class, EventPriority, EventListener) - Method in class com.cotani.redis.event.RedisDistributedEventBus
 
subscribe(Consumer) - Method in class com.cotani.redis.cache.RedisCacheInvalidationBus
 
subscribe(Consumer) - Method in interface com.cotani.redis.channel.RedisChannel
Subscribes a listener to receive messages from this channel on default virtual/async thread.
subscribe(Consumer, Executor) - Method in interface com.cotani.redis.channel.RedisChannel
Subscribes a listener to receive messages from this channel dispatched via an explicit executor.

T

text(Function, Function) - Static method in interface com.cotani.redis.codec.RedisCodec
Creates a text-based codec that transforms to and from UTF-8 strings.
timeout() - Method in record class com.cotani.redis.config.RedisConfig
Returns the value of the timeout record component.
timeout(Duration) - Method in class com.cotani.redis.config.RedisConfig.Builder
 
timestamp() - Method in record class com.cotani.redis.channel.ChannelMessage
Returns the value of the timestamp record component.
token() - Method in interface com.cotani.redis.lock.DistributedLock
Returns the unique token identifying this client's ownership of the lock.
toString() - Method in record class com.cotani.redis.channel.ChannelId
Returns a string representation of this record class.
toString() - Method in record class com.cotani.redis.channel.ChannelMessage
Returns a string representation of this record class.
toString() - Method in record class com.cotani.redis.config.RedisConfig
Returns a string representation of this record class.
toString() - Method in record class com.cotani.redis.leaderboard.RankEntry
Returns a string representation of this record class.
toString() - Method in record class com.cotani.redis.lock.LockKey
Returns a string representation of this record class.
toString() - Method in record class com.cotani.redis.lock.LockToken
Returns a string representation of this record class.
toString() - Method in record class com.cotani.redis.ratelimit.RateLimitResult
Returns a string representation of this record class.
toString() - Method in record class com.cotani.redis.store.RedisKey
Returns a string representation of this record class.
tryAcquireAsync(LockKey, Duration) - Method in interface com.cotani.redis.lock.DistributedLockService
Attempts to acquire a distributed lock immediately without waiting.
tryAcquireAsync(String, int, int, Duration) - Method in interface com.cotani.redis.ratelimit.RedisRateLimiter
Attempts to acquire multiple permits for a rate limit key.
tryAcquireAsync(String, int, Duration) - Method in interface com.cotani.redis.ratelimit.RedisRateLimiter
Attempts to acquire a single permit for a rate limit key.

U

unsubscribe(EventSubscription) - Method in class com.cotani.redis.event.RedisDistributedEventBus
 
unsubscribeAsync() - Method in interface com.cotani.redis.channel.ChannelSubscription
Asynchronously cancels this subscription and unregisters its listener.
username() - Method in record class com.cotani.redis.config.RedisConfig
Returns the value of the username record component.
username(String) - Method in class com.cotani.redis.config.RedisConfig.Builder
 

V

value() - Method in record class com.cotani.redis.channel.ChannelId
Returns the value of the value record component.
value() - Method in record class com.cotani.redis.lock.LockKey
Returns the value of the value record component.
value() - Method in record class com.cotani.redis.lock.LockToken
Returns the value of the value record component.
value() - Method in record class com.cotani.redis.store.RedisKey
Returns the value of the value record component.
valueOf(String) - Static method in enum class com.cotani.redis.RedisState
Returns the enum constant of this class with the specified name.
values() - Static method in enum class com.cotani.redis.RedisState
Returns an array containing the constants of this enum class, in the order they are declared.

W

withLockAsync(LockKey, Duration, Supplier) - Method in interface com.cotani.redis.lock.DistributedLockService
Executes an asynchronous task safely under the protection of a distributed lock, guaranteeing that the lock is released when the task completes (successfully or exceptionally).
withWatchdogLockAsync(LockKey, Duration, Supplier) - Method in interface com.cotani.redis.lock.DistributedLockService
Executes an asynchronous task safely under a distributed lock with automatic lease renewal (Watchdog), periodically extending the lock's expiration until the task completes.
A B C D E F G H I K L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Serialized Form