| Package | Description |
|---|---|
| io.lettuce.core |
The Redis client package containing
RedisClient for Redis Standalone and Redis Sentinel operations. |
| io.lettuce.core.api |
Standalone Redis connection API.
|
| 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.array | |
| 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.failover | |
| io.lettuce.core.failover.api | |
| io.lettuce.core.failover.event | |
| io.lettuce.core.failover.health |
Health check infrastructure for automatic failover in multi-database Redis connections.
|
| io.lettuce.core.failover.metrics | |
| io.lettuce.core.output |
Implementation of different output protocols including the Streaming API.
|
| io.lettuce.core.search |
Support for the RediSearch features.
|
| io.lettuce.core.search.aggregateutils | |
| io.lettuce.core.search.arguments.hybrid | |
| io.lettuce.core.support.http |
HTTP client infrastructure for lightweight HTTP operations.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CompareCondition<V>
A compare condition to be used with commands that support conditional value checks (e.g.
|
interface |
Delegating<T>
A delegating interface that allows access to the underlying delegate.
|
class |
HashImport<K>
Reusable set of field names shared by many hashes, imported with the
HIMPORT command family. |
class |
HotkeysArgs
Argument list builder for the Redis HOTKEYS START command.
|
class |
HotkeysReply
Reply from the Redis HOTKEYS GET command.
|
| Modifier and Type | Method and Description |
|---|---|
static SetArgs |
SetArgs.Builder.compareCondition(CompareCondition condition)
Creates new
SetArgs with compare condition CompareCondition |
<V> SetArgs |
SetArgs.compareCondition(CompareCondition<V> compareCondition)
Set a compare condition for the SET operation.
|
protected DefaultEndpoint |
RedisClient.createEndpoint()
Create a new
DefaultEndpoint. |
protected <K,V> PubSubEndpoint<K,V> |
RedisClient.createPubSubEndpoint()
Create a new
PubSubEndpoint. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
BaseRedisClient |
| Modifier and Type | Method and Description |
|---|---|
RedisFuture<Long> |
RedisArrayAsyncCommands.arcount(K key)
Get the count of populated (non-empty) slots in the array.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.ardel(K key,
long... indices)
Delete elements at the given indices.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.ardel(K key,
long index)
Delete a single element at the given index.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.ardelrange(K key,
ArrayIndexRange... ranges)
Delete elements in the given ranges.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.ardelrange(K key,
long start,
long end)
Delete elements in the given range (inclusive).
|
RedisFuture<V> |
RedisArrayAsyncCommands.arget(K key,
long index)
Get the value at the given index in the array stored at
key. |
RedisFuture<List<V>> |
RedisArrayAsyncCommands.argetrange(K key,
long start,
long end)
Get all values in a range, including
null for empty slots. |
RedisFuture<List<Long>> |
RedisArrayAsyncCommands.argrep(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning matching indices.
|
RedisFuture<List<IndexedValue<V>>> |
RedisArrayAsyncCommands.argrepWithValues(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning index/value pairs.
|
RedisFuture<ArrayInfo> |
RedisArrayAsyncCommands.arinfo(K key)
Get metadata about the array.
|
RedisFuture<ArrayInfoFull> |
RedisArrayAsyncCommands.arinfoFull(K key)
Get extended metadata about the array (including per-slice stats).
|
RedisFuture<Long> |
RedisArrayAsyncCommands.arinsert(K key,
V... values)
Insert one or more values at the next available index.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.arinsert(K key,
V value)
Insert a single value at the next available index.
|
RedisFuture<List<V>> |
RedisArrayAsyncCommands.arlastitems(K key,
long count)
Get the last N items in insertion order.
|
RedisFuture<List<V>> |
RedisArrayAsyncCommands.arlastitems(K key,
long count,
boolean rev)
Get the last N items, optionally in reverse order.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.arlen(K key)
Get the logical length of the array (max index + 1).
|
RedisFuture<List<V>> |
RedisArrayAsyncCommands.armget(K key,
long... indices)
Get the values at multiple indices in the array stored at
key. |
RedisFuture<Long> |
RedisArrayAsyncCommands.armset(K key,
Map<Long,V> indexValueMap)
Set multiple index-value pairs in the array stored at
key. |
RedisFuture<Long> |
RedisArrayAsyncCommands.arnext(K key)
Get the next insert index for the array.
|
RedisFuture<V> |
RedisArrayAsyncCommands.aropAggregate(K key,
long start,
long end,
ArAggregateType operation)
Perform an aggregate operation (SUM, MIN, MAX) over elements in a range.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.aropBitwise(K key,
long start,
long end,
ArBitwiseType operation)
Perform a bitwise operation (AND, OR, XOR) over elements in a range.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.aropCount(K key,
long start,
long end)
Count the number of non-empty (populated) elements in a range (AROP USED).
|
RedisFuture<Long> |
RedisArrayAsyncCommands.aropCount(K key,
long start,
long end,
V matchValue)
Count occurrences of a value in a range (AROP MATCH).
|
RedisFuture<Long> |
RedisArrayAsyncCommands.arring(K key,
long size,
V... values)
Insert values in a ring buffer fashion, wrapping around when the size is exceeded.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.arring(K key,
long size,
V value)
Insert a single value in a ring buffer fashion, wrapping around when the size is exceeded.
|
RedisFuture<List<IndexedValue<V>>> |
RedisArrayAsyncCommands.arscan(K key,
long start,
long end)
Scan populated entries in a range, returning index/value pairs.
|
RedisFuture<List<IndexedValue<V>>> |
RedisArrayAsyncCommands.arscan(K key,
long start,
long end,
long limit)
Scan populated entries in a range with a limit, returning index/value pairs.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.arseek(K key,
long index)
Set the insert cursor to a specific index.
|
RedisFuture<Long> |
RedisArrayAsyncCommands.arset(K key,
long index,
V... values)
Set one or more contiguous values starting at the given index in the array stored at
key. |
RedisFuture<Long> |
RedisArrayAsyncCommands.arset(K key,
long index,
V value)
Set a value at the given index in the array stored at
key. |
RedisFuture<Long> |
RedisKeyAsyncCommands.delex(K key,
CompareCondition<V> compareCondition)
Delete the specified key if the compare condition matches.
|
RedisFuture<String> |
RedisKeyAsyncCommands.digestKey(K key)
Return the XXH3 64-bit digest of the string value stored at a key as a 16-character hex string.
|
RedisFuture<AggregationReply<K,V>> |
RediSearchAsyncCommands.ftAggregate(String index,
V query)
Run a search query on an index and perform basic aggregate transformations using default options.
|
RedisFuture<AggregationReply<K,V>> |
RediSearchAsyncCommands.ftAggregate(String index,
V query,
AggregateArgs<K,V> args)
Run a search query on an index and perform advanced aggregate transformations with a processing pipeline.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftAliasadd(String alias,
String index)
Add an alias to a search index.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftAliasdel(String alias)
Remove an alias from a search index.
|
RedisFuture<List<String>> |
RediSearchAsyncCommands.ftAliaslist(String index)
List all aliases associated with the given index.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftAliasupdate(String alias,
String index)
Update an existing alias to point to a different search index.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftAlter(String index,
boolean skipInitialScan,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftAlter(String index,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftCreate(String index,
CreateArgs<K,V> arguments,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name, custom configuration, and field definitions.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftCreate(String index,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name and field definitions using default settings.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftCursordel(String index,
AggregationReply.Cursor cursor)
Delete a cursor and free its associated resources.
|
RedisFuture<AggregationReply<K,V>> |
RediSearchAsyncCommands.ftCursorread(String index,
AggregationReply.Cursor cursor)
Read next results from an existing cursor using the default batch size.
|
RedisFuture<AggregationReply<K,V>> |
RediSearchAsyncCommands.ftCursorread(String index,
AggregationReply.Cursor cursor,
int count)
Read next results from an existing cursor and optionally override the batch size.
|
RedisFuture<Long> |
RediSearchAsyncCommands.ftDictadd(String dict,
V... terms)
Add terms to a dictionary.
|
RedisFuture<Long> |
RediSearchAsyncCommands.ftDictdel(String dict,
V... terms)
Delete terms from a dictionary.
|
RedisFuture<List<V>> |
RediSearchAsyncCommands.ftDictdump(String dict)
Dump all terms in a dictionary.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftDropindex(String index)
Drop a search index without deleting the associated documents.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftDropindex(String index,
boolean deleteDocuments)
Drop a search index with optional document deletion.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftExplain(String index,
V query)
Return the execution plan for a complex query.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftExplain(String index,
V query,
ExplainArgs<K,V> args)
Return the execution plan for a complex query with additional options.
|
RedisFuture<HybridReply<K,V>> |
RediSearchAsyncCommands.ftHybrid(String index,
HybridArgs<K,V> args)
Execute a hybrid query combining text search and vector similarity.
|
RedisFuture<List<V>> |
RediSearchAsyncCommands.ftList()
Return a list of all existing indexes.
|
RedisFuture<SearchReply<K,V>> |
RediSearchAsyncCommands.ftSearch(String index,
V query)
Search the index with a textual query using default search options.
|
RedisFuture<SearchReply<K,V>> |
RediSearchAsyncCommands.ftSearch(String index,
V query,
SearchArgs<K,V> args)
Search the index with a textual query using advanced search options and filters.
|
RedisFuture<SpellCheckResult<V>> |
RediSearchAsyncCommands.ftSpellcheck(String index,
V query)
Perform spelling correction on a query, returning suggestions for misspelled terms.
|
RedisFuture<SpellCheckResult<V>> |
RediSearchAsyncCommands.ftSpellcheck(String index,
V query,
SpellCheckArgs<K,V> args)
Perform spelling correction on a query with additional options.
|
RedisFuture<Long> |
RediSearchAsyncCommands.ftSugadd(K key,
V suggestion,
double score)
Add a suggestion string to an auto-complete suggestion dictionary.
|
RedisFuture<Long> |
RediSearchAsyncCommands.ftSugadd(K key,
V suggestion,
double score,
SugAddArgs<K,V> args)
Add a suggestion string to an auto-complete suggestion dictionary with additional options.
|
RedisFuture<Boolean> |
RediSearchAsyncCommands.ftSugdel(K key,
V suggestion)
Delete a string from a suggestion dictionary.
|
RedisFuture<List<Suggestion<V>>> |
RediSearchAsyncCommands.ftSugget(K key,
V prefix)
Get completion suggestions for a prefix.
|
RedisFuture<List<Suggestion<V>>> |
RediSearchAsyncCommands.ftSugget(K key,
V prefix,
SugGetArgs<K,V> args)
Get completion suggestions for a prefix with additional options.
|
RedisFuture<Long> |
RediSearchAsyncCommands.ftSuglen(K key)
Get the size of an auto-complete suggestion dictionary.
|
RedisFuture<Map<V,List<V>>> |
RediSearchAsyncCommands.ftSyndump(String index)
Dump synonym group contents.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftSynupdate(String index,
V synonymGroupId,
SynUpdateArgs<K,V> args,
V... terms)
Update a synonym group with additional terms and options.
|
RedisFuture<String> |
RediSearchAsyncCommands.ftSynupdate(String index,
V synonymGroupId,
V... terms)
Update a synonym group with additional terms.
|
RedisFuture<List<V>> |
RediSearchAsyncCommands.ftTagvals(String index,
String fieldName)
Return a distinct set of values indexed in a Tag field.
|
RedisFuture<String> |
RedisHashAsyncCommands.himportSet(K key,
HashImport<K> fieldset,
V... values)
Create the hash stored at
key from fieldset, sending only the values, positionally paired to the
fieldset's field names. |
RedisFuture<HotkeysReply> |
RedisServerAsyncCommands.hotkeysGet()
Get hotkeys tracking results.
|
RedisFuture<String> |
RedisServerAsyncCommands.hotkeysReset()
Reset hotkeys tracking data.
|
RedisFuture<String> |
RedisServerAsyncCommands.hotkeysStart(HotkeysArgs args)
Start hotkeys tracking.
|
RedisFuture<String> |
RedisServerAsyncCommands.hotkeysStop()
Stop hotkeys tracking but retain data.
|
RedisFuture<Boolean> |
RedisVectorSetAsyncCommands.vadd(K key,
int dimensionality,
V element,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality. |
RedisFuture<Boolean> |
RedisVectorSetAsyncCommands.vadd(K key,
int dimensionality,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality and additional options. |
RedisFuture<Boolean> |
RedisVectorSetAsyncCommands.vadd(K key,
V element,
Double... vectors)
Add a new element into the vector set specified by
key. |
RedisFuture<Boolean> |
RedisVectorSetAsyncCommands.vadd(K key,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with additional options. |
RedisFuture<Long> |
RedisVectorSetAsyncCommands.vcard(K key)
Returns the number of elements in the vector set stored at
key. |
RedisFuture<Boolean> |
RedisVectorSetAsyncCommands.vClearAttributes(K key,
V element)
Clears all attributes for the specified
element in the vector set stored at key. |
RedisFuture<Long> |
RedisVectorSetAsyncCommands.vdim(K key)
Returns the dimensionality of the vector set stored at
key. |
RedisFuture<List<Double>> |
RedisVectorSetAsyncCommands.vemb(K key,
V element)
Returns the approximate vector associated with a given
element in the vector set stored at key. |
RedisFuture<RawVector> |
RedisVectorSetAsyncCommands.vembRaw(K key,
V element)
Returns the raw vector data for the specified
element in the vector set stored at key. |
RedisFuture<String> |
RedisVectorSetAsyncCommands.vgetattr(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
RedisFuture<List<JsonValue>> |
RedisVectorSetAsyncCommands.vgetattrAsJsonValue(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
RedisFuture<VectorMetadata> |
RedisVectorSetAsyncCommands.vinfo(K key)
Returns metadata and internal details about the vector set stored at
key. |
RedisFuture<Boolean> |
RedisVectorSetAsyncCommands.vismember(K key,
V element)
Checks whether
element exists in the vector set stored at key. |
RedisFuture<List<V>> |
RedisVectorSetAsyncCommands.vlinks(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph of the vector set stored at key. |
RedisFuture<Map<V,Double>> |
RedisVectorSetAsyncCommands.vlinksWithScores(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph along with their scores. |
RedisFuture<V> |
RedisVectorSetAsyncCommands.vrandmember(K key)
Returns a random element from the vector set stored at
key. |
RedisFuture<List<V>> |
RedisVectorSetAsyncCommands.vrandmember(K key,
int count)
Returns multiple random elements from the vector set stored at
key. |
RedisFuture<Boolean> |
RedisVectorSetAsyncCommands.vrem(K key,
V element)
Removes the specified
element from the vector set stored at key. |
RedisFuture<Boolean> |
RedisVectorSetAsyncCommands.vsetattr(K key,
V element,
JsonValue json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
RedisFuture<Boolean> |
RedisVectorSetAsyncCommands.vsetattr(K key,
V element,
String json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
RedisFuture<List<V>> |
RedisVectorSetAsyncCommands.vsim(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key. |
RedisFuture<List<V>> |
RedisVectorSetAsyncCommands.vsim(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key. |
RedisFuture<List<V>> |
RedisVectorSetAsyncCommands.vsim(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options. |
RedisFuture<List<V>> |
RedisVectorSetAsyncCommands.vsim(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options. |
RedisFuture<Map<V,Double>> |
RedisVectorSetAsyncCommands.vsimWithScore(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores. |
RedisFuture<Map<V,Double>> |
RedisVectorSetAsyncCommands.vsimWithScore(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores. |
RedisFuture<Map<V,Double>> |
RedisVectorSetAsyncCommands.vsimWithScore(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores. |
RedisFuture<Map<V,Double>> |
RedisVectorSetAsyncCommands.vsimWithScore(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores. |
RedisFuture<Map<V,VSimScoreAttribs>> |
RedisVectorSetAsyncCommands.vsimWithScoreWithAttribs(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores and attributes. |
RedisFuture<Map<V,VSimScoreAttribs>> |
RedisVectorSetAsyncCommands.vsimWithScoreWithAttribs(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores and attributes. |
RedisFuture<Map<V,VSimScoreAttribs>> |
RedisVectorSetAsyncCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores and attributes. |
RedisFuture<Map<V,VSimScoreAttribs>> |
RedisVectorSetAsyncCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores and attributes. |
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arcount(K key)
Get the count of populated (non-empty) slots in the array.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.ardel(K key,
long... indices)
Delete elements at the given indices.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.ardel(K key,
long index)
Delete a single element at the given index.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.ardelrange(K key,
ArrayIndexRange... ranges)
Delete elements in the given ranges.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.ardelrange(K key,
long start,
long end)
Delete elements in the given range (inclusive).
|
reactor.core.publisher.Mono<V> |
RedisArrayReactiveCommands.arget(K key,
long index)
Get the value at the given index in the array stored at
key. |
reactor.core.publisher.Flux<Value<V>> |
RedisArrayReactiveCommands.argetrange(K key,
long start,
long end)
Get all values in a range, including
Value.empty() for empty slots. |
reactor.core.publisher.Flux<Long> |
RedisArrayReactiveCommands.argrep(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning matching indices.
|
reactor.core.publisher.Flux<IndexedValue<V>> |
RedisArrayReactiveCommands.argrepWithValues(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning index/value pairs.
|
reactor.core.publisher.Mono<ArrayInfo> |
RedisArrayReactiveCommands.arinfo(K key)
Get metadata about the array.
|
reactor.core.publisher.Mono<ArrayInfoFull> |
RedisArrayReactiveCommands.arinfoFull(K key)
Get extended metadata about the array (including per-slice stats).
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arinsert(K key,
V... values)
Insert one or more values at the next available index.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arinsert(K key,
V value)
Insert a single value at the next available index.
|
reactor.core.publisher.Flux<V> |
RedisArrayReactiveCommands.arlastitems(K key,
long count)
Get the last N items in insertion order.
|
reactor.core.publisher.Flux<V> |
RedisArrayReactiveCommands.arlastitems(K key,
long count,
boolean rev)
Get the last N items, optionally in reverse order.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arlen(K key)
Get the logical length of the array (max index + 1).
|
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.Mono<Long> |
RedisArrayReactiveCommands.armset(K key,
Map<Long,V> indexValueMap)
Set multiple index-value pairs in the array stored at
key. |
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arnext(K key)
Get the next insert index for the array.
|
reactor.core.publisher.Mono<V> |
RedisArrayReactiveCommands.aropAggregate(K key,
long start,
long end,
ArAggregateType operation)
Perform an aggregate operation (SUM, MIN, MAX) over elements in a range.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.aropBitwise(K key,
long start,
long end,
ArBitwiseType operation)
Perform a bitwise operation (AND, OR, XOR) over elements in a range.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.aropCount(K key,
long start,
long end)
Count the number of non-empty (populated) elements in a range (AROP USED).
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.aropCount(K key,
long start,
long end,
V matchValue)
Count occurrences of a value in a range (AROP MATCH).
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arring(K key,
long size,
V... values)
Insert values in a ring buffer fashion, wrapping around when the size is exceeded.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arring(K key,
long size,
V value)
Insert a single value in a ring buffer fashion, wrapping around when the size is exceeded.
|
reactor.core.publisher.Flux<IndexedValue<V>> |
RedisArrayReactiveCommands.arscan(K key,
long start,
long end)
Scan populated entries in a range, returning index/value pairs.
|
reactor.core.publisher.Flux<IndexedValue<V>> |
RedisArrayReactiveCommands.arscan(K key,
long start,
long end,
long limit)
Scan populated entries in a range with a limit, returning index/value pairs.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arseek(K key,
long index)
Set the insert cursor to a specific index.
|
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arset(K key,
long index,
V... values)
Set one or more contiguous values starting at the given index in the array stored at
key. |
reactor.core.publisher.Mono<Long> |
RedisArrayReactiveCommands.arset(K key,
long index,
V value)
Set a value at the given index in the array stored at
key. |
reactor.core.publisher.Mono<Long> |
RedisKeyReactiveCommands.delex(K key,
CompareCondition<V> compareCondition)
Delete the specified key if the compare condition matches.
|
reactor.core.publisher.Mono<String> |
RedisKeyReactiveCommands.digestKey(K key)
Return the XXH3 64-bit digest of the string value stored at a key as a 16-character hex string.
|
reactor.core.publisher.Mono<AggregationReply<K,V>> |
RediSearchReactiveCommands.ftAggregate(String index,
V query)
Run a search query on an index and perform basic aggregate transformations using default options.
|
reactor.core.publisher.Mono<AggregationReply<K,V>> |
RediSearchReactiveCommands.ftAggregate(String index,
V query,
AggregateArgs<K,V> args)
Run a search query on an index and perform advanced aggregate transformations with a processing pipeline.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftAliasadd(String alias,
String index)
Add an alias to a search index.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftAliasdel(String alias)
Remove an alias from a search index.
|
reactor.core.publisher.Flux<String> |
RediSearchReactiveCommands.ftAliaslist(String index)
List all aliases associated with the given index.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftAliasupdate(String alias,
String index)
Update an existing alias to point to a different search index.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftAlter(String index,
boolean skipInitialScan,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftAlter(String index,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftCreate(String index,
CreateArgs<K,V> arguments,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name, custom configuration, and field definitions.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftCreate(String index,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name and field definitions using default settings.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftCursordel(String index,
AggregationReply.Cursor cursor)
Delete a cursor and free its associated resources.
|
reactor.core.publisher.Mono<AggregationReply<K,V>> |
RediSearchReactiveCommands.ftCursorread(String index,
AggregationReply.Cursor cursor)
Read next results from an existing cursor using the default batch size.
|
reactor.core.publisher.Mono<AggregationReply<K,V>> |
RediSearchReactiveCommands.ftCursorread(String index,
AggregationReply.Cursor cursor,
int count)
Read next results from an existing cursor and optionally override the batch size.
|
reactor.core.publisher.Mono<Long> |
RediSearchReactiveCommands.ftDictadd(String dict,
V... terms)
Add terms to a dictionary.
|
reactor.core.publisher.Mono<Long> |
RediSearchReactiveCommands.ftDictdel(String dict,
V... terms)
Delete terms from a dictionary.
|
reactor.core.publisher.Flux<V> |
RediSearchReactiveCommands.ftDictdump(String dict)
Dump all terms in a dictionary.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftDropindex(String index)
Drop a search index without deleting the associated documents.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftDropindex(String index,
boolean deleteDocuments)
Drop a search index with optional document deletion.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftExplain(String index,
V query)
Return the execution plan for a complex query.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftExplain(String index,
V query,
ExplainArgs<K,V> args)
Return the execution plan for a complex query with additional options.
|
reactor.core.publisher.Mono<HybridReply<K,V>> |
RediSearchReactiveCommands.ftHybrid(String index,
HybridArgs<K,V> args)
Execute a hybrid query combining text search and vector similarity.
|
reactor.core.publisher.Flux<V> |
RediSearchReactiveCommands.ftList()
Return a list of all existing indexes.
|
reactor.core.publisher.Mono<SearchReply<K,V>> |
RediSearchReactiveCommands.ftSearch(String index,
V query)
Search the index with a textual query using default search options.
|
reactor.core.publisher.Mono<SearchReply<K,V>> |
RediSearchReactiveCommands.ftSearch(String index,
V query,
SearchArgs<K,V> args)
Search the index with a textual query using advanced search options and filters.
|
reactor.core.publisher.Mono<SpellCheckResult<V>> |
RediSearchReactiveCommands.ftSpellcheck(String index,
V query)
Perform spelling correction on a query, returning suggestions for misspelled terms.
|
reactor.core.publisher.Mono<SpellCheckResult<V>> |
RediSearchReactiveCommands.ftSpellcheck(String index,
V query,
SpellCheckArgs<K,V> args)
Perform spelling correction on a query with additional options.
|
reactor.core.publisher.Mono<Long> |
RediSearchReactiveCommands.ftSugadd(K key,
V suggestion,
double score)
Add a suggestion string to an auto-complete suggestion dictionary.
|
reactor.core.publisher.Mono<Long> |
RediSearchReactiveCommands.ftSugadd(K key,
V suggestion,
double score,
SugAddArgs<K,V> args)
Add a suggestion string to an auto-complete suggestion dictionary with additional options.
|
reactor.core.publisher.Mono<Boolean> |
RediSearchReactiveCommands.ftSugdel(K key,
V suggestion)
Delete a string from a suggestion dictionary.
|
reactor.core.publisher.Flux<Suggestion<V>> |
RediSearchReactiveCommands.ftSugget(K key,
V prefix)
Get completion suggestions for a prefix.
|
reactor.core.publisher.Flux<Suggestion<V>> |
RediSearchReactiveCommands.ftSugget(K key,
V prefix,
SugGetArgs<K,V> args)
Get completion suggestions for a prefix with additional options.
|
reactor.core.publisher.Mono<Long> |
RediSearchReactiveCommands.ftSuglen(K key)
Get the size of an auto-complete suggestion dictionary.
|
reactor.core.publisher.Mono<Map<V,List<V>>> |
RediSearchReactiveCommands.ftSyndump(String index)
Dump synonym group contents.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftSynupdate(String index,
V synonymGroupId,
SynUpdateArgs<K,V> args,
V... terms)
Update a synonym group with additional terms and options.
|
reactor.core.publisher.Mono<String> |
RediSearchReactiveCommands.ftSynupdate(String index,
V synonymGroupId,
V... terms)
Update a synonym group with additional terms.
|
reactor.core.publisher.Flux<V> |
RediSearchReactiveCommands.ftTagvals(String index,
String fieldName)
Return a distinct set of values indexed in a Tag field.
|
reactor.core.publisher.Mono<String> |
RedisHashReactiveCommands.himportSet(K key,
HashImport<K> fieldset,
V... values)
Create the hash stored at
key from fieldset, sending only the values, positionally paired to the
fieldset's field names. |
reactor.core.publisher.Mono<HotkeysReply> |
RedisServerReactiveCommands.hotkeysGet()
Get hotkeys tracking results.
|
reactor.core.publisher.Mono<String> |
RedisServerReactiveCommands.hotkeysReset()
Reset hotkeys tracking data.
|
reactor.core.publisher.Mono<String> |
RedisServerReactiveCommands.hotkeysStart(HotkeysArgs args)
Start hotkeys tracking.
|
reactor.core.publisher.Mono<String> |
RedisServerReactiveCommands.hotkeysStop()
Stop hotkeys tracking but retain data.
|
reactor.core.publisher.Mono<Boolean> |
RedisVectorSetReactiveCommands.vadd(K key,
int dimensionality,
V element,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality. |
reactor.core.publisher.Mono<Boolean> |
RedisVectorSetReactiveCommands.vadd(K key,
int dimensionality,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality and additional options. |
reactor.core.publisher.Mono<Boolean> |
RedisVectorSetReactiveCommands.vadd(K key,
V element,
Double... vectors)
Add a new element into the vector set specified by
key. |
reactor.core.publisher.Mono<Boolean> |
RedisVectorSetReactiveCommands.vadd(K key,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with additional options. |
reactor.core.publisher.Mono<Long> |
RedisVectorSetReactiveCommands.vcard(K key)
Returns the number of elements in the vector set stored at
key. |
reactor.core.publisher.Mono<Boolean> |
RedisVectorSetReactiveCommands.vClearAttributes(K key,
V element)
Clears all attributes for the specified
element in the vector set stored at key. |
reactor.core.publisher.Mono<Long> |
RedisVectorSetReactiveCommands.vdim(K key)
Returns the dimensionality of the vector set stored at
key. |
reactor.core.publisher.Flux<Double> |
RedisVectorSetReactiveCommands.vemb(K key,
V element)
Returns the approximate vector associated with a given
element in the vector set stored at key. |
reactor.core.publisher.Mono<RawVector> |
RedisVectorSetReactiveCommands.vembRaw(K key,
V element)
Returns the raw vector data for the specified
element in the vector set stored at key. |
reactor.core.publisher.Mono<String> |
RedisVectorSetReactiveCommands.vgetattr(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
reactor.core.publisher.Flux<JsonValue> |
RedisVectorSetReactiveCommands.vgetattrAsJsonValue(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
reactor.core.publisher.Mono<VectorMetadata> |
RedisVectorSetReactiveCommands.vinfo(K key)
Returns metadata and internal details about the vector set stored at
key. |
reactor.core.publisher.Mono<Boolean> |
RedisVectorSetReactiveCommands.vismember(K key,
V element)
Checks whether
element exists in the vector set stored at key. |
reactor.core.publisher.Flux<V> |
RedisVectorSetReactiveCommands.vlinks(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph of the vector set stored at key. |
reactor.core.publisher.Mono<Map<V,Double>> |
RedisVectorSetReactiveCommands.vlinksWithScores(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph along with their scores. |
reactor.core.publisher.Mono<V> |
RedisVectorSetReactiveCommands.vrandmember(K key)
Returns a random element from the vector set stored at
key. |
reactor.core.publisher.Flux<V> |
RedisVectorSetReactiveCommands.vrandmember(K key,
int count)
Returns multiple random elements from the vector set stored at
key. |
reactor.core.publisher.Mono<Boolean> |
RedisVectorSetReactiveCommands.vrem(K key,
V element)
Removes the specified
element from the vector set stored at key. |
reactor.core.publisher.Mono<Boolean> |
RedisVectorSetReactiveCommands.vsetattr(K key,
V element,
JsonValue json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
reactor.core.publisher.Mono<Boolean> |
RedisVectorSetReactiveCommands.vsetattr(K key,
V element,
String json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
reactor.core.publisher.Flux<V> |
RedisVectorSetReactiveCommands.vsim(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key. |
reactor.core.publisher.Flux<V> |
RedisVectorSetReactiveCommands.vsim(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key. |
reactor.core.publisher.Flux<V> |
RedisVectorSetReactiveCommands.vsim(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options. |
reactor.core.publisher.Flux<V> |
RedisVectorSetReactiveCommands.vsim(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options. |
reactor.core.publisher.Mono<Map<V,Double>> |
RedisVectorSetReactiveCommands.vsimWithScore(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores. |
reactor.core.publisher.Mono<Map<V,Double>> |
RedisVectorSetReactiveCommands.vsimWithScore(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores. |
reactor.core.publisher.Mono<Map<V,Double>> |
RedisVectorSetReactiveCommands.vsimWithScore(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores. |
reactor.core.publisher.Mono<Map<V,Double>> |
RedisVectorSetReactiveCommands.vsimWithScore(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores. |
reactor.core.publisher.Mono<Map<V,VSimScoreAttribs>> |
RedisVectorSetReactiveCommands.vsimWithScoreWithAttribs(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores and attributes. |
reactor.core.publisher.Mono<Map<V,VSimScoreAttribs>> |
RedisVectorSetReactiveCommands.vsimWithScoreWithAttribs(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores and attributes. |
reactor.core.publisher.Mono<Map<V,VSimScoreAttribs>> |
RedisVectorSetReactiveCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores and attributes. |
reactor.core.publisher.Mono<Map<V,VSimScoreAttribs>> |
RedisVectorSetReactiveCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores and attributes. |
| Modifier and Type | Method and Description |
|---|---|
Long |
RedisArrayCommands.arcount(K key)
Get the count of populated (non-empty) slots in the array.
|
Long |
RedisArrayCommands.ardel(K key,
long... indices)
Delete elements at the given indices.
|
Long |
RedisArrayCommands.ardel(K key,
long index)
Delete a single element at the given index.
|
Long |
RedisArrayCommands.ardelrange(K key,
ArrayIndexRange... ranges)
Delete elements in the given ranges.
|
Long |
RedisArrayCommands.ardelrange(K key,
long start,
long end)
Delete elements in the given range (inclusive).
|
V |
RedisArrayCommands.arget(K key,
long index)
Get the value at the given index in the array stored at
key. |
List<V> |
RedisArrayCommands.argetrange(K key,
long start,
long end)
Get all values in a range, including
null for empty slots. |
List<Long> |
RedisArrayCommands.argrep(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning matching indices.
|
List<IndexedValue<V>> |
RedisArrayCommands.argrepWithValues(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning index/value pairs.
|
ArrayInfo |
RedisArrayCommands.arinfo(K key)
Get metadata about the array.
|
ArrayInfoFull |
RedisArrayCommands.arinfoFull(K key)
Get extended metadata about the array (including per-slice stats).
|
Long |
RedisArrayCommands.arinsert(K key,
V... values)
Insert one or more values at the next available index.
|
Long |
RedisArrayCommands.arinsert(K key,
V value)
Insert a single value at the next available index.
|
List<V> |
RedisArrayCommands.arlastitems(K key,
long count)
Get the last N items in insertion order.
|
List<V> |
RedisArrayCommands.arlastitems(K key,
long count,
boolean rev)
Get the last N items, optionally in reverse order.
|
Long |
RedisArrayCommands.arlen(K key)
Get the logical length of the array (max index + 1).
|
List<V> |
RedisArrayCommands.armget(K key,
long... indices)
Get the values at multiple indices in the array stored at
key. |
Long |
RedisArrayCommands.armset(K key,
Map<Long,V> indexValueMap)
Set multiple index-value pairs in the array stored at
key. |
Long |
RedisArrayCommands.arnext(K key)
Get the next insert index for the array.
|
V |
RedisArrayCommands.aropAggregate(K key,
long start,
long end,
ArAggregateType operation)
Perform an aggregate operation (SUM, MIN, MAX) over elements in a range.
|
Long |
RedisArrayCommands.aropBitwise(K key,
long start,
long end,
ArBitwiseType operation)
Perform a bitwise operation (AND, OR, XOR) over elements in a range.
|
Long |
RedisArrayCommands.aropCount(K key,
long start,
long end)
Count the number of non-empty (populated) elements in a range (AROP USED).
|
Long |
RedisArrayCommands.aropCount(K key,
long start,
long end,
V matchValue)
Count occurrences of a value in a range (AROP MATCH).
|
Long |
RedisArrayCommands.arring(K key,
long size,
V... values)
Insert values in a ring buffer fashion, wrapping around when the size is exceeded.
|
Long |
RedisArrayCommands.arring(K key,
long size,
V value)
Insert a single value in a ring buffer fashion, wrapping around when the size is exceeded.
|
List<IndexedValue<V>> |
RedisArrayCommands.arscan(K key,
long start,
long end)
Scan populated entries in a range, returning index/value pairs.
|
List<IndexedValue<V>> |
RedisArrayCommands.arscan(K key,
long start,
long end,
long limit)
Scan populated entries in a range with a limit, returning index/value pairs.
|
Long |
RedisArrayCommands.arseek(K key,
long index)
Set the insert cursor to a specific index.
|
Long |
RedisArrayCommands.arset(K key,
long index,
V... values)
Set one or more contiguous values starting at the given index in the array stored at
key. |
Long |
RedisArrayCommands.arset(K key,
long index,
V value)
Set a value at the given index in the array stored at
key. |
Long |
RedisKeyCommands.delex(K key,
CompareCondition<V> compareCondition)
Delete the specified key if the compare condition matches.
|
String |
RedisKeyCommands.digestKey(K key)
Return the XXH3 64-bit digest of the string value stored at a key as a 16-character hex string.
|
AggregationReply<K,V> |
RediSearchCommands.ftAggregate(String index,
V query)
Run a search query on an index and perform basic aggregate transformations using default options.
|
AggregationReply<K,V> |
RediSearchCommands.ftAggregate(String index,
V query,
AggregateArgs<K,V> args)
Run a search query on an index and perform advanced aggregate transformations with a processing pipeline.
|
String |
RediSearchCommands.ftAliasadd(String alias,
String index)
Add an alias to a search index.
|
String |
RediSearchCommands.ftAliasdel(String alias)
Remove an alias from a search index.
|
List<String> |
RediSearchCommands.ftAliaslist(String index)
List all aliases associated with the given index.
|
String |
RediSearchCommands.ftAliasupdate(String alias,
String index)
Update an existing alias to point to a different search index.
|
String |
RediSearchCommands.ftAlter(String index,
boolean skipInitialScan,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
String |
RediSearchCommands.ftAlter(String index,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
String |
RediSearchCommands.ftCreate(String index,
CreateArgs<K,V> arguments,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name, custom configuration, and field definitions.
|
String |
RediSearchCommands.ftCreate(String index,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name and field definitions using default settings.
|
String |
RediSearchCommands.ftCursordel(String index,
AggregationReply.Cursor cursor)
Delete a cursor and free its associated resources.
|
AggregationReply<K,V> |
RediSearchCommands.ftCursorread(String index,
AggregationReply.Cursor cursor)
Read next results from an existing cursor using the default batch size.
|
AggregationReply<K,V> |
RediSearchCommands.ftCursorread(String index,
AggregationReply.Cursor cursor,
int count)
Read next results from an existing cursor and optionally override the batch size.
|
Long |
RediSearchCommands.ftDictadd(String dict,
V... terms)
Add terms to a dictionary.
|
Long |
RediSearchCommands.ftDictdel(String dict,
V... terms)
Delete terms from a dictionary.
|
List<V> |
RediSearchCommands.ftDictdump(String dict)
Dump all terms in a dictionary.
|
String |
RediSearchCommands.ftDropindex(String index)
Drop a search index without deleting the associated documents.
|
String |
RediSearchCommands.ftDropindex(String index,
boolean deleteDocuments)
Drop a search index with optional document deletion.
|
String |
RediSearchCommands.ftExplain(String index,
V query)
Return the execution plan for a complex query.
|
String |
RediSearchCommands.ftExplain(String index,
V query,
ExplainArgs<K,V> args)
Return the execution plan for a complex query with additional options.
|
HybridReply<K,V> |
RediSearchCommands.ftHybrid(String index,
HybridArgs<K,V> args)
Execute a hybrid query combining text search and vector similarity.
|
List<V> |
RediSearchCommands.ftList()
Return a list of all existing indexes.
|
SearchReply<K,V> |
RediSearchCommands.ftSearch(String index,
V query)
Search the index with a textual query using default search options.
|
SearchReply<K,V> |
RediSearchCommands.ftSearch(String index,
V query,
SearchArgs<K,V> args)
Search the index with a textual query using advanced search options and filters.
|
SpellCheckResult<V> |
RediSearchCommands.ftSpellcheck(String index,
V query)
Perform spelling correction on a query, returning suggestions for misspelled terms.
|
SpellCheckResult<V> |
RediSearchCommands.ftSpellcheck(String index,
V query,
SpellCheckArgs<K,V> args)
Perform spelling correction on a query with additional options.
|
Long |
RediSearchCommands.ftSugadd(K key,
V suggestion,
double score)
Add a suggestion string to an auto-complete suggestion dictionary.
|
Long |
RediSearchCommands.ftSugadd(K key,
V suggestion,
double score,
SugAddArgs<K,V> args)
Add a suggestion string to an auto-complete suggestion dictionary with additional options.
|
Boolean |
RediSearchCommands.ftSugdel(K key,
V suggestion)
Delete a string from a suggestion dictionary.
|
List<Suggestion<V>> |
RediSearchCommands.ftSugget(K key,
V prefix)
Get completion suggestions for a prefix.
|
List<Suggestion<V>> |
RediSearchCommands.ftSugget(K key,
V prefix,
SugGetArgs<K,V> args)
Get completion suggestions for a prefix with additional options.
|
Long |
RediSearchCommands.ftSuglen(K key)
Get the size of an auto-complete suggestion dictionary.
|
Map<V,List<V>> |
RediSearchCommands.ftSyndump(String index)
Dump synonym group contents.
|
String |
RediSearchCommands.ftSynupdate(String index,
V synonymGroupId,
SynUpdateArgs<K,V> args,
V... terms)
Update a synonym group with additional terms and options.
|
String |
RediSearchCommands.ftSynupdate(String index,
V synonymGroupId,
V... terms)
Update a synonym group with additional terms.
|
List<V> |
RediSearchCommands.ftTagvals(String index,
String fieldName)
Return a distinct set of values indexed in a Tag field.
|
String |
RedisHashCommands.himportSet(K key,
HashImport<K> fieldset,
V... values)
Create the hash stored at
key from fieldset, sending only the values, positionally paired to the
fieldset's field names. |
HotkeysReply |
RedisServerCommands.hotkeysGet()
Get hotkeys tracking results.
|
String |
RedisServerCommands.hotkeysReset()
Reset hotkeys tracking data.
|
String |
RedisServerCommands.hotkeysStart(HotkeysArgs args)
Start hotkeys tracking.
|
String |
RedisServerCommands.hotkeysStop()
Stop hotkeys tracking but retain data.
|
Boolean |
RedisVectorSetCommands.vadd(K key,
int dimensionality,
V element,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality. |
Boolean |
RedisVectorSetCommands.vadd(K key,
int dimensionality,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality and additional options. |
Boolean |
RedisVectorSetCommands.vadd(K key,
V element,
Double... vectors)
Add a new element into the vector set specified by
key. |
Boolean |
RedisVectorSetCommands.vadd(K key,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with additional options. |
Long |
RedisVectorSetCommands.vcard(K key)
Returns the number of elements in the vector set stored at
key. |
Boolean |
RedisVectorSetCommands.vClearAttributes(K key,
V element)
Clears all attributes for the specified
element in the vector set stored at key. |
Long |
RedisVectorSetCommands.vdim(K key)
Returns the dimensionality of the vector set stored at
key. |
List<Double> |
RedisVectorSetCommands.vemb(K key,
V element)
Returns the approximate vector associated with a given
element in the vector set stored at key. |
RawVector |
RedisVectorSetCommands.vembRaw(K key,
V element)
Returns the raw vector data for the specified
element in the vector set stored at key. |
String |
RedisVectorSetCommands.vgetattr(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
List<JsonValue> |
RedisVectorSetCommands.vgetattrAsJsonValue(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
VectorMetadata |
RedisVectorSetCommands.vinfo(K key)
Returns metadata and internal details about the vector set stored at
key. |
Boolean |
RedisVectorSetCommands.vismember(K key,
V element)
Checks whether
element exists in the vector set stored at key. |
List<V> |
RedisVectorSetCommands.vlinks(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph of the vector set stored at key. |
Map<V,Double> |
RedisVectorSetCommands.vlinksWithScores(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph along with their scores. |
V |
RedisVectorSetCommands.vrandmember(K key)
Returns a random element from the vector set stored at
key. |
List<V> |
RedisVectorSetCommands.vrandmember(K key,
int count)
Returns multiple random elements from the vector set stored at
key. |
Boolean |
RedisVectorSetCommands.vrem(K key,
V element)
Removes the specified
element from the vector set stored at key. |
Boolean |
RedisVectorSetCommands.vsetattr(K key,
V element,
JsonValue json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
Boolean |
RedisVectorSetCommands.vsetattr(K key,
V element,
String json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
List<V> |
RedisVectorSetCommands.vsim(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key. |
List<V> |
RedisVectorSetCommands.vsim(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key. |
List<V> |
RedisVectorSetCommands.vsim(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options. |
List<V> |
RedisVectorSetCommands.vsim(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options. |
Map<V,Double> |
RedisVectorSetCommands.vsimWithScore(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores. |
Map<V,Double> |
RedisVectorSetCommands.vsimWithScore(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores. |
Map<V,Double> |
RedisVectorSetCommands.vsimWithScore(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores. |
Map<V,Double> |
RedisVectorSetCommands.vsimWithScore(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores. |
Map<V,VSimScoreAttribs> |
RedisVectorSetCommands.vsimWithScoreWithAttribs(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores and attributes. |
Map<V,VSimScoreAttribs> |
RedisVectorSetCommands.vsimWithScoreWithAttribs(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores and attributes. |
Map<V,VSimScoreAttribs> |
RedisVectorSetCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores and attributes. |
Map<V,VSimScoreAttribs> |
RedisVectorSetCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores and attributes. |
| Modifier and Type | Class and Description |
|---|---|
class |
ArAggregateType
Aggregate operations for the Redis
AROP command that return a bulk string value (V). |
class |
ArBitwiseType
Bitwise operations for the Redis
AROP command that return an integer (Long). |
class |
ArGrepArgs
Argument builder for the Redis
ARGREP command. |
class |
ArGrepPredicate
Represents a single predicate for the Redis
ARGREP command. |
class |
ArrayIndexRange
Lightweight index range for Redis Array commands that require a start/end pair.
|
class |
ArrayInfo
Immutable representation of metadata about a Redis array, returned by the
ARINFO command. |
class |
ArrayInfoFull
Immutable representation of extended metadata about a Redis array, returned by the
ARINFO key FULL command. |
class |
IndexedValue<V>
Represents an indexed value in a Redis array, pairing a long index with a value.
|
| Modifier and Type | Method and Description |
|---|---|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arcount(K key)
Get the count of populated (non-empty) slots in the array.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.ardel(K key,
long... indices)
Delete elements at the given indices.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.ardel(K key,
long index)
Delete a single element at the given index.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.ardelrange(K key,
ArrayIndexRange... ranges)
Delete elements in the given ranges.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.ardelrange(K key,
long start,
long end)
Delete elements in the given range (inclusive).
|
AsyncExecutions<V> |
NodeSelectionArrayAsyncCommands.arget(K key,
long index)
Get the value at the given index in the array stored at
key. |
AsyncExecutions<List<V>> |
NodeSelectionArrayAsyncCommands.argetrange(K key,
long start,
long end)
Get all values in a range, including
null for empty slots. |
AsyncExecutions<List<Long>> |
NodeSelectionArrayAsyncCommands.argrep(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning matching indices.
|
AsyncExecutions<List<IndexedValue<V>>> |
NodeSelectionArrayAsyncCommands.argrepWithValues(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning index/value pairs.
|
AsyncExecutions<ArrayInfo> |
NodeSelectionArrayAsyncCommands.arinfo(K key)
Get metadata about the array.
|
AsyncExecutions<ArrayInfoFull> |
NodeSelectionArrayAsyncCommands.arinfoFull(K key)
Get extended metadata about the array (including per-slice stats).
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arinsert(K key,
V... values)
Insert one or more values at the next available index.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arinsert(K key,
V value)
Insert a single value at the next available index.
|
AsyncExecutions<List<V>> |
NodeSelectionArrayAsyncCommands.arlastitems(K key,
long count)
Get the last N items in insertion order.
|
AsyncExecutions<List<V>> |
NodeSelectionArrayAsyncCommands.arlastitems(K key,
long count,
boolean rev)
Get the last N items, optionally in reverse order.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arlen(K key)
Get the logical length of the array (max index + 1).
|
AsyncExecutions<List<V>> |
NodeSelectionArrayAsyncCommands.armget(K key,
long... indices)
Get the values at multiple indices in the array stored at
key. |
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.armset(K key,
Map<Long,V> indexValueMap)
Set multiple index-value pairs in the array stored at
key. |
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arnext(K key)
Get the next insert index for the array.
|
AsyncExecutions<V> |
NodeSelectionArrayAsyncCommands.aropAggregate(K key,
long start,
long end,
ArAggregateType operation)
Perform an aggregate operation (SUM, MIN, MAX) over elements in a range.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.aropBitwise(K key,
long start,
long end,
ArBitwiseType operation)
Perform a bitwise operation (AND, OR, XOR) over elements in a range.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.aropCount(K key,
long start,
long end)
Count the number of non-empty (populated) elements in a range (AROP USED).
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.aropCount(K key,
long start,
long end,
V matchValue)
Count occurrences of a value in a range (AROP MATCH).
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arring(K key,
long size,
V... values)
Insert values in a ring buffer fashion, wrapping around when the size is exceeded.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arring(K key,
long size,
V value)
Insert a single value in a ring buffer fashion, wrapping around when the size is exceeded.
|
AsyncExecutions<List<IndexedValue<V>>> |
NodeSelectionArrayAsyncCommands.arscan(K key,
long start,
long end)
Scan populated entries in a range, returning index/value pairs.
|
AsyncExecutions<List<IndexedValue<V>>> |
NodeSelectionArrayAsyncCommands.arscan(K key,
long start,
long end,
long limit)
Scan populated entries in a range with a limit, returning index/value pairs.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arseek(K key,
long index)
Set the insert cursor to a specific index.
|
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arset(K key,
long index,
V... values)
Set one or more contiguous values starting at the given index in the array stored at
key. |
AsyncExecutions<Long> |
NodeSelectionArrayAsyncCommands.arset(K key,
long index,
V value)
Set a value at the given index in the array stored at
key. |
AsyncExecutions<Long> |
NodeSelectionKeyAsyncCommands.delex(K key,
CompareCondition<V> compareCondition)
Delete the specified key if the compare condition matches.
|
AsyncExecutions<String> |
NodeSelectionKeyAsyncCommands.digestKey(K key)
Return the XXH3 64-bit digest of the string value stored at a key as a 16-character hex string.
|
AsyncExecutions<AggregationReply<K,V>> |
NodeSelectionSearchAsyncCommands.ftAggregate(String index,
V query)
Run a search query on an index and perform basic aggregate transformations using default options.
|
AsyncExecutions<AggregationReply<K,V>> |
NodeSelectionSearchAsyncCommands.ftAggregate(String index,
V query,
AggregateArgs<K,V> args)
Run a search query on an index and perform advanced aggregate transformations with a processing pipeline.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftAliasadd(String alias,
String index)
Add an alias to a search index.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftAliasdel(String alias)
Remove an alias from a search index.
|
AsyncExecutions<List<String>> |
NodeSelectionSearchAsyncCommands.ftAliaslist(String index)
List all aliases associated with the given index.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftAliasupdate(String alias,
String index)
Update an existing alias to point to a different search index.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftAlter(String index,
boolean skipInitialScan,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftAlter(String index,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftCreate(String index,
CreateArgs<K,V> arguments,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name, custom configuration, and field definitions.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftCreate(String index,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name and field definitions using default settings.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftCursordel(String index,
AggregationReply.Cursor cursor)
Delete a cursor and free its associated resources.
|
AsyncExecutions<AggregationReply<K,V>> |
NodeSelectionSearchAsyncCommands.ftCursorread(String index,
AggregationReply.Cursor cursor)
Read next results from an existing cursor using the default batch size.
|
AsyncExecutions<AggregationReply<K,V>> |
NodeSelectionSearchAsyncCommands.ftCursorread(String index,
AggregationReply.Cursor cursor,
int count)
Read next results from an existing cursor and optionally override the batch size.
|
AsyncExecutions<Long> |
NodeSelectionSearchAsyncCommands.ftDictadd(String dict,
V... terms)
Add terms to a dictionary.
|
AsyncExecutions<Long> |
NodeSelectionSearchAsyncCommands.ftDictdel(String dict,
V... terms)
Delete terms from a dictionary.
|
AsyncExecutions<List<V>> |
NodeSelectionSearchAsyncCommands.ftDictdump(String dict)
Dump all terms in a dictionary.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftDropindex(String index)
Drop a search index without deleting the associated documents.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftDropindex(String index,
boolean deleteDocuments)
Drop a search index with optional document deletion.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftExplain(String index,
V query)
Return the execution plan for a complex query.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftExplain(String index,
V query,
ExplainArgs<K,V> args)
Return the execution plan for a complex query with additional options.
|
AsyncExecutions<HybridReply<K,V>> |
NodeSelectionSearchAsyncCommands.ftHybrid(String index,
HybridArgs<K,V> args)
Execute a hybrid query combining text search and vector similarity.
|
AsyncExecutions<List<V>> |
NodeSelectionSearchAsyncCommands.ftList()
Return a list of all existing indexes.
|
AsyncExecutions<SearchReply<K,V>> |
NodeSelectionSearchAsyncCommands.ftSearch(String index,
V query)
Search the index with a textual query using default search options.
|
AsyncExecutions<SearchReply<K,V>> |
NodeSelectionSearchAsyncCommands.ftSearch(String index,
V query,
SearchArgs<K,V> args)
Search the index with a textual query using advanced search options and filters.
|
AsyncExecutions<SpellCheckResult<V>> |
NodeSelectionSearchAsyncCommands.ftSpellcheck(String index,
V query)
Perform spelling correction on a query, returning suggestions for misspelled terms.
|
AsyncExecutions<SpellCheckResult<V>> |
NodeSelectionSearchAsyncCommands.ftSpellcheck(String index,
V query,
SpellCheckArgs<K,V> args)
Perform spelling correction on a query with additional options.
|
AsyncExecutions<Long> |
NodeSelectionSearchAsyncCommands.ftSugadd(K key,
V suggestion,
double score)
Add a suggestion string to an auto-complete suggestion dictionary.
|
AsyncExecutions<Long> |
NodeSelectionSearchAsyncCommands.ftSugadd(K key,
V suggestion,
double score,
SugAddArgs<K,V> args)
Add a suggestion string to an auto-complete suggestion dictionary with additional options.
|
AsyncExecutions<Boolean> |
NodeSelectionSearchAsyncCommands.ftSugdel(K key,
V suggestion)
Delete a string from a suggestion dictionary.
|
AsyncExecutions<List<Suggestion<V>>> |
NodeSelectionSearchAsyncCommands.ftSugget(K key,
V prefix)
Get completion suggestions for a prefix.
|
AsyncExecutions<List<Suggestion<V>>> |
NodeSelectionSearchAsyncCommands.ftSugget(K key,
V prefix,
SugGetArgs<K,V> args)
Get completion suggestions for a prefix with additional options.
|
AsyncExecutions<Long> |
NodeSelectionSearchAsyncCommands.ftSuglen(K key)
Get the size of an auto-complete suggestion dictionary.
|
AsyncExecutions<Map<V,List<V>>> |
NodeSelectionSearchAsyncCommands.ftSyndump(String index)
Dump synonym group contents.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftSynupdate(String index,
V synonymGroupId,
SynUpdateArgs<K,V> args,
V... terms)
Update a synonym group with additional terms and options.
|
AsyncExecutions<String> |
NodeSelectionSearchAsyncCommands.ftSynupdate(String index,
V synonymGroupId,
V... terms)
Update a synonym group with additional terms.
|
AsyncExecutions<List<V>> |
NodeSelectionSearchAsyncCommands.ftTagvals(String index,
String fieldName)
Return a distinct set of values indexed in a Tag field.
|
AsyncExecutions<String> |
NodeSelectionHashAsyncCommands.himportSet(K key,
HashImport<K> fieldset,
V... values)
Create the hash stored at
key from fieldset, sending only the values, positionally paired to the
fieldset's field names. |
AsyncExecutions<HotkeysReply> |
NodeSelectionServerAsyncCommands.hotkeysGet()
Get hotkeys tracking results.
|
AsyncExecutions<String> |
NodeSelectionServerAsyncCommands.hotkeysReset()
Reset hotkeys tracking data.
|
AsyncExecutions<String> |
NodeSelectionServerAsyncCommands.hotkeysStart(HotkeysArgs args)
Start hotkeys tracking.
|
AsyncExecutions<String> |
NodeSelectionServerAsyncCommands.hotkeysStop()
Stop hotkeys tracking but retain data.
|
AsyncExecutions<Boolean> |
NodeSelectionVectorSetAsyncCommands.vadd(K key,
int dimensionality,
V element,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality. |
AsyncExecutions<Boolean> |
NodeSelectionVectorSetAsyncCommands.vadd(K key,
int dimensionality,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality and additional options. |
AsyncExecutions<Boolean> |
NodeSelectionVectorSetAsyncCommands.vadd(K key,
V element,
Double... vectors)
Add a new element into the vector set specified by
key. |
AsyncExecutions<Boolean> |
NodeSelectionVectorSetAsyncCommands.vadd(K key,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with additional options. |
AsyncExecutions<Long> |
NodeSelectionVectorSetAsyncCommands.vcard(K key)
Returns the number of elements in the vector set stored at
key. |
AsyncExecutions<Boolean> |
NodeSelectionVectorSetAsyncCommands.vClearAttributes(K key,
V element)
Clears all attributes for the specified
element in the vector set stored at key. |
AsyncExecutions<Long> |
NodeSelectionVectorSetAsyncCommands.vdim(K key)
Returns the dimensionality of the vector set stored at
key. |
AsyncExecutions<List<Double>> |
NodeSelectionVectorSetAsyncCommands.vemb(K key,
V element)
Returns the approximate vector associated with a given
element in the vector set stored at key. |
AsyncExecutions<RawVector> |
NodeSelectionVectorSetAsyncCommands.vembRaw(K key,
V element)
Returns the raw vector data for the specified
element in the vector set stored at key. |
AsyncExecutions<String> |
NodeSelectionVectorSetAsyncCommands.vgetattr(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
AsyncExecutions<List<JsonValue>> |
NodeSelectionVectorSetAsyncCommands.vgetattrAsJsonValue(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
AsyncExecutions<VectorMetadata> |
NodeSelectionVectorSetAsyncCommands.vinfo(K key)
Returns metadata and internal details about the vector set stored at
key. |
AsyncExecutions<Boolean> |
NodeSelectionVectorSetAsyncCommands.vismember(K key,
V element)
Checks whether
element exists in the vector set stored at key. |
AsyncExecutions<List<V>> |
NodeSelectionVectorSetAsyncCommands.vlinks(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph of the vector set stored at key. |
AsyncExecutions<Map<V,Double>> |
NodeSelectionVectorSetAsyncCommands.vlinksWithScores(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph along with their scores. |
AsyncExecutions<V> |
NodeSelectionVectorSetAsyncCommands.vrandmember(K key)
Returns a random element from the vector set stored at
key. |
AsyncExecutions<List<V>> |
NodeSelectionVectorSetAsyncCommands.vrandmember(K key,
int count)
Returns multiple random elements from the vector set stored at
key. |
AsyncExecutions<Boolean> |
NodeSelectionVectorSetAsyncCommands.vrem(K key,
V element)
Removes the specified
element from the vector set stored at key. |
AsyncExecutions<Boolean> |
NodeSelectionVectorSetAsyncCommands.vsetattr(K key,
V element,
JsonValue json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
AsyncExecutions<Boolean> |
NodeSelectionVectorSetAsyncCommands.vsetattr(K key,
V element,
String json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
AsyncExecutions<List<V>> |
NodeSelectionVectorSetAsyncCommands.vsim(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key. |
AsyncExecutions<List<V>> |
NodeSelectionVectorSetAsyncCommands.vsim(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key. |
AsyncExecutions<List<V>> |
NodeSelectionVectorSetAsyncCommands.vsim(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options. |
AsyncExecutions<List<V>> |
NodeSelectionVectorSetAsyncCommands.vsim(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options. |
AsyncExecutions<Map<V,Double>> |
NodeSelectionVectorSetAsyncCommands.vsimWithScore(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores. |
AsyncExecutions<Map<V,Double>> |
NodeSelectionVectorSetAsyncCommands.vsimWithScore(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores. |
AsyncExecutions<Map<V,Double>> |
NodeSelectionVectorSetAsyncCommands.vsimWithScore(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores. |
AsyncExecutions<Map<V,Double>> |
NodeSelectionVectorSetAsyncCommands.vsimWithScore(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores. |
AsyncExecutions<Map<V,VSimScoreAttribs>> |
NodeSelectionVectorSetAsyncCommands.vsimWithScoreWithAttribs(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores and attributes. |
AsyncExecutions<Map<V,VSimScoreAttribs>> |
NodeSelectionVectorSetAsyncCommands.vsimWithScoreWithAttribs(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores and attributes. |
AsyncExecutions<Map<V,VSimScoreAttribs>> |
NodeSelectionVectorSetAsyncCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores and attributes. |
AsyncExecutions<Map<V,VSimScoreAttribs>> |
NodeSelectionVectorSetAsyncCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores and attributes. |
| Modifier and Type | Method and Description |
|---|---|
Executions<Long> |
NodeSelectionArrayCommands.arcount(K key)
Get the count of populated (non-empty) slots in the array.
|
Executions<Long> |
NodeSelectionArrayCommands.ardel(K key,
long... indices)
Delete elements at the given indices.
|
Executions<Long> |
NodeSelectionArrayCommands.ardel(K key,
long index)
Delete a single element at the given index.
|
Executions<Long> |
NodeSelectionArrayCommands.ardelrange(K key,
ArrayIndexRange... ranges)
Delete elements in the given ranges.
|
Executions<Long> |
NodeSelectionArrayCommands.ardelrange(K key,
long start,
long end)
Delete elements in the given range (inclusive).
|
Executions<V> |
NodeSelectionArrayCommands.arget(K key,
long index)
Get the value at the given index in the array stored at
key. |
Executions<List<V>> |
NodeSelectionArrayCommands.argetrange(K key,
long start,
long end)
Get all values in a range, including
null for empty slots. |
Executions<List<Long>> |
NodeSelectionArrayCommands.argrep(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning matching indices.
|
Executions<List<IndexedValue<V>>> |
NodeSelectionArrayCommands.argrepWithValues(K key,
ArGrepArgs grepArgs)
Search for elements matching predicates, returning index/value pairs.
|
Executions<ArrayInfo> |
NodeSelectionArrayCommands.arinfo(K key)
Get metadata about the array.
|
Executions<ArrayInfoFull> |
NodeSelectionArrayCommands.arinfoFull(K key)
Get extended metadata about the array (including per-slice stats).
|
Executions<Long> |
NodeSelectionArrayCommands.arinsert(K key,
V... values)
Insert one or more values at the next available index.
|
Executions<Long> |
NodeSelectionArrayCommands.arinsert(K key,
V value)
Insert a single value at the next available index.
|
Executions<List<V>> |
NodeSelectionArrayCommands.arlastitems(K key,
long count)
Get the last N items in insertion order.
|
Executions<List<V>> |
NodeSelectionArrayCommands.arlastitems(K key,
long count,
boolean rev)
Get the last N items, optionally in reverse order.
|
Executions<Long> |
NodeSelectionArrayCommands.arlen(K key)
Get the logical length of the array (max index + 1).
|
Executions<List<V>> |
NodeSelectionArrayCommands.armget(K key,
long... indices)
Get the values at multiple indices in the array stored at
key. |
Executions<Long> |
NodeSelectionArrayCommands.armset(K key,
Map<Long,V> indexValueMap)
Set multiple index-value pairs in the array stored at
key. |
Executions<Long> |
NodeSelectionArrayCommands.arnext(K key)
Get the next insert index for the array.
|
Executions<V> |
NodeSelectionArrayCommands.aropAggregate(K key,
long start,
long end,
ArAggregateType operation)
Perform an aggregate operation (SUM, MIN, MAX) over elements in a range.
|
Executions<Long> |
NodeSelectionArrayCommands.aropBitwise(K key,
long start,
long end,
ArBitwiseType operation)
Perform a bitwise operation (AND, OR, XOR) over elements in a range.
|
Executions<Long> |
NodeSelectionArrayCommands.aropCount(K key,
long start,
long end)
Count the number of non-empty (populated) elements in a range (AROP USED).
|
Executions<Long> |
NodeSelectionArrayCommands.aropCount(K key,
long start,
long end,
V matchValue)
Count occurrences of a value in a range (AROP MATCH).
|
Executions<Long> |
NodeSelectionArrayCommands.arring(K key,
long size,
V... values)
Insert values in a ring buffer fashion, wrapping around when the size is exceeded.
|
Executions<Long> |
NodeSelectionArrayCommands.arring(K key,
long size,
V value)
Insert a single value in a ring buffer fashion, wrapping around when the size is exceeded.
|
Executions<List<IndexedValue<V>>> |
NodeSelectionArrayCommands.arscan(K key,
long start,
long end)
Scan populated entries in a range, returning index/value pairs.
|
Executions<List<IndexedValue<V>>> |
NodeSelectionArrayCommands.arscan(K key,
long start,
long end,
long limit)
Scan populated entries in a range with a limit, returning index/value pairs.
|
Executions<Long> |
NodeSelectionArrayCommands.arseek(K key,
long index)
Set the insert cursor to a specific index.
|
Executions<Long> |
NodeSelectionArrayCommands.arset(K key,
long index,
V... values)
Set one or more contiguous values starting at the given index in the array stored at
key. |
Executions<Long> |
NodeSelectionArrayCommands.arset(K key,
long index,
V value)
Set a value at the given index in the array stored at
key. |
Executions<Long> |
NodeSelectionKeyCommands.delex(K key,
CompareCondition<V> compareCondition)
Delete the specified key if the compare condition matches.
|
Executions<String> |
NodeSelectionKeyCommands.digestKey(K key)
Return the XXH3 64-bit digest of the string value stored at a key as a 16-character hex string.
|
Executions<AggregationReply<K,V>> |
NodeSelectionSearchCommands.ftAggregate(String index,
V query)
Run a search query on an index and perform basic aggregate transformations using default options.
|
Executions<AggregationReply<K,V>> |
NodeSelectionSearchCommands.ftAggregate(String index,
V query,
AggregateArgs<K,V> args)
Run a search query on an index and perform advanced aggregate transformations with a processing pipeline.
|
Executions<String> |
NodeSelectionSearchCommands.ftAliasadd(String alias,
String index)
Add an alias to a search index.
|
Executions<String> |
NodeSelectionSearchCommands.ftAliasdel(String alias)
Remove an alias from a search index.
|
Executions<List<String>> |
NodeSelectionSearchCommands.ftAliaslist(String index)
List all aliases associated with the given index.
|
Executions<String> |
NodeSelectionSearchCommands.ftAliasupdate(String alias,
String index)
Update an existing alias to point to a different search index.
|
Executions<String> |
NodeSelectionSearchCommands.ftAlter(String index,
boolean skipInitialScan,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
Executions<String> |
NodeSelectionSearchCommands.ftAlter(String index,
List<FieldArgs<K>> fieldArgs)
Add new attributes to an existing search index.
|
Executions<String> |
NodeSelectionSearchCommands.ftCreate(String index,
CreateArgs<K,V> arguments,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name, custom configuration, and field definitions.
|
Executions<String> |
NodeSelectionSearchCommands.ftCreate(String index,
List<FieldArgs<K>> fieldArgs)
Create a new search index with the given name and field definitions using default settings.
|
Executions<String> |
NodeSelectionSearchCommands.ftCursordel(String index,
AggregationReply.Cursor cursor)
Delete a cursor and free its associated resources.
|
Executions<AggregationReply<K,V>> |
NodeSelectionSearchCommands.ftCursorread(String index,
AggregationReply.Cursor cursor)
Read next results from an existing cursor using the default batch size.
|
Executions<AggregationReply<K,V>> |
NodeSelectionSearchCommands.ftCursorread(String index,
AggregationReply.Cursor cursor,
int count)
Read next results from an existing cursor and optionally override the batch size.
|
Executions<Long> |
NodeSelectionSearchCommands.ftDictadd(String dict,
V... terms)
Add terms to a dictionary.
|
Executions<Long> |
NodeSelectionSearchCommands.ftDictdel(String dict,
V... terms)
Delete terms from a dictionary.
|
Executions<List<V>> |
NodeSelectionSearchCommands.ftDictdump(String dict)
Dump all terms in a dictionary.
|
Executions<String> |
NodeSelectionSearchCommands.ftDropindex(String index)
Drop a search index without deleting the associated documents.
|
Executions<String> |
NodeSelectionSearchCommands.ftDropindex(String index,
boolean deleteDocuments)
Drop a search index with optional document deletion.
|
Executions<String> |
NodeSelectionSearchCommands.ftExplain(String index,
V query)
Return the execution plan for a complex query.
|
Executions<String> |
NodeSelectionSearchCommands.ftExplain(String index,
V query,
ExplainArgs<K,V> args)
Return the execution plan for a complex query with additional options.
|
Executions<HybridReply<K,V>> |
NodeSelectionSearchCommands.ftHybrid(String index,
HybridArgs<K,V> args)
Execute a hybrid query combining text search and vector similarity.
|
Executions<List<V>> |
NodeSelectionSearchCommands.ftList()
Return a list of all existing indexes.
|
Executions<SearchReply<K,V>> |
NodeSelectionSearchCommands.ftSearch(String index,
V query)
Search the index with a textual query using default search options.
|
Executions<SearchReply<K,V>> |
NodeSelectionSearchCommands.ftSearch(String index,
V query,
SearchArgs<K,V> args)
Search the index with a textual query using advanced search options and filters.
|
Executions<SpellCheckResult<V>> |
NodeSelectionSearchCommands.ftSpellcheck(String index,
V query)
Perform spelling correction on a query, returning suggestions for misspelled terms.
|
Executions<SpellCheckResult<V>> |
NodeSelectionSearchCommands.ftSpellcheck(String index,
V query,
SpellCheckArgs<K,V> args)
Perform spelling correction on a query with additional options.
|
Executions<Long> |
NodeSelectionSearchCommands.ftSugadd(K key,
V suggestion,
double score)
Add a suggestion string to an auto-complete suggestion dictionary.
|
Executions<Long> |
NodeSelectionSearchCommands.ftSugadd(K key,
V suggestion,
double score,
SugAddArgs<K,V> args)
Add a suggestion string to an auto-complete suggestion dictionary with additional options.
|
Executions<Boolean> |
NodeSelectionSearchCommands.ftSugdel(K key,
V suggestion)
Delete a string from a suggestion dictionary.
|
Executions<List<Suggestion<V>>> |
NodeSelectionSearchCommands.ftSugget(K key,
V prefix)
Get completion suggestions for a prefix.
|
Executions<List<Suggestion<V>>> |
NodeSelectionSearchCommands.ftSugget(K key,
V prefix,
SugGetArgs<K,V> args)
Get completion suggestions for a prefix with additional options.
|
Executions<Long> |
NodeSelectionSearchCommands.ftSuglen(K key)
Get the size of an auto-complete suggestion dictionary.
|
Executions<Map<V,List<V>>> |
NodeSelectionSearchCommands.ftSyndump(String index)
Dump synonym group contents.
|
Executions<String> |
NodeSelectionSearchCommands.ftSynupdate(String index,
V synonymGroupId,
SynUpdateArgs<K,V> args,
V... terms)
Update a synonym group with additional terms and options.
|
Executions<String> |
NodeSelectionSearchCommands.ftSynupdate(String index,
V synonymGroupId,
V... terms)
Update a synonym group with additional terms.
|
Executions<List<V>> |
NodeSelectionSearchCommands.ftTagvals(String index,
String fieldName)
Return a distinct set of values indexed in a Tag field.
|
Executions<String> |
NodeSelectionHashCommands.himportSet(K key,
HashImport<K> fieldset,
V... values)
Create the hash stored at
key from fieldset, sending only the values, positionally paired to the
fieldset's field names. |
Executions<HotkeysReply> |
NodeSelectionServerCommands.hotkeysGet()
Get hotkeys tracking results.
|
Executions<String> |
NodeSelectionServerCommands.hotkeysReset()
Reset hotkeys tracking data.
|
Executions<String> |
NodeSelectionServerCommands.hotkeysStart(HotkeysArgs args)
Start hotkeys tracking.
|
Executions<String> |
NodeSelectionServerCommands.hotkeysStop()
Stop hotkeys tracking but retain data.
|
Executions<Boolean> |
NodeSelectionVectorSetCommands.vadd(K key,
int dimensionality,
V element,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality. |
Executions<Boolean> |
NodeSelectionVectorSetCommands.vadd(K key,
int dimensionality,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with the specified dimensionality and additional options. |
Executions<Boolean> |
NodeSelectionVectorSetCommands.vadd(K key,
V element,
Double... vectors)
Add a new element into the vector set specified by
key. |
Executions<Boolean> |
NodeSelectionVectorSetCommands.vadd(K key,
V element,
VAddArgs args,
Double... vectors)
Add a new element into the vector set specified by
key with additional options. |
Executions<Long> |
NodeSelectionVectorSetCommands.vcard(K key)
Returns the number of elements in the vector set stored at
key. |
Executions<Boolean> |
NodeSelectionVectorSetCommands.vClearAttributes(K key,
V element)
Clears all attributes for the specified
element in the vector set stored at key. |
Executions<Long> |
NodeSelectionVectorSetCommands.vdim(K key)
Returns the dimensionality of the vector set stored at
key. |
Executions<List<Double>> |
NodeSelectionVectorSetCommands.vemb(K key,
V element)
Returns the approximate vector associated with a given
element in the vector set stored at key. |
Executions<RawVector> |
NodeSelectionVectorSetCommands.vembRaw(K key,
V element)
Returns the raw vector data for the specified
element in the vector set stored at key. |
Executions<String> |
NodeSelectionVectorSetCommands.vgetattr(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
Executions<List<JsonValue>> |
NodeSelectionVectorSetCommands.vgetattrAsJsonValue(K key,
V element)
Returns the attributes associated with the specified
element in the vector set stored at key. |
Executions<VectorMetadata> |
NodeSelectionVectorSetCommands.vinfo(K key)
Returns metadata and internal details about the vector set stored at
key. |
Executions<Boolean> |
NodeSelectionVectorSetCommands.vismember(K key,
V element)
Checks whether
element exists in the vector set stored at key. |
Executions<List<V>> |
NodeSelectionVectorSetCommands.vlinks(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph of the vector set stored at key. |
Executions<Map<V,Double>> |
NodeSelectionVectorSetCommands.vlinksWithScores(K key,
V element)
Returns the neighbors of the specified
element in the HNSW graph along with their scores. |
Executions<V> |
NodeSelectionVectorSetCommands.vrandmember(K key)
Returns a random element from the vector set stored at
key. |
Executions<List<V>> |
NodeSelectionVectorSetCommands.vrandmember(K key,
int count)
Returns multiple random elements from the vector set stored at
key. |
Executions<Boolean> |
NodeSelectionVectorSetCommands.vrem(K key,
V element)
Removes the specified
element from the vector set stored at key. |
Executions<Boolean> |
NodeSelectionVectorSetCommands.vsetattr(K key,
V element,
JsonValue json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
Executions<Boolean> |
NodeSelectionVectorSetCommands.vsetattr(K key,
V element,
String json)
Sets or updates the attributes for the specified
element in the vector set stored at key. |
Executions<List<V>> |
NodeSelectionVectorSetCommands.vsim(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key. |
Executions<List<V>> |
NodeSelectionVectorSetCommands.vsim(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key. |
Executions<List<V>> |
NodeSelectionVectorSetCommands.vsim(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options. |
Executions<List<V>> |
NodeSelectionVectorSetCommands.vsim(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options. |
Executions<Map<V,Double>> |
NodeSelectionVectorSetCommands.vsimWithScore(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores. |
Executions<Map<V,Double>> |
NodeSelectionVectorSetCommands.vsimWithScore(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores. |
Executions<Map<V,Double>> |
NodeSelectionVectorSetCommands.vsimWithScore(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores. |
Executions<Map<V,Double>> |
NodeSelectionVectorSetCommands.vsimWithScore(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores. |
Executions<Map<V,VSimScoreAttribs>> |
NodeSelectionVectorSetCommands.vsimWithScoreWithAttribs(K key,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key and returns them with
their similarity scores and attributes. |
Executions<Map<V,VSimScoreAttribs>> |
NodeSelectionVectorSetCommands.vsimWithScoreWithAttribs(K key,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key and returns them
with their similarity scores and attributes. |
Executions<Map<V,VSimScoreAttribs>> |
NodeSelectionVectorSetCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
Double... vectors)
Finds the most similar vectors to the given query vector in the vector set stored at
key with additional options
and returns them with their similarity scores and attributes. |
Executions<Map<V,VSimScoreAttribs>> |
NodeSelectionVectorSetCommands.vsimWithScoreWithAttribs(K key,
VSimArgs args,
V element)
Finds the most similar vectors to the given element's vector in the vector set stored at
key with additional
options and returns them with their similarity scores and attributes. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
CircuitBreaker
Circuit breaker for tracking command metrics and managing circuit breaker state.
|
interface |
MultiDbClient |
| Modifier and Type | Interface and Description |
|---|---|
interface |
BaseRedisMultiDbConnection |
class |
CircuitBreakerConfig
Configuration for circuit breaker behavior.
|
class |
CircuitBreakerStateChangeEvent
Event representing a circuit breaker state change.
|
interface |
CircuitBreakerStateListener
Listener interface for circuit breaker state change events.
|
class |
DatabaseConfig
Configuration for a database in a multi-database client.
|
class |
ImmutableRedisURI
An immutable implementation of
RedisURI that prevents any modifications after construction. |
interface |
InitializationPolicy
Interface for initialization policies.
|
class |
MultiDbConnectionFuture<C extends BaseRedisMultiDbConnection>
A
MultiDbConnectionFuture represents the result of an asynchronous multi-database connection initialization. |
class |
MultiDbOptions
Options for multi-database client behavior.
|
interface |
RawConnectionFactory
Factory interface to obtain direct
connections to Redis database nodes. |
class |
RedisCircuitBreakerException
Exception thrown when a circuit breaker is not in closed state.
|
interface |
RedisDatabase
Represents a Redis database with a weight and a connection.
|
class |
RedisNoHealthyDatabaseException |
interface |
StatefulRedisMultiDbConnection<K,V>
Stateful multi-database Redis connection that supports failover between multiple endpoints.
|
interface |
StatefulRedisMultiDbPubSubConnection<K,V>
Stateful multi-database Redis PubSub connection that supports failover between multiple endpoints.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AllDatabasesUnhealthyEvent
Event that is fired when all configured databases are unhealthy and no failover target can be selected for a failover
attempt.
|
class |
DatabaseSwitchEvent
Event that is fired when a database switch occurs.
|
class |
SwitchReason
Reasons for database switch.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractHealthCheckStrategy
Abstract base class for health check strategies.
|
interface |
HealthCheck
Interface for health check operations on a Redis endpoint.
|
interface |
HealthCheckStrategy
Interface for health check strategies.
|
interface |
HealthCheckStrategySupplier
Supplier for health check strategies.
|
class |
HealthStatus
Enumeration representing the health status of a database endpoint as determined by the health check service.
|
class |
HealthStatusChangeEvent
Event arguments for health status change events.
|
interface |
HealthStatusListener
Listener for health status changes.
|
interface |
HealthStatusManager
Manager for health status of Redis endpoints.
|
class |
HealthStatusManagerImpl
Implementation of the
HealthStatusManager interface. |
class |
LagAwareStrategy
Health check strategy that uses the Redis Enterprise REST API database availability endpoint.
|
class |
PingStrategy
Health check strategy that uses PING command to check endpoint health.
|
interface |
ProbingPolicy
Interface for probing policies.
|
class |
RedisRestException
Exception thrown when a Redis REST API operation fails.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
CircuitBreakerMetrics
Interface for sliding window metrics.
|
class |
MetricsFactory
Factory for creating
CircuitBreakerMetrics instances. |
interface |
MetricsSnapshot
Represents the state of success and failure counts within a specific time window.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HotkeysReplyParser
Parser for Redis HOTKEYS GET command output.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HybridReply<K,V>
Represents the results of an
FT.HYBRID command. |
class |
HybridReplyParser<K,V>
Parser for
FT.HYBRID responses. |
| Modifier and Type | Class and Description |
|---|---|
class |
Apply<K,V>
APPLY post-processing operation.
|
class |
Filter<K,V>
FILTER post-processing operation.
|
class |
GroupBy<K,V>
GROUPBY post-processing operation.
|
class |
Limit<K,V>
LIMIT post-processing operation.
|
interface |
PostProcessingOperation<K,V>
Interface for post-processing operations applied in user-specified order.
|
class |
ReduceFunction
Enumeration of REDUCE functions for GROUPBY operations in FT.HYBRID and FT.AGGREGATE commands.
|
class |
Reducer<K>
Abstract reducer for GROUPBY operations in FT.HYBRID and FT.AGGREGATE commands.
|
class |
Reducers
Factory class for creating
Reducer instances. |
class |
Scorer
Abstract scorer for text search.
|
class |
Scorers
Factory class for creating
Scorer instances for text search. |
class |
SortBy<K>
SORTBY post-processing operation.
|
class |
SortDirection
Sort direction enumeration for SORTBY operations in FT.HYBRID and FT.AGGREGATE commands.
|
class |
SortProperty<K>
Represents a sort property with direction for SORTBY operations in FT.HYBRID and FT.AGGREGATE commands.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Combiner<K>
Abstract combiner for combining multiple search scores in FT.HYBRID command.
|
class |
Combiners
Factory class for creating
Combiner instances. |
class |
HybridSearchArgs<K,V>
Arguments for the SEARCH clause in FT.HYBRID command.
|
class |
HybridVectorArgs<K,V>
Arguments for the VSIM clause in FT.HYBRID command.
|
class |
PostProcessingArgs<K,V>
Argument list builder for FT.HYBRID and FT.AGGREGATE post-processing operations.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
HttpClient
Interface for performing HTTP requests in a dependency-agnostic manner.
|
interface |
HttpClientProvider
SPI (Service Provider Interface) for providing custom
HttpClient implementations. |
class |
HttpClientResources
Manages a shared
HttpClient instance with lazy initialization. |
class |
NettyHttpClientProvider
Default
HttpClientProvider that creates Netty-based HTTP clients. |
Copyright © 2026 lettuce.io. All rights reserved.