K
- V
- public class DefaultClusterOperations<K,V> extends Object implements ClusterOperations<K,V>
ClusterOperations
implementation.Constructor and Description |
---|
DefaultClusterOperations(RedisTemplate<K,V> template)
Creates new
DefaultClusterOperations delegating to the given RedisTemplate . |
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.
|
<T> T |
execute(RedisClusterCallback<T> callback)
Executed wrapped command upon
RedisClusterConnection . |
void |
flushDb(RedisClusterNode node)
Flush db on node.
|
void |
forget(RedisClusterNode node)
Remove the node from the cluster.
|
RedisOperations<K,V> |
getOperations() |
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.
|
public DefaultClusterOperations(RedisTemplate<K,V> template)
DefaultClusterOperations
delegating to the given RedisTemplate
.template
- must not be null.public Set<K> keys(RedisClusterNode node, K pattern)
ClusterOperations
keys
in interface ClusterOperations<K,V>
node
- must not be null.RedisKeyCommands.keys(byte[])
public K randomKey(RedisClusterNode node)
ClusterOperations
randomKey
in interface ClusterOperations<K,V>
node
- must not be null.RedisKeyCommands.randomKey()
public String ping(RedisClusterNode node)
ClusterOperations
ping
in interface ClusterOperations<K,V>
node
- must not be null.RedisConnectionCommands.ping()
public void addSlots(RedisClusterNode node, int... slots)
ClusterOperations
addSlots
in interface ClusterOperations<K,V>
node
- must not be null.slots
- must not be null.public void addSlots(RedisClusterNode node, RedisClusterNode.SlotRange range)
ClusterOperations
RedisClusterNode.SlotRange
to given node.addSlots
in interface ClusterOperations<K,V>
node
- must not be null.range
- must not be null.public void bgReWriteAof(RedisClusterNode node)
ClusterOperations
bgReWriteAof
in interface ClusterOperations<K,V>
node
- must not be null.RedisServerCommands.bgReWriteAof()
public void bgSave(RedisClusterNode node)
ClusterOperations
bgSave
in interface ClusterOperations<K,V>
node
- must not be null.RedisServerCommands.bgSave()
public void meet(RedisClusterNode node)
ClusterOperations
meet
in interface ClusterOperations<K,V>
node
- must not be null.public void forget(RedisClusterNode node)
ClusterOperations
forget
in interface ClusterOperations<K,V>
node
- must not be null.public void flushDb(RedisClusterNode node)
ClusterOperations
flushDb
in interface ClusterOperations<K,V>
node
- must not be null.RedisServerCommands.flushDb()
public Collection<RedisClusterNode> getSlaves(RedisClusterNode node)
getSlaves
in interface ClusterOperations<K,V>
node
- must not be null.public void save(RedisClusterNode node)
ClusterOperations
save
in interface ClusterOperations<K,V>
node
- must not be null.RedisServerCommands.save()
public void shutdown(RedisClusterNode node)
ClusterOperations
shutdown
in interface ClusterOperations<K,V>
node
- must not be null.RedisServerCommands.shutdown()
public void reshard(RedisClusterNode source, int slot, RedisClusterNode target)
ClusterOperations
reshard
in interface ClusterOperations<K,V>
source
- must not be null.target
- must not be null.public <T> T execute(RedisClusterCallback<T> callback)
RedisClusterConnection
.callback
- public RedisOperations<K,V> getOperations()
Copyright © 2011–2018 Pivotal Software, Inc.. All rights reserved.