Package io.lettuce.core.output
Implementation of different output protocols including the Streaming API.
-
Interface Summary Interface Description KeyStreamingChannel<K> Streaming API for multiple Keys.KeyValueStreamingChannel<K,V> Streaming API for multiple keys and values (tuples).ScoredValueStreamingChannel<V> Streaming API for multiple Keys.StreamingChannel Marker interface for streaming channels.StreamingOutput<T> Implementors of this class support a streamingCommandOutput
while the command is still processed.ValueStreamingChannel<V> Streaming API for multiple Keys. -
Class Summary Class Description ArrayOutput<K,V> List
of objects and lists to support dynamic nested structures (List with mixed content of values and sublists).BooleanListOutput<K,V> List
of boolean output.BooleanOutput<K,V> Boolean output.ByteArrayOutput<K,V> Byte array output.ClaimedMessagesOutput<K,V> DecodesClaimedMessages
.CommandOutput<K,V,T> Base class for Redis command outputs.DateOutput<K,V> Date output with no milliseconds.DoubleListOutput<K,V> List
of Double output.DoubleOutput<K,V> Double output, may be null.EnumSetOutput<K,V,E extends Enum<E>> EnumSet
output.GenericMapOutput<K,V> Map
of keys and objects output.GeoCoordinatesListOutput<K,V> A list output that creates a list withGeoCoordinates
's.GeoCoordinatesValueListOutput<K,V> A list output that creates a list withGeoCoordinates
Value
s.GeoWithinListOutput<K,V> A list output that creates a list with either double/long orGeoCoordinates
's.IntegerListOutput<K,V> List
of 64-bit integer output.IntegerOutput<K,V> 64-bit integer output, may be null.KeyListOutput<K,V> List
of keys output.KeyOutput<K,V> Key output.KeyScanOutput<K,V> KeyScanCursor
for scan cursor output.KeyScanStreamingOutput<K,V> Streaming API for multiple Keys.KeyStreamingOutput<K,V> Streaming-Output of Keys.KeyValueListOutput<K,V> KeyValueListScoredValueOutput<K,V> Output for multiple [B]ZMPOP result items.KeyValueOfScoredValueOutput<K,V> Output for a single [B]ZMPOP result.KeyValueOutput<K,V> Key-value pair output.KeyValueScanStreamingOutput<K,V> Streaming-Output of Key Value Pairs.KeyValueScoredValueOutput<K,V> KeyValue
encapsulatingScoredValue
.KeyValueStreamingOutput<K,V> Streaming-Output of Key Value Pairs.KeyValueValueListOutput<K,V> Key-value pair output holding a list of values.ListOfGenericMapsOutput<K,V> List
of maps output.ListOfMapsOutput<K,V> List
of maps output.ListSubscriber<T> Simple subscriber feeding aCollection
ListSubscriber.onNext(Collection, Object)
.MapOutput<K,V> Map
of keys and values output.MapScanOutput<K,V> MapScanCursor
for scan cursor output.MultiOutput<K,V> Output of all commands within a MULTI block.NestedMultiOutput<K,V> List
of flat arrays, possibly deeply nested.ObjectOutput<K,V> RESP3-capable command output that represents the RESP3 response as RESP3 primitives including support for nesting.PendingMessageListOutput<K,V> Decodes a list ofPendingMessage
.PendingMessagesOutput<K,V> DecodesPendingMessages
.PushOutput<K,V> Output for push notifications.ReplayOutput<K,V> ReplayableCommandOutput
capturing output signals to replay these on a targetCommandOutput
.ReplayOutput.BulkString ReplayOutput.ErrorBytes ReplayOutput.Signal Encapsulates a replayable decoding signal.ScanOutput<K,V,T extends ScanCursor> Cursor handling output.ScoredValueListOutput<K,V> List
of values and their associated scores.ScoredValueOutput<K,V> A singleScoredValue
.ScoredValueScanOutput<K,V> ScoredValueScanCursor
for scan cursor output.ScoredValueScanStreamingOutput<K,V> Streaming-Output of of values and their associated scores.ScoredValueStreamingOutput<K,V> Streaming-Output of of values and their associated scores.SocketAddressOutput<K,V> Output capturing a hostname and port (both string elements) into aSocketAddress
.StatusOutput<K,V> Status message output.StreamingOutput.Subscriber<T> Subscriber to aStreamingOutput
.StreamMessageListOutput<K,V> List
ofStreamMessage
s.StreamReadOutput<K,V> StringListOutput<K,V> List
of string output.StringMatchResultOutput<K,V> Command output forSTRALGO
returningStringMatchResult
.StringValueListOutput<K,V> TransformingOutput<K,V,S,T> Command output that can transform the output from an underlying command output by applying a mapping function.TransformingOutput.TransformingAccessor Accessor for the underlying output.ValueListOutput<K,V> List
of values output.ValueOutput<K,V> Value output.ValueScanOutput<K,V> ValueScanCursor
for scan cursor output.ValueScanStreamingOutput<K,V> Streaming API for multiple Values.ValueSetOutput<K,V> Set
of value output.ValueStreamingOutput<K,V> Streaming-Output of Values.ValueValueListOutput<K,V> VoidOutput<K,V> Void
command output to consume data silently without actually processing it.