Interface RedisClusterPubSubReactiveCommands<K,V>
-
- Type Parameters:
K
- Key type.V
- Value type.
- All Superinterfaces:
BaseRedisReactiveCommands<K,V>
,RedisAclReactiveCommands<K,V>
,RedisClusterReactiveCommands<K,V>
,RedisFunctionReactiveCommands<K,V>
,RedisGeoReactiveCommands<K,V>
,RedisHashReactiveCommands<K,V>
,RedisHLLReactiveCommands<K,V>
,RedisKeyReactiveCommands<K,V>
,RedisListReactiveCommands<K,V>
,RedisPubSubReactiveCommands<K,V>
,RedisReactiveCommands<K,V>
,RedisScriptingReactiveCommands<K,V>
,RedisServerReactiveCommands<K,V>
,RedisSetReactiveCommands<K,V>
,RedisSortedSetReactiveCommands<K,V>
,RedisStreamReactiveCommands<K,V>
,RedisStringReactiveCommands<K,V>
,RedisTransactionalReactiveCommands<K,V>
- All Known Implementing Classes:
RedisClusterPubSubReactiveCommandsImpl
public interface RedisClusterPubSubReactiveCommands<K,V> extends RedisPubSubReactiveCommands<K,V>
Reactive and thread-safe Redis Cluster PubSub API. Operations are executed either on the main connection or aPubSubReactiveNodeSelection
.- Since:
- 4.4
- Author:
- Mark Paluch
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods Modifier and Type Method Description default PubSubReactiveNodeSelection<K,V>
all()
Select all known cluster nodes.StatefulRedisClusterPubSubConnection<K,V>
getStatefulConnection()
Deprecated.default PubSubReactiveNodeSelection<K,V>
masters()
Deprecated.since 6.0 in favor ofupstream()
.PubSubReactiveNodeSelection<K,V>
nodes(Predicate<RedisClusterNode> predicate)
Select nodes by a predicate.default PubSubReactiveNodeSelection<K,V>
replicas()
Select all replicas.default PubSubReactiveNodeSelection<K,V>
replicas(Predicate<RedisClusterNode> predicate)
Select all replicas.default PubSubReactiveNodeSelection<K,V>
slaves()
Deprecated.since 5.2, usereplicas()
.default PubSubReactiveNodeSelection<K,V>
slaves(Predicate<RedisClusterNode> predicate)
Deprecated.since 5.2, usereplicas()
.default PubSubReactiveNodeSelection<K,V>
upstream()
Select all upstream nodes.-
Methods inherited from interface io.lettuce.core.api.reactive.BaseRedisReactiveCommands
dispatch, dispatch, echo, flushCommands, isOpen, ping, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, reset, role, setAutoFlushCommands, waitForReplication
-
Methods inherited from interface io.lettuce.core.api.reactive.RedisAclReactiveCommands
aclCat, aclCat, aclDeluser, aclDryRun, aclDryRun, aclGenpass, aclGenpass, aclGetuser, aclList, aclLoad, aclLog, aclLog, aclLogReset, aclSave, aclSetuser, aclUsers, aclWhoami
-
Methods inherited from interface io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands
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, readOnly, readWrite, setTimeout
-
Methods inherited from interface io.lettuce.core.api.reactive.RedisFunctionReactiveCommands
fcall, fcall, fcallReadOnly, fcallReadOnly, functionDump, functionFlush, functionKill, functionList, functionList, functionLoad, functionLoad, functionRestore, functionRestore
-
Methods inherited from interface io.lettuce.core.api.reactive.RedisGeoReactiveCommands
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.reactive.RedisHashReactiveCommands
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.reactive.RedisHLLReactiveCommands
pfadd, pfcount, pfmerge
-
Methods inherited from interface io.lettuce.core.api.reactive.RedisKeyReactiveCommands
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.reactive.RedisListReactiveCommands
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.reactive.RedisPubSubReactiveCommands
observeChannels, observeChannels, observePatterns, observePatterns, psubscribe, punsubscribe, subscribe, unsubscribe
-
Methods inherited from interface io.lettuce.core.api.reactive.RedisReactiveCommands
auth, auth, select, swapdb
-
Methods inherited from interface io.lettuce.core.api.reactive.RedisScriptingReactiveCommands
digest, digest, eval, eval, eval, eval, evalReadOnly, evalsha, evalsha, evalshaReadOnly, scriptExists, scriptFlush, scriptFlush, scriptKill, scriptLoad, scriptLoad
-
Methods inherited from interface io.lettuce.core.api.reactive.RedisServerReactiveCommands
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.reactive.RedisSetReactiveCommands
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.reactive.RedisSortedSetReactiveCommands
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.reactive.RedisStreamReactiveCommands
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.reactive.RedisStringReactiveCommands
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, msetnx, psetex, set, set, setbit, setex, setGet, setGet, setnx, setrange, stralgoLcs, strlen
-
-
-
-
Method Detail
-
getStatefulConnection
@Deprecated StatefulRedisClusterPubSubConnection<K,V> getStatefulConnection()
Deprecated.- Specified by:
getStatefulConnection
in interfaceRedisPubSubReactiveCommands<K,V>
- Specified by:
getStatefulConnection
in interfaceRedisReactiveCommands<K,V>
- Returns:
- the underlying connection.
- Since:
- 6.2, will be removed with Lettuce 7 to avoid exposing the underlying connection.
-
masters
@Deprecated default PubSubReactiveNodeSelection<K,V> masters()
Deprecated.since 6.0 in favor ofupstream()
.Select all upstream nodes.- Returns:
- API with reactive executed commands on a selection of upstream cluster nodes.
-
upstream
default PubSubReactiveNodeSelection<K,V> upstream()
Select all upstream nodes.- Returns:
- API with reactive executed commands on a selection of upstream cluster nodes.
-
slaves
@Deprecated default PubSubReactiveNodeSelection<K,V> slaves()
Deprecated.since 5.2, usereplicas()
.Select all replicas.- Returns:
- API with reactive executed commands on a selection of replica cluster nodes.
-
slaves
@Deprecated default PubSubReactiveNodeSelection<K,V> slaves(Predicate<RedisClusterNode> predicate)
Deprecated.since 5.2, usereplicas()
.Select all replicas.- Parameters:
predicate
- Predicate to filter nodes- Returns:
- API with reactive executed commands on a selection of replica cluster nodes.
-
replicas
default PubSubReactiveNodeSelection<K,V> replicas()
Select all replicas.- Returns:
- API with reactive executed commands on a selection of replica cluster nodes.
- Since:
- 5.2
-
replicas
default PubSubReactiveNodeSelection<K,V> replicas(Predicate<RedisClusterNode> predicate)
Select all replicas.- Parameters:
predicate
- Predicate to filter nodes- Returns:
- API with reactive executed commands on a selection of replica cluster nodes.
- Since:
- 5.2
-
all
default PubSubReactiveNodeSelection<K,V> all()
Select all known cluster nodes.- Returns:
- API with reactive executed commands on a selection of all cluster nodes.
-
nodes
PubSubReactiveNodeSelection<K,V> nodes(Predicate<RedisClusterNode> predicate)
Select nodes by a predicate.- Parameters:
predicate
- Predicate to filter nodes- Returns:
- API with reactive executed commands on a selection of cluster nodes matching
predicate
-
-