Package io.lettuce.core.protocol
Redis protocol layer abstraction.
-
Interface Summary Interface Description CompleteableCommand<T> Extension to commands that provide registration of command completion callbacks.ConnectionFacade Represents a stateful connection facade.ConnectionInitializer Initialize a connection to prepare it for usage.DecodeBufferPolicy Strategy defining the approach to discard bytes from the response aggregationbuffer
inCommandHandler.decode(ChannelHandlerContext ctx, ByteBuf buffer)
to reclaim memory after various response decoding phases.DecoratedCommand<K,V,T> A decorated command allowing access to the underlyingDecoratedCommand.getDelegate()
.DemandAware Interface for demand-aware components.DemandAware.Sink A demand-awareDemandAware.Sink
that accepts data.DemandAware.Source ADemandAware.Source
provides data to aDemandAware
and can be notified to produce more input for the command.Endpoint Wraps a statefulEndpoint
that abstracts the underlying channel.ProtocolKeyword Interface for protocol keywords providing an encoded representation.PushHandler A handler object that provides access toPushListener
.ReadOnlyCommands.ReadOnlyPredicate A predicate to determine whether a command qualifies as Read-Only command.ReconnectionListener Listener for reconnection events.RedisCommand<K,V,T> A redis command that holds an output, arguments and a state, whether it is completed or not. -
Class Summary Class Description AsyncCommand<K,V,T> An asynchronous redis command and its result.BaseRedisCommandBuilder<K,V> Command<K,V,T> CommandArgs<K,V> Redis command arguments.CommandArgsAccessor Accessor for first encoded key, first string and firstinteger
argument ofCommandArgs
.CommandEncoder A nettyChannelHandler
responsible for encoding commands.CommandExpiryWriter Extension toRedisChannelWriter
that expires commands.CommandHandler A nettyChannelHandler
responsible for writing redis commands and reading responses from the server.CommandWrapper<K,V,T> Wrapper for a command.ConnectionWatchdog A nettyChannelHandler
responsible for monitoring the channel and reconnecting when the connection is lost.DecodeBufferPolicies Utility class to construct commonly usedDecodeBufferPolicy
objects.DefaultEndpoint DefaultEndpoint
implementation.ReadOnlyCommands Contains all command names that are read-only commands.RedisHandshakeHandler Handler to initialize a Redis Connection using aConnectionInitializer
.RedisStateMachine State machine that decodes redis server responses encoded according to the Unified Request Protocol (RESP).TracedCommand<K,V,T> Redis command that is aware of an associatedTraceContext
.TransactionalCommand<K,V,T> A wrapper for commands within a MULTI transaction. -
Enum Summary Enum Description CommandHandler.LifecycleState CommandKeyword Keyword modifiers for redis commands.CommandType Redis commands.ConnectionIntent Enumeration of intentions for how a connection is going to be used.ProtocolVersion Versions of the native protocol supported by the driver. -
Exception Summary Exception Description RedisProtocolException Exception thrown on Redis protocol failures.