Package | Description |
---|---|
io.lettuce.core |
The Redis client package containing
RedisClient for Redis Standalone and Redis Sentinel operations. |
io.lettuce.core.api.async |
Standalone Redis API for asynchronous executed commands.
|
io.lettuce.core.api.reactive |
Standalone Redis API for reactive command execution.
|
io.lettuce.core.api.sync |
Standalone Redis API for synchronous executed commands.
|
io.lettuce.core.cluster.api.async |
Redis Cluster API for asynchronous executed commands.
|
io.lettuce.core.protocol |
Redis protocol layer abstraction.
|
io.lettuce.core.sentinel |
Redis Sentinel connection classes.
|
io.lettuce.core.sentinel.api.async |
Redis Sentinel API for asynchronous executed commands.
|
io.lettuce.core.sentinel.api.reactive |
Redis Sentinel API for reactive command execution.
|
io.lettuce.core.sentinel.api.sync |
Redis Sentinel API for synchronous executed commands.
|
Modifier and Type | Method and Description |
---|---|
<K,V> void |
SortArgs.build(CommandArgs<K,V> args) |
<K,V> void |
SetArgs.build(CommandArgs<K,V> args) |
<K,V> void |
XAddArgs.build(CommandArgs<K,V> args) |
<K,V> void |
ScanArgs.build(CommandArgs<K,V> args) |
<K,V> void |
KillArgs.build(CommandArgs<K,V> args) |
<K,V> void |
MigrateArgs.build(CommandArgs<K,V> args) |
<K,V> void |
XClaimArgs.build(CommandArgs<K,V> args) |
<K,V> void |
GeoArgs.build(CommandArgs<K,V> args) |
<K,V> void |
ZStoreArgs.build(CommandArgs<K,V> args) |
<K,V> void |
XGroupCreateArgs.build(CommandArgs<K,V> args) |
<K,V> void |
CompositeArgument.build(CommandArgs<K,V> args)
Build command arguments and contribute arguments to
CommandArgs . |
<K,V> void |
XReadArgs.build(CommandArgs<K,V> args) |
<K,V> void |
BitFieldArgs.build(CommandArgs<K,V> args) |
<K,V> void |
ZAddArgs.build(CommandArgs<K,V> args) |
<K,V> void |
GeoRadiusStoreArgs.build(CommandArgs<K,V> args) |
protected <T> Mono<T> |
AbstractRedisReactiveCommands.createMono(CommandType type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
protected <T> RedisFuture<T> |
AbstractRedisAsyncCommands.dispatch(CommandType type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
<T> Flux<T> |
AbstractRedisReactiveCommands.dispatch(ProtocolKeyword type,
CommandOutput<K,V,?> output,
CommandArgs<K,V> args) |
<T> RedisFuture<T> |
AbstractRedisAsyncCommands.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
Modifier and Type | Method and Description |
---|---|
<T> RedisFuture<T> |
BaseRedisAsyncCommands.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
Modifier and Type | Method and Description |
---|---|
<T> Flux<T> |
BaseRedisReactiveCommands.dispatch(ProtocolKeyword type,
CommandOutput<K,V,?> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
Modifier and Type | Method and Description |
---|---|
<T> T |
BaseRedisCommands.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
Modifier and Type | Method and Description |
---|---|
<T> AsyncExecutions<T> |
BaseNodeSelectionAsyncCommands.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
Modifier and Type | Field and Description |
---|---|
protected CommandArgs<K,V> |
Command.args |
Modifier and Type | Method and Description |
---|---|
CommandArgs<K,V> |
CommandArgs.add(byte[] value)
Add a byte-array argument.
|
CommandArgs<K,V> |
CommandArgs.add(char[] cs)
Add a string as char-array.
|
CommandArgs<K,V> |
CommandArgs.add(CommandKeyword keyword)
Add a
CommandKeyword argument. |
CommandArgs<K,V> |
CommandArgs.add(CommandType type)
Add a
CommandType argument. |
CommandArgs<K,V> |
CommandArgs.add(double n)
Add a double argument.
|
CommandArgs<K,V> |
CommandArgs.add(long n)
Add an 64-bit integer (long) argument.
|
CommandArgs<K,V> |
CommandArgs.add(Map<K,V> map)
Add a map (hash) argument.
|
CommandArgs<K,V> |
CommandArgs.add(ProtocolKeyword keyword)
Add a
ProtocolKeyword argument. |
CommandArgs<K,V> |
CommandArgs.add(String s)
Add a string argument.
|
CommandArgs<K,V> |
CommandArgs.addKey(K key)
Adds a key argument.
|
CommandArgs<K,V> |
CommandArgs.addKeys(Iterable<K> keys)
Add multiple key arguments.
|
CommandArgs<K,V> |
CommandArgs.addKeys(K... keys)
Add multiple key arguments.
|
CommandArgs<K,V> |
CommandArgs.addValue(V value)
Add a value argument.
|
CommandArgs<K,V> |
CommandArgs.addValues(Iterable<V> values)
Add multiple value arguments.
|
CommandArgs<K,V> |
CommandArgs.addValues(V... values)
Add multiple value arguments.
|
CommandArgs<K,V> |
CommandWrapper.getArgs() |
CommandArgs<K,V> |
Command.getArgs() |
CommandArgs<K,V> |
RedisCommand.getArgs() |
CommandArgs<K,V> |
AsyncCommand.getArgs() |
Modifier and Type | Method and Description |
---|---|
protected <T> Command<K,V,T> |
BaseRedisCommandBuilder.createCommand(CommandType type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
static <K,V> ByteBuffer |
CommandArgsAccessor.encodeFirstKey(CommandArgs<K,V> commandArgs)
Get the first encoded key for cluster command routing.
|
static <K,V> char[] |
CommandArgsAccessor.getFirstCharArray(CommandArgs<K,V> commandArgs)
Get the first
char -array argument. |
static <K,V> Long |
CommandArgsAccessor.getFirstInteger(CommandArgs<K,V> commandArgs)
Get the first
integer argument. |
static <K,V> String |
CommandArgsAccessor.getFirstString(CommandArgs<K,V> commandArgs)
Get the first
String argument. |
Constructor and Description |
---|
Command(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Create a new command with the supplied type and args.
|
Modifier and Type | Method and Description |
---|---|
<T> Flux<T> |
RedisSentinelReactiveCommandsImpl.dispatch(ProtocolKeyword type,
CommandOutput<K,V,?> output,
CommandArgs<K,V> args) |
<T> RedisFuture<T> |
RedisSentinelAsyncCommandsImpl.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
Modifier and Type | Method and Description |
---|---|
<T> RedisFuture<T> |
RedisSentinelAsyncCommands.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
Modifier and Type | Method and Description |
---|---|
<T> Flux<T> |
RedisSentinelReactiveCommands.dispatch(ProtocolKeyword type,
CommandOutput<K,V,?> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
Modifier and Type | Method and Description |
---|---|
<T> T |
RedisSentinelCommands.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
Copyright © 2019 lettuce.io. All rights reserved.