| Package | Description |
|---|---|
| io.lettuce.core |
The Redis client package containing
RedisClient for Redis Standalone and Redis Sentinel operations. |
| io.lettuce.core.api.async |
Standalone Redis API for asynchronous executed commands.
|
| io.lettuce.core.api.reactive |
Standalone Redis API for reactive command execution.
|
| io.lettuce.core.api.sync |
Standalone Redis API for synchronous executed commands.
|
| io.lettuce.core.cluster.api.async |
Redis Cluster API for asynchronous executed commands.
|
| io.lettuce.core.cluster.api.sync |
Redis Cluster API for synchronous executed commands.
|
| io.lettuce.core.output |
Implementation of different output protocols including the Streaming API.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GeoValue<V>
A Geo value extension to
Value. |
class |
KeyValue<K,V>
A key-value container extension to
Value. |
class |
ScoredValue<V>
A scored-value extension to
Value. |
| Modifier and Type | Method and Description |
|---|---|
static <V> Value<V> |
Value.empty()
Returns an empty
Value instance. |
static <T extends V,V> |
ScoredValue.from(double score,
Optional<T> optional)
|
static <T extends V,V> |
GeoValue.from(GeoCoordinates coordinates,
Optional<T> optional)
|
static <T extends V,V> |
Value.from(Optional<T> optional)
|
static <T extends V,V> |
ScoredValue.fromNullable(double score,
T value)
|
static <T extends V,V> |
GeoValue.fromNullable(GeoCoordinates coordinates,
T value)
|
static <T extends V,V> |
Value.fromNullable(T value)
Creates a
Value from a value. |
static <T extends V,V> |
Value.just(T value)
Creates a
Value from a value. |
<R> Value<R> |
Value.map(Function<? super V,? extends R> mapper)
Returns a
Value consisting of the results of applying the given function to the value of this element. |
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Flux<Value<V>> |
AbstractRedisReactiveCommands.argetrange(K key,
long start,
long end) |
Command<K,V,List<Value<V>>> |
RedisArrayCommandBuilder.argetrangeValues(K key,
long start,
long end) |
reactor.core.publisher.Flux<Value<V>> |
AbstractRedisReactiveCommands.armget(K key,
long... indices) |
Command<K,V,List<Value<V>>> |
RedisArrayCommandBuilder.armgetValues(K key,
long... indices) |
reactor.core.publisher.Flux<Value<Boolean>> |
AbstractRedisReactiveCommands.bfInsert(K key,
BfInsertArgs insertArgs,
V... values) |
reactor.core.publisher.Flux<Value<Boolean>> |
AbstractRedisReactiveCommands.bfInsert(K key,
BfInsertArgs insertArgs,
V value) |
reactor.core.publisher.Flux<Value<Boolean>> |
AbstractRedisReactiveCommands.bfInsert(K key,
V... values) |
reactor.core.publisher.Flux<Value<Boolean>> |
AbstractRedisReactiveCommands.bfInsert(K key,
V value) |
reactor.core.publisher.Flux<Value<Boolean>> |
AbstractRedisReactiveCommands.bfMAdd(K key,
V... values) |
reactor.core.publisher.Flux<Value<Long>> |
AbstractRedisReactiveCommands.bitfield(K key,
BitFieldArgs args) |
reactor.core.publisher.Flux<Value<Boolean>> |
AbstractRedisReactiveCommands.cfInsertNx(K key,
CfInsertArgs args,
V... values) |
reactor.core.publisher.Flux<Value<Boolean>> |
AbstractRedisReactiveCommands.cfInsertNx(K key,
CfInsertArgs args,
V value) |
reactor.core.publisher.Flux<Value<Boolean>> |
AbstractRedisReactiveCommands.cfInsertNx(K key,
V... values) |
reactor.core.publisher.Flux<Value<Boolean>> |
AbstractRedisReactiveCommands.cfInsertNx(K key,
V value) |
RedisFuture<List<Value<String>>> |
AbstractRedisAsyncCommands.geohash(K key,
V... members) |
reactor.core.publisher.Flux<Value<String>> |
AbstractRedisReactiveCommands.geohash(K key,
V... members) |
reactor.core.publisher.Flux<Value<GeoCoordinates>> |
AbstractRedisReactiveCommands.geopos(K key,
V... members) |
reactor.core.publisher.Flux<Value<String>> |
AbstractRedisReactiveCommands.topKAdd(K key,
V... values) |
reactor.core.publisher.Flux<Value<String>> |
AbstractRedisReactiveCommands.topKAdd(K key,
V value) |
reactor.core.publisher.Flux<Value<String>> |
AbstractRedisReactiveCommands.topKIncrBy(K key,
IncrementPair<V>... pairs) |
reactor.core.publisher.Flux<Value<String>> |
AbstractRedisReactiveCommands.topKIncrBy(K key,
V value,
long increment) |
| Modifier and Type | Method and Description |
|---|---|
RedisFuture<List<Value<String>>> |
RedisGeoAsyncCommands.geohash(K key,
V... members)
Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a
geospatial index.
|
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Flux<Value<V>> |
RedisArrayReactiveCommands.argetrange(K key,
long start,
long end)
Get all values in a range, including
empty() for empty slots. |
reactor.core.publisher.Flux<Value<V>> |
RedisArrayReactiveCommands.armget(K key,
long... indices)
Get the values at multiple indices in the array stored at
key. |
reactor.core.publisher.Flux<Value<Boolean>> |
RedisBloomFilterReactiveCommands.bfInsert(K key,
BfInsertArgs insertArgs,
V... values)
Add one or more items to the Bloom Filter.
|
reactor.core.publisher.Flux<Value<Boolean>> |
RedisBloomFilterReactiveCommands.bfInsert(K key,
BfInsertArgs insertArgs,
V value)
Add an item to the Bloom Filter.
|
reactor.core.publisher.Flux<Value<Boolean>> |
RedisBloomFilterReactiveCommands.bfInsert(K key,
V... values)
Add one or more items to the Bloom Filter.
|
reactor.core.publisher.Flux<Value<Boolean>> |
RedisBloomFilterReactiveCommands.bfInsert(K key,
V value)
Add an item to the Bloom Filter.
|
reactor.core.publisher.Flux<Value<Boolean>> |
RedisBloomFilterReactiveCommands.bfMAdd(K key,
V... values)
Add one or more items to the Bloom Filter.
|
reactor.core.publisher.Flux<Value<Long>> |
RedisStringReactiveCommands.bitfield(K key,
BitFieldArgs bitFieldArgs)
Execute
BITFIELD with its subcommands. |
reactor.core.publisher.Flux<Value<Boolean>> |
RedisCuckooFilterReactiveCommands.cfInsertNx(K key,
CfInsertArgs args,
V... values)
Add one or more items to a Cuckoo Filter only if the items do not already exist.
|
reactor.core.publisher.Flux<Value<Boolean>> |
RedisCuckooFilterReactiveCommands.cfInsertNx(K key,
CfInsertArgs args,
V value)
Add one or more items to a Cuckoo Filter only if the items do not already exist.
|
reactor.core.publisher.Flux<Value<Boolean>> |
RedisCuckooFilterReactiveCommands.cfInsertNx(K key,
V... values)
Add one or more items to a Cuckoo Filter only if the items do not already exist.
|
reactor.core.publisher.Flux<Value<Boolean>> |
RedisCuckooFilterReactiveCommands.cfInsertNx(K key,
V value)
Add one or more items to a Cuckoo Filter only if the items do not already exist.
|
reactor.core.publisher.Flux<Value<String>> |
RedisGeoReactiveCommands.geohash(K key,
V... members)
Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a
geospatial index.
|
reactor.core.publisher.Flux<Value<GeoCoordinates>> |
RedisGeoReactiveCommands.geopos(K key,
V... members)
Get geo coordinates for the
members. |
reactor.core.publisher.Flux<Value<String>> |
RedisTopKReactiveCommands.topKAdd(K key,
V... values)
Adds a
value to a Top-k sketch. |
reactor.core.publisher.Flux<Value<String>> |
RedisTopKReactiveCommands.topKAdd(K key,
V value)
Adds a
value to a Top-k sketch. |
reactor.core.publisher.Flux<Value<String>> |
RedisTopKReactiveCommands.topKIncrBy(K key,
IncrementPair<V>... pairs)
Adds a
value to a Top-k sketch. |
reactor.core.publisher.Flux<Value<String>> |
RedisTopKReactiveCommands.topKIncrBy(K key,
V value,
long increment)
Increments the count of a
value in a Top-K sketch by the given increment. |
| Modifier and Type | Method and Description |
|---|---|
List<Value<String>> |
RedisGeoCommands.geohash(K key,
V... members)
Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a
geospatial index.
|
| Modifier and Type | Method and Description |
|---|---|
AsyncExecutions<List<Value<String>>> |
NodeSelectionGeoAsyncCommands.geohash(K key,
V... members)
Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a
geospatial index.
|
| Modifier and Type | Method and Description |
|---|---|
Executions<List<Value<String>>> |
NodeSelectionGeoCommands.geohash(K key,
V... members)
Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a
geospatial index.
|
| Modifier and Type | Method and Description |
|---|---|
StreamingOutput.Subscriber<Value<V>> |
ValueValueListOutput.getSubscriber() |
StreamingOutput.Subscriber<Value<GeoCoordinates>> |
GeoCoordinatesValueListOutput.getSubscriber() |
StreamingOutput.Subscriber<Value<Boolean>> |
ErrorTolerantBooleanValueListOutput.getSubscriber() |
StreamingOutput.Subscriber<Value<String>> |
StringValueListOutput.getSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
void |
ErrorTolerantBooleanValueListOutput.setSubscriber(StreamingOutput.Subscriber<Value<Boolean>> subscriber) |
void |
GeoCoordinatesValueListOutput.setSubscriber(StreamingOutput.Subscriber<Value<GeoCoordinates>> subscriber) |
void |
StringValueListOutput.setSubscriber(StreamingOutput.Subscriber<Value<String>> subscriber) |
void |
ValueValueListOutput.setSubscriber(StreamingOutput.Subscriber<Value<V>> subscriber) |
Copyright © 2026 lettuce.io. All rights reserved.