public interface RedisClusterConnection extends RedisConnection, RedisClusterCommands
RedisClusterConnection
allows sending commands to dedicated nodes within the cluster. A
RedisClusterNode
can be obtained from RedisClusterCommands.clusterGetNodes()
or it can be constructed using either
host
and RedisNode.getPort()
or the node Id
.RedisStringCommands.BitOperation, RedisStringCommands.SetOption
RedisListCommands.Position
RedisZSetCommands.Aggregate, RedisZSetCommands.Limit, RedisZSetCommands.Range, RedisZSetCommands.Tuple
RedisServerCommands.MigrateOption, RedisServerCommands.ShutdownOption
RedisGeoCommands.DistanceUnit, RedisGeoCommands.GeoLocation<T>, RedisGeoCommands.GeoRadiusCommandArgs
RedisClusterCommands.AddSlots
Modifier and Type | Method and Description |
---|---|
void |
bgReWriteAof(RedisClusterNode node) |
void |
bgSave(RedisClusterNode node) |
Long |
dbSize(RedisClusterNode node) |
void |
flushAll(RedisClusterNode node) |
void |
flushDb(RedisClusterNode node) |
List<RedisClientInfo> |
getClientList(RedisClusterNode node) |
List<String> |
getConfig(RedisClusterNode node,
String pattern) |
Properties |
info(RedisClusterNode node) |
Properties |
info(RedisClusterNode node,
String section) |
Set<byte[]> |
keys(RedisClusterNode node,
byte[] pattern) |
Long |
lastSave(RedisClusterNode node) |
String |
ping(RedisClusterNode node) |
byte[] |
randomKey(RedisClusterNode node) |
void |
resetConfigStats(RedisClusterNode node) |
void |
save(RedisClusterNode node) |
void |
setConfig(RedisClusterNode node,
String param,
String value) |
void |
shutdown(RedisClusterNode node) |
Long |
time(RedisClusterNode node) |
close, closePipeline, getNativeConnection, getSentinelConnection, isClosed, isPipelined, isQueueing, openPipeline
execute
del, dump, exists, expire, expireAt, keys, move, persist, pExpire, pExpireAt, pTtl, pTtl, randomKey, rename, renameNX, restore, scan, sort, sort, ttl, ttl, type
append, bitCount, bitCount, bitOp, decr, decrBy, get, getBit, getRange, getSet, incr, incrBy, incrBy, mGet, mSet, mSetNX, pSetEx, set, set, setBit, setEx, setNX, setRange, strLen
bLPop, bRPop, bRPopLPush, lIndex, lInsert, lLen, lPop, lPush, lPushX, lRange, lRem, lSet, lTrim, rPop, rPopLPush, rPush, rPushX
sAdd, sCard, sDiff, sDiffStore, sInter, sInterStore, sIsMember, sMembers, sMove, sPop, sRandMember, sRandMember, sRem, sScan, sUnion, sUnionStore
zAdd, zAdd, zCard, zCount, zCount, zIncrBy, zInterStore, zInterStore, zRange, zRangeByLex, zRangeByLex, zRangeByLex, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeWithScores, zRank, zRem, zRemRange, zRemRangeByScore, zRemRangeByScore, zRevRange, zRevRangeByScore, zRevRangeByScore, zRevRangeByScore, zRevRangeByScore, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores, zRevRangeWithScores, zRevRank, zScan, zScore, zUnionStore, zUnionStore
hDel, hExists, hGet, hGetAll, hIncrBy, hIncrBy, hKeys, hLen, hMGet, hMSet, hScan, hSet, hSetNX, hVals
discard, exec, multi, unwatch, watch
getSubscription, isSubscribed, pSubscribe, publish, subscribe
echo, ping, select
bgReWriteAof, bgSave, bgWriteAof, dbSize, flushAll, flushDb, getClientList, getClientName, getConfig, info, info, killClient, lastSave, migrate, migrate, resetConfigStats, save, setClientName, setConfig, shutdown, shutdown, slaveOf, slaveOfNoOne, time
eval, evalSha, evalSha, scriptExists, scriptFlush, scriptKill, scriptLoad
geoAdd, geoAdd, geoAdd, geoAdd, geoDist, geoDist, geoHash, geoPos, geoRadius, geoRadius, geoRadiusByMember, geoRadiusByMember, geoRadiusByMember, geoRemove
pfAdd, pfCount, pfMerge
clusterAddSlots, clusterAddSlots, clusterCountKeysInSlot, clusterDeleteSlots, clusterDeleteSlotsInRange, clusterForget, clusterGetClusterInfo, clusterGetKeysInSlot, clusterGetMasterSlaveMap, clusterGetNodeForKey, clusterGetNodeForSlot, clusterGetNodes, clusterGetSlaves, clusterGetSlotForKey, clusterMeet, clusterReplicate, clusterSetSlot
String ping(RedisClusterNode node)
node
- must not be null.RedisConnectionCommands.ping()
void bgReWriteAof(RedisClusterNode node)
node
- must not be null.RedisServerCommands.bgReWriteAof()
void bgSave(RedisClusterNode node)
node
- must not be null.RedisServerCommands.bgSave()
Long lastSave(RedisClusterNode node)
node
- must not be null.RedisServerCommands.lastSave()
void save(RedisClusterNode node)
node
- must not be null.RedisServerCommands.save()
Long dbSize(RedisClusterNode node)
node
- must not be null.RedisServerCommands.dbSize()
void flushDb(RedisClusterNode node)
node
- must not be null.RedisServerCommands.flushDb()
void flushAll(RedisClusterNode node)
node
- must not be null.RedisServerCommands.flushAll()
Properties info(RedisClusterNode node)
node
- must not be null.RedisServerCommands.info()
Properties info(RedisClusterNode node, String section)
node
- must not be null.section
- RedisServerCommands.info(String)
Set<byte[]> keys(RedisClusterNode node, byte[] pattern)
node
- must not be null.pattern
- must not be null.RedisKeyCommands.keys(byte[])
byte[] randomKey(RedisClusterNode node)
node
- must not be null.RedisKeyCommands.randomKey()
void shutdown(RedisClusterNode node)
node
- must not be null.RedisServerCommands.shutdown()
List<String> getConfig(RedisClusterNode node, String pattern)
node
- must not be null.pattern
- RedisServerCommands.getConfig(String)
void setConfig(RedisClusterNode node, String param, String value)
node
- must not be null.param
- value
- RedisServerCommands.setConfig(String, String)
void resetConfigStats(RedisClusterNode node)
node
- must not be null.RedisServerCommands.resetConfigStats()
Long time(RedisClusterNode node)
node
- must not be null.RedisServerCommands.time()
List<RedisClientInfo> getClientList(RedisClusterNode node)
node
- must not be null.RedisServerCommands.getClientList()
Copyright © 2011-2016–2016 Pivotal Software, Inc.. All rights reserved.