java.lang.Object
- io.toro.martini.redis.RedisBaseMethods
- - io.toro.martini.redis.RedisServerMethods

public class RedisServerMethods
extends io.toro.martini.redis.RedisBaseMethods

Methods for Server Control.

Constructor Summary

Constructors
Constructor Description

RedisServerMethods(io.toro.martini.database.DataSourceManager dataSourceManager)

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static String`	`bgrewriteaof(String connectionName, GloopExecutionContext context)`	Asynchronously rewrite the append-only file.
`static Future<String>`	`bgrewriteaofAsync(String connectionName, GloopExecutionContext context)`	Asynchronously asynchronously rewrite the append-only file.
`static String`	`bgsave(String connectionName, GloopExecutionContext context)`	Asynchronously save the dataset to disk.
`static Future<String>`	`bgsaveAsync(String connectionName, GloopExecutionContext context)`	Asynchronously asynchronously save the dataset to disk.
`static Object`	`clientGetname(String connectionName, GloopExecutionContext context)`	Get the current connection name.
`static Future<Object>`	`clientGetnameAsync(String connectionName, GloopExecutionContext context)`	Asynchronously get the current connection name.
`static Long`	`clientKill(String connectionName, GloopModel killArgs, GloopExecutionContext context)`	Kill connections of clients which are filtered by `killArgs`
`static String`	`clientKill(String connectionName, String addr, GloopExecutionContext context)`	Kill the connection of a client identified by ip:port.
`static Future<Long>`	`clientKillAsync(String connectionName, GloopModel killArgs, GloopExecutionContext context)`	Asynchronously kill connections of clients which are filtered by `killArgs`
`static Future<String>`	`clientKillAsync(String connectionName, String addr, GloopExecutionContext context)`	Asynchronously kill the connection of a client identified by ip:port.
`static String`	`clientList(String connectionName, GloopExecutionContext context)`	Get the list of client connections.
`static Future<String>`	`clientListAsync(String connectionName, GloopExecutionContext context)`	Asynchronously get the list of client connections.
`static String`	`clientPause(String connectionName, long timeout, GloopExecutionContext context)`	Stop processing commands from clients for some time.
`static Future<String>`	`clientPauseAsync(String connectionName, long timeout, GloopExecutionContext context)`	Asynchronously stop processing commands from clients for some time.
`static String`	`clientSetname(String connectionName, Object name, GloopExecutionContext context)`	Set the current connection name.
`static Future<String>`	`clientSetnameAsync(String connectionName, Object name, GloopExecutionContext context)`	Asynchronously set the current connection name.
`static Long`	`clientUnblock(String connectionName, long id, String type, GloopExecutionContext context)`	Unblock the specified blocked client.
`static Future<Long>`	`clientUnblockAsync(String connectionName, long id, String type, GloopExecutionContext context)`	Asynchronously unblock the specified blocked client.
`static List<Object>`	`command(String connectionName, GloopExecutionContext context)`	Returns an array reply of details about all Redis commands.
`static Future<List<Object>>`	`commandAsync(String connectionName, GloopExecutionContext context)`	Asynchronously returns an array reply of details about all redis commands.
`static Long`	`commandCount(String connectionName, GloopExecutionContext context)`	Get total number of Redis commands.
`static Future<Long>`	`commandCountAsync(String connectionName, GloopExecutionContext context)`	Asynchronously get total number of redis commands.
`static List<Object>`	`commandInfo(String connectionName, GloopExecutionContext context, CommandType... commands)`	Returns an array reply of details about the requested commands.
`static List<Object>`	`commandInfo(String connectionName, GloopExecutionContext context, String... commandType)`	Returns an array reply of details about the requested commands.
`static Future<List<Object>>`	`commandInfoAsync(String connectionName, GloopExecutionContext context, CommandType... commands)`	Asynchronously returns an array reply of details about the requested commands.
`static Future<List<Object>>`	`commandInfoAsync(String connectionName, GloopExecutionContext context, String... commandType)`	Asynchronously returns an array reply of details about the requested commands.
`static GloopModel`	`configGet(String connectionName, String parameter, GloopExecutionContext context)`	Get the value of a configuration parameter.
`static Future<Map<String,String>>`	`configGetAsync(String connectionName, String parameter, GloopExecutionContext context)`	Asynchronously get the value of a configuration parameter.
`static String`	`configResetstat(String connectionName, GloopExecutionContext context)`	Reset the stats returned by INFO.
`static Future<String>`	`configResetstatAsync(String connectionName, GloopExecutionContext context)`	Asynchronously reset the stats returned by iNFO.
`static String`	`configRewrite(String connectionName, GloopExecutionContext context)`	Rewrite the configuration file with the in memory configuration.
`static Future<String>`	`configRewriteAsync(String connectionName, GloopExecutionContext context)`	Asynchronously rewrite the configuration file with the in memory configuration.
`static String`	`configSet(String connectionName, String parameter, String value, GloopExecutionContext context)`	Set a configuration parameter to the given value.
`static Future<String>`	`configSetAsync(String connectionName, String parameter, String value, GloopExecutionContext context)`	Asynchronously set a configuration parameter to the given value.
`static Long`	`dbsize(String connectionName, GloopExecutionContext context)`	Return the number of keys in the selected database.
`static Future<Long>`	`dbsizeAsync(String connectionName, GloopExecutionContext context)`	Asynchronously return the number of keys in the selected database.
`static String`	`debugCrashAndRecover(String connectionName, Long delay, GloopExecutionContext context)`	Crash and recover
`static Future<String>`	`debugCrashAndRecoverAsync(String connectionName, Long delay, GloopExecutionContext context)`	Asynchronously crash and recover
`static String`	`debugHtstats(String connectionName, int db, GloopExecutionContext context)`	Get debugging information about the internal hash-table state.
`static Future<String>`	`debugHtstatsAsync(String connectionName, int db, GloopExecutionContext context)`	Asynchronously get debugging information about the internal hash-table state.
`static String`	`debugObject(String connectionName, Object key, GloopExecutionContext context)`	Get debugging information about a key.
`static Future<String>`	`debugObjectAsync(String connectionName, Object key, GloopExecutionContext context)`	Asynchronously get debugging information about a key.
`static void`	`debugOom(String connectionName, GloopExecutionContext context)`	Make the server crash: Out of memory.
`static void`	`debugOomAsync(String connectionName, GloopExecutionContext context)`	Asynchronously make the server crash: out of memory.
`static String`	`debugReload(String connectionName, GloopExecutionContext context)`	Save RDB, clear the database and reload RDB.
`static Future<String>`	`debugReloadAsync(String connectionName, GloopExecutionContext context)`	Asynchronously save rDB, clear the database and reload rDB.
`static String`	`debugRestart(String connectionName, Long delay, GloopExecutionContext context)`	Restart the server gracefully.
`static Future<String>`	`debugRestartAsync(String connectionName, Long delay, GloopExecutionContext context)`	Asynchronously restart the server gracefully.
`static String`	`debugSdslen(String connectionName, Object key, GloopExecutionContext context)`	Get debugging information about the internal SDS length.
`static Future<String>`	`debugSdslenAsync(String connectionName, Object key, GloopExecutionContext context)`	Asynchronously get debugging information about the internal sDS length.
`static void`	`debugSegfault(String connectionName, GloopExecutionContext context)`	Make the server crash: Invalid pointer access.
`static void`	`debugSegfaultAsync(String connectionName, GloopExecutionContext context)`	Asynchronously make the server crash: invalid pointer access.
`static String`	`flushall(String connectionName, GloopExecutionContext context)`	Remove all keys from all databases.
`static Future<String>`	`flushallAsync(String connectionName, GloopExecutionContext context)`	Asynchronously remove all keys from all databases.
`static Future<String>`	`flushallAsyncAsync(String connectionName, GloopExecutionContext context)`	Asynchronously remove all keys asynchronously from all databases.
`static String`	`flushdb(String connectionName, GloopExecutionContext context)`	Remove all keys from the current database.
`static Future<String>`	`flushdbAsync(String connectionName, GloopExecutionContext context)`	Asynchronously remove all keys from the current database.
`static Future<String>`	`flushdbAsyncAsync(String connectionName, GloopExecutionContext context)`	Asynchronously remove all keys asynchronously from the current database.
`static String`	`info(String connectionName, GloopExecutionContext context)`	Get information and statistics about the server.
`static String`	`info(String connectionName, String section, GloopExecutionContext context)`	Get information and statistics about the server.
`static Future<String>`	`infoAsync(String connectionName, GloopExecutionContext context)`	Asynchronously get information and statistics about the server.
`static Future<String>`	`infoAsync(String connectionName, String section, GloopExecutionContext context)`	Asynchronously get information and statistics about the server.
`static Date`	`lastsave(String connectionName, GloopExecutionContext context)`	Get the UNIX time stamp of the last successful save to disk.
`static Future<Date>`	`lastsaveAsync(String connectionName, GloopExecutionContext context)`	Asynchronously get the uNIX time stamp of the last successful save to disk.
`static String`	`save(String connectionName, GloopExecutionContext context)`	Synchronously save the dataset to disk.
`static Future<String>`	`saveAsync(String connectionName, GloopExecutionContext context)`	Asynchronously synchronously save the dataset to disk.
`static void`	`shutdown(String connectionName, boolean save, GloopExecutionContext context)`	Synchronously save the dataset to disk and then shut down the server.
`static void`	`shutdownAsync(String connectionName, boolean save, GloopExecutionContext context)`	Asynchronously synchronously save the dataset to disk and then shut down the server.
`static String`	`slaveof(String connectionName, String host, int port, GloopExecutionContext context)`	Make the server a slave of another instance, or promote it as master.
`static Future<String>`	`slaveofAsync(String connectionName, String host, int port, GloopExecutionContext context)`	Asynchronously make the server a slave of another instance, or promote it as master.
`static String`	`slaveofNoOne(String connectionName, GloopExecutionContext context)`	Promote server as master.
`static Future<String>`	`slaveofNoOneAsync(String connectionName, GloopExecutionContext context)`	Asynchronously promote server as master.
`static List<Object>`	`slowlogGet(String connectionName, int count, GloopExecutionContext context)`	Read the slow log.
`static List<Object>`	`slowlogGet(String connectionName, GloopExecutionContext context)`	Read the slow log.
`static Future<List<Object>>`	`slowlogGetAsync(String connectionName, int count, GloopExecutionContext context)`	Asynchronously read the slow log.
`static Future<List<Object>>`	`slowlogGetAsync(String connectionName, GloopExecutionContext context)`	Asynchronously read the slow log.
`static Long`	`slowlogLen(String connectionName, GloopExecutionContext context)`	Obtaining the current length of the slow log.
`static Future<Long>`	`slowlogLenAsync(String connectionName, GloopExecutionContext context)`	Asynchronously obtaining the current length of the slow log.
`static String`	`slowlogReset(String connectionName, GloopExecutionContext context)`	Resetting the slow log.
`static Future<String>`	`slowlogResetAsync(String connectionName, GloopExecutionContext context)`	Asynchronously resetting the slow log.
`static List<Object>`	`time(String connectionName, GloopExecutionContext context)`	Return the current server time.
`static Future<List<Object>>`	`timeAsync(String connectionName, GloopExecutionContext context)`	Asynchronously return the current server time.

Methods inherited from class io.toro.martini.redis.RedisBaseMethods
getDataSourceManager, getRedisConnection, getRedisConnection

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedisServerMethods

@Autowired
RedisServerMethods(io.toro.martini.database.DataSourceManager dataSourceManager)

Method Detail

bgrewriteaof

@GloopParameter(name="redisBgrewriteaofOutput")
public static String bgrewriteaof(@GloopParameter(allowNull=false)
                                  String connectionName,
                                  GloopExecutionContext context)

Asynchronously rewrite the append-only file.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply always OK.

bgrewriteaofAsync

@GloopParameter(name="redisFutureBgrewriteaofOutput")
public static Future<String> bgrewriteaofAsync(@GloopParameter(allowNull=false)
                                               String connectionName,
                                               GloopExecutionContext context)

Asynchronously asynchronously rewrite the append-only file.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply always oK.

bgsave

@GloopParameter(name="redisBgsaveOutput")
public static String bgsave(@GloopParameter(allowNull=false)
                            String connectionName,
                            GloopExecutionContext context)

Asynchronously save the dataset to disk.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply

bgsaveAsync

@GloopParameter(name="redisFutureBgsaveOutput")
public static Future<String> bgsaveAsync(@GloopParameter(allowNull=false)
                                         String connectionName,
                                         GloopExecutionContext context)

Asynchronously asynchronously save the dataset to disk.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply

clientGetname

@GloopParameter(name="redisClientGetnameOutput")
public static Object clientGetname(@GloopParameter(allowNull=false)
                                   String connectionName,
                                   GloopExecutionContext context)

Get the current connection name.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: K bulk-string-reply The connection name, or a null bulk reply if no name is set.

clientGetnameAsync

@GloopParameter(name="redisFutureClientGetnameOutput")
public static Future<Object> clientGetnameAsync(@GloopParameter(allowNull=false)
                                                String connectionName,
                                                GloopExecutionContext context)

Asynchronously get the current connection name.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: k bulk-string-reply the connection name, or a null bulk reply if no name is set.

clientSetname

@GloopParameter(name="redisClientSetnameOutput")
public static String clientSetname(@GloopParameter(allowNull=false)
                                   String connectionName,
                                   @GloopParameter(allowNull=false)
                                   Object name,
                                   GloopExecutionContext context)

Set the current connection name.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; name - the client name
Returns:: simple-string-reply OK if the connection name was successfully set.

clientSetnameAsync

@GloopParameter(name="redisFutureClientSetnameOutput")
public static Future<String> clientSetnameAsync(@GloopParameter(allowNull=false)
                                                String connectionName,
                                                @GloopParameter(allowNull=false)
                                                Object name,
                                                GloopExecutionContext context)

Asynchronously set the current connection name.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; name - the client name
Returns:: simple-string-reply oK if the connection name was successfully set.

clientKill

@GloopParameter(name="redisClientKillOutput")
public static String clientKill(@GloopParameter(allowNull=false)
                                String connectionName,
                                @GloopParameter(allowNull=false)
                                String addr,
                                GloopExecutionContext context)

Kill the connection of a client identified by ip:port.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; addr - ip:port
Returns:: String simple-string-reply OK if the connection exists and has been closed

clientKill

@GloopParameter(name="redisClientKillOutput")
public static Long clientKill(@GloopParameter(allowNull=false)
                              String connectionName,
                              @GloopObjectParameter("killArgs{\n  skipme:boolean:By default this option is enabled, that is, the client calling the command will not get killed, however setting this option to false will have the effect of also killing the client calling the command\n addr::Kill the client at this address\n id:long:Kill the client with this client id\n type::This closes the connections of all the clients in the specified {@link Type class}. Note that clients blocked into the {@link Type MONITOR} command are considered to belong to the normal class:false::[\'NORMAL\',\'MASTER\',\'SLAVE\',\'PUBSUB\']\n}")
                              GloopModel killArgs,
                              GloopExecutionContext context)

Kill connections of clients which are filtered by killArgs

Parameters:: connectionName - The Martini Runtime Redis connection pool name; killArgs - args for the kill operation
Returns:: Long integer-reply number of killed connections

clientKillAsync

@GloopParameter(name="redisFutureClientKillOutput")
public static Future<String> clientKillAsync(@GloopParameter(allowNull=false)
                                             String connectionName,
                                             @GloopParameter(allowNull=false)
                                             String addr,
                                             GloopExecutionContext context)

Asynchronously kill the connection of a client identified by ip:port.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; addr - ip:port
Returns:: string simple-string-reply oK if the connection exists and has been closed

clientKillAsync

@GloopParameter(name="redisFutureClientKillOutput")
public static Future<Long> clientKillAsync(@GloopParameter(allowNull=false)
                                           String connectionName,
                                           @GloopObjectParameter("killArgs{\n  skipme:boolean:By default this option is enabled, that is, the client calling the command will not get killed, however setting this option to false will have the effect of also killing the client calling the command\n addr::Kill the client at this address\n id:long:Kill the client with this client id\n type::This closes the connections of all the clients in the specified {@link Type class}. Note that clients blocked into the {@link Type MONITOR} command are considered to belong to the normal class:false::[\'NORMAL\',\'MASTER\',\'SLAVE\',\'PUBSUB\']\n}")
                                           GloopModel killArgs,
                                           GloopExecutionContext context)

Asynchronously kill connections of clients which are filtered by killArgs

Parameters:: connectionName - The Martini Runtime Redis connection pool name; killArgs - args for the kill operation
Returns:: long integer-reply number of killed connections

clientUnblock

@GloopParameter(name="redisClientUnblockOutput")
public static Long clientUnblock(@GloopParameter(allowNull=false)
                                 String connectionName,
                                 @GloopParameter(allowNull=false)
                                 long id,
                                 @GloopParameter(allowNull=false,choices={"TIMEOUT","ERROR"})
                                 String type,
                                 GloopExecutionContext context)

Unblock the specified blocked client.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; id - the client id.; type - unblock type.
Returns:: Long integer-reply number of unblocked connections.
Since:: 5.1

clientUnblockAsync

@GloopParameter(name="redisFutureClientUnblockOutput")
public static Future<Long> clientUnblockAsync(@GloopParameter(allowNull=false)
                                              String connectionName,
                                              @GloopParameter(allowNull=false)
                                              long id,
                                              @GloopParameter(allowNull=false,choices={"TIMEOUT","ERROR"})
                                              String type,
                                              GloopExecutionContext context)

Asynchronously unblock the specified blocked client.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; id - the client id.; type - unblock type.
Returns:: long integer-reply number of unblocked connections.
Since:: 5.1

clientPause

@GloopParameter(name="redisClientPauseOutput")
public static String clientPause(@GloopParameter(allowNull=false)
                                 String connectionName,
                                 @GloopParameter(allowNull=false)
                                 long timeout,
                                 GloopExecutionContext context)

Stop processing commands from clients for some time.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; timeout - the timeout value in milliseconds
Returns:: String simple-string-reply The command returns OK or an error if the timeout is invalid.

clientPauseAsync

@GloopParameter(name="redisFutureClientPauseOutput")
public static Future<String> clientPauseAsync(@GloopParameter(allowNull=false)
                                              String connectionName,
                                              @GloopParameter(allowNull=false)
                                              long timeout,
                                              GloopExecutionContext context)

Asynchronously stop processing commands from clients for some time.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; timeout - the timeout value in milliseconds
Returns:: string simple-string-reply the command returns oK or an error if the timeout is invalid.

clientList
```
@GloopParameter(name="redisClientListOutput")
public static String clientList(@GloopParameter(allowNull=false)
                                String connectionName,
                                GloopExecutionContext context)
