Uses of Class
io.lettuce.core.output.CommandOutput
-
Packages that use CommandOutput Package Description io.lettuce.core The Redis client package containingRedisClient
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.dynamic.output CommandOutput
resolution support.io.lettuce.core.output Implementation of different output protocols including the Streaming API.io.lettuce.core.protocol Redis protocol layer abstraction.io.lettuce.core.pubsub Pub/Sub connection classes.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. -
-
Uses of CommandOutput in io.lettuce.core
Methods in io.lettuce.core with parameters of type CommandOutput Modifier and Type Method Description 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)
protected <T> RedisFuture<T>
AbstractRedisAsyncCommands. dispatch(CommandType type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
<T> RedisFuture<T>
AbstractRedisAsyncCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
<T> RedisFuture<T>
AbstractRedisAsyncCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
<T> Flux<T>
AbstractRedisReactiveCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output)
<T> Flux<T>
AbstractRedisReactiveCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output, CommandArgs<K,V> args)
-
Uses of CommandOutput in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type CommandOutput Modifier and Type Method Description <T> RedisFuture<T>
BaseRedisAsyncCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
Dispatch a command to the Redis Server.<T> RedisFuture<T>
BaseRedisAsyncCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
Dispatch a command to the Redis Server. -
Uses of CommandOutput in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type CommandOutput Modifier and Type Method Description <T> Flux<T>
BaseRedisReactiveCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output)
Dispatch a command to the Redis Server.<T> Flux<T>
BaseRedisReactiveCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output, CommandArgs<K,V> args)
Dispatch a command to the Redis Server. -
Uses of CommandOutput in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type CommandOutput Modifier and Type Method Description <T> T
BaseRedisCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
Dispatch a command to the Redis Server.<T> T
BaseRedisCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
Dispatch a command to the Redis Server. -
Uses of CommandOutput in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type CommandOutput Modifier and Type Method Description <T> AsyncExecutions<T>
BaseNodeSelectionAsyncCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
Deprecated.since 6.2, asCommandOutput
is being reused for all responses of all nodes and that leads to unwanted behavior.<T> AsyncExecutions<T>
BaseNodeSelectionAsyncCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
Deprecated.since 6.2, asCommandOutput
is being reused for all responses of all nodes and that leads to unwanted behavior.Method parameters in io.lettuce.core.cluster.api.async with type arguments of type CommandOutput Modifier and Type Method Description <T> AsyncExecutions<T>
BaseNodeSelectionAsyncCommands. dispatch(ProtocolKeyword type, Supplier<CommandOutput<K,V,T>> outputSupplier)
Dispatch a command to the Redis Server.<T> AsyncExecutions<T>
BaseNodeSelectionAsyncCommands. dispatch(ProtocolKeyword type, Supplier<CommandOutput<K,V,T>> outputSupplier, CommandArgs<K,V> args)
Dispatch a command to the Redis Server. -
Uses of CommandOutput in io.lettuce.core.dynamic.output
Methods in io.lettuce.core.dynamic.output with type parameters of type CommandOutput Modifier and Type Method Description <T extends CommandOutput<?,?,?>>
voidOutputRegistry. register(Class<T> commandOutputClass, CommandOutputFactory commandOutputFactory)
Register aCommandOutput
type with itsCommandOutputFactory
.Methods in io.lettuce.core.dynamic.output that return CommandOutput Modifier and Type Method Description <K,V>
CommandOutput<K,V,?>CommandOutputFactory. create(RedisCodec<K,V> codec)
Create and initialize a newCommandOutput
givenRedisCodec
. -
Uses of CommandOutput in io.lettuce.core.output
Subclasses of CommandOutput in io.lettuce.core.output Modifier and Type Class Description class
ArrayOutput<K,V>
List
of objects and lists to support dynamic nested structures (List with mixed content of values and sublists).class
BooleanListOutput<K,V>
List
of boolean output.class
BooleanOutput<K,V>
Boolean output.class
ByteArrayOutput<K,V>
Byte array output.class
ClaimedMessagesOutput<K,V>
DecodesClaimedMessages
.class
DateOutput<K,V>
Date output with no milliseconds.class
DoubleListOutput<K,V>
List
of Double output.class
DoubleOutput<K,V>
Double output, may be null.class
EnumSetOutput<K,V,E extends Enum<E>>
EnumSet
output.class
GenericMapOutput<K,V>
Map
of keys and objects output.class
GeoCoordinatesListOutput<K,V>
A list output that creates a list withGeoCoordinates
's.class
GeoCoordinatesValueListOutput<K,V>
A list output that creates a list withGeoCoordinates
Value
s.class
GeoWithinListOutput<K,V>
A list output that creates a list with either double/long orGeoCoordinates
's.class
IntegerListOutput<K,V>
List
of 64-bit integer output.class
IntegerOutput<K,V>
64-bit integer output, may be null.class
KeyListOutput<K,V>
List
of keys output.class
KeyOutput<K,V>
Key output.class
KeyScanOutput<K,V>
KeyScanCursor
for scan cursor output.class
KeyScanStreamingOutput<K,V>
Streaming API for multiple Keys.class
KeyStreamingOutput<K,V>
Streaming-Output of Keys.class
KeyValueListOutput<K,V>
class
KeyValueListScoredValueOutput<K,V>
Output for multiple [B]ZMPOP result items.class
KeyValueOfScoredValueOutput<K,V>
Output for a single [B]ZMPOP result.class
KeyValueOutput<K,V>
Key-value pair output.class
KeyValueScanStreamingOutput<K,V>
Streaming-Output of Key Value Pairs.class
KeyValueScoredValueOutput<K,V>
KeyValue
encapsulatingScoredValue
.class
KeyValueStreamingOutput<K,V>
Streaming-Output of Key Value Pairs.class
KeyValueValueListOutput<K,V>
Key-value pair output holding a list of values.class
ListOfGenericMapsOutput<K,V>
List
of maps output.class
ListOfMapsOutput<K,V>
List
of maps output.class
MapOutput<K,V>
Map
of keys and values output.class
MapScanOutput<K,V>
MapScanCursor
for scan cursor output.class
MultiOutput<K,V>
Output of all commands within a MULTI block.class
NestedMultiOutput<K,V>
List
of flat arrays, possibly deeply nested.class
ObjectOutput<K,V>
RESP3-capable command output that represents the RESP3 response as RESP3 primitives including support for nesting.class
PendingMessageListOutput<K,V>
Decodes a list ofPendingMessage
.class
PendingMessagesOutput<K,V>
DecodesPendingMessages
.class
PushOutput<K,V>
Output for push notifications.class
ReplayOutput<K,V>
ReplayableCommandOutput
capturing output signals to replay these on a targetCommandOutput
.class
ScanOutput<K,V,T extends ScanCursor>
Cursor handling output.class
ScoredValueListOutput<K,V>
List
of values and their associated scores.class
ScoredValueOutput<K,V>
A singleScoredValue
.class
ScoredValueScanOutput<K,V>
ScoredValueScanCursor
for scan cursor output.class
ScoredValueScanStreamingOutput<K,V>
Streaming-Output of of values and their associated scores.class
ScoredValueStreamingOutput<K,V>
Streaming-Output of of values and their associated scores.class
SocketAddressOutput<K,V>
Output capturing a hostname and port (both string elements) into aSocketAddress
.class
StatusOutput<K,V>
Status message output.class
StreamMessageListOutput<K,V>
List
ofStreamMessage
s.class
StreamReadOutput<K,V>
class
StringListOutput<K,V>
List
of string output.class
StringMatchResultOutput<K,V>
Command output forSTRALGO
returningStringMatchResult
.class
StringValueListOutput<K,V>
class
TransformingOutput<K,V,S,T>
Command output that can transform the output from an underlying command output by applying a mapping function.class
ValueListOutput<K,V>
List
of values output.class
ValueOutput<K,V>
Value output.class
ValueScanOutput<K,V>
ValueScanCursor
for scan cursor output.class
ValueScanStreamingOutput<K,V>
Streaming API for multiple Values.class
ValueSetOutput<K,V>
Set
of value output.class
ValueStreamingOutput<K,V>
Streaming-Output of Values.class
ValueValueListOutput<K,V>
class
VoidOutput<K,V>
Void
command output to consume data silently without actually processing it.Methods in io.lettuce.core.output that return CommandOutput Modifier and Type Method Description static <K,V,S,T>
CommandOutput<K,V,T>TransformingOutput. transform(CommandOutput<K,V,S> delegate, Function<TransformingOutput.TransformingAccessor,T> mappingFunction)
Create a new transforming output.Methods in io.lettuce.core.output with parameters of type CommandOutput Modifier and Type Method Description protected void
ReplayOutput.BulkString. replay(CommandOutput<?,?,?> target)
protected void
ReplayOutput.ErrorBytes. replay(CommandOutput<?,?,?> target)
void
ReplayOutput. replay(CommandOutput<?,?,?> target)
Replay all captured signals on aCommandOutput
.protected abstract void
ReplayOutput.Signal. replay(CommandOutput<?,?,?> target)
Replay the signal on aCommandOutput
.static <K,V,S,T>
CommandOutput<K,V,T>TransformingOutput. transform(CommandOutput<K,V,S> delegate, Function<TransformingOutput.TransformingAccessor,T> mappingFunction)
Create a new transforming output. -
Uses of CommandOutput in io.lettuce.core.protocol
Fields in io.lettuce.core.protocol declared as CommandOutput Modifier and Type Field Description protected CommandOutput<K,V,T>
Command. output
Methods in io.lettuce.core.protocol that return CommandOutput Modifier and Type Method Description protected CommandOutput<?,?,?>
CommandHandler. getCommandOutput(RedisCommand<?,?,?> command)
Decoding hook: RetrieveCommandOutput
forRedisCommand
decoding.CommandOutput<K,V,T>
AsyncCommand. getOutput()
Get the object that holds this command's output.CommandOutput<K,V,T>
Command. getOutput()
Get the object that holds this command's output.CommandOutput<K,V,T>
CommandWrapper. getOutput()
CommandOutput<K,V,T>
RedisCommand. getOutput()
The command output.protected <T> CommandOutput<K,V,T>
BaseRedisCommandBuilder. newScriptOutput(RedisCodec<K,V> codec, ScriptOutputType type)
Methods in io.lettuce.core.protocol with parameters of type CommandOutput Modifier and Type Method Description protected <T> Command<K,V,T>
BaseRedisCommandBuilder. createCommand(CommandType type, CommandOutput<K,V,T> output)
protected <T> Command<K,V,T>
BaseRedisCommandBuilder. createCommand(CommandType type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
protected <T> Command<K,V,T>
BaseRedisCommandBuilder. createCommand(CommandType type, CommandOutput<K,V,T> output, K key)
protected <T> Command<K,V,T>
BaseRedisCommandBuilder. createCommand(CommandType type, CommandOutput<K,V,T> output, K key, V value)
protected <T> Command<K,V,T>
BaseRedisCommandBuilder. createCommand(CommandType type, CommandOutput<K,V,T> output, K key, V[] values)
protected boolean
CommandHandler. decode(ByteBuf buffer, CommandOutput<?,?,?> output)
protected boolean
CommandHandler. decode(ByteBuf buffer, RedisCommand<?,?,?> command, CommandOutput<?,?,?> output)
boolean
RedisStateMachine. decode(ByteBuf buffer, CommandOutput<?,?,?> output)
Decode a command using the input buffer.boolean
RedisStateMachine. decode(ByteBuf buffer, CommandOutput<?,?,?> output, Consumer<Exception> errorHandler)
Attempt to decode a redis response and return a flag indicating whether a complete response was read.protected void
RedisStateMachine. safeMultiArray(CommandOutput<?,?,?> output, int count, Consumer<Exception> errorHandler)
Safely setsmultiArray(int)
.protected void
RedisStateMachine. safeMultiMap(CommandOutput<?,?,?> output, int count, Consumer<Exception> errorHandler)
Safely setsmultiMap(int)
.protected void
RedisStateMachine. safeMultiPush(CommandOutput<?,?,?> output, int count, Consumer<Exception> errorHandler)
Safely setsmultiPush(int)
.protected void
RedisStateMachine. safeMultiSet(CommandOutput<?,?,?> output, int count, Consumer<Exception> errorHandler)
Safely setsmultiSet(int)
.protected void
RedisStateMachine. safeSet(CommandOutput<?,?,?> output, boolean value, Consumer<Exception> errorHandler)
Safely setsset(boolean)
.protected void
RedisStateMachine. safeSet(CommandOutput<?,?,?> output, double number, Consumer<Exception> errorHandler)
Safely setsset(double)
.protected void
RedisStateMachine. safeSet(CommandOutput<?,?,?> output, long number, Consumer<Exception> errorHandler)
Safely setsset(long)
.protected void
RedisStateMachine. safeSet(CommandOutput<?,?,?> output, ByteBuffer bytes, Consumer<Exception> errorHandler)
Safely setsset(ByteBuffer)
.protected void
RedisStateMachine. safeSetBigNumber(CommandOutput<?,?,?> output, ByteBuffer bytes, Consumer<Exception> errorHandler)
Safely setsset(ByteBuffer)
.protected void
RedisStateMachine. safeSetError(CommandOutput<?,?,?> output, ByteBuffer bytes, Consumer<Exception> errorHandler)
Safely setssetError(ByteBuffer)
.protected void
RedisStateMachine. safeSetSingle(CommandOutput<?,?,?> output, ByteBuffer bytes, Consumer<Exception> errorHandler)
Safely setsset(ByteBuffer)
.void
AsyncCommand. setOutput(CommandOutput<K,V,T> output)
void
Command. setOutput(CommandOutput<K,V,T> output)
void
CommandWrapper. setOutput(CommandOutput<K,V,T> output)
void
RedisCommand. setOutput(CommandOutput<K,V,T> output)
Set a new output.Constructors in io.lettuce.core.protocol with parameters of type CommandOutput Constructor Description Command(ProtocolKeyword type, CommandOutput<K,V,T> output)
Create a new command with the supplied type.Command(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
Create a new command with the supplied type and args. -
Uses of CommandOutput in io.lettuce.core.pubsub
Subclasses of CommandOutput in io.lettuce.core.pubsub Modifier and Type Class Description class
PubSubOutput<K,V>
One element of the Redis pub/sub stream.Methods in io.lettuce.core.pubsub that return CommandOutput Modifier and Type Method Description protected CommandOutput<?,?,?>
PubSubCommandHandler. getCommandOutput(RedisCommand<?,?,?> command)
-
Uses of CommandOutput in io.lettuce.core.sentinel
Methods in io.lettuce.core.sentinel with parameters of type CommandOutput Modifier and Type Method Description <T> RedisFuture<T>
RedisSentinelAsyncCommandsImpl. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
<T> RedisFuture<T>
RedisSentinelAsyncCommandsImpl. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
<T> Flux<T>
RedisSentinelReactiveCommandsImpl. dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output)
<T> Flux<T>
RedisSentinelReactiveCommandsImpl. dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output, CommandArgs<K,V> args)
-
Uses of CommandOutput in io.lettuce.core.sentinel.api.async
Methods in io.lettuce.core.sentinel.api.async with parameters of type CommandOutput Modifier and Type Method Description <T> RedisFuture<T>
RedisSentinelAsyncCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
Dispatch a command to the Redis Server.<T> RedisFuture<T>
RedisSentinelAsyncCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
Dispatch a command to the Redis Server. -
Uses of CommandOutput in io.lettuce.core.sentinel.api.reactive
Methods in io.lettuce.core.sentinel.api.reactive with parameters of type CommandOutput Modifier and Type Method Description <T> Flux<T>
RedisSentinelReactiveCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output)
Dispatch a command to the Redis Server.<T> Flux<T>
RedisSentinelReactiveCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output, CommandArgs<K,V> args)
Dispatch a command to the Redis Server. -
Uses of CommandOutput in io.lettuce.core.sentinel.api.sync
Methods in io.lettuce.core.sentinel.api.sync with parameters of type CommandOutput Modifier and Type Method Description <T> T
RedisSentinelCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
Dispatch a command to the Redis Server.<T> T
RedisSentinelCommands. dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
-