Uses of Interface
io.lettuce.core.protocol.RedisCommand
-
Packages that use RedisCommand Package Description io.lettuce.core The Redis client package containingRedisClient
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.cluster Client for Redis Cluster, seeRedisClusterClient
.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.dynamic Core package for Redis Command Interface support throughRedisCommandFactory
.io.lettuce.core.dynamic.batch Batching with Redis Command interfaces.io.lettuce.core.event.command Command-related events.io.lettuce.core.internal Contains internal API.io.lettuce.core.metrics Collectors for client metrics.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.tracing Integration of Brave and Micrometer Tracing for Lettuce Observability. -
-
Uses of RedisCommand in io.lettuce.core
Methods in io.lettuce.core that return RedisCommand Modifier and Type Method Description protected <T> RedisCommand<K,V,T>
RedisChannelHandler. dispatch(RedisCommand<K,V,T> cmd)
<T> RedisCommand<K,V,T>
StatefulRedisConnectionImpl. dispatch(RedisCommand<K,V,T> command)
protected <T> RedisCommand<K,V,T>
StatefulRedisConnectionImpl. preProcessCommand(RedisCommand<K,V,T> command)
<K,V,T>
RedisCommand<K,V,T>CommandListenerWriter. write(RedisCommand<K,V,T> command)
<K,V,T>
RedisCommand<K,V,T>RedisChannelWriter. write(RedisCommand<K,V,T> command)
Write a command on the channel.Methods in io.lettuce.core that return types with arguments of type RedisCommand Modifier and Type Method Description protected Collection<RedisCommand<K,V,?>>
RedisChannelHandler. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
Collection<RedisCommand<K,V,?>>
StatefulRedisConnectionImpl. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
<K,V>
Collection<RedisCommand<K,V,?>>CommandListenerWriter. write(Collection<? extends RedisCommand<K,V,?>> redisCommands)
<K,V>
Collection<RedisCommand<K,V,?>>RedisChannelWriter. write(Collection<? extends RedisCommand<K,V,?>> commands)
Write multiple commands on the channel.Methods in io.lettuce.core with parameters of type RedisCommand Modifier and Type Method Description RedisFuture<String>
AbstractRedisAsyncCommands. aclDryRun(String username, RedisCommand<K,V,?> command)
Mono<String>
AbstractRedisReactiveCommands. aclDryRun(String username, RedisCommand<K,V,?> command)
<T> AsyncCommand<K,V,T>
AbstractRedisAsyncCommands. dispatch(RedisCommand<K,V,T> cmd)
protected <T> RedisCommand<K,V,T>
RedisChannelHandler. dispatch(RedisCommand<K,V,T> cmd)
<T> RedisCommand<K,V,T>
StatefulRedisConnectionImpl. dispatch(RedisCommand<K,V,T> command)
abstract long
TimeoutOptions.TimeoutSource. getTimeout(RedisCommand<?,?,?> command)
Obtains the timeout for aRedisCommand
.protected <T> RedisCommand<K,V,T>
StatefulRedisConnectionImpl. preProcessCommand(RedisCommand<K,V,T> command)
<K,V,T>
RedisCommand<K,V,T>CommandListenerWriter. write(RedisCommand<K,V,T> command)
<K,V,T>
RedisCommand<K,V,T>RedisChannelWriter. write(RedisCommand<K,V,T> command)
Write a command on the channel.Method parameters in io.lettuce.core with type arguments of type RedisCommand Modifier and Type Method Description <T,R>
Flux<R>AbstractRedisReactiveCommands. createDissolvingFlux(Supplier<RedisCommand<K,V,T>> commandSupplier)
<T> Flux<T>
AbstractRedisReactiveCommands. createFlux(Supplier<RedisCommand<K,V,T>> commandSupplier)
<T> Mono<T>
AbstractRedisReactiveCommands. createMono(Supplier<RedisCommand<K,V,T>> commandSupplier)
protected Collection<RedisCommand<K,V,?>>
RedisChannelHandler. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
Collection<RedisCommand<K,V,?>>
StatefulRedisConnectionImpl. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
<K,V>
Collection<RedisCommand<K,V,?>>CommandListenerWriter. write(Collection<? extends RedisCommand<K,V,?>> redisCommands)
<K,V>
Collection<RedisCommand<K,V,?>>RedisChannelWriter. write(Collection<? extends RedisCommand<K,V,?>> commands)
Write multiple commands on the channel. -
Uses of RedisCommand in io.lettuce.core.api
Methods in io.lettuce.core.api that return RedisCommand Modifier and Type Method Description <T> RedisCommand<K,V,T>
StatefulConnection. dispatch(RedisCommand<K,V,T> command)
Dispatch a command.Methods in io.lettuce.core.api that return types with arguments of type RedisCommand Modifier and Type Method Description Collection<RedisCommand<K,V,?>>
StatefulConnection. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
Dispatch multiple command in a single write on the channel.Methods in io.lettuce.core.api with parameters of type RedisCommand Modifier and Type Method Description <T> RedisCommand<K,V,T>
StatefulConnection. dispatch(RedisCommand<K,V,T> command)
Dispatch a command.Method parameters in io.lettuce.core.api with type arguments of type RedisCommand Modifier and Type Method Description Collection<RedisCommand<K,V,?>>
StatefulConnection. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
Dispatch multiple command in a single write on the channel. -
Uses of RedisCommand in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type RedisCommand Modifier and Type Method Description RedisFuture<String>
RedisAclAsyncCommands. aclDryRun(String username, RedisCommand<K,V,?> command)
Simulate the execution of a given command by a given user. -
Uses of RedisCommand in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type RedisCommand Modifier and Type Method Description Mono<String>
RedisAclReactiveCommands. aclDryRun(String username, RedisCommand<K,V,?> command)
Simulate the execution of a given command by a given user. -
Uses of RedisCommand in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type RedisCommand Modifier and Type Method Description String
RedisAclCommands. aclDryRun(String username, RedisCommand<K,V,?> command)
Simulate the execution of a given command by a given user. -
Uses of RedisCommand in io.lettuce.core.cluster
Methods in io.lettuce.core.cluster that return RedisCommand Modifier and Type Method Description <T> RedisCommand<K,V,T>
StatefulRedisClusterConnectionImpl. dispatch(RedisCommand<K,V,T> command)
Methods in io.lettuce.core.cluster that return types with arguments of type RedisCommand Modifier and Type Method Description Collection<RedisCommand<K,V,?>>
StatefulRedisClusterConnectionImpl. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
Methods in io.lettuce.core.cluster with parameters of type RedisCommand Modifier and Type Method Description <T> RedisCommand<K,V,T>
StatefulRedisClusterConnectionImpl. dispatch(RedisCommand<K,V,T> command)
Method parameters in io.lettuce.core.cluster with type arguments of type RedisCommand Modifier and Type Method Description Collection<RedisCommand<K,V,?>>
StatefulRedisClusterConnectionImpl. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
-
Uses of RedisCommand in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type RedisCommand Modifier and Type Method Description AsyncExecutions<String>
NodeSelectionAclAsyncCommands. aclDryRun(String username, RedisCommand<K,V,?> command)
Simulate the execution of a given command by a given user. -
Uses of RedisCommand in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync with parameters of type RedisCommand Modifier and Type Method Description Executions<String>
NodeSelectionAclCommands. aclDryRun(String username, RedisCommand<K,V,?> command)
Simulate the execution of a given command by a given user. -
Uses of RedisCommand in io.lettuce.core.dynamic
Methods in io.lettuce.core.dynamic with parameters of type RedisCommand Modifier and Type Method Description io.lettuce.core.dynamic.BatchTasks
Batcher. batch(RedisCommand<Object,Object,Object> command, CommandBatching batching)
Add command to theBatcher
. -
Uses of RedisCommand in io.lettuce.core.dynamic.batch
Methods in io.lettuce.core.dynamic.batch that return types with arguments of type RedisCommand Modifier and Type Method Description List<RedisCommand<?,?,?>>
BatchException. getFailedCommands()
Constructor parameters in io.lettuce.core.dynamic.batch with type arguments of type RedisCommand Constructor Description BatchException(List<RedisCommand<?,?,?>> failedCommands)
Create a newBatchException
. -
Uses of RedisCommand in io.lettuce.core.event.command
Methods in io.lettuce.core.event.command that return RedisCommand Modifier and Type Method Description RedisCommand<Object,Object,Object>
CommandBaseEvent. getCommand()
Constructors in io.lettuce.core.event.command with parameters of type RedisCommand Constructor Description CommandBaseEvent(RedisCommand<Object,Object,Object> command, Map<String,Object> context)
CommandFailedEvent(RedisCommand<Object,Object,Object> command, Map<String,Object> context, Throwable cause)
CommandStartedEvent(RedisCommand<Object,Object,Object> command, long startedAt)
CommandSucceededEvent(RedisCommand<Object,Object,Object> command, Map<String,Object> context, long started, long completed)
-
Uses of RedisCommand in io.lettuce.core.internal
Methods in io.lettuce.core.internal with parameters of type RedisCommand Modifier and Type Method Description long
TimeoutProvider. getTimeoutNs(RedisCommand<?,?,?> command)
Returns the timeout inTimeUnit.NANOSECONDS
forRedisCommand
. -
Uses of RedisCommand in io.lettuce.core.metrics
Methods in io.lettuce.core.metrics that return types with arguments of type RedisCommand Modifier and Type Method Description Predicate<RedisCommand<?,?,?>>
MicrometerOptions. getMetricsFilter()
Methods in io.lettuce.core.metrics with parameters of type RedisCommand Modifier and Type Method Description default void
CommandLatencyRecorder. recordCommandLatency(SocketAddress local, SocketAddress remote, RedisCommand<?,?,?> command, long firstResponseLatency, long completionLatency)
Record the command latency perconnectionPoint
andcommandType
.void
MicrometerCommandLatencyRecorder. recordCommandLatency(SocketAddress local, SocketAddress remote, RedisCommand<?,?,?> redisCommand, long firstResponseLatency, long completionLatency)
Method parameters in io.lettuce.core.metrics with type arguments of type RedisCommand Modifier and Type Method Description MicrometerOptions.Builder
MicrometerOptions.Builder. metricsFilter(Predicate<RedisCommand<?,?,?>> filter)
Configures a filterPredicate
to filter which commands should be reported to Micrometer. -
Uses of RedisCommand in io.lettuce.core.output
Methods in io.lettuce.core.output with parameters of type RedisCommand Modifier and Type Method Description void
MultiOutput. add(RedisCommand<K,V,?> cmd)
-
Uses of RedisCommand in io.lettuce.core.protocol
Classes in io.lettuce.core.protocol that implement RedisCommand Modifier and Type Class Description class
AsyncCommand<K,V,T>
An asynchronous redis command and its result.class
Command<K,V,T>
class
CommandWrapper<K,V,T>
Wrapper for a command.class
TracedCommand<K,V,T>
Redis command that is aware of an associatedTraceContext
.class
TransactionalCommand<K,V,T>
A wrapper for commands within a MULTI transaction.Fields in io.lettuce.core.protocol declared as RedisCommand Modifier and Type Field Description protected RedisCommand<K,V,T>
CommandWrapper. command
Methods in io.lettuce.core.protocol with type parameters of type RedisCommand Modifier and Type Method Description protected <C extends RedisCommand<?,?,T>,T>
voidDefaultEndpoint. writeToBuffer(C command)
Methods in io.lettuce.core.protocol that return RedisCommand Modifier and Type Method Description RedisCommand<K,V,T>
AsyncCommand. getDelegate()
RedisCommand<K,V,T>
CommandWrapper. getDelegate()
RedisCommand<K,V,T>
DecoratedCommand. getDelegate()
The underlying command.static <K,V,T>
RedisCommand<K,V,T>CommandWrapper. unwrap(RedisCommand<K,V,T> wrapped)
Unwrap a wrapped command.<K,V,T>
RedisCommand<K,V,T>CommandExpiryWriter. write(RedisCommand<K,V,T> command)
<K,V,T>
RedisCommand<K,V,T>DefaultEndpoint. write(RedisCommand<K,V,T> command)
Methods in io.lettuce.core.protocol that return types with arguments of type RedisCommand Modifier and Type Method Description protected List<RedisCommand<?,?,?>>
DefaultEndpoint. drainCommands()
Collection<RedisCommand<?,?,?>>
CommandHandler. drainQueue()
Queue<RedisCommand<?,?,?>>
CommandHandler. getStack()
<K,V>
Collection<RedisCommand<K,V,?>>CommandExpiryWriter. write(Collection<? extends RedisCommand<K,V,?>> redisCommands)
<K,V>
Collection<RedisCommand<K,V,?>>DefaultEndpoint. write(Collection<? extends RedisCommand<K,V,?>> commands)
Methods in io.lettuce.core.protocol with parameters of type RedisCommand Modifier and Type Method Description protected void
CommandHandler. afterDecode(ChannelHandlerContext ctx, RedisCommand<?,?,?> command)
Hook method called after command completion.protected boolean
CommandHandler. canComplete(RedisCommand<?,?,?> command)
Decoding hook: Can the command be completed.protected void
CommandHandler. complete(RedisCommand<?,?,?> command)
Decoding hook: Complete a command.protected boolean
CommandHandler. decode(ByteBuf buffer, RedisCommand<?,?,?> command, CommandOutput<?,?,?> output)
protected CommandOutput<?,?,?>
CommandHandler. getCommandOutput(RedisCommand<?,?,?> command)
Decoding hook: RetrieveCommandOutput
forRedisCommand
decoding.boolean
ReadOnlyCommands.ReadOnlyPredicate. isReadOnly(RedisCommand<?,?,?> command)
Evaluates this predicate on the givenRedisCommand
.static <K,V,T>
RedisCommand<K,V,T>CommandWrapper. unwrap(RedisCommand<K,V,T> wrapped)
Unwrap a wrapped command.static <R,K,V,T>
RCommandWrapper. unwrap(RedisCommand<K,V,T> wrapped, Class<R> iface)
Returns an object that implements the given interface to allow access to non-standard methods, or standard methods not exposed by the proxy.<K,V,T>
RedisCommand<K,V,T>CommandExpiryWriter. write(RedisCommand<K,V,T> command)
<K,V,T>
RedisCommand<K,V,T>DefaultEndpoint. write(RedisCommand<K,V,T> command)
Method parameters in io.lettuce.core.protocol with type arguments of type RedisCommand Modifier and Type Method Description <K,V>
Collection<RedisCommand<K,V,?>>CommandExpiryWriter. write(Collection<? extends RedisCommand<K,V,?>> redisCommands)
<K,V>
Collection<RedisCommand<K,V,?>>DefaultEndpoint. write(Collection<? extends RedisCommand<K,V,?>> commands)
Constructors in io.lettuce.core.protocol with parameters of type RedisCommand Constructor Description AsyncCommand(RedisCommand<K,V,T> command)
AsyncCommand(RedisCommand<K,V,T> command, int count)
CommandWrapper(RedisCommand<K,V,T> command)
TracedCommand(RedisCommand<K,V,T> command, TraceContext traceContext)
TransactionalCommand(RedisCommand<K,V,T> command)
-
Uses of RedisCommand in io.lettuce.core.pubsub
Methods in io.lettuce.core.pubsub that return RedisCommand Modifier and Type Method Description <K1,V1,T>
RedisCommand<K1,V1,T>PubSubEndpoint. write(RedisCommand<K1,V1,T> command)
Methods in io.lettuce.core.pubsub that return types with arguments of type RedisCommand Modifier and Type Method Description <K1,V1>
Collection<RedisCommand<K1,V1,?>>PubSubEndpoint. write(Collection<? extends RedisCommand<K1,V1,?>> redisCommands)
Methods in io.lettuce.core.pubsub with parameters of type RedisCommand Modifier and Type Method Description protected void
PubSubCommandHandler. afterDecode(ChannelHandlerContext ctx, RedisCommand<?,?,?> command)
protected boolean
PubSubCommandHandler. canComplete(RedisCommand<?,?,?> command)
protected void
PubSubCommandHandler. complete(RedisCommand<?,?,?> command)
protected CommandOutput<?,?,?>
PubSubCommandHandler. getCommandOutput(RedisCommand<?,?,?> command)
protected void
PubSubEndpoint. rejectCommand(RedisCommand<?,?,?> command)
<K1,V1,T>
RedisCommand<K1,V1,T>PubSubEndpoint. write(RedisCommand<K1,V1,T> command)
Method parameters in io.lettuce.core.pubsub with type arguments of type RedisCommand Modifier and Type Method Description protected boolean
PubSubEndpoint. containsViolatingCommands(Collection<? extends RedisCommand<?,?,?>> redisCommands)
protected void
PubSubEndpoint. rejectCommands(Collection<? extends RedisCommand<?,?,?>> redisCommands)
<K1,V1>
Collection<RedisCommand<K1,V1,?>>PubSubEndpoint. write(Collection<? extends RedisCommand<K1,V1,?>> redisCommands)
-
Uses of RedisCommand in io.lettuce.core.sentinel
Methods in io.lettuce.core.sentinel that return RedisCommand Modifier and Type Method Description <T> RedisCommand<K,V,T>
StatefulRedisSentinelConnectionImpl. dispatch(RedisCommand<K,V,T> command)
Methods in io.lettuce.core.sentinel that return types with arguments of type RedisCommand Modifier and Type Method Description Collection<RedisCommand<K,V,?>>
StatefulRedisSentinelConnectionImpl. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
Methods in io.lettuce.core.sentinel with parameters of type RedisCommand Modifier and Type Method Description <T> AsyncCommand<K,V,T>
RedisSentinelAsyncCommandsImpl. dispatch(RedisCommand<K,V,T> cmd)
<T> RedisCommand<K,V,T>
StatefulRedisSentinelConnectionImpl. dispatch(RedisCommand<K,V,T> command)
Method parameters in io.lettuce.core.sentinel with type arguments of type RedisCommand Modifier and Type Method Description Collection<RedisCommand<K,V,?>>
StatefulRedisSentinelConnectionImpl. dispatch(Collection<? extends RedisCommand<K,V,?>> commands)
-
Uses of RedisCommand in io.lettuce.core.tracing
Methods in io.lettuce.core.tracing that return RedisCommand Modifier and Type Method Description RedisCommand<?,?,?>
LettuceObservationContext. getRequiredCommand()
Returns the requiredRedisCommand
or throwsIllegalStateException
if no command is associated with the context.Methods in io.lettuce.core.tracing with parameters of type RedisCommand Modifier and Type Method Description void
LettuceObservationContext. setCommand(RedisCommand<?,?,?> command)
Set theRedisCommand
.abstract Tracer.Span
Tracer.Span. start(RedisCommand<?,?,?> command)
Starts the span with.Method parameters in io.lettuce.core.tracing with type arguments of type RedisCommand Modifier and Type Method Description BraveTracing.Builder
BraveTracing.Builder. spanCustomizer(BiConsumer<RedisCommand<Object,Object,Object>,brave.Span> spanCustomizer)
-