public interface ClusterOperations<K,V>
RedisClusterNode
can be obtained from
a connection
or it can be
constructed using either host
and RedisNode.getPort()
or the
node Id
.Modifier and Type | Method and Description |
---|---|
void |
addSlots(RedisClusterNode node,
int... slots)
Add slots to given node;
|
void |
addSlots(RedisClusterNode node,
RedisClusterNode.SlotRange range)
Add slots in
RedisClusterNode.SlotRange to given node. |
void |
bgReWriteAof(RedisClusterNode node)
Start an Append Only File rewrite process on given node.
|
void |
bgSave(RedisClusterNode node)
Start background saving of db on given node.
|
void |
flushDb(RedisClusterNode node)
Flush db on node.
|
void |
forget(RedisClusterNode node)
Remove the node from the cluster.
|
Collection<RedisClusterNode> |
getSlaves(RedisClusterNode node) |
Set<K> |
keys(RedisClusterNode node,
K pattern)
Get all keys located at given node.
|
void |
meet(RedisClusterNode node)
Add the node to cluster.
|
String |
ping(RedisClusterNode node)
Ping the given node;
|
K |
randomKey(RedisClusterNode node)
Get a random key from the range served by the given node.
|
void |
reshard(RedisClusterNode source,
int slot,
RedisClusterNode target)
Move slot assignment from one source to target node and copy keys associated with the slot.
|
void |
save(RedisClusterNode node)
Synchronous save current db snapshot on server.
|
void |
shutdown(RedisClusterNode node)
Shutdown given node.
|
Set<K> keys(RedisClusterNode node, K pattern)
node
- must not be null.pattern
- RedisKeyCommands.keys(byte[])
String ping(RedisClusterNode node)
node
- must not be null.RedisConnectionCommands.ping()
K randomKey(RedisClusterNode node)
node
- must not be null.RedisKeyCommands.randomKey()
void addSlots(RedisClusterNode node, int... slots)
node
- must not be null.slots
- must not be null.void addSlots(RedisClusterNode node, RedisClusterNode.SlotRange range)
RedisClusterNode.SlotRange
to given node.node
- must not be null.range
- must not be null.void bgReWriteAof(RedisClusterNode node)
node
- must not be null.RedisServerCommands.bgReWriteAof()
void bgSave(RedisClusterNode node)
node
- must not be null.RedisServerCommands.bgSave()
void meet(RedisClusterNode node)
node
- must not be null.void forget(RedisClusterNode node)
node
- must not be null.void flushDb(RedisClusterNode node)
node
- must not be null.RedisServerCommands.flushDb()
Collection<RedisClusterNode> getSlaves(RedisClusterNode node)
node
- must not be null.void save(RedisClusterNode node)
node
- must not be null.RedisServerCommands.save()
void shutdown(RedisClusterNode node)
node
- must not be null.RedisServerCommands.shutdown()
void reshard(RedisClusterNode source, int slot, RedisClusterNode target)
source
- must not be null.slot
- target
- must not be null.Copyright © 2011-2015–2017 Pivotal Software, Inc.. All rights reserved.