public class RedisHashMethods
extends io.toro.martini.redis.RedisBaseMethods
Constructor and Description |
---|
RedisHashMethods(io.toro.martini.database.DataSourceManager dataSourceManager) |
Modifier and Type | Method and Description |
---|---|
static Long |
hdel(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... fields)
Delete one or more hash fields.
|
static Future<Long> |
hdelAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... fields)
Asynchronously delete one or more hash fields.
|
static Boolean |
hexists(String connectionName,
Object key,
Object field,
io.toro.gloop.engine.GloopExecutionContext context)
Determine if a hash field exists.
|
static Future<Boolean> |
hexistsAsync(String connectionName,
Object key,
Object field,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously determine if a hash field exists.
|
static Object |
hget(String connectionName,
Object key,
Object field,
io.toro.gloop.engine.GloopExecutionContext context)
Get the value of a hash field.
|
static Long |
hgetall(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Stream over all the fields and values in a hash.
|
static io.toro.gloop.object.property.GloopModel |
hgetall(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Get all the fields and values in a hash.
|
static Future<Long> |
hgetallAsync(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously stream over all the fields and values in a hash.
|
static Future<Map<Object,Object>> |
hgetallAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get all the fields and values in a hash.
|
static Future<Object> |
hgetAsync(String connectionName,
Object key,
Object field,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get the value of a hash field.
|
static Long |
hincrby(String connectionName,
Object key,
Object field,
long amount,
io.toro.gloop.engine.GloopExecutionContext context)
Increment the integer value of a hash field by the given number.
|
static Future<Long> |
hincrbyAsync(String connectionName,
Object key,
Object field,
long amount,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously increment the integer value of a hash field by the given number.
|
static Double |
hincrbyfloat(String connectionName,
Object key,
Object field,
double amount,
io.toro.gloop.engine.GloopExecutionContext context)
Increment the float value of a hash field by the given amount.
|
static Future<Double> |
hincrbyfloatAsync(String connectionName,
Object key,
Object field,
double amount,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously increment the float value of a hash field by the given amount.
|
static Long |
hkeys(String connectionName,
io.lettuce.core.output.KeyStreamingChannel<Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Stream over all the fields in a hash.
|
static List<Object> |
hkeys(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Get all the fields in a hash.
|
static Future<Long> |
hkeysAsync(String connectionName,
io.lettuce.core.output.KeyStreamingChannel<Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously stream over all the fields in a hash.
|
static Future<List<Object>> |
hkeysAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get all the fields in a hash.
|
static Long |
hlen(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Get the number of fields in a hash.
|
static Future<Long> |
hlenAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get the number of fields in a hash.
|
static Long |
hmget(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... fields)
Stream over the values of all the given hash fields.
|
static io.toro.gloop.object.property.GloopModel |
hmget(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... fields)
Get the values of all the given hash fields.
|
static Future<Long> |
hmgetAsync(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... fields)
Asynchronously stream over the values of all the given hash fields.
|
static Future<List<io.lettuce.core.KeyValue<Object,Object>>> |
hmgetAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... fields)
Asynchronously get the values of all the given hash fields.
|
static String |
hmset(String connectionName,
Object key,
io.toro.gloop.object.property.GloopModel redisMap,
io.toro.gloop.engine.GloopExecutionContext context)
Set multiple hash fields to multiple values.
|
static Future<String> |
hmsetAsync(String connectionName,
Object key,
io.toro.gloop.object.property.GloopModel redisMap,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously set multiple hash fields to multiple values.
|
static io.lettuce.core.StreamScanCursor |
hscan(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate hash fields and associated values.
|
static io.lettuce.core.StreamScanCursor |
hscan(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate hash fields and associated values.
|
static io.lettuce.core.StreamScanCursor |
hscan(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.lettuce.core.ScanCursor scanCursor,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate hash fields and associated values.
|
static io.lettuce.core.StreamScanCursor |
hscan(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.lettuce.core.ScanCursor scanCursor,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate hash fields and associated values.
|
static io.lettuce.core.MapScanCursor<Object,Object> |
hscan(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate hash fields and associated values.
|
static io.lettuce.core.MapScanCursor<Object,Object> |
hscan(String connectionName,
Object key,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate hash fields and associated values.
|
static io.lettuce.core.MapScanCursor<Object,Object> |
hscan(String connectionName,
Object key,
io.lettuce.core.ScanCursor scanCursor,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate hash fields and associated values.
|
static io.lettuce.core.MapScanCursor<Object,Object> |
hscan(String connectionName,
Object key,
io.lettuce.core.ScanCursor scanCursor,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate hash fields and associated values.
|
static Future<io.lettuce.core.StreamScanCursor> |
hscanAsync(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate hash fields and associated values.
|
static Future<io.lettuce.core.StreamScanCursor> |
hscanAsync(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate hash fields and associated values.
|
static Future<io.lettuce.core.StreamScanCursor> |
hscanAsync(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.lettuce.core.ScanCursor scanCursor,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate hash fields and associated values.
|
static Future<io.lettuce.core.StreamScanCursor> |
hscanAsync(String connectionName,
io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel,
Object key,
io.lettuce.core.ScanCursor scanCursor,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate hash fields and associated values.
|
static Future<io.lettuce.core.MapScanCursor<Object,Object>> |
hscanAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate hash fields and associated values.
|
static Future<io.lettuce.core.MapScanCursor<Object,Object>> |
hscanAsync(String connectionName,
Object key,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate hash fields and associated values.
|
static Future<io.lettuce.core.MapScanCursor<Object,Object>> |
hscanAsync(String connectionName,
Object key,
io.lettuce.core.ScanCursor scanCursor,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate hash fields and associated values.
|
static Future<io.lettuce.core.MapScanCursor<Object,Object>> |
hscanAsync(String connectionName,
Object key,
io.lettuce.core.ScanCursor scanCursor,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate hash fields and associated values.
|
static Boolean |
hset(String connectionName,
Object key,
Object field,
Object value,
io.toro.gloop.engine.GloopExecutionContext context)
Set the string value of a hash field.
|
static Future<Boolean> |
hsetAsync(String connectionName,
Object key,
Object field,
Object value,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously set the string value of a hash field.
|
static Boolean |
hsetnx(String connectionName,
Object key,
Object field,
Object value,
io.toro.gloop.engine.GloopExecutionContext context)
Set the value of a hash field, only if the field does not exist.
|
static Future<Boolean> |
hsetnxAsync(String connectionName,
Object key,
Object field,
Object value,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously set the value of a hash field, only if the field does not exist.
|
static Long |
hstrlen(String connectionName,
Object key,
Object field,
io.toro.gloop.engine.GloopExecutionContext context)
Get the string length of the field value in a hash.
|
static Future<Long> |
hstrlenAsync(String connectionName,
Object key,
Object field,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get the string length of the field value in a hash.
|
static List<Object> |
hvals(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Get all the values in a hash.
|
static Long |
hvals(String connectionName,
io.lettuce.core.output.ValueStreamingChannel<Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Stream over all the values in a hash.
|
static Future<List<Object>> |
hvalsAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get all the values in a hash.
|
static Future<Long> |
hvalsAsync(String connectionName,
io.lettuce.core.output.ValueStreamingChannel<Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously stream over all the values in a hash.
|
@Autowired RedisHashMethods(io.toro.martini.database.DataSourceManager dataSourceManager)
@GloopParameter(name="redisHdelOutput") public static Long hdel(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... fields)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfields
- the field type: key@GloopParameter(name="redisFutureHdelOutput") public static Future<Long> hdelAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... fields)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfields
- the field type: key@GloopParameter(name="redisHexistsOutput") public static Boolean hexists(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyfield
.
false if the hash does not contain field
, or key
does not exist.@GloopParameter(name="redisFutureHexistsOutput") public static Future<Boolean> hexistsAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyfield
.
false if the hash does not contain field
, or key
does not exist.@GloopParameter(name="redisHgetOutput") public static Object hget(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyfield
, or null when field
is not
present in the hash or key
does not exist.@GloopParameter(name="redisFutureHgetOutput") public static Future<Object> hgetAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyfield
, or null when field
is not
present in the hash or key
does not exist.@GloopParameter(name="redisHincrbyOutput") public static Long hincrby(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, @GloopParameter(allowNull=false) long amount, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyamount
- the increment type: longfield
after the increment operation.@GloopParameter(name="redisFutureHincrbyOutput") public static Future<Long> hincrbyAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, @GloopParameter(allowNull=false) long amount, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyamount
- the increment type: longfield
after the increment operation.@GloopParameter(name="redisHincrbyfloatOutput") public static Double hincrbyfloat(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, @GloopParameter(allowNull=false) double amount, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyamount
- the increment type: doublefield
after the increment.@GloopParameter(name="redisFutureHincrbyfloatOutput") public static Future<Double> hincrbyfloatAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, @GloopParameter(allowNull=false) double amount, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyamount
- the increment type: doublefield
after the increment.@GloopObjectParameter(value="output{\nredisMap[]{\n name:object\n value:object\n}\n}") public static io.toro.gloop.object.property.GloopModel hgetall(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist.@GloopParameter(name="redisHgetallOutput") public static Long hgetall(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkey
- the key@GloopParameter(name="redisFutureHgetallOutput") public static Future<Long> hgetallAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkey
- the key@GloopParameter(name="redisFutureHgetallOutput") public static Future<Map<Object,Object>> hgetallAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist.@GloopParameter(name="redisHkeysOutput") public static List<Object> hkeys(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist.@GloopParameter(name="redisHkeysOutput") public static Long hkeys(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkey
- the key@GloopParameter(name="redisFutureHkeysOutput") public static Future<Long> hkeysAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkey
- the key@GloopParameter(name="redisFutureHkeysOutput") public static Future<List<Object>> hkeysAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist.@GloopParameter(name="redisHlenOutput") public static Long hlen(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key0
when key
does not exist.@GloopParameter(name="redisFutureHlenOutput") public static Future<Long> hlenAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key0
when key
does not exist.@GloopObjectParameter(value="output{\n redisKeyValues[]{\n key:object\n value:object\n }\n}") public static io.toro.gloop.object.property.GloopModel hmget(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... fields)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfields
- the field type: key@GloopParameter(name="redisHmgetOutput") public static Long hmget(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... fields)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkey
- the keyfields
- the fields@GloopParameter(name="redisFutureHmgetOutput") public static Future<List<io.lettuce.core.KeyValue<Object,Object>>> hmgetAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... fields)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfields
- the field type: key@GloopParameter(name="redisFutureHmgetOutput") public static Future<Long> hmgetAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... fields)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkey
- the keyfields
- the fields@GloopParameter(name="redisHmsetOutput") public static String hmset(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="redisMap[]{\n name:object\n value:object\n}\n") io.toro.gloop.object.property.GloopModel redisMap, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyredisMap
- the key/value pairs@GloopParameter(name="redisFutureHmsetOutput") public static Future<String> hmsetAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="redisMap[]{\n name:object\n value:object\n}\n") io.toro.gloop.object.property.GloopModel redisMap, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyredisMap
- the key/value pairs@GloopParameter(name="redisHscanOutput") public static io.lettuce.core.MapScanCursor<Object,Object> hscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisHscanOutput") public static io.lettuce.core.MapScanCursor<Object,Object> hscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") io.toro.gloop.object.property.GloopModel scanArgs, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisHscanOutput") public static io.lettuce.core.MapScanCursor<Object,Object> hscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) io.lettuce.core.ScanCursor scanCursor, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") io.toro.gloop.object.property.GloopModel scanArgs, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisHscanOutput") public static io.lettuce.core.MapScanCursor<Object,Object> hscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) io.lettuce.core.ScanCursor scanCursor, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisHscanOutput") public static io.lettuce.core.StreamScanCursor hscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key-value pairkey
- the key@GloopParameter(name="redisHscanOutput") public static io.lettuce.core.StreamScanCursor hscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") io.toro.gloop.object.property.GloopModel scanArgs, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key-value pairkey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisHscanOutput") public static io.lettuce.core.StreamScanCursor hscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) io.lettuce.core.ScanCursor scanCursor, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") io.toro.gloop.object.property.GloopModel scanArgs, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key-value pairkey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisHscanOutput") public static io.lettuce.core.StreamScanCursor hscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) io.lettuce.core.ScanCursor scanCursor, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key-value pairkey
- the keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisFutureHscanOutput") public static Future<io.lettuce.core.MapScanCursor<Object,Object>> hscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureHscanOutput") public static Future<io.lettuce.core.MapScanCursor<Object,Object>> hscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") io.toro.gloop.object.property.GloopModel scanArgs, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisFutureHscanOutput") public static Future<io.lettuce.core.MapScanCursor<Object,Object>> hscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) io.lettuce.core.ScanCursor scanCursor, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") io.toro.gloop.object.property.GloopModel scanArgs, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisFutureHscanOutput") public static Future<io.lettuce.core.MapScanCursor<Object,Object>> hscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) io.lettuce.core.ScanCursor scanCursor, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisFutureHscanOutput") public static Future<io.lettuce.core.StreamScanCursor> hscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key-value pairkey
- the key@GloopParameter(name="redisFutureHscanOutput") public static Future<io.lettuce.core.StreamScanCursor> hscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") io.toro.gloop.object.property.GloopModel scanArgs, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key-value pairkey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisFutureHscanOutput") public static Future<io.lettuce.core.StreamScanCursor> hscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) io.lettuce.core.ScanCursor scanCursor, @GloopObjectParameter(value="scanArgs{\n limit:long:Limit the scan by count:false\n match::Set the match filter:false\n}\n") io.toro.gloop.object.property.GloopModel scanArgs, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key-value pairkey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisFutureHscanOutput") public static Future<io.lettuce.core.StreamScanCursor> hscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.KeyValueStreamingChannel<Object,Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) io.lettuce.core.ScanCursor scanCursor, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every key-value pairkey
- the keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisHsetOutput") public static Boolean hset(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, @GloopParameter(allowNull=false) Object value, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyvalue
- the valuefield
is a new field in the hash
and value
was set. false if field
already exists in the hash and the value was
updated.@GloopParameter(name="redisFutureHsetOutput") public static Future<Boolean> hsetAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, @GloopParameter(allowNull=false) Object value, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyvalue
- the valuefield
is a new field in the hash
and value
was set. false if field
already exists in the hash and the value was
updated.@GloopParameter(name="redisHsetnxOutput") public static Boolean hsetnx(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, @GloopParameter(allowNull=false) Object value, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyvalue
- the value1
if field
is a new field in the hash and
value
was set. 0
if field
already exists in the hash and no operation was
performed.@GloopParameter(name="redisFutureHsetnxOutput") public static Future<Boolean> hsetnxAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, @GloopParameter(allowNull=false) Object value, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyvalue
- the value1
if field
is a new field in the hash and
value
was set. 0
if field
already exists in the hash and no operation was
performed.@GloopParameter(name="redisHstrlenOutput") public static Long hstrlen(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyfield
value, or 0
when field
is not
present in the hash or key
does not exist at all.@GloopParameter(name="redisFutureHstrlenOutput") public static Future<Long> hstrlenAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object field, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyfield
- the field type: keyfield
value, or 0
when field
is not
present in the hash or key
does not exist at all.@GloopParameter(name="redisHvalsOutput") public static List<Object> hvals(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist.@GloopParameter(name="redisHvalsOutput") public static Long hvals(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the key@GloopParameter(name="redisFutureHvalsOutput") public static Future<List<Object>> hvalsAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist.@GloopParameter(name="redisFutureHvalsOutput") public static Future<Long> hvalsAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) io.lettuce.core.output.ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyCopyright © 2020. All rights reserved.