Package org.redisson.command

Interface CommandAsyncExecutor

All Known Subinterfaces:

CommandExecutor, CommandReactiveExecutor, CommandRxExecutor

All Known Implementing Classes:

CommandAsyncService, CommandBatchService, CommandReactiveBatchService, CommandReactiveService, CommandRxBatchService, CommandRxService, CommandSyncService

public interface CommandAsyncExecutor

Author:

Nikita Koksharov

Method Summary

Modifier and Type	Method	Description
<V> RedisException	convertException(RFuture<V> future)
io.netty.buffer.ByteBuf	encode(Codec codec, value)
io.netty.buffer.ByteBuf	encodeMapKey(Codec codec, value)
io.netty.buffer.ByteBuf	encodeMapValue(Codec codec, value)
<T,R> RFuture<R>	key, Codec codec, RedisCommand<T> evalCommandType, script, <> keys, ... params)
<T,R> RFuture<R>	evalReadAsync(RedisClient client, name, Codec codec, RedisCommand<T> evalCommandType, script, <> keys, ... params)
<T,R> RFuture<R>	evalReadAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> evalCommandType, script, <> keys, ... params)
<T,R> RFuture<R>	evalWriteAllAsync(RedisCommand<T> command, SlotCallback<T,R> callback, script, <> keys, ... params)
<T,R> RFuture<R>	key, Codec codec, RedisCommand<T> evalCommandType, script, <> keys, ... params)
<T,R> RFuture<R>	evalWriteAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> evalCommandType, script, <> keys, ... params)
<V> V	get(RFuture<V> future)
ConnectionManager	getConnectionManager()
<V> V	getInterrupted(RFuture<V> future)
RedissonObjectBuilder	getObjectBuilder()
<V> RFuture<V>	name, Codec codec, > command, long secondsTimeout, ... queueNames)
<T,R> <R>>	<R> results, Codec codec, RedisCommand<T> command, ... params)
<T,R> <R>>	readAllAsync(Codec codec, RedisCommand<T> command, ... params)
<T,R> <R>>	readAllAsync(RedisCommand<T> command, ... params)
<R,T> RFuture<R>	readAllAsync(RedisCommand<T> command, SlotCallback<T,R> callback, ... params)
<T,R> RFuture<R>	readAsync(byte[] key, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	key, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	key, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	readAsync(RedisClient client, byte[] key, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	readAsync(RedisClient client, name, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	readAsync(RedisClient client, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	readAsync(RedisClient client, MasterSlaveEntry entry, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	readAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	readBatchedAsync(Codec codec, RedisCommand<T> command, SlotCallback<T,R> callback, ... keys)
<T,R> RFuture<R>	readRandomAsync(Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	readRandomAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> command, ... params)
void	syncSubscription(RFuture<?> future)
void	syncSubscriptionInterrupted(RFuture<?> future)
<R,T> RFuture<R>	writeAllAsync(Codec codec, RedisCommand<T> command, SlotCallback<T,R> callback, ... params)
<T> >	writeAllAsync(RedisCommand<T> command, ... params)
<R,T> RFuture<R>	writeAllAsync(RedisCommand<T> command, SlotCallback<T,R> callback, ... params)
<T,R> RFuture<R>	writeAsync(byte[] key, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	key, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	key, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	writeAsync(RedisClient client, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	writeAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> command, ... params)
<T,R> RFuture<R>	writeBatchedAsync(Codec codec, RedisCommand<T> command, SlotCallback<T,R> callback, ... keys)

Method Detail

getObjectBuilder

RedissonObjectBuilder getObjectBuilder()

getConnectionManager

ConnectionManager getConnectionManager()

convertException

<V> RedisException convertException(RFuture<V> future)

syncSubscription

void syncSubscription(RFuture<?> future)

syncSubscriptionInterrupted

void syncSubscriptionInterrupted(RFuture<?> future)
                          throws 

Throws:

get

<V> V get(RFuture<V> future)

getInterrupted

<V> V getInterrupted(RFuture<V> future)
              throws 

Throws:

writeAsync

<T,R> RFuture<R> writeAsync(RedisClient client,
                                  Codec codec,
                                  RedisCommand<T> command,
                                  ... params)

writeAsync

<T,R> RFuture<R> writeAsync(MasterSlaveEntry entry,
                                  Codec codec,
                                  RedisCommand<T> command,
                                  ... params)

writeAsync

<T,R> RFuture<R> writeAsync(byte[] key,
                                  Codec codec,
                                  RedisCommand<T> command,
                                  ... params)

readAsync

<T,R> RFuture<R> readAsync(RedisClient client,
                                 MasterSlaveEntry entry,
                                 Codec codec,
                                 RedisCommand<T> command,
                                 ... params)

readAsync

<T,R> RFuture<R> readAsync(RedisClient client,
                                  name,
                                 Codec codec,
                                 RedisCommand<T> command,
                                 ... params)

readAsync

<T,R> RFuture<R> readAsync(RedisClient client,
                                 byte[] key,
                                 Codec codec,
                                 RedisCommand<T> command,
                                 ... params)

readAsync

<T,R> RFuture<R> readAsync(RedisClient client,
                                 Codec codec,
                                 RedisCommand<T> command,
                                 ... params)

evalWriteAllAsync

<T,R> RFuture<R> evalWriteAllAsync(RedisCommand<T> command,
                                         SlotCallback<T,R> callback,
                                          script,
                                         <> keys,
                                         ... params)

writeAllAsync

<R,T> RFuture<R> writeAllAsync(RedisCommand<T> command,
                                     SlotCallback<T,R> callback,
                                     ... params)

readAllAsync

<T,R> <R>> readAllAsync(Codec codec,
                                                RedisCommand<T> command,
                                                ... params)

readAllAsync

<R,T> RFuture<R> readAllAsync(RedisCommand<T> command,
                                    SlotCallback<T,R> callback,
                                    ... params)

readAllAsync

<T,R> <R>> readAllAsync(<R> results,
                                                Codec codec,
                                                RedisCommand<T> command,
                                                ... params)

evalReadAsync

<T,R> RFuture<R> evalReadAsync(RedisClient client,
                                      name,
                                     Codec codec,
                                     RedisCommand<T> evalCommandType,
                                      script,
                                     <> keys,
                                     ... params)

evalReadAsync

<T,R>  key,
                                     Codec codec,
                                     RedisCommand<T> evalCommandType,
                                      script,
                                     <> keys,
                                     ... params)

evalReadAsync

<T,R> RFuture<R> evalReadAsync(MasterSlaveEntry entry,
                                     Codec codec,
                                     RedisCommand<T> evalCommandType,
                                      script,
                                     <> keys,
                                     ... params)

evalWriteAsync

<T,R>  key,
                                      Codec codec,
                                      RedisCommand<T> evalCommandType,
                                       script,
                                      <> keys,
                                      ... params)

evalWriteAsync

<T,R> RFuture<R> evalWriteAsync(MasterSlaveEntry entry,
                                      Codec codec,
                                      RedisCommand<T> evalCommandType,
                                       script,
                                      <> keys,
                                      ... params)

readAsync

<T,R> RFuture<R> readAsync(byte[] key,
                                 Codec codec,
                                 RedisCommand<T> command,
                                 ... params)

readAsync

<T,R>  key,
                                 Codec codec,
                                 RedisCommand<T> command,
                                 ... params)

writeAsync

<T,R>  key,
                                  Codec codec,
                                  RedisCommand<T> command,
                                  ... params)

readAllAsync

<T,R> <R>> readAllAsync(RedisCommand<T> command,
                                                ... params)

writeAllAsync

<R,T> RFuture<R> writeAllAsync(Codec codec,
                                     RedisCommand<T> command,
                                     SlotCallback<T,R> callback,
                                     ... params)

writeAllAsync

<T> > writeAllAsync(RedisCommand<T> command,
                                ... params)

writeAsync

<T,R>  key,
                                  RedisCommand<T> command,
                                  ... params)

readAsync

<T,R>  key,
                                 RedisCommand<T> command,
                                 ... params)

