Interface RedisClusterPubSubAsyncCommands<K,V>
-
- Type Parameters:
K
- Key type.V
- Value type.
- All Superinterfaces:
BaseRedisAsyncCommands<K,V>
,RedisAclAsyncCommands<K,V>
,RedisAsyncCommands<K,V>
,RedisClusterAsyncCommands<K,V>
,RedisFunctionAsyncCommands<K,V>
,RedisGeoAsyncCommands<K,V>
,RedisHashAsyncCommands<K,V>
,RedisHLLAsyncCommands<K,V>
,RedisKeyAsyncCommands<K,V>
,RedisListAsyncCommands<K,V>
,RedisPubSubAsyncCommands<K,V>
,RedisScriptingAsyncCommands<K,V>
,RedisServerAsyncCommands<K,V>
,RedisSetAsyncCommands<K,V>
,RedisSortedSetAsyncCommands<K,V>
,RedisStreamAsyncCommands<K,V>
,RedisStringAsyncCommands<K,V>
,RedisTransactionalAsyncCommands<K,V>
- All Known Implementing Classes:
RedisClusterPubSubAsyncCommandsImpl
public interface RedisClusterPubSubAsyncCommands<K,V> extends RedisPubSubAsyncCommands<K,V>
Asynchronous and thread-safe Redis Cluster PubSub API. Operations are executed either on the main connection or aPubSubAsyncNodeSelection
.- Since:
- 4.4
- Author:
- Mark Paluch
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods Modifier and Type Method Description default PubSubAsyncNodeSelection<K,V>
all()
Select all known cluster nodes.StatefulRedisClusterPubSubConnection<K,V>
getStatefulConnection()
default PubSubAsyncNodeSelection<K,V>
masters()
Deprecated.since 6.0 in favor ofupstream()
.PubSubAsyncNodeSelection<K,V>
nodes(Predicate<RedisClusterNode> predicate)
Select nodes by a predicate.default PubSubAsyncNodeSelection<K,V>
replicas()
Deprecated.default PubSubAsyncNodeSelection<K,V>
replicas(Predicate<RedisClusterNode> predicate)
Select all replicas.default PubSubAsyncNodeSelection<K,V>
slaves()
Deprecated.since 5.2, usereplicas()
default PubSubAsyncNodeSelection<K,V>
slaves(Predicate<RedisClusterNode> predicate)
Deprecated.since 5.2, usereplicas(Predicate)
default PubSubAsyncNodeSelection<K,V>
upstream()
Select all upstream nodes.-
Methods inherited from interface io.lettuce.core.api.async.BaseRedisAsyncCommands
dispatch, dispatch, echo, flushCommands, isOpen, ping, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, reset, role, setAutoFlushCommands, waitForReplication
-
Methods inherited from interface io.lettuce.core.api.async.RedisAclAsyncCommands
aclCat, aclCat, aclDeluser, aclDryRun, aclDryRun, aclGenpass, aclGenpass, aclGetuser, aclList, aclLoad, aclLog, aclLog, aclLogReset, aclSave, aclSetuser, aclUsers, aclWhoami
-
Methods inherited from interface io.lettuce.core.api.async.RedisAsyncCommands
auth, auth, select, swapdb
-
Methods inherited from interface io.lettuce.core.cluster.api.async.RedisClusterAsyncCommands
asking, clusterAddSlots, clusterAddSlotsRange, clusterBumpepoch, clusterCountFailureReports, clusterCountKeysInSlot, clusterDelSlots, clusterDelSlotsRange, clusterFailover, clusterFailover, clusterFlushslots, clusterForget, clusterGetKeysInSlot, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicas, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterShards, clusterSlaves, clusterSlots, msetnx, readOnly, readWrite, setTimeout
-
Methods inherited from interface io.lettuce.core.api.async.RedisFunctionAsyncCommands
fcall, fcall, fcallReadOnly, fcallReadOnly, functionDump, functionFlush, functionKill, functionList, functionList, functionLoad, functionLoad, functionRestore, functionRestore
-
Methods inherited from interface io.lettuce.core.api.async.RedisGeoAsyncCommands
geoadd, geoadd, geoadd, geoadd, geoadd, geoadd, geodist, geohash, geopos, georadius, georadius, georadius, georadiusbymember, georadiusbymember, georadiusbymember, geosearch, geosearch, geosearchstore
-
Methods inherited from interface io.lettuce.core.api.async.RedisHashAsyncCommands
hdel, hexists, hget, hgetall, hgetall, hincrby, hincrbyfloat, hkeys, hkeys, hlen, hmget, hmget, hmset, hrandfield, hrandfield, hrandfieldWithvalues, hrandfieldWithvalues, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hset, hset, hsetnx, hstrlen, hvals, hvals
-
Methods inherited from interface io.lettuce.core.api.async.RedisHLLAsyncCommands
pfadd, pfcount, pfmerge
-
Methods inherited from interface io.lettuce.core.api.async.RedisKeyAsyncCommands
copy, copy, del, dump, exists, expire, expire, expire, expire, expireat, expireat, expireat, expireat, expireat, expireat, expiretime, keys, keys, migrate, migrate, move, objectEncoding, objectFreq, objectIdletime, objectRefcount, persist, pexpire, pexpire, pexpire, pexpire, pexpireat, pexpireat, pexpireat, pexpireat, pexpireat, pexpireat, pexpiretime, pttl, randomkey, rename, renamenx, restore, restore, scan, scan, scan, scan, scan, scan, scan, scan, sort, sort, sort, sort, sortReadOnly, sortReadOnly, sortReadOnly, sortReadOnly, sortStore, touch, ttl, type, unlink
-
Methods inherited from interface io.lettuce.core.api.async.RedisListAsyncCommands
blmove, blmove, blmpop, blmpop, blpop, blpop, brpop, brpop, brpoplpush, brpoplpush, lindex, linsert, llen, lmove, lmpop, lpop, lpop, lpos, lpos, lpos, lpos, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpop, rpoplpush, rpush, rpushx
-
Methods inherited from interface io.lettuce.core.pubsub.api.async.RedisPubSubAsyncCommands
psubscribe, punsubscribe, subscribe, unsubscribe
-
Methods inherited from interface io.lettuce.core.api.async.RedisScriptingAsyncCommands
digest, digest, eval, eval, eval, eval, evalReadOnly, evalsha, evalsha, evalshaReadOnly, scriptExists, scriptFlush, scriptFlush, scriptKill, scriptLoad, scriptLoad
-
Methods inherited from interface io.lettuce.core.api.async.RedisServerAsyncCommands
bgrewriteaof, bgsave, clientCaching, clientGetname, clientGetredir, clientId, clientInfo, clientKill, clientKill, clientList, clientList, clientNoEvict, clientPause, clientSetinfo, clientSetname, clientTracking, clientUnblock, command, commandCount, commandInfo, commandInfo, configGet, configGet, configResetstat, configRewrite, configSet, configSet, dbsize, debugCrashAndRecover, debugHtstats, debugObject, debugOom, debugReload, debugRestart, debugSdslen, debugSegfault, flushall, flushall, flushallAsync, flushdb, flushdb, flushdbAsync, info, info, lastsave, memoryUsage, replicaof, replicaofNoOne, save, shutdown, shutdown, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, time
-
Methods inherited from interface io.lettuce.core.api.async.RedisSetAsyncCommands
sadd, scard, sdiff, sdiff, sdiffstore, sinter, sinter, sintercard, sintercard, sinterstore, sismember, smembers, smembers, smismember, smove, spop, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sunion, sunion, sunionstore
-
Methods inherited from interface io.lettuce.core.api.async.RedisSortedSetAsyncCommands
bzmpop, bzmpop, bzmpop, bzmpop, bzpopmax, bzpopmax, bzpopmin, bzpopmin, zadd, zadd, zadd, zadd, zadd, zadd, zaddincr, zaddincr, zcard, zcount, zcount, zcount, zdiff, zdiffstore, zdiffWithScores, zincrby, zinter, zinter, zintercard, zintercard, zinterstore, zinterstore, zinterWithScores, zinterWithScores, zlexcount, zlexcount, zmpop, zmpop, zmscore, zpopmax, zpopmax, zpopmin, zpopmin, zrandmember, zrandmember, zrandmemberWithScores, zrandmemberWithScores, zrange, zrange, zrangebylex, zrangebylex, zrangebylex, zrangebylex, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangestore, zrangestorebylex, zrangestorebyscore, zrangeWithScores, zrangeWithScores, zrank, zrankWithScore, zrem, zremrangebylex, zremrangebylex, zremrangebyrank, zremrangebyscore, zremrangebyscore, zremrangebyscore, zrevrange, zrevrange, zrevrangebylex, zrevrangebylex, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangestore, zrevrangestorebylex, zrevrangestorebyscore, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zrevrankWithScore, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscore, zunion, zunion, zunionstore, zunionstore, zunionWithScores, zunionWithScores
-
Methods inherited from interface io.lettuce.core.api.async.RedisStreamAsyncCommands
xack, xadd, xadd, xadd, xadd, xautoclaim, xclaim, xclaim, xdel, xgroupCreate, xgroupCreate, xgroupCreateconsumer, xgroupDelconsumer, xgroupDestroy, xgroupSetid, xinfoConsumers, xinfoGroups, xinfoStream, xlen, xpending, xpending, xpending, xpending, xrange, xrange, xread, xread, xreadgroup, xreadgroup, xrevrange, xrevrange, xtrim, xtrim, xtrim
-
Methods inherited from interface io.lettuce.core.api.async.RedisStringAsyncCommands
append, bitcount, bitcount, bitfield, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, bitpos, decr, decrby, get, getbit, getdel, getex, getrange, getset, incr, incrby, incrbyfloat, mget, mget, mset, psetex, set, set, setbit, setex, setGet, setGet, setnx, setrange, stralgoLcs, strlen
-
-
-
-
Method Detail
-
getStatefulConnection
StatefulRedisClusterPubSubConnection<K,V> getStatefulConnection()
- Specified by:
getStatefulConnection
in interfaceRedisAsyncCommands<K,V>
- Specified by:
getStatefulConnection
in interfaceRedisPubSubAsyncCommands<K,V>
- Returns:
- the underlying connection.
-
masters
@Deprecated default PubSubAsyncNodeSelection<K,V> masters()
Deprecated.since 6.0 in favor ofupstream()
.Select all upstream nodes.- Returns:
- API with asynchronous executed commands on a selection of upstream cluster nodes.
-
upstream
default PubSubAsyncNodeSelection<K,V> upstream()
Select all upstream nodes.- Returns:
- API with asynchronous executed commands on a selection of upstream cluster nodes.
-
slaves
@Deprecated default PubSubAsyncNodeSelection<K,V> slaves()
Deprecated.since 5.2, usereplicas()
Select all replicas.- Returns:
- API with asynchronous executed commands on a selection of replica cluster nodes.
-
slaves
@Deprecated default PubSubAsyncNodeSelection<K,V> slaves(Predicate<RedisClusterNode> predicate)
Deprecated.since 5.2, usereplicas(Predicate)
Select all replicas.- Parameters:
predicate
- Predicate to filter nodes- Returns:
- API with asynchronous executed commands on a selection of replica cluster nodes.
-
replicas
@Deprecated default PubSubAsyncNodeSelection<K,V> replicas()
Deprecated.Select all replicas.- Returns:
- API with asynchronous executed commands on a selection of replica cluster nodes.
- Since:
- 5.2
-
replicas
default PubSubAsyncNodeSelection<K,V> replicas(Predicate<RedisClusterNode> predicate)
Select all replicas.- Parameters:
predicate
- Predicate to filter nodes- Returns:
- API with asynchronous executed commands on a selection of replica cluster nodes.
- Since:
- 5.2
-
all
default PubSubAsyncNodeSelection<K,V> all()
Select all known cluster nodes.- Returns:
- API with asynchronous executed commands on a selection of all cluster nodes.
-
nodes
PubSubAsyncNodeSelection<K,V> nodes(Predicate<RedisClusterNode> predicate)
Select nodes by a predicate.- Parameters:
predicate
- Predicate to filter nodes- Returns:
- API with asynchronous executed commands on a selection of cluster nodes matching
predicate
-
-