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, Object value)
io.netty.buffer.ByteBuf	encodeMapKey(Codec codec, Object value)
io.netty.buffer.ByteBuf	encodeMapValue(Codec codec, Object value)
<T,R> RFuture<R>	evalReadAsync(String key, Codec codec, RedisCommand<T> evalCommandType, String script, List<Object> keys, Object... params)
<T,R> RFuture<R>	evalReadAsync(RedisClient client, String name, Codec codec, RedisCommand<T> evalCommandType, String script, List<Object> keys, Object... params)
<T,R> RFuture<R>	evalReadAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> evalCommandType, String script, List<Object> keys, Object... params)
<T,R> RFuture<R>	evalWriteAllAsync(RedisCommand<T> command, SlotCallback<T,R> callback, String script, List<Object> keys, Object... params)
<T,R> RFuture<R>	evalWriteAsync(String key, Codec codec, RedisCommand<T> evalCommandType, String script, List<Object> keys, Object... params)
<T,R> RFuture<R>	evalWriteAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> evalCommandType, String script, List<Object> keys, Object... params)
<V> V	get(RFuture<V> future)
ConnectionManager	getConnectionManager()
<V> V	getInterrupted(RFuture<V> future)
RedissonObjectBuilder	getObjectBuilder()
<V> RFuture<V>	pollFromAnyAsync(String name, Codec codec, RedisCommand<Object> command, long secondsTimeout, String... queueNames)
<T,R> RFuture<Collection<R>>	readAllAsync(Collection<R> results, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<Collection<R>>	readAllAsync(Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<Collection<R>>	readAllAsync(RedisCommand<T> command, Object... params)
<R,T> RFuture<R>	readAllAsync(RedisCommand<T> command, SlotCallback<T,R> callback, Object... params)
<T,R> RFuture<R>	readAsync(byte[] key, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	readAsync(String key, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	readAsync(String key, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	readAsync(RedisClient client, byte[] key, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	readAsync(RedisClient client, String name, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	readAsync(RedisClient client, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	readAsync(RedisClient client, MasterSlaveEntry entry, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	readAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	readBatchedAsync(Codec codec, RedisCommand<T> command, SlotCallback<T,R> callback, String... keys)
<T,R> RFuture<R>	readRandomAsync(Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	readRandomAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> command, Object... params)
void	syncSubscription(RFuture<?> future)
void	syncSubscriptionInterrupted(RFuture<?> future)
<R,T> RFuture<R>	writeAllAsync(Codec codec, RedisCommand<T> command, SlotCallback<T,R> callback, Object... params)
<T> RFuture<Void>	writeAllAsync(RedisCommand<T> command, Object... params)
<R,T> RFuture<R>	writeAllAsync(RedisCommand<T> command, SlotCallback<T,R> callback, Object... params)
<T,R> RFuture<R>	writeAsync(byte[] key, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	writeAsync(String key, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	writeAsync(String key, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	writeAsync(RedisClient client, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	writeAsync(MasterSlaveEntry entry, Codec codec, RedisCommand<T> command, Object... params)
<T,R> RFuture<R>	writeBatchedAsync(Codec codec, RedisCommand<T> command, SlotCallback<T,R> callback, String... 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 InterruptedException

Throws:

InterruptedException

get

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

getInterrupted

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

Throws:

InterruptedException

writeAsync

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

writeAsync

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

writeAsync

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

readAsync

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

readAsync

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

readAsync

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

readAsync

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

evalWriteAllAsync

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

writeAllAsync

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

readAllAsync

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

readAllAsync

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

readAllAsync

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

evalReadAsync

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

evalReadAsync

<T,R> RFuture<R> evalReadAsync(String key,
                                     Codec codec,
                                     RedisCommand<T> evalCommandType,
                                     String script,
                                     List<Object> keys,
                                     Object... params)

evalReadAsync

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

evalWriteAsync

<T,R> RFuture<R> evalWriteAsync(String key,
                                      Codec codec,
                                      RedisCommand<T> evalCommandType,
                                      String script,
                                      List<Object> keys,
                                      Object... params)

evalWriteAsync

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

readAsync

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

readAsync

<T,R> RFuture<R> readAsync(String key,
                                 Codec codec,
                                 RedisCommand<T> command,
                                 Object... params)

writeAsync

<T,R> RFuture<R> writeAsync(String key,
                                  Codec codec,
                                  RedisCommand<T> command,
                                  Object... params)

readAllAsync

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

writeAllAsync

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

writeAllAsync

<T> RFuture<Void> writeAllAsync(RedisCommand<T> command,
                                Object... params)

writeAsync

<T,R> RFuture<R> writeAsync(String key,
                                  RedisCommand<T> command,
                                  Object... params)

readAsync

<T,R> RFuture<R> readAsync(String key,
                                 RedisCommand<T> command,
                                 Object... params)

readAsync

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

readRandomAsync

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

readRandomAsync

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

pollFromAnyAsync

<V> RFuture<V> pollFromAnyAsync(String name,
                                Codec codec,
                                RedisCommand<Object> command,
                                long secondsTimeout,
                                String... queueNames)

encode

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

encodeMapKey

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

encodeMapValue

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

readBatchedAsync

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

writeBatchedAsync

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