readAsync

<T,R> RFuture<R> readAsync(MasterSlaveEntry entry,
                                 Codec codec,
                                 RedisCommand<T> command,
                                 ... params)

readRandomAsync

<T,R> RFuture<R> readRandomAsync(Codec codec,
                                       RedisCommand<T> command,
                                       ... params)

readRandomAsync

<T,R> RFuture<R> readRandomAsync(MasterSlaveEntry entry,
                                       Codec codec,
                                       RedisCommand<T> command,
                                       ... params)

pollFromAnyAsync

<V>  name,
                                Codec codec,
                                > command,
                                long secondsTimeout,
                                ... queueNames)

encode

io.netty.buffer.ByteBuf encode(Codec codec,
                                value)

encodeMapKey

io.netty.buffer.ByteBuf encodeMapKey(Codec codec,
                                      value)

encodeMapValue

io.netty.buffer.ByteBuf encodeMapValue(Codec codec,
                                        value)

readBatchedAsync

<T,R> RFuture<R> readBatchedAsync(Codec codec,
                                        RedisCommand<T> command,
                                        SlotCallback<T,R> callback,
                                        ... keys)

writeBatchedAsync

<T,R> RFuture<R> writeBatchedAsync(Codec codec,
                                         RedisCommand<T> command,
                                         SlotCallback<T,R> callback,
                                         ... keys)