public class RedisKeyMethods
extends io.toro.martini.redis.RedisBaseMethods
Modifier and Type | Field and Description |
---|---|
static String |
MIGRATE_ARGS_GLOOP_DOC |
static String |
SORT_ARGS_GLOOP_DOC |
Constructor and Description |
---|
RedisKeyMethods(DataSourceManager dataSourceManager) |
Modifier and Type | Method and Description |
---|---|
static Long |
del(String connectionName,
GloopExecutionContext context,
Object... keys)
Delete one or more keys.
|
static Future<Long> |
delAsync(String connectionName,
GloopExecutionContext context,
Object... keys)
Asynchronously delete one or more keys.
|
static byte[] |
dump(String connectionName,
GloopExecutionContext context,
Object key)
Return a serialized version of the value stored at the specified key.
|
static Future<byte[]> |
dumpAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously return a serialized version of the value stored at the specified key.
|
static Long |
exists(String connectionName,
GloopExecutionContext context,
Object... keys)
Determine how many keys exist.
|
static Future<Long> |
existsAsync(String connectionName,
GloopExecutionContext context,
Object... keys)
Asynchronously determine how many keys exist.
|
static Boolean |
expire(String connectionName,
Object key,
long seconds,
GloopExecutionContext context)
Set a key's time to live in seconds.
|
static Future<Boolean> |
expireAsync(String connectionName,
Object key,
long seconds,
GloopExecutionContext context)
Asynchronously set a key's time to live in seconds.
|
static Boolean |
expireat(String connectionName,
Object key,
Date timestamp,
GloopExecutionContext context)
Set the expiration for a key as a UNIX timestamp.
|
static Boolean |
expireat(String connectionName,
Object key,
long timestamp,
GloopExecutionContext context)
Set the expiration for a key as a UNIX timestamp.
|
static Future<Boolean> |
expireatAsync(String connectionName,
Object key,
Date timestamp,
GloopExecutionContext context)
Asynchronously set the expiration for a key as a uNIX timestamp.
|
static Future<Boolean> |
expireatAsync(String connectionName,
Object key,
long timestamp,
GloopExecutionContext context)
Asynchronously set the expiration for a key as a uNIX timestamp.
|
static Long |
keys(String connectionName,
KeyStreamingChannel<Object> channel,
Object pattern,
GloopExecutionContext context)
Find all keys matching the given pattern.
|
static List<Object> |
keys(String connectionName,
Object pattern,
GloopExecutionContext context)
Find all keys matching the given pattern.
|
static Future<Long> |
keysAsync(String connectionName,
KeyStreamingChannel<Object> channel,
Object pattern,
GloopExecutionContext context)
Asynchronously find all keys matching the given pattern.
|
static Future<List<Object>> |
keysAsync(String connectionName,
Object pattern,
GloopExecutionContext context)
Asynchronously find all keys matching the given pattern.
|
static String |
migrate(String connectionName,
String host,
int port,
int db,
long timeout,
GloopModel migrateArgs,
GloopExecutionContext context)
Atomically transfer one or more keys from a Redis instance to another one.
|
static String |
migrate(String connectionName,
String host,
int port,
Object key,
int db,
long timeout,
GloopExecutionContext context)
Atomically transfer a key from a Redis instance to another one.
|
static Future<String> |
migrateAsync(String connectionName,
String host,
int port,
int db,
long timeout,
GloopModel migrateArgs,
GloopExecutionContext context)
Asynchronously atomically transfer one or more keys from a redis instance to another one.
|
static Future<String> |
migrateAsync(String connectionName,
String host,
int port,
Object key,
int db,
long timeout,
GloopExecutionContext context)
Asynchronously atomically transfer a key from a redis instance to another one.
|
static Boolean |
move(String connectionName,
Object key,
int db,
GloopExecutionContext context)
Move a key to another database.
|
static Future<Boolean> |
moveAsync(String connectionName,
Object key,
int db,
GloopExecutionContext context)
Asynchronously move a key to another database.
|
static String |
objectEncoding(String connectionName,
Object key,
GloopExecutionContext context)
returns the kind of internal representation used in order to store the value associated with a key.
|
static Future<String> |
objectEncodingAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously returns the kind of internal representation used in order to store the value associated with a
key.
|
static Long |
objectIdletime(String connectionName,
Object key,
GloopExecutionContext context)
returns the number of seconds since the object stored at the specified key is idle (not requested by read or
write operations).
|
static Future<Long> |
objectIdletimeAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously returns the number of seconds since the object stored at the specified key is idle (not requested
by read or write operations).
|
static Long |
objectRefcount(String connectionName,
Object key,
GloopExecutionContext context)
returns the number of references of the value associated with the specified key.
|
static Future<Long> |
objectRefcountAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously returns the number of references of the value associated with the specified key.
|
static Boolean |
persist(String connectionName,
Object key,
GloopExecutionContext context)
Remove the expiration from a key.
|
static Future<Boolean> |
persistAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously remove the expiration from a key.
|
static Boolean |
pexpire(String connectionName,
Object key,
long milliseconds,
GloopExecutionContext context)
Set a key's time to live in milliseconds.
|
static Future<Boolean> |
pexpireAsync(String connectionName,
Object key,
long milliseconds,
GloopExecutionContext context)
Asynchronously set a key's time to live in milliseconds.
|
static Boolean |
pexpireat(String connectionName,
Object key,
Date timestamp,
GloopExecutionContext context)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
static Boolean |
pexpireat(String connectionName,
Object key,
long timestamp,
GloopExecutionContext context)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
static Future<Boolean> |
pexpireatAsync(String connectionName,
Object key,
Date timestamp,
GloopExecutionContext context)
Asynchronously set the expiration for a key as a uNIX timestamp specified in milliseconds.
|
static Future<Boolean> |
pexpireatAsync(String connectionName,
Object key,
long timestamp,
GloopExecutionContext context)
Asynchronously set the expiration for a key as a uNIX timestamp specified in milliseconds.
|
static Long |
pttl(String connectionName,
Object key,
GloopExecutionContext context)
Get the time to live for a key in milliseconds.
|
static Future<Long> |
pttlAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously get the time to live for a key in milliseconds.
|
static Object |
randomkey(String connectionName,
GloopExecutionContext context)
Return a random key from the keyspace.
|
static Future<Object> |
randomkeyAsync(String connectionName,
GloopExecutionContext context)
Asynchronously return a random key from the keyspace.
|
static String |
rename(String connectionName,
Object key,
Object newKey,
GloopExecutionContext context)
Rename a key.
|
static Future<String> |
renameAsync(String connectionName,
Object key,
Object newKey,
GloopExecutionContext context)
Asynchronously rename a key.
|
static Boolean |
renamenx(String connectionName,
Object key,
Object newKey,
GloopExecutionContext context)
Rename a key, only if the new key does not exist.
|
static Future<Boolean> |
renamenxAsync(String connectionName,
Object key,
Object newKey,
GloopExecutionContext context)
Asynchronously rename a key, only if the new key does not exist.
|
static String |
restore(String connectionName,
Object key,
long ttl,
byte[] value,
GloopExecutionContext context)
Create a key using the provided serialized value, previously obtained using DUMP.
|
static Future<String> |
restoreAsync(String connectionName,
Object key,
long ttl,
byte[] value,
GloopExecutionContext context)
Asynchronously create a key using the provided serialized value, previously obtained using dUMP.
|
static KeyScanCursor<Object> |
scan(String connectionName,
GloopExecutionContext context)
Incrementally iterate the keys space.
|
static KeyScanCursor<Object> |
scan(String connectionName,
GloopModel scanArgs,
GloopExecutionContext context)
Incrementally iterate the keys space.
|
static StreamScanCursor |
scan(String connectionName,
KeyStreamingChannel<Object> channel,
GloopExecutionContext context)
Incrementally iterate the keys space.
|
static StreamScanCursor |
scan(String connectionName,
KeyStreamingChannel<Object> channel,
GloopModel scanArgs,
GloopExecutionContext context)
Incrementally iterate the keys space.
|
static StreamScanCursor |
scan(String connectionName,
KeyStreamingChannel<Object> channel,
ScanCursor scanCursor,
GloopExecutionContext context)
Incrementally iterate the keys space.
|
static StreamScanCursor |
scan(String connectionName,
KeyStreamingChannel<Object> channel,
ScanCursor scanCursor,
GloopModel scanArgs,
GloopExecutionContext context)
Incrementally iterate the keys space.
|
static KeyScanCursor<Object> |
scan(String connectionName,
ScanCursor scanCursor,
GloopExecutionContext context)
Incrementally iterate the keys space.
|
static KeyScanCursor<Object> |
scan(String connectionName,
ScanCursor scanCursor,
GloopModel scanArgs,
GloopExecutionContext context)
Incrementally iterate the keys space.
|
static Future<KeyScanCursor<Object>> |
scanAsync(String connectionName,
GloopExecutionContext context)
Asynchronously incrementally iterate the keys space.
|
static Future<KeyScanCursor<Object>> |
scanAsync(String connectionName,
GloopModel scanArgs,
GloopExecutionContext context)
Asynchronously incrementally iterate the keys space.
|
static Future<StreamScanCursor> |
scanAsync(String connectionName,
KeyStreamingChannel<Object> channel,
GloopExecutionContext context)
Asynchronously incrementally iterate the keys space.
|
static Future<StreamScanCursor> |
scanAsync(String connectionName,
KeyStreamingChannel<Object> channel,
GloopModel scanArgs,
GloopExecutionContext context)
Asynchronously incrementally iterate the keys space.
|
static Future<StreamScanCursor> |
scanAsync(String connectionName,
KeyStreamingChannel<Object> channel,
ScanCursor scanCursor,
GloopExecutionContext context)
Asynchronously incrementally iterate the keys space.
|
static Future<StreamScanCursor> |
scanAsync(String connectionName,
KeyStreamingChannel<Object> channel,
ScanCursor scanCursor,
GloopModel scanArgs,
GloopExecutionContext context)
Asynchronously incrementally iterate the keys space.
|
static Future<KeyScanCursor<Object>> |
scanAsync(String connectionName,
ScanCursor scanCursor,
GloopExecutionContext context)
Asynchronously incrementally iterate the keys space.
|
static Future<KeyScanCursor<Object>> |
scanAsync(String connectionName,
ScanCursor scanCursor,
GloopModel scanArgs,
GloopExecutionContext context)
Asynchronously incrementally iterate the keys space.
|
static List<Object> |
sort(String connectionName,
Object key,
GloopExecutionContext context)
Sort the elements in a list, set or sorted set.
|
static List<Object> |
sort(String connectionName,
Object key,
GloopModel sortArgs,
GloopExecutionContext context)
Sort the elements in a list, set or sorted set.
|
static Long |
sort(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
GloopExecutionContext context)
Sort the elements in a list, set or sorted set.
|
static Long |
sort(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
GloopModel sortArgs,
GloopExecutionContext context)
Sort the elements in a list, set or sorted set.
|
static Future<List<Object>> |
sortAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously sort the elements in a list, set or sorted set.
|
static Future<List<Object>> |
sortAsync(String connectionName,
Object key,
GloopModel sortArgs,
GloopExecutionContext context)
Asynchronously sort the elements in a list, set or sorted set.
|
static Future<Long> |
sortAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
GloopExecutionContext context)
Asynchronously sort the elements in a list, set or sorted set.
|
static Future<Long> |
sortAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
GloopModel sortArgs,
GloopExecutionContext context)
Asynchronously sort the elements in a list, set or sorted set.
|
static Long |
sortStore(String connectionName,
Object key,
GloopModel sortArgs,
Object destination,
GloopExecutionContext context)
Sort the elements in a list, set or sorted set.
|
static Future<Long> |
sortStoreAsync(String connectionName,
Object key,
GloopModel sortArgs,
Object destination,
GloopExecutionContext context)
Asynchronously sort the elements in a list, set or sorted set.
|
static Long |
touch(String connectionName,
GloopExecutionContext context,
Object... keys)
Touch one or more keys.
|
static Future<Long> |
touchAsync(String connectionName,
GloopExecutionContext context,
Object... keys)
Asynchronously touch one or more keys.
|
static Long |
ttl(String connectionName,
Object key,
GloopExecutionContext context)
Get the time to live for a key.
|
static Future<Long> |
ttlAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously get the time to live for a key.
|
static String |
type(String connectionName,
Object key,
GloopExecutionContext context)
Determine the type stored at key.
|
static Future<String> |
typeAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously determine the type stored at key.
|
static Long |
unlink(String connectionName,
GloopExecutionContext context,
Object... keys)
Unlink one or more keys (non blocking DEL).
|
static Future<Long> |
unlinkAsync(String connectionName,
GloopExecutionContext context,
Object... keys)
Asynchronously unlink one or more keys (non blocking dEL).
|
public static final String MIGRATE_ARGS_GLOOP_DOC
public static final String SORT_ARGS_GLOOP_DOC
@Autowired RedisKeyMethods(DataSourceManager dataSourceManager)
@GloopParameter(name="redisDelOutput") public static Long del(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keys@GloopParameter(name="redisFutureDelOutput") public static Future<Long> delAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keys@GloopParameter(name="redisUnlinkOutput") public static Long unlink(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keys@GloopParameter(name="redisFutureUnlinkOutput") public static Future<Long> unlinkAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keys@GloopParameter(name="redisDumpOutput") public static byte[] dump(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object key)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureDumpOutput") public static Future<byte[]> dumpAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisExistsOutput") public static Long exists(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keys@GloopParameter(name="redisFutureExistsOutput") public static Future<Long> existsAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keys@GloopParameter(name="redisExpireOutput") public static Boolean expire(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long seconds, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyseconds
- the seconds type: longkey
does not exist or the timeout could not be set.@GloopParameter(name="redisFutureExpireOutput") public static Future<Boolean> expireAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long seconds, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyseconds
- the seconds type: longkey
does not exist or the timeout could not be set.@GloopParameter(name="redisExpireatOutput") public static Boolean expireat(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Date timestamp, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keytimestamp
- the timestamp type: posix timekey
does not exist or the timeout could not be set (see: EXPIRE
).@GloopParameter(name="redisExpireatOutput") public static Boolean expireat(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long timestamp, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keytimestamp
- the timestamp type: posix timekey
does not exist or the timeout could not be set (see: EXPIRE
).@GloopParameter(name="redisFutureExpireatOutput") public static Future<Boolean> expireatAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Date timestamp, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keytimestamp
- the timestamp type: posix timekey
does not exist or the timeout could not be set (see: eXPIRE
).@GloopParameter(name="redisFutureExpireatOutput") public static Future<Boolean> expireatAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long timestamp, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keytimestamp
- the timestamp type: posix timekey
does not exist or the timeout could not be set (see: eXPIRE
).@GloopParameter(name="redisKeysOutput") public static List<Object> keys(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object pattern, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namepattern
- the pattern type: patternkey (pattern)pattern
.@GloopParameter(name="redisKeysOutput") public static Long keys(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object pattern, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelpattern
- the patternpattern
.@GloopParameter(name="redisFutureKeysOutput") public static Future<List<Object>> keysAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object pattern, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namepattern
- the pattern type: patternkey (pattern)pattern
.@GloopParameter(name="redisFutureKeysOutput") public static Future<Long> keysAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object pattern, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelpattern
- the patternpattern
.@GloopParameter(name="redisMigrateOutput") public static String migrate(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) String host, @GloopParameter(allowNull=false) int port, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) int db, @GloopParameter(allowNull=false) long timeout, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namehost
- the hostport
- the portkey
- the keydb
- the databasetimeout
- the timeout in milliseconds@GloopParameter(name="redisMigrateOutput") public static String migrate(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) String host, @GloopParameter(allowNull=false) int port, @GloopParameter(allowNull=false) int db, @GloopParameter(allowNull=false) long timeout, @GloopObjectParameter(value="migrateArgs{\n copy:boolean:Do not remove the key from the local instance by setting {@code COPY}\n replace:boolean:Replace existing key on the remote instance by setting {@code REPLACE}\n keys[]:object:Migrate one or more {@code keys}:false\n password::Creates new {@link MigrateArgs} with {@code AUTH} (target authentication) enabled:false\n}") GloopModel migrateArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namehost
- the hostport
- the portdb
- the databasetimeout
- the timeout in millisecondsmigrateArgs
- migrate args that allow to configure further options@GloopParameter(name="redisFutureMigrateOutput") public static Future<String> migrateAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) String host, @GloopParameter(allowNull=false) int port, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) int db, @GloopParameter(allowNull=false) long timeout, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namehost
- the hostport
- the portkey
- the keydb
- the databasetimeout
- the timeout in milliseconds@GloopParameter(name="redisFutureMigrateOutput") public static Future<String> migrateAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) String host, @GloopParameter(allowNull=false) int port, @GloopParameter(allowNull=false) int db, @GloopParameter(allowNull=false) long timeout, @GloopObjectParameter(value="migrateArgs{\n copy:boolean:Do not remove the key from the local instance by setting {@code COPY}\n replace:boolean:Replace existing key on the remote instance by setting {@code REPLACE}\n keys[]:object:Migrate one or more {@code keys}:false\n password::Creates new {@link MigrateArgs} with {@code AUTH} (target authentication) enabled:false\n}") GloopModel migrateArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namehost
- the hostport
- the portdb
- the databasetimeout
- the timeout in millisecondsmigrateArgs
- migrate args that allow to configure further options@GloopParameter(name="redisMoveOutput") public static Boolean move(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) int db, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keydb
- the db type: long@GloopParameter(name="redisFutureMoveOutput") public static Future<Boolean> moveAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) int db, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keydb
- the db type: long@GloopParameter(name="redisObjectEncodingOutput") public static String objectEncoding(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureObjectEncodingOutput") public static Future<String> objectEncodingAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisObjectIdletimeOutput") public static Long objectIdletime(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureObjectIdletimeOutput") public static Future<Long> objectIdletimeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisObjectRefcountOutput") public static Long objectRefcount(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureObjectRefcountOutput") public static Future<Long> objectRefcountAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisPersistOutput") public static Boolean persist(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist or does not have an associated timeout.@GloopParameter(name="redisFuturePersistOutput") public static Future<Boolean> persistAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist or does not have an associated timeout.@GloopParameter(name="redisPexpireOutput") public static Boolean pexpire(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long milliseconds, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymilliseconds
- the milliseconds type: longkey
does not exist or the timeout could not be set.@GloopParameter(name="redisFuturePexpireOutput") public static Future<Boolean> pexpireAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long milliseconds, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymilliseconds
- the milliseconds type: longkey
does not exist or the timeout could not be set.@GloopParameter(name="redisPexpireatOutput") public static Boolean pexpireat(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Date timestamp, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keytimestamp
- the milliseconds-timestamp type: posix timekey
does not exist or the timeout could not be set (see: EXPIRE
).@GloopParameter(name="redisPexpireatOutput") public static Boolean pexpireat(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long timestamp, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keytimestamp
- the milliseconds-timestamp type: posix timekey
does not exist or the timeout could not be set (see: EXPIRE
).@GloopParameter(name="redisFuturePexpireatOutput") public static Future<Boolean> pexpireatAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Date timestamp, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keytimestamp
- the milliseconds-timestamp type: posix timekey
does not exist or the timeout could not be set (see: eXPIRE
).@GloopParameter(name="redisFuturePexpireatOutput") public static Future<Boolean> pexpireatAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long timestamp, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keytimestamp
- the milliseconds-timestamp type: posix timekey
does not exist or the timeout could not be set (see: eXPIRE
).@GloopParameter(name="redisPttlOutput") public static Long pttl(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFuturePttlOutput") public static Future<Long> pttlAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisRandomkeyOutput") public static Object randomkey(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool name@GloopParameter(name="redisFutureRandomkeyOutput") public static Future<Object> randomkeyAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool name@GloopParameter(name="redisRenameOutput") public static String rename(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object newKey, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keynewKey
- the newkey type: key@GloopParameter(name="redisFutureRenameOutput") public static Future<String> renameAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object newKey, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keynewKey
- the newkey type: key@GloopParameter(name="redisRenamenxOutput") public static Boolean renamenx(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object newKey, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keynewKey
- the newkey type: keykey
was renamed to newkey
. false if newkey
already exists.@GloopParameter(name="redisFutureRenamenxOutput") public static Future<Boolean> renamenxAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object newKey, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keynewKey
- the newkey type: keykey
was renamed to newkey
. false if newkey
already exists.@GloopParameter(name="redisRestoreOutput") public static String restore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long ttl, @GloopParameter(allowNull=false) byte[] value, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyttl
- the ttl type: longvalue
- the serialized-value type: string@GloopParameter(name="redisFutureRestoreOutput") public static Future<String> restoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long ttl, @GloopParameter(allowNull=false) byte[] value, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyttl
- the ttl type: longvalue
- the serialized-value type: string@GloopParameter(name="redisSortOutput") public static List<Object> sort(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisSortOutput") public static Long sort(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the key@GloopParameter(name="redisSortOutput") public static List<Object> sort(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="sortArgs{\n by::Sort keys by an external list. Key names are obtained substituting the first occurrence of {@code *} with the actual value of the element in the list.\n limit:Limit the number of returned elements{\n offset:long\n count:long\n }\n get[]::Retrieve external keys during sort. {@literal GET} supports {@code #} and {@code *} wildcards\n asc:boolean:Apply numeric sort in ascending order\n alpha:boolean:Apply lexicographically sort\n}") GloopModel sortArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keysortArgs
- sort arguments@GloopParameter(name="redisSortOutput") public static Long sort(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="sortArgs{\n by::Sort keys by an external list. Key names are obtained substituting the first occurrence of {@code *} with the actual value of the element in the list.\n limit:Limit the number of returned elements{\n offset:long\n count:long\n }\n get[]::Retrieve external keys during sort. {@literal GET} supports {@code #} and {@code *} wildcards\n asc:boolean:Apply numeric sort in ascending order\n alpha:boolean:Apply lexicographically sort\n}") GloopModel sortArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keysortArgs
- sort arguments@GloopParameter(name="redisFutureSortOutput") public static Future<List<Object>> sortAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureSortOutput") public static Future<Long> sortAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the key@GloopParameter(name="redisFutureSortOutput") public static Future<List<Object>> sortAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="sortArgs{\n by::Sort keys by an external list. Key names are obtained substituting the first occurrence of {@code *} with the actual value of the element in the list.\n limit:Limit the number of returned elements{\n offset:long\n count:long\n }\n get[]::Retrieve external keys during sort. {@literal GET} supports {@code #} and {@code *} wildcards\n asc:boolean:Apply numeric sort in ascending order\n alpha:boolean:Apply lexicographically sort\n}") GloopModel sortArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keysortArgs
- sort arguments@GloopParameter(name="redisFutureSortOutput") public static Future<Long> sortAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="sortArgs{\n by::Sort keys by an external list. Key names are obtained substituting the first occurrence of {@code *} with the actual value of the element in the list.\n limit:Limit the number of returned elements{\n offset:long\n count:long\n }\n get[]::Retrieve external keys during sort. {@literal GET} supports {@code #} and {@code *} wildcards\n asc:boolean:Apply numeric sort in ascending order\n alpha:boolean:Apply lexicographically sort\n}") GloopModel sortArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keysortArgs
- sort arguments@GloopParameter(name="redisSortStoreOutput") public static Long sortStore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="sortArgs{\n by::Sort keys by an external list. Key names are obtained substituting the first occurrence of {@code *} with the actual value of the element in the list.\n limit:Limit the number of returned elements{\n offset:long\n count:long\n }\n get[]::Retrieve external keys during sort. {@literal GET} supports {@code #} and {@code *} wildcards\n asc:boolean:Apply numeric sort in ascending order\n alpha:boolean:Apply lexicographically sort\n}") GloopModel sortArgs, @GloopParameter(allowNull=false) Object destination, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keysortArgs
- sort argumentsdestination
- the destination key to store sort results@GloopParameter(name="redisFutureSortStoreOutput") public static Future<Long> sortStoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="sortArgs{\n by::Sort keys by an external list. Key names are obtained substituting the first occurrence of {@code *} with the actual value of the element in the list.\n limit:Limit the number of returned elements{\n offset:long\n count:long\n }\n get[]::Retrieve external keys during sort. {@literal GET} supports {@code #} and {@code *} wildcards\n asc:boolean:Apply numeric sort in ascending order\n alpha:boolean:Apply lexicographically sort\n}") GloopModel sortArgs, @GloopParameter(allowNull=false) Object destination, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keysortArgs
- sort argumentsdestination
- the destination key to store sort results@GloopParameter(name="redisTouchOutput") public static Long touch(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keys@GloopParameter(name="redisFutureTouchOutput") public static Future<Long> touchAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keys@GloopParameter(name="redisTtlOutput") public static Long ttl(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureTtlOutput") public static Future<Long> ttlAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisTypeOutput") public static String type(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
, or none
when key
does not exist.@GloopParameter(name="redisFutureTypeOutput") public static Future<String> typeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
, or none
when key
does not exist.@GloopParameter(name="redisScanOutput") public static KeyScanCursor<Object> scan(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool name@GloopParameter(name="redisScanOutput") public static KeyScanCursor<Object> scan(@GloopParameter(allowNull=false) String connectionName, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") GloopModel scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namescanArgs
- scan arguments@GloopParameter(name="redisScanOutput") public static KeyScanCursor<Object> scan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScanCursor scanCursor, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") GloopModel scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namescanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisScanOutput") public static StreamScanCursor scan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key@GloopParameter(name="redisScanOutput") public static StreamScanCursor scan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") GloopModel scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every keyscanArgs
- scan arguments@GloopParameter(name="redisScanOutput") public static StreamScanCursor scan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, @GloopParameter(allowNull=false) ScanCursor scanCursor, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") GloopModel scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisScanOutput") public static StreamScanCursor scan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, @GloopParameter(allowNull=false) ScanCursor scanCursor, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisScanOutput") public static KeyScanCursor<Object> scan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScanCursor scanCursor, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namescanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisFutureScanOutput") public static Future<KeyScanCursor<Object>> scanAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool name@GloopParameter(name="redisFutureScanOutput") public static Future<KeyScanCursor<Object>> scanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") GloopModel scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namescanArgs
- scan arguments@GloopParameter(name="redisFutureScanOutput") public static Future<KeyScanCursor<Object>> scanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScanCursor scanCursor, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") GloopModel scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namescanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisFutureScanOutput") public static Future<KeyScanCursor<Object>> scanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScanCursor scanCursor, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namescanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisFutureScanOutput") public static Future<StreamScanCursor> scanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key@GloopParameter(name="redisFutureScanOutput") public static Future<StreamScanCursor> scanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") GloopModel scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every keyscanArgs
- scan arguments@GloopParameter(name="redisFutureScanOutput") public static Future<StreamScanCursor> scanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, @GloopParameter(allowNull=false) ScanCursor scanCursor, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") GloopModel scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisFutureScanOutput") public static Future<StreamScanCursor> scanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) KeyStreamingChannel<Object> channel, @GloopParameter(allowNull=false) ScanCursor scanCursor, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume from a previous scan, must not be nullCopyright © 2023. All rights reserved.