```
Get the list of client connections.

Parameters:

connectionName - The Martini Runtime Redis connection pool name

Returns:

String bulk-string-reply a unique string, formatted as follows: One client connection per line (separated by LF), each line is composed of a succession of property=value fields separated by a space character.

clientListAsync

@GloopParameter(name="redisFutureClientListOutput")
public static Future<String> clientListAsync(@GloopParameter(allowNull=false)
                                             String connectionName,
                                             GloopExecutionContext context)

Asynchronously get the list of client connections.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string bulk-string-reply a unique string, formatted as follows: one client connection per line (separated by lF), each line is composed of a succession of property=value fields separated by a space character.

command

@GloopParameter(name="redisCommandOutput")
public static List<Object> command(@GloopParameter(allowNull=false)
                                   String connectionName,
                                   GloopExecutionContext context)

Returns an array reply of details about all Redis commands.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: List<Object> array-reply

commandAsync

@GloopParameter(name="redisFutureCommandOutput")
public static Future<List<Object>> commandAsync(@GloopParameter(allowNull=false)
                                                String connectionName,
                                                GloopExecutionContext context)

Asynchronously returns an array reply of details about all redis commands.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: list<Object> array-reply

commandInfo

@GloopParameter(name="redisCommandInfoOutput")
public static List<Object> commandInfo(@GloopParameter(allowNull=false)
                                       String connectionName,
                                       GloopExecutionContext context,
                                       @GloopObjectParameter("commandType[]:::false::[\'APPEND\',\'ASKING\',\'AUTH\',\'BGREWRITEAOF\',\'BGSAVE\',\'BITCOUNT\',\'BITFIELD\',\'BITOP\',\'BITPOS\',\'BLPOP\',\'BRPOP\',\'BRPOPLPUSH\',\'BZPOPMAX\',\'BZPOPMIN\',\'CLIENT\',\'CLUSTER\',\'COMMAND\',\'CONFIG\',\'DBSIZE\',\'DEBUG\',\'DECR\',\'DECRBY\',\'DEL\',\'DISCARD\',\'DUMP\',\'ECHO\',\'EVAL\',\'EVALSHA\',\'EXEC\',\'EXISTS\',\'EXPIRE\',\'EXPIREAT\',\'FLUSHALL\',\'FLUSHDB\',\'GEOADD\',\'GEODECODE\',\'GEODIST\',\'GEOENCODE\',\'GEOHASH\',\'GEOPOS\',\'GEORADIUS\',\'GEORADIUSBYMEMBER\',\'GEORADIUSBYMEMBER_RO\',\'GEORADIUS_RO\',\'GET\',\'GETBIT\',\'GETRANGE\',\'GETSET\',\'HDEL\',\'HEXISTS\',\'HGET\',\'HGETALL\',\'HINCRBY\',\'HINCRBYFLOAT\',\'HKEYS\',\'HLEN\',\'HMGET\',\'HMSET\',\'HSCAN\',\'HSET\',\'HSETNX\',\'HSTRLEN\',\'HVALS\',\'INCR\',\'INCRBY\',\'INCRBYFLOAT\',\'INFO\',\'KEYS\',\'LASTSAVE\',\'LINDEX\',\'LINSERT\',\'LLEN\',\'LPOP\',\'LPUSH\',\'LPUSHX\',\'LRANGE\',\'LREM\',\'LSET\',\'LTRIM\',\'MGET\',\'MIGRATE\',\'MONITOR\',\'MOVE\',\'MSET\',\'MSETNX\',\'MULTI\',\'MYID\',\'OBJECT\',\'PERSIST\',\'PEXPIRE\',\'PEXPIREAT\',\'PFADD\',\'PFCOUNT\',\'PFMERGE\',\'PING\',\'PSETEX\',\'PSUBSCRIBE\',\'PTTL\',\'PUBLISH\',\'PUBSUB\',\'PUNSUBSCRIBE\',\'QUIT\',\'RANDOMKEY\',\'READONLY\',\'READWRITE\',\'RENAME\',\'RENAMENX\',\'RESTORE\',\'ROLE\',\'RPOP\',\'RPOPLPUSH\',\'RPUSH\',\'RPUSHX\',\'SADD\',\'SAVE\',\'SCAN\',\'SCARD\',\'SCRIPT\',\'SDIFF\',\'SDIFFSTORE\',\'SELECT\',\'SENTINEL\',\'SET\',\'SETBIT\',\'SETEX\',\'SETNX\',\'SETRANGE\',\'SHUTDOWN\',\'SINTER\',\'SINTERSTORE\',\'SISMEMBER\',\'SLAVEOF\',\'SLOWLOG\',\'SMEMBERS\',\'SMOVE\',\'SORT\',\'SPOP\',\'SRANDMEMBER\',\'SREM\',\'SSCAN\',\'STRLEN\',\'SUBSCRIBE\',\'SUNION\',\'SUNIONSTORE\',\'SWAPDB\',\'SYNC\',\'TIME\',\'TOUCH\',\'TTL\',\'TYPE\',\'UNLINK\',\'UNSUBSCRIBE\',\'UNWATCH\',\'WAIT\',\'WATCH\',\'XACK\',\'XADD\',\'XCLAIM\',\'XDEL\',\'XGROUP\',\'XINFO\',\'XLEN\',\'XPENDING\',\'XRANGE\',\'XREAD\',\'XREADGROUP\',\'XREVRANGE\',\'XTRIM\',\'ZADD\',\'ZCARD\',\'ZCOUNT\',\'ZINCRBY\',\'ZINTERSTORE\',\'ZLEXCOUNT\',\'ZPOPMAX\',\'ZPOPMIN\',\'ZRANGE\',\'ZRANGEBYLEX\',\'ZRANGEBYSCORE\',\'ZRANK\',\'ZREM\',\'ZREMRANGEBYLEX\',\'ZREMRANGEBYRANK\',\'ZREMRANGEBYSCORE\',\'ZREVRANGE\',\'ZREVRANGEBYLEX\',\'ZREVRANGEBYSCORE\',\'ZREVRANK\',\'ZSCAN\',\'ZSCORE\',\'ZUNIONSTORE\']")
                                       String... commandType)

Returns an array reply of details about the requested commands.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; commandType - the commands to query for
Returns:: List<Object> array-reply

commandInfo

@GloopParameter(name="redisCommandInfoOutput")
public static List<Object> commandInfo(@GloopParameter(allowNull=false)
                                       String connectionName,
                                       GloopExecutionContext context,
                                       @GloopParameter(allowNull=false)
                                       CommandType... commands)

Returns an array reply of details about the requested commands.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; commands - the commands to query for
Returns:: List<Object> array-reply

commandInfoAsync

@GloopParameter(name="redisFutureCommandInfoOutput")
public static Future<List<Object>> commandInfoAsync(@GloopParameter(allowNull=false)
                                                    String connectionName,
                                                    GloopExecutionContext context,
                                                    @GloopParameter(allowNull=false)
                                                    CommandType... commands)

Asynchronously returns an array reply of details about the requested commands.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; commands - the commands to query for
Returns:: list<Object> array-reply

commandInfoAsync

@GloopParameter(name="redisFutureCommandInfoOutput")
public static Future<List<Object>> commandInfoAsync(@GloopParameter(allowNull=false)
                                                    String connectionName,
                                                    GloopExecutionContext context,
                                                    @GloopObjectParameter("commandType[]:::false::[\'APPEND\',\'ASKING\',\'AUTH\',\'BGREWRITEAOF\',\'BGSAVE\',\'BITCOUNT\',\'BITFIELD\',\'BITOP\',\'BITPOS\',\'BLPOP\',\'BRPOP\',\'BRPOPLPUSH\',\'BZPOPMAX\',\'BZPOPMIN\',\'CLIENT\',\'CLUSTER\',\'COMMAND\',\'CONFIG\',\'DBSIZE\',\'DEBUG\',\'DECR\',\'DECRBY\',\'DEL\',\'DISCARD\',\'DUMP\',\'ECHO\',\'EVAL\',\'EVALSHA\',\'EXEC\',\'EXISTS\',\'EXPIRE\',\'EXPIREAT\',\'FLUSHALL\',\'FLUSHDB\',\'GEOADD\',\'GEODECODE\',\'GEODIST\',\'GEOENCODE\',\'GEOHASH\',\'GEOPOS\',\'GEORADIUS\',\'GEORADIUSBYMEMBER\',\'GEORADIUSBYMEMBER_RO\',\'GEORADIUS_RO\',\'GET\',\'GETBIT\',\'GETRANGE\',\'GETSET\',\'HDEL\',\'HEXISTS\',\'HGET\',\'HGETALL\',\'HINCRBY\',\'HINCRBYFLOAT\',\'HKEYS\',\'HLEN\',\'HMGET\',\'HMSET\',\'HSCAN\',\'HSET\',\'HSETNX\',\'HSTRLEN\',\'HVALS\',\'INCR\',\'INCRBY\',\'INCRBYFLOAT\',\'INFO\',\'KEYS\',\'LASTSAVE\',\'LINDEX\',\'LINSERT\',\'LLEN\',\'LPOP\',\'LPUSH\',\'LPUSHX\',\'LRANGE\',\'LREM\',\'LSET\',\'LTRIM\',\'MGET\',\'MIGRATE\',\'MONITOR\',\'MOVE\',\'MSET\',\'MSETNX\',\'MULTI\',\'MYID\',\'OBJECT\',\'PERSIST\',\'PEXPIRE\',\'PEXPIREAT\',\'PFADD\',\'PFCOUNT\',\'PFMERGE\',\'PING\',\'PSETEX\',\'PSUBSCRIBE\',\'PTTL\',\'PUBLISH\',\'PUBSUB\',\'PUNSUBSCRIBE\',\'QUIT\',\'RANDOMKEY\',\'READONLY\',\'READWRITE\',\'RENAME\',\'RENAMENX\',\'RESTORE\',\'ROLE\',\'RPOP\',\'RPOPLPUSH\',\'RPUSH\',\'RPUSHX\',\'SADD\',\'SAVE\',\'SCAN\',\'SCARD\',\'SCRIPT\',\'SDIFF\',\'SDIFFSTORE\',\'SELECT\',\'SENTINEL\',\'SET\',\'SETBIT\',\'SETEX\',\'SETNX\',\'SETRANGE\',\'SHUTDOWN\',\'SINTER\',\'SINTERSTORE\',\'SISMEMBER\',\'SLAVEOF\',\'SLOWLOG\',\'SMEMBERS\',\'SMOVE\',\'SORT\',\'SPOP\',\'SRANDMEMBER\',\'SREM\',\'SSCAN\',\'STRLEN\',\'SUBSCRIBE\',\'SUNION\',\'SUNIONSTORE\',\'SWAPDB\',\'SYNC\',\'TIME\',\'TOUCH\',\'TTL\',\'TYPE\',\'UNLINK\',\'UNSUBSCRIBE\',\'UNWATCH\',\'WAIT\',\'WATCH\',\'XACK\',\'XADD\',\'XCLAIM\',\'XDEL\',\'XGROUP\',\'XINFO\',\'XLEN\',\'XPENDING\',\'XRANGE\',\'XREAD\',\'XREADGROUP\',\'XREVRANGE\',\'XTRIM\',\'ZADD\',\'ZCARD\',\'ZCOUNT\',\'ZINCRBY\',\'ZINTERSTORE\',\'ZLEXCOUNT\',\'ZPOPMAX\',\'ZPOPMIN\',\'ZRANGE\',\'ZRANGEBYLEX\',\'ZRANGEBYSCORE\',\'ZRANK\',\'ZREM\',\'ZREMRANGEBYLEX\',\'ZREMRANGEBYRANK\',\'ZREMRANGEBYSCORE\',\'ZREVRANGE\',\'ZREVRANGEBYLEX\',\'ZREVRANGEBYSCORE\',\'ZREVRANK\',\'ZSCAN\',\'ZSCORE\',\'ZUNIONSTORE\']")
                                                    String... commandType)

Asynchronously returns an array reply of details about the requested commands.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; commandType - the commands to query for
Returns:: list<Object> array-reply

commandCount

@GloopParameter(name="redisCommandCountOutput")
public static Long commandCount(@GloopParameter(allowNull=false)
                                String connectionName,
                                GloopExecutionContext context)

Get total number of Redis commands.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: Long integer-reply of number of total commands in this Redis server.

commandCountAsync

@GloopParameter(name="redisFutureCommandCountOutput")
public static Future<Long> commandCountAsync(@GloopParameter(allowNull=false)
                                             String connectionName,
                                             GloopExecutionContext context)

Asynchronously get total number of redis commands.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: long integer-reply of number of total commands in this redis server.

configGet

@GloopObjectParameter("redisMap[]{\n  name:object\n  value:object\n}\n")
public static GloopModel configGet(@GloopParameter(allowNull=false)
                                   String connectionName,
                                   @GloopParameter(allowNull=false)
                                   String parameter,
                                   GloopExecutionContext context)

Get the value of a configuration parameter.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; parameter - name of the parameter
Returns:: Map<String, String> bulk-string-reply

configGetAsync

@GloopParameter(name="redisFutureConfigGetOutput")
public static Future<Map<String,String>> configGetAsync(@GloopParameter(allowNull=false)
                                                              String connectionName,
                                                              @GloopParameter(allowNull=false)
                                                              String parameter,
                                                              GloopExecutionContext context)

Asynchronously get the value of a configuration parameter.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; parameter - name of the parameter
Returns:: map<String, string> bulk-string-reply

configResetstat

@GloopParameter(name="redisConfigResetstatOutput")
public static String configResetstat(@GloopParameter(allowNull=false)
                                     String connectionName,
                                     GloopExecutionContext context)

Reset the stats returned by INFO.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply always OK.

configResetstatAsync

@GloopParameter(name="redisFutureConfigResetstatOutput")
public static Future<String> configResetstatAsync(@GloopParameter(allowNull=false)
                                                  String connectionName,
                                                  GloopExecutionContext context)

Asynchronously reset the stats returned by iNFO.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply always oK.

configRewrite

@GloopParameter(name="redisConfigRewriteOutput")
public static String configRewrite(@GloopParameter(allowNull=false)
                                   String connectionName,
                                   GloopExecutionContext context)

Rewrite the configuration file with the in memory configuration.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply OK when the configuration was rewritten properly. Otherwise an error is returned.

configRewriteAsync

@GloopParameter(name="redisFutureConfigRewriteOutput")
public static Future<String> configRewriteAsync(@GloopParameter(allowNull=false)
                                                String connectionName,
                                                GloopExecutionContext context)

Asynchronously rewrite the configuration file with the in memory configuration.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply oK when the configuration was rewritten properly. otherwise an error is returned.

configSet

@GloopParameter(name="redisConfigSetOutput")
public static String configSet(@GloopParameter(allowNull=false)
                               String connectionName,
                               @GloopParameter(allowNull=false)
                               String parameter,
                               @GloopParameter(allowNull=false)
                               String value,
                               GloopExecutionContext context)

Set a configuration parameter to the given value.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; parameter - the parameter name; value - the parameter value
Returns:: String simple-string-reply: OK when the configuration was set properly. Otherwise an error is returned.

configSetAsync

@GloopParameter(name="redisFutureConfigSetOutput")
public static Future<String> configSetAsync(@GloopParameter(allowNull=false)
                                            String connectionName,
                                            @GloopParameter(allowNull=false)
                                            String parameter,
                                            @GloopParameter(allowNull=false)
                                            String value,
                                            GloopExecutionContext context)

Asynchronously set a configuration parameter to the given value.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; parameter - the parameter name; value - the parameter value
Returns:: string simple-string-reply: oK when the configuration was set properly. otherwise an error is returned.

dbsize

@GloopParameter(name="redisDbsizeOutput")
public static Long dbsize(@GloopParameter(allowNull=false)
                          String connectionName,
                          GloopExecutionContext context)

Return the number of keys in the selected database.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: Long integer-reply

dbsizeAsync

@GloopParameter(name="redisFutureDbsizeOutput")
public static Future<Long> dbsizeAsync(@GloopParameter(allowNull=false)
                                       String connectionName,
                                       GloopExecutionContext context)

Asynchronously return the number of keys in the selected database.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: long integer-reply

debugCrashAndRecover

@GloopParameter(name="redisDebugCrashAndRecoverOutput")
public static String debugCrashAndRecover(@GloopParameter(allowNull=false)
                                          String connectionName,
                                          Long delay,
                                          GloopExecutionContext context)

Crash and recover

Parameters:: connectionName - The Martini Runtime Redis connection pool name; delay - optional delay in milliseconds
Returns:: String simple-string-reply

debugCrashAndRecoverAsync

@GloopParameter(name="redisFutureDebugCrashAndRecoverOutput")
public static Future<String> debugCrashAndRecoverAsync(@GloopParameter(allowNull=false)
                                                       String connectionName,
                                                       Long delay,
                                                       GloopExecutionContext context)

Asynchronously crash and recover

Parameters:: connectionName - The Martini Runtime Redis connection pool name; delay - optional delay in milliseconds
Returns:: string simple-string-reply

debugHtstats

@GloopParameter(name="redisDebugHtstatsOutput")
public static String debugHtstats(@GloopParameter(allowNull=false)
                                  String connectionName,
                                  @GloopParameter(allowNull=false)
                                  int db,
                                  GloopExecutionContext context)

Get debugging information about the internal hash-table state.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; db - the database number
Returns:: String simple-string-reply

debugHtstatsAsync

@GloopParameter(name="redisFutureDebugHtstatsOutput")
public static Future<String> debugHtstatsAsync(@GloopParameter(allowNull=false)
                                               String connectionName,
                                               @GloopParameter(allowNull=false)
                                               int db,
                                               GloopExecutionContext context)

Asynchronously get debugging information about the internal hash-table state.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; db - the database number
Returns:: string simple-string-reply

debugObject

@GloopParameter(name="redisDebugObjectOutput")
public static String debugObject(@GloopParameter(allowNull=false)
                                 String connectionName,
                                 @GloopParameter(allowNull=false)
                                 Object key,
                                 GloopExecutionContext context)

Get debugging information about a key.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; key - the key
Returns:: String simple-string-reply

debugObjectAsync

@GloopParameter(name="redisFutureDebugObjectOutput")
public static Future<String> debugObjectAsync(@GloopParameter(allowNull=false)
                                              String connectionName,
                                              @GloopParameter(allowNull=false)
                                              Object key,
                                              GloopExecutionContext context)

Asynchronously get debugging information about a key.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; key - the key
Returns:: string simple-string-reply

debugOom

public static void debugOom(@GloopParameter(allowNull=false)
                            String connectionName,
                            GloopExecutionContext context)

Make the server crash: Out of memory.

Parameters:: connectionName - The Martini Runtime Redis connection pool name

debugOomAsync

public static void debugOomAsync(@GloopParameter(allowNull=false)
                                 String connectionName,
                                 GloopExecutionContext context)

Asynchronously make the server crash: out of memory.

Parameters:: connectionName - The Martini Runtime Redis connection pool name

debugSegfault

public static void debugSegfault(@GloopParameter(allowNull=false)
                                 String connectionName,
                                 GloopExecutionContext context)

Make the server crash: Invalid pointer access.

Parameters:: connectionName - The Martini Runtime Redis connection pool name

debugSegfaultAsync

public static void debugSegfaultAsync(@GloopParameter(allowNull=false)
                                      String connectionName,
                                      GloopExecutionContext context)

Asynchronously make the server crash: invalid pointer access.

Parameters:: connectionName - The Martini Runtime Redis connection pool name

debugReload

@GloopParameter(name="redisDebugReloadOutput")
public static String debugReload(@GloopParameter(allowNull=false)
                                 String connectionName,
                                 GloopExecutionContext context)

Save RDB, clear the database and reload RDB.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply The commands returns OK on success.

debugReloadAsync

@GloopParameter(name="redisFutureDebugReloadOutput")
public static Future<String> debugReloadAsync(@GloopParameter(allowNull=false)
                                              String connectionName,
                                              GloopExecutionContext context)

Asynchronously save rDB, clear the database and reload rDB.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply the commands returns oK on success.

debugRestart

@GloopParameter(name="redisDebugRestartOutput")
public static String debugRestart(@GloopParameter(allowNull=false)
                                  String connectionName,
                                  Long delay,
                                  GloopExecutionContext context)

Restart the server gracefully.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; delay - optional delay in milliseconds
Returns:: String simple-string-reply

debugRestartAsync

@GloopParameter(name="redisFutureDebugRestartOutput")
public static Future<String> debugRestartAsync(@GloopParameter(allowNull=false)
                                               String connectionName,
                                               Long delay,
                                               GloopExecutionContext context)

Asynchronously restart the server gracefully.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; delay - optional delay in milliseconds
Returns:: string simple-string-reply

debugSdslen

@GloopParameter(name="redisDebugSdslenOutput")
public static String debugSdslen(@GloopParameter(allowNull=false)
                                 String connectionName,
                                 @GloopParameter(allowNull=false)
                                 Object key,
                                 GloopExecutionContext context)

Get debugging information about the internal SDS length.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; key - the key
Returns:: String simple-string-reply

debugSdslenAsync

@GloopParameter(name="redisFutureDebugSdslenOutput")
public static Future<String> debugSdslenAsync(@GloopParameter(allowNull=false)
                                              String connectionName,
                                              @GloopParameter(allowNull=false)
                                              Object key,
                                              GloopExecutionContext context)

Asynchronously get debugging information about the internal sDS length.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; key - the key
Returns:: string simple-string-reply

flushall

@GloopParameter(name="redisFlushallOutput")
public static String flushall(@GloopParameter(allowNull=false)
                              String connectionName,
                              GloopExecutionContext context)

Remove all keys from all databases.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply

flushallAsync

@GloopParameter(name="redisFutureFlushallOutput")
public static Future<String> flushallAsync(@GloopParameter(allowNull=false)
                                           String connectionName,
                                           GloopExecutionContext context)

Asynchronously remove all keys from all databases.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply

flushallAsyncAsync

@GloopParameter(name="redisFutureFlushallAsyncOutput")
public static Future<String> flushallAsyncAsync(@GloopParameter(allowNull=false)
                                                String connectionName,
                                                GloopExecutionContext context)

Asynchronously remove all keys asynchronously from all databases.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply

flushdb

@GloopParameter(name="redisFlushdbOutput")
public static String flushdb(@GloopParameter(allowNull=false)
                             String connectionName,
                             GloopExecutionContext context)

Remove all keys from the current database.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply

flushdbAsync

@GloopParameter(name="redisFutureFlushdbOutput")
public static Future<String> flushdbAsync(@GloopParameter(allowNull=false)
                                          String connectionName,
                                          GloopExecutionContext context)

Asynchronously remove all keys from the current database.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply

flushdbAsyncAsync

@GloopParameter(name="redisFutureFlushdbAsyncOutput")
public static Future<String> flushdbAsyncAsync(@GloopParameter(allowNull=false)
                                               String connectionName,
                                               GloopExecutionContext context)

Asynchronously remove all keys asynchronously from the current database.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply

info

@GloopParameter(name="redisInfoOutput")
public static String info(@GloopParameter(allowNull=false)
                          String connectionName,
                          GloopExecutionContext context)

Get information and statistics about the server.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String bulk-string-reply as a collection of text lines.

info

@GloopParameter(name="redisInfoOutput")
public static String info(@GloopParameter(allowNull=false)
                          String connectionName,
                          @GloopParameter(allowNull=false)
                          String section,
                          GloopExecutionContext context)

Get information and statistics about the server.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; section - the section type: string
Returns:: String bulk-string-reply as a collection of text lines.

infoAsync

@GloopParameter(name="redisFutureInfoOutput")
public static Future<String> infoAsync(@GloopParameter(allowNull=false)
                                       String connectionName,
                                       GloopExecutionContext context)

Asynchronously get information and statistics about the server.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string bulk-string-reply as a collection of text lines.

infoAsync

@GloopParameter(name="redisFutureInfoOutput")
public static Future<String> infoAsync(@GloopParameter(allowNull=false)
                                       String connectionName,
                                       @GloopParameter(allowNull=false)
                                       String section,
                                       GloopExecutionContext context)

Asynchronously get information and statistics about the server.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; section - the section type: string
Returns:: string bulk-string-reply as a collection of text lines.

lastsave

@GloopParameter(name="redisLastsaveOutput")
public static Date lastsave(@GloopParameter(allowNull=false)
                            String connectionName,
                            GloopExecutionContext context)

Get the UNIX time stamp of the last successful save to disk.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: Date integer-reply an UNIX time stamp.

lastsaveAsync

@GloopParameter(name="redisFutureLastsaveOutput")
public static Future<Date> lastsaveAsync(@GloopParameter(allowNull=false)
                                         String connectionName,
                                         GloopExecutionContext context)

Asynchronously get the uNIX time stamp of the last successful save to disk.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: date integer-reply an uNIX time stamp.

save

@GloopParameter(name="redisSaveOutput")
public static String save(@GloopParameter(allowNull=false)
                          String connectionName,
                          GloopExecutionContext context)

Synchronously save the dataset to disk.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply The commands returns OK on success.

saveAsync

@GloopParameter(name="redisFutureSaveOutput")
public static Future<String> saveAsync(@GloopParameter(allowNull=false)
                                       String connectionName,
                                       GloopExecutionContext context)

Asynchronously synchronously save the dataset to disk.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply the commands returns oK on success.

shutdown

public static void shutdown(@GloopParameter(allowNull=false)
                            String connectionName,
                            @GloopParameter(allowNull=false)
                            boolean save,
                            GloopExecutionContext context)

Synchronously save the dataset to disk and then shut down the server.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; save -

shutdownAsync

public static void shutdownAsync(@GloopParameter(allowNull=false)
                                 String connectionName,
                                 @GloopParameter(allowNull=false)
                                 boolean save,
                                 GloopExecutionContext context)

Asynchronously synchronously save the dataset to disk and then shut down the server.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; save -

slaveof

@GloopParameter(name="redisSlaveofOutput")
public static String slaveof(@GloopParameter(allowNull=false)
                             String connectionName,
                             @GloopParameter(allowNull=false)
                             String host,
                             @GloopParameter(allowNull=false)
                             int port,
                             GloopExecutionContext context)

Make the server a slave of another instance, or promote it as master.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; host - the host type: string; port - the port type: string
Returns:: String simple-string-reply

slaveofAsync

@GloopParameter(name="redisFutureSlaveofOutput")
public static Future<String> slaveofAsync(@GloopParameter(allowNull=false)
                                          String connectionName,
                                          @GloopParameter(allowNull=false)
                                          String host,
                                          @GloopParameter(allowNull=false)
                                          int port,
                                          GloopExecutionContext context)

Asynchronously make the server a slave of another instance, or promote it as master.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; host - the host type: string; port - the port type: string
Returns:: string simple-string-reply

slaveofNoOne

@GloopParameter(name="redisSlaveofNoOneOutput")
public static String slaveofNoOne(@GloopParameter(allowNull=false)
                                  String connectionName,
                                  GloopExecutionContext context)

Promote server as master.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply

slaveofNoOneAsync

@GloopParameter(name="redisFutureSlaveofNoOneOutput")
public static Future<String> slaveofNoOneAsync(@GloopParameter(allowNull=false)
                                               String connectionName,
                                               GloopExecutionContext context)

Asynchronously promote server as master.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply

slowlogGet

@GloopParameter(name="redisSlowlogGetOutput")
public static List<Object> slowlogGet(@GloopParameter(allowNull=false)
                                      String connectionName,
                                      GloopExecutionContext context)

Read the slow log.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: List<Object> deeply nested multi bulk replies

slowlogGet

@GloopParameter(name="redisSlowlogGetOutput")
public static List<Object> slowlogGet(@GloopParameter(allowNull=false)
                                      String connectionName,
                                      @GloopParameter(allowNull=false)
                                      int count,
                                      GloopExecutionContext context)

Read the slow log.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; count - the count
Returns:: List<Object> deeply nested multi bulk replies

slowlogGetAsync

@GloopParameter(name="redisFutureSlowlogGetOutput")
public static Future<List<Object>> slowlogGetAsync(@GloopParameter(allowNull=false)
                                                   String connectionName,
                                                   GloopExecutionContext context)

Asynchronously read the slow log.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: list<Object> deeply nested multi bulk replies

slowlogGetAsync

@GloopParameter(name="redisFutureSlowlogGetOutput")
public static Future<List<Object>> slowlogGetAsync(@GloopParameter(allowNull=false)
                                                   String connectionName,
                                                   @GloopParameter(allowNull=false)
                                                   int count,
                                                   GloopExecutionContext context)

Asynchronously read the slow log.

Parameters:: connectionName - The Martini Runtime Redis connection pool name; count - the count
Returns:: list<Object> deeply nested multi bulk replies

slowlogLen

@GloopParameter(name="redisSlowlogLenOutput")
public static Long slowlogLen(@GloopParameter(allowNull=false)
                              String connectionName,
                              GloopExecutionContext context)

Obtaining the current length of the slow log.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: Long length of the slow log.

slowlogLenAsync

@GloopParameter(name="redisFutureSlowlogLenOutput")
public static Future<Long> slowlogLenAsync(@GloopParameter(allowNull=false)
                                           String connectionName,
                                           GloopExecutionContext context)

Asynchronously obtaining the current length of the slow log.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: long length of the slow log.

slowlogReset

@GloopParameter(name="redisSlowlogResetOutput")
public static String slowlogReset(@GloopParameter(allowNull=false)
                                  String connectionName,
                                  GloopExecutionContext context)

Resetting the slow log.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: String simple-string-reply The commands returns OK on success.

slowlogResetAsync

@GloopParameter(name="redisFutureSlowlogResetOutput")
public static Future<String> slowlogResetAsync(@GloopParameter(allowNull=false)
                                               String connectionName,
                                               GloopExecutionContext context)

Asynchronously resetting the slow log.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: string simple-string-reply the commands returns oK on success.

time

@GloopParameter(name="redisTimeOutput")
public static List<Object> time(@GloopParameter(allowNull=false)
                                String connectionName,
                                GloopExecutionContext context)

Return the current server time.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: List<V> array-reply specifically: A multi bulk reply containing two elements: unix time in seconds. microseconds.

timeAsync

@GloopParameter(name="redisFutureTimeOutput")
public static Future<List<Object>> timeAsync(@GloopParameter(allowNull=false)
                                             String connectionName,
                                             GloopExecutionContext context)

Asynchronously return the current server time.

Parameters:: connectionName - The Martini Runtime Redis connection pool name
Returns:: list<V> array-reply specifically: a multi bulk reply containing two elements: unix time in seconds. microseconds.

Class RedisServerMethods

Constructor Summary

Method Summary

Methods inherited from class io.toro.martini.redis.RedisBaseMethods

Methods inherited from class java.lang.Object

Constructor Detail

RedisServerMethods

Method Detail

bgrewriteaof

bgrewriteaofAsync

bgsave

bgsaveAsync

clientGetname

clientGetnameAsync

clientSetname

clientSetnameAsync

clientKill

clientKill

clientKillAsync

clientKillAsync

clientUnblock

clientUnblockAsync

clientPause

clientPauseAsync

clientList

clientListAsync

command

commandAsync

commandInfo

commandInfo

commandInfoAsync

commandInfoAsync

commandCount

commandCountAsync

configGet

configGetAsync

configResetstat

configResetstatAsync

configRewrite

configRewriteAsync

configSet

configSetAsync

dbsize

dbsizeAsync

debugCrashAndRecover

debugCrashAndRecoverAsync

debugHtstats

debugHtstatsAsync

debugObject

debugObjectAsync

debugOom

debugOomAsync

debugSegfault

debugSegfaultAsync

debugReload

debugReloadAsync

debugRestart

debugRestartAsync

debugSdslen

debugSdslenAsync

flushall

flushallAsync

flushallAsyncAsync

flushdb

flushdbAsync

flushdbAsyncAsync

info

info

infoAsync

infoAsync

lastsave

lastsaveAsync

save

saveAsync

shutdown

shutdownAsync

slaveof

slaveofAsync

slaveofNoOne

slaveofNoOneAsync