Package io.lettuce.core.cluster.api.sync
Interface NodeSelectionSetCommands<K,V>
-
- Type Parameters:
K
- Key type.V
- Value type.
- All Known Subinterfaces:
NodeSelectionCommands<K,V>
public interface NodeSelectionSetCommands<K,V>
Synchronous executed commands on a node selection for Sets.- Since:
- 4.0
- Author:
- Mark Paluch
- Generated class:
- by io.lettuce.apigenerator.CreateSyncNodeSelectionClusterApi
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Executions<Long>
sadd(K key, V... members)
Add one or more members to a set.Executions<Long>
scard(K key)
Get the number of members in a set.Executions<Long>
sdiff(ValueStreamingChannel<V> channel, K... keys)
Subtract multiple sets.Executions<Set<V>>
sdiff(K... keys)
Subtract multiple sets.Executions<Long>
sdiffstore(K destination, K... keys)
Subtract multiple sets and store the resulting set in a key.Executions<Long>
sinter(ValueStreamingChannel<V> channel, K... keys)
Intersect multiple sets.Executions<Set<V>>
sinter(K... keys)
Intersect multiple sets.Executions<Long>
sintercard(long limit, K... keys)
This command works exactly likesinter(java.lang.Object[])
but instead of returning the result set, it returns just the cardinality of the result.Executions<Long>
sintercard(K... keys)
This command works exactly likesinter(java.lang.Object[])
but instead of returning the result set, it returns just the cardinality of the result.Executions<Long>
sinterstore(K destination, K... keys)
Intersect multiple sets and store the resulting set in a key.Executions<Boolean>
sismember(K key, V member)
Determine if a given value is a member of a set.Executions<Long>
smembers(ValueStreamingChannel<V> channel, K key)
Get all the members in a set.Executions<Set<V>>
smembers(K key)
Get all the members in a set.Executions<List<Boolean>>
smismember(K key, V... members)
Returns whether each member is a member of the set stored at key.Executions<Boolean>
smove(K source, K destination, V member)
Move a member from one set to another.Executions<V>
spop(K key)
Remove and return a random member from a set.Executions<Set<V>>
spop(K key, long count)
Remove and return one or multiple random members from a set.Executions<Long>
srandmember(ValueStreamingChannel<V> channel, K key, long count)
Get one or multiple random members from a set.Executions<V>
srandmember(K key)
Get one random member from a set.Executions<List<V>>
srandmember(K key, long count)
Get one or multiple random members from a set.Executions<Long>
srem(K key, V... members)
Remove one or more members from a set.Executions<StreamScanCursor>
sscan(ValueStreamingChannel<V> channel, K key)
Incrementally iterate Set elements.Executions<StreamScanCursor>
sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate Set elements.Executions<StreamScanCursor>
sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate Set elements.Executions<StreamScanCursor>
sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate Set elements.Executions<ValueScanCursor<V>>
sscan(K key)
Incrementally iterate Set elements.Executions<ValueScanCursor<V>>
sscan(K key, ScanArgs scanArgs)
Incrementally iterate Set elements.Executions<ValueScanCursor<V>>
sscan(K key, ScanCursor scanCursor)
Incrementally iterate Set elements.Executions<ValueScanCursor<V>>
sscan(K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate Set elements.Executions<Long>
sunion(ValueStreamingChannel<V> channel, K... keys)
Add multiple sets.Executions<Set<V>>
sunion(K... keys)
Add multiple sets.Executions<Long>
sunionstore(K destination, K... keys)
Add multiple sets and store the resulting set in a key.
-
-
-
Method Detail
-
sadd
Executions<Long> sadd(K key, V... members)
Add one or more members to a set.- Parameters:
key
- the key.members
- the member type: value.- Returns:
- Long integer-reply the number of elements that were added to the set, not including all the elements already present into the set.
-
scard
Executions<Long> scard(K key)
Get the number of members in a set.- Parameters:
key
- the key.- Returns:
- Long integer-reply the cardinality (number of elements) of the set, or
false
ifkey
does not exist.
-
sdiff
Executions<Set<V>> sdiff(K... keys)
Subtract multiple sets.- Parameters:
keys
- the key.- Returns:
- Set<V> array-reply list with members of the resulting set.
-
sdiff
Executions<Long> sdiff(ValueStreamingChannel<V> channel, K... keys)
Subtract multiple sets.- Parameters:
channel
- the channel.keys
- the keys.- Returns:
- Long count of members of the resulting set.
-
sdiffstore
Executions<Long> sdiffstore(K destination, K... keys)
Subtract multiple sets and store the resulting set in a key.- Parameters:
destination
- the destination type: key.keys
- the key.- Returns:
- Long integer-reply the number of elements in the resulting set.
-
sinter
Executions<Set<V>> sinter(K... keys)
Intersect multiple sets.- Parameters:
keys
- the key.- Returns:
- Set<V> array-reply list with members of the resulting set.
-
sinter
Executions<Long> sinter(ValueStreamingChannel<V> channel, K... keys)
Intersect multiple sets.- Parameters:
channel
- the channel.keys
- the keys.- Returns:
- Long count of members of the resulting set.
-
sintercard
Executions<Long> sintercard(K... keys)
This command works exactly likesinter(java.lang.Object[])
but instead of returning the result set, it returns just the cardinality of the result.- Parameters:
keys
- the keys.- Returns:
- The cardinality of the set which would result from the intersection of all the given sets.
- Since:
- 6.2
-
sintercard
Executions<Long> sintercard(long limit, K... keys)
This command works exactly likesinter(java.lang.Object[])
but instead of returning the result set, it returns just the cardinality of the result.- Parameters:
limit
- If the intersection cardinality reaches limit partway through the computation, the algorithm will exit and yield limit as the cardinality.keys
- the keys.- Returns:
- The cardinality of the set which would result from the intersection of all the given sets.
- Since:
- 6.2
-
sinterstore
Executions<Long> sinterstore(K destination, K... keys)
Intersect multiple sets and store the resulting set in a key.- Parameters:
destination
- the destination type: key.keys
- the key.- Returns:
- Long integer-reply the number of elements in the resulting set.
-
sismember
Executions<Boolean> sismember(K key, V member)
Determine if a given value is a member of a set.- Parameters:
key
- the key.member
- the member type: value.- Returns:
- Boolean integer-reply specifically:
true
if the element is a member of the set.false
if the element is not a member of the set, or ifkey
does not exist.
-
smembers
Executions<Set<V>> smembers(K key)
Get all the members in a set.- Parameters:
key
- the key.- Returns:
- Set<V> array-reply all elements of the set.
-
smembers
Executions<Long> smembers(ValueStreamingChannel<V> channel, K key)
Get all the members in a set.- Parameters:
channel
- the channel.key
- the keys.- Returns:
- Long count of members of the resulting set.
-
smismember
Executions<List<Boolean>> smismember(K key, V... members)
Returns whether each member is a member of the set stored at key.- Parameters:
key
- the key.members
- the member type: value.- Returns:
- List<Boolean> array-reply list representing the membership of the given elements, in the same order as they are requested.
- Since:
- 6.1
-
smove
Executions<Boolean> smove(K source, K destination, V member)
Move a member from one set to another.- Parameters:
source
- the source key.destination
- the destination type: key.member
- the member type: value.- Returns:
- Boolean integer-reply specifically:
true
if the element is moved.false
if the element is not a member ofsource
and no operation was performed.
-
spop
Executions<V> spop(K key)
Remove and return a random member from a set.- Parameters:
key
- the key.- Returns:
- V bulk-string-reply the removed element, or
null
whenkey
does not exist.
-
spop
Executions<Set<V>> spop(K key, long count)
Remove and return one or multiple random members from a set.- Parameters:
key
- the key.count
- number of members to pop.- Returns:
- V bulk-string-reply the removed element, or
null
whenkey
does not exist.
-
srandmember
Executions<V> srandmember(K key)
Get one random member from a set.- Parameters:
key
- the key.- Returns:
- V bulk-string-reply without the additional
count
argument the command returns a Bulk Reply with the randomly selected element, ornull
whenkey
does not exist.
-
srandmember
Executions<List<V>> srandmember(K key, long count)
Get one or multiple random members from a set.- Parameters:
key
- the key.count
- the count type: long.- Returns:
- Set<V> bulk-string-reply without the additional
count
argument the command returns a Bulk Reply with the randomly selected element, ornull
whenkey
does not exist.
-
srandmember
Executions<Long> srandmember(ValueStreamingChannel<V> channel, K key, long count)
Get one or multiple random members from a set.- Parameters:
channel
- streaming channel that receives a call for every value.key
- the key.count
- the count.- Returns:
- Long count of members of the resulting set.
-
srem
Executions<Long> srem(K key, V... members)
Remove one or more members from a set.- Parameters:
key
- the key.members
- the member type: value.- Returns:
- Long integer-reply the number of members that were removed from the set, not including non existing members.
-
sunion
Executions<Set<V>> sunion(K... keys)
Add multiple sets.- Parameters:
keys
- the key.- Returns:
- Set<V> array-reply list with members of the resulting set.
-
sunion
Executions<Long> sunion(ValueStreamingChannel<V> channel, K... keys)
Add multiple sets.- Parameters:
channel
- streaming channel that receives a call for every value.keys
- the keys.- Returns:
- Long count of members of the resulting set.
-
sunionstore
Executions<Long> sunionstore(K destination, K... keys)
Add multiple sets and store the resulting set in a key.- Parameters:
destination
- the destination type: key.keys
- the key.- Returns:
- Long integer-reply the number of elements in the resulting set.
-
sscan
Executions<ValueScanCursor<V>> sscan(K key)
Incrementally iterate Set elements.- Parameters:
key
- the key.- Returns:
- ValueScanCursor<V> scan cursor.
-
sscan
Executions<ValueScanCursor<V>> sscan(K key, ScanArgs scanArgs)
Incrementally iterate Set elements.- Parameters:
key
- the key.scanArgs
- scan arguments.- Returns:
- ValueScanCursor<V> scan cursor.
-
sscan
Executions<ValueScanCursor<V>> sscan(K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate Set elements.- Parameters:
key
- the key.scanCursor
- cursor to resume from a previous scan, must not benull
.scanArgs
- scan arguments.- Returns:
- ValueScanCursor<V> scan cursor.
-
sscan
Executions<ValueScanCursor<V>> sscan(K key, ScanCursor scanCursor)
Incrementally iterate Set elements.- Parameters:
key
- the key.scanCursor
- cursor to resume from a previous scan, must not benull
.- Returns:
- ValueScanCursor<V> scan cursor.
-
sscan
Executions<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key)
Incrementally iterate Set elements.- Parameters:
channel
- streaming channel that receives a call for every value.key
- the key.- Returns:
- StreamScanCursor scan cursor.
-
sscan
Executions<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
Incrementally iterate Set elements.- Parameters:
channel
- streaming channel that receives a call for every value.key
- the key.scanArgs
- scan arguments.- Returns:
- StreamScanCursor scan cursor.
-
sscan
Executions<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
Incrementally iterate Set elements.- Parameters:
channel
- streaming channel that receives a call for every value.key
- the key.scanCursor
- cursor to resume from a previous scan, must not benull
.scanArgs
- scan arguments.- Returns:
- StreamScanCursor scan cursor.
-
sscan
Executions<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
Incrementally iterate Set elements.- Parameters:
channel
- streaming channel that receives a call for every value.key
- the key.scanCursor
- cursor to resume from a previous scan, must not benull
.- Returns:
- StreamScanCursor scan cursor.
-
-