com.lambdaworks.redis.cluster

Interface RedisAdvancedClusterAsyncConnection<K,V>

All Superinterfaces:

AutoCloseable, BaseRedisAsyncConnection<K,V>, Closeable, RedisClusterAsyncConnection<K,V>, RedisGeoAsyncConnection<K,V>, RedisHashesAsyncConnection<K,V>, RedisHLLAsyncConnection<K,V>, RedisKeysAsyncConnection<K,V>, RedisListsAsyncConnection<K,V>, RedisScriptingAsyncConnection<K,V>, RedisServerAsyncConnection<K,V>, RedisSetsAsyncConnection<K,V>, RedisSortedSetsAsyncConnection<K,V>, RedisStringsAsyncConnection<K,V>

All Known Implementing Classes:

RedisAdvancedClusterAsyncConnectionImpl

public interface RedisAdvancedClusterAsyncConnection<K,V>
extends RedisClusterAsyncConnection<K,V>

Advanced asynchronous cluster API.

Since:

3.3

Author:

Mark Paluch

Method Summary

Modifier and Type	Method and Description
RedisClusterAsyncConnection<K,V>	getConnection(String nodeId) Retrieve a connection to the specified cluster node using the nodeId.
RedisClusterAsyncConnection<K,V>	getConnection(String host, int port) Retrieve a connection to the specified cluster node using the nodeId.
ReadFrom	getReadFrom() Gets the ReadFrom setting for this connection.
void	setReadFrom(ReadFrom readFrom) Set from which nodes data is read.

Methods inherited from interface com.lambdaworks.redis.RedisClusterAsyncConnection

asking, close, clusterAddSlots, clusterBumpepoch, clusterCountFailureReports, clusterCountKeysInSlot, clusterDelSlots, clusterFailover, clusterFlushslots, clusterForget, clusterGetKeysInSlot, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterSlaves, clusterSlots, readOnly, readWrite

Methods inherited from interface com.lambdaworks.redis.RedisHashesAsyncConnection

hdel, hexists, hget, hgetall, hgetall, hincrby, hincrbyfloat, hkeys, hkeys, hlen, hmget, hmget, hmset, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hset, hsetnx, hstrlen, hvals, hvals

Methods inherited from interface com.lambdaworks.redis.RedisKeysAsyncConnection

del, dump, exists, exists, expire, expireat, expireat, keys, keys, migrate, migrate, move, objectEncoding, objectIdletime, objectRefcount, persist, pexpire, pexpireat, pexpireat, pttl, randomkey, rename, renamenx, restore, scan, scan, scan, scan, scan, scan, scan, scan, sort, sort, sort, sort, sortStore, touch, ttl, type, unlink

Methods inherited from interface com.lambdaworks.redis.RedisStringsAsyncConnection

append, bitcount, bitcount, bitfield, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, decr, decrby, get, getbit, getrange, getset, incr, incrby, incrbyfloat, mget, mget, mset, msetnx, psetex, set, set, setbit, setex, setnx, setrange, strlen

Methods inherited from interface com.lambdaworks.redis.RedisListsAsyncConnection

blpop, brpop, brpoplpush, lindex, linsert, llen, lpop, lpush, lpushx, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpoplpush, rpush, rpushx, rpushx

Methods inherited from interface com.lambdaworks.redis.RedisSetsAsyncConnection

sadd, scard, sdiff, sdiff, sdiffstore, sinter, sinter, sinterstore, sismember, smembers, smembers, smove, spop, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sunion, sunion, sunionstore

Methods inherited from interface com.lambdaworks.redis.RedisSortedSetsAsyncConnection

zadd, zadd, zadd, zadd, zaddincr, zcard, zcount, zcount, zincrby, zinterstore, zinterstore, zlexcount, zrange, zrange, zrangebylex, zrangebylex, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangeWithScores, zrangeWithScores, zrank, zrem, zremrangebylex, zremrangebyrank, zremrangebyscore, zremrangebyscore, zrevrange, zrevrange, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscore, zunionstore, zunionstore

Methods inherited from interface com.lambdaworks.redis.RedisScriptingAsyncConnection

eval, eval, evalsha, evalsha, scriptExists, scriptFlush, scriptKill, scriptLoad

Methods inherited from interface com.lambdaworks.redis.RedisServerAsyncConnection

bgrewriteaof, bgsave, clientGetname, clientKill, clientKill, clientList, clientPause, clientSetname, command, commandCount, commandInfo, commandInfo, configGet, configResetstat, configRewrite, configSet, dbsize, debugHtstats, debugObject, debugOom, debugSegfault, flushall, flushallAsync, flushdb, flushdbAsync, info, info, lastsave, save, shutdown, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, sync, time

Methods inherited from interface com.lambdaworks.redis.RedisHLLAsyncConnection

pfadd, pfcount, pfmerge

Methods inherited from interface com.lambdaworks.redis.RedisGeoAsyncConnection

geoadd, geoadd, geodist, geohash, geopos, georadius, georadius, georadius, georadiusbymember, georadiusbymember, georadiusbymember

Methods inherited from interface com.lambdaworks.redis.BaseRedisAsyncConnection

digest, discard, dispatch, dispatch, echo, exec, flushCommands, isOpen, multi, ping, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, role, setAutoFlushCommands, unwatch, waitForReplication, watch

Method Detail

getConnection

RedisClusterAsyncConnection<K,V> getConnection(String nodeId)

Retrieve a connection to the specified cluster node using the nodeId. Host and port are looked up in the node list. This connection is bound to the node id. Once the cluster topology view is updated, the connection will try to reconnect the to the node with the specified nodeId, that behavior can also lead to a closed connection once the node with the specified nodeId is no longer part of the cluster. Do not close the connections. Otherwise, unpredictable behavior will occur. The nodeId must be part of the cluster and is validated against the current topology view in Partitions. In contrast to the RedisAdvancedClusterAsyncConnection, node-connections do not route commands to other cluster nodes.

Parameters:

nodeId - the node Id

Returns:

a connection to the requested cluster node

Throws:

RedisException - if the requested node identified by nodeId is not part of the cluster

getConnection

RedisClusterAsyncConnection<K,V> getConnection(String host,
                                               int port)

Retrieve a connection to the specified cluster node using the nodeId. This connection is bound to a host and port. Updates to the cluster topology view can close the connection once the host, identified by host and port, are no longer part of the cluster. Do not close the connections. Otherwise, unpredictable behavior will occur. The node must be part of the cluster and host/port are validated (exact check) against the current topology view in Partitions. In contrast to the RedisAdvancedClusterAsyncConnection, node-connections do not route commands to other cluster nodes.

Parameters:

host - the host

port - the port

Returns:

a connection to the requested cluster node

Throws:

RedisException - if the requested node identified by host and port is not part of the cluster

setReadFrom

void setReadFrom(ReadFrom readFrom)

Set from which nodes data is read. The setting is used as default for read operations on this connection. See the documentation for ReadFrom for more information.

Parameters:

readFrom - the read from setting, must not be null

getReadFrom

ReadFrom getReadFrom()

Gets the ReadFrom setting for this connection. Defaults to ReadFrom.MASTER if not set.

Returns:

the read from setting or null