public class RedisSetMethods
extends io.toro.martini.redis.RedisBaseMethods
Constructor and Description |
---|
RedisSetMethods(DataSourceManager dataSourceManager) |
Modifier and Type | Method and Description |
---|---|
static Long |
sadd(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... members)
Add one or more members to a set.
|
static Future<Long> |
saddAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... members)
Asynchronously add one or more members to a set.
|
static Long |
scard(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Get the number of members in a set.
|
static Future<Long> |
scardAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get the number of members in a set.
|
static Set<Object> |
sdiff(String connectionName,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Subtract multiple sets.
|
static Long |
sdiff(String connectionName,
ValueStreamingChannel<Object> channel,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Subtract multiple sets.
|
static Future<Set<Object>> |
sdiffAsync(String connectionName,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Asynchronously subtract multiple sets.
|
static Future<Long> |
sdiffAsync(String connectionName,
ValueStreamingChannel<Object> channel,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Asynchronously subtract multiple sets.
|
static Long |
sdiffstore(String connectionName,
Object destination,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Subtract multiple sets and store the resulting set in a key.
|
static Future<Long> |
sdiffstoreAsync(String connectionName,
Object destination,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Asynchronously subtract multiple sets and store the resulting set in a key.
|
static Set<Object> |
sinter(String connectionName,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Intersect multiple sets.
|
static Long |
sinter(String connectionName,
ValueStreamingChannel<Object> channel,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Intersect multiple sets.
|
static Future<Set<Object>> |
sinterAsync(String connectionName,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Asynchronously intersect multiple sets.
|
static Future<Long> |
sinterAsync(String connectionName,
ValueStreamingChannel<Object> channel,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Asynchronously intersect multiple sets.
|
static Long |
sinterstore(String connectionName,
Object destination,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Intersect multiple sets and store the resulting set in a key.
|
static Future<Long> |
sinterstoreAsync(String connectionName,
Object destination,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Asynchronously intersect multiple sets and store the resulting set in a key.
|
static Boolean |
sismember(String connectionName,
Object key,
Object member,
io.toro.gloop.engine.GloopExecutionContext context)
Determine if a given value is a member of a set.
|
static Future<Boolean> |
sismemberAsync(String connectionName,
Object key,
Object member,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously determine if a given value is a member of a set.
|
static Set<Object> |
smembers(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Get all the members in a set.
|
static Long |
smembers(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Get all the members in a set.
|
static Future<Set<Object>> |
smembersAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get all the members in a set.
|
static Future<Long> |
smembersAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get all the members in a set.
|
static Boolean |
smove(String connectionName,
Object source,
Object destination,
Object member,
io.toro.gloop.engine.GloopExecutionContext context)
Move a member from one set to another.
|
static Future<Boolean> |
smoveAsync(String connectionName,
Object source,
Object destination,
Object member,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously move a member from one set to another.
|
static Object |
spop(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Remove and return a random member from a set.
|
static Set<Object> |
spop(String connectionName,
Object key,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Remove and return one or multiple random members from a set.
|
static Future<Object> |
spopAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously remove and return a random member from a set.
|
static Future<Set<Object>> |
spopAsync(String connectionName,
Object key,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously remove and return one or multiple random members from a set.
|
static Object |
srandmember(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Get one random member from a set.
|
static List<Object> |
srandmember(String connectionName,
Object key,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Get one or multiple random members from a set.
|
static Long |
srandmember(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Get one or multiple random members from a set.
|
static Future<Object> |
srandmemberAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get one random member from a set.
|
static Future<List<Object>> |
srandmemberAsync(String connectionName,
Object key,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get one or multiple random members from a set.
|
static Future<Long> |
srandmemberAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get one or multiple random members from a set.
|
static Long |
srem(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... members)
Remove one or more members from a set.
|
static Future<Long> |
sremAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... members)
Asynchronously remove one or more members from a set.
|
static ValueScanCursor<Object> |
sscan(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate Set elements.
|
static ValueScanCursor<Object> |
sscan(String connectionName,
Object key,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate Set elements.
|
static ValueScanCursor<Object> |
sscan(String connectionName,
Object key,
ScanCursor scanCursor,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate Set elements.
|
static ValueScanCursor<Object> |
sscan(String connectionName,
Object key,
ScanCursor scanCursor,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate Set elements.
|
static StreamScanCursor |
sscan(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate Set elements.
|
static StreamScanCursor |
sscan(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate Set elements.
|
static StreamScanCursor |
sscan(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
ScanCursor scanCursor,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate Set elements.
|
static StreamScanCursor |
sscan(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
ScanCursor scanCursor,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Incrementally iterate Set elements.
|
static Future<ValueScanCursor<Object>> |
sscanAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate set elements.
|
static Future<ValueScanCursor<Object>> |
sscanAsync(String connectionName,
Object key,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate set elements.
|
static Future<ValueScanCursor<Object>> |
sscanAsync(String connectionName,
Object key,
ScanCursor scanCursor,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate set elements.
|
static Future<ValueScanCursor<Object>> |
sscanAsync(String connectionName,
Object key,
ScanCursor scanCursor,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate set elements.
|
static Future<StreamScanCursor> |
sscanAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate set elements.
|
static Future<StreamScanCursor> |
sscanAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate set elements.
|
static Future<StreamScanCursor> |
sscanAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
ScanCursor scanCursor,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate set elements.
|
static Future<StreamScanCursor> |
sscanAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
ScanCursor scanCursor,
io.toro.gloop.object.property.GloopModel scanArgs,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously incrementally iterate set elements.
|
static Set<Object> |
sunion(String connectionName,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Add multiple sets.
|
static Long |
sunion(String connectionName,
ValueStreamingChannel<Object> channel,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Add multiple sets.
|
static Future<Set<Object>> |
sunionAsync(String connectionName,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Asynchronously add multiple sets.
|
static Future<Long> |
sunionAsync(String connectionName,
ValueStreamingChannel<Object> channel,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Asynchronously add multiple sets.
|
static Long |
sunionstore(String connectionName,
Object destination,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Add multiple sets and store the resulting set in a key.
|
static Future<Long> |
sunionstoreAsync(String connectionName,
Object destination,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keys)
Asynchronously add multiple sets and store the resulting set in a key.
|
@Autowired RedisSetMethods(DataSourceManager dataSourceManager)
@GloopParameter(name="redisSaddOutput") public static Long sadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... members)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymembers
- the member type: value@GloopParameter(name="redisFutureSaddOutput") public static Future<Long> saddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... members)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymembers
- the member type: value@GloopParameter(name="redisScardOutput") public static Long scard(@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="redisFutureScardOutput") public static Future<Long> scardAsync(@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="redisSdiffOutput") public static Set<Object> sdiff(@GloopParameter(allowNull=false) String connectionName, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the key@GloopParameter(name="redisSdiffOutput") public static Long sdiff(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkeys
- the keys@GloopParameter(name="redisFutureSdiffOutput") public static Future<Set<Object>> sdiffAsync(@GloopParameter(allowNull=false) String connectionName, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the key@GloopParameter(name="redisFutureSdiffOutput") public static Future<Long> sdiffAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkeys
- the keys@GloopParameter(name="redisSdiffstoreOutput") public static Long sdiffstore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destination type: keykeys
- the key@GloopParameter(name="redisFutureSdiffstoreOutput") public static Future<Long> sdiffstoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destination type: keykeys
- the key@GloopParameter(name="redisSinterOutput") public static Set<Object> sinter(@GloopParameter(allowNull=false) String connectionName, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the key@GloopParameter(name="redisSinterOutput") public static Long sinter(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkeys
- the keys@GloopParameter(name="redisFutureSinterOutput") public static Future<Set<Object>> sinterAsync(@GloopParameter(allowNull=false) String connectionName, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the key@GloopParameter(name="redisFutureSinterOutput") public static Future<Long> sinterAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkeys
- the keys@GloopParameter(name="redisSinterstoreOutput") public static Long sinterstore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destination type: keykeys
- the key@GloopParameter(name="redisFutureSinterstoreOutput") public static Future<Long> sinterstoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destination type: keykeys
- the key@GloopParameter(name="redisSismemberOutput") public static Boolean sismember(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object member, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymember
- the member type: valuekey
does not exist.@GloopParameter(name="redisFutureSismemberOutput") public static Future<Boolean> sismemberAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object member, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymember
- the member type: valuekey
does not exist.@GloopParameter(name="redisSmoveOutput") public static Boolean smove(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object source, @GloopParameter(allowNull=false) Object destination, @GloopParameter(allowNull=false) Object member, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namesource
- the source keydestination
- the destination type: keymember
- the member type: valuesource
and no operation was performed.@GloopParameter(name="redisFutureSmoveOutput") public static Future<Boolean> smoveAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object source, @GloopParameter(allowNull=false) Object destination, @GloopParameter(allowNull=false) Object member, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namesource
- the source keydestination
- the destination type: keymember
- the member type: valuesource
and no operation was performed.@GloopParameter(name="redisSmembersOutput") public static Set<Object> smembers(@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="redisSmembersOutput") public static Long smembers(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkey
- the keys@GloopParameter(name="redisFutureSmembersOutput") public static Future<Set<Object>> smembersAsync(@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="redisFutureSmembersOutput") public static Future<Long> smembersAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- the channelkey
- the keys@GloopParameter(name="redisSpopOutput") public static Object spop(@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="redisSpopOutput") public static Set<Object> spop(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keycount
- number of members to popkey
does not exist.@GloopParameter(name="redisFutureSpopOutput") public static Future<Object> spopAsync(@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="redisFutureSpopOutput") public static Future<Set<Object>> spopAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keycount
- number of members to popkey
does not exist.@GloopParameter(name="redisSrandmemberOutput") public static Object srandmember(@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 keycount
argument the command returns a Bulk Reply with
the randomly selected element, or null when key
does not exist.@GloopParameter(name="redisSrandmemberOutput") public static List<Object> srandmember(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keycount
- the count type: longcount
argument the command returns a Bulk
Reply with the randomly selected element, or null when key
does not exist.@GloopParameter(name="redisSrandmemberOutput") public static Long srandmember(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keycount
- the count@GloopParameter(name="redisFutureSrandmemberOutput") public static Future<Object> srandmemberAsync(@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 keycount
argument the command returns a bulk reply with
the randomly selected element, or null when key
does not exist.@GloopParameter(name="redisFutureSrandmemberOutput") public static Future<List<Object>> srandmemberAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keycount
- the count type: longcount
argument the command returns a bulk
reply with the randomly selected element, or null when key
does not exist.@GloopParameter(name="redisFutureSrandmemberOutput") public static Future<Long> srandmemberAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keycount
- the count@GloopParameter(name="redisSremOutput") public static Long srem(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... members)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymembers
- the member type: value@GloopParameter(name="redisFutureSremOutput") public static Future<Long> sremAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... members)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymembers
- the member type: value@GloopParameter(name="redisSunionOutput") public static Set<Object> sunion(@GloopParameter(allowNull=false) String connectionName, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the key@GloopParameter(name="redisSunionOutput") public static Long sunion(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekeys
- the keys@GloopParameter(name="redisFutureSunionOutput") public static Future<Set<Object>> sunionAsync(@GloopParameter(allowNull=false) String connectionName, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the key@GloopParameter(name="redisFutureSunionOutput") public static Future<Long> sunionAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekeys
- the keys@GloopParameter(name="redisSunionstoreOutput") public static Long sunionstore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destination type: keykeys
- the key@GloopParameter(name="redisFutureSunionstoreOutput") public static Future<Long> sunionstoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destination type: keykeys
- the key@GloopParameter(name="redisSscanOutput") public static ValueScanCursor<Object> sscan(@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="redisSscanOutput") public static ValueScanCursor<Object> sscan(@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="redisSscanOutput") public static ValueScanCursor<Object> sscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @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") 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="redisSscanOutput") public static ValueScanCursor<Object> sscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) 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="redisSscanOutput") public static StreamScanCursor sscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) 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="redisSscanOutput") public static StreamScanCursor sscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<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 valuekey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisSscanOutput") public static StreamScanCursor sscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @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") 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 valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisSscanOutput") public static StreamScanCursor sscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisFutureSscanOutput") public static Future<ValueScanCursor<Object>> sscanAsync(@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="redisFutureSscanOutput") public static Future<ValueScanCursor<Object>> sscanAsync(@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="redisFutureSscanOutput") public static Future<ValueScanCursor<Object>> sscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @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") 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="redisFutureSscanOutput") public static Future<ValueScanCursor<Object>> sscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) 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="redisFutureSscanOutput") public static Future<StreamScanCursor> sscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) 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="redisFutureSscanOutput") public static Future<StreamScanCursor> sscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<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 valuekey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisFutureSscanOutput") public static Future<StreamScanCursor> sscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @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") 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 valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisFutureSscanOutput") public static Future<StreamScanCursor> sscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullCopyright © 2020. All rights reserved.