Index
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
allowedrecord 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
channelrecord 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
ChannelIdrecord 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
ChannelMessagerecord 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
clientNamerecord 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
connectTimeoutrecord 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
CotaniRedisinstances. - CotaniRedisBuilder() - Constructor for class com.cotani.redis.CotaniRedisBuilder
- CotaniRedises - Class in com.cotani.redis
-
Entrypoint factory for the
cotani-redismodule. - 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
CotaniRedisinstance for a plugin using the given configuration. - create(Plugin, RedisConfig) - Static method in class com.cotani.redis.CotaniRedises
-
Creates a
CotaniRedisinstance 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
CotaniRedisinstance for a plugin using the given configuration and scheduler. - create(Plugin, RedisConfig, PaperTaskScheduler) - Static method in class com.cotani.redis.CotaniRedises
-
Creates a
CotaniRedisinstance 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
currentRequestsrecord component.
D
- database() - Method in record class com.cotani.redis.config.RedisConfig
-
Returns the value of the
databaserecord 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
hostrecord 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
LockKeyrecord 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
LockTokenrecord class.
M
- maxRequests() - Method in record class com.cotani.redis.ratelimit.RateLimitResult
-
Returns the value of the
maxRequestsrecord component. - member() - Method in record class com.cotani.redis.leaderboard.RankEntry
-
Returns the value of the
memberrecord 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
passwordrecord 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
payloadrecord 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
portrecord 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
rankrecord 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
RankEntryrecord 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
RateLimitResultrecord 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
RedisKeyValueStoreas a persistent backing store forCacheRepository. - 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
RedisConfigrecord 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
EventBuslisteners 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
RedisKeyrecord 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
CotaniRedisclient 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
resetAfterrecord 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
scorerecord 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
sslrecord 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
timeoutrecord 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
timestamprecord 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
usernamerecord 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
valuerecord component. - value() - Method in record class com.cotani.redis.lock.LockKey
-
Returns the value of the
valuerecord component. - value() - Method in record class com.cotani.redis.lock.LockToken
-
Returns the value of the
valuerecord component. - value() - Method in record class com.cotani.redis.store.RedisKey
-
Returns the value of the
valuerecord 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.
All Classes and Interfaces|All Packages|Serialized Form