public class SimNodeStateProvider extends Object implements NodeStateProvider
NodeStateProvider
.
Note: in order to setup node-level metrics use simSetNodeValues(String, Map)
. However, in order
to setup core-level metrics use SimClusterStateProvider.simSetCollectionValue(String, String, Object, boolean, boolean)
.Constructor and Description |
---|
SimNodeStateProvider(LiveNodesSet liveNodesSet,
SimDistribStateManager stateManager,
SimClusterStateProvider clusterStateProvider,
Map<String,Map<String,Object>> nodeValues) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Map<String,Object> |
getNodeValues(String node,
Collection<String> tags) |
Map<String,Map<String,List<ReplicaInfo>>> |
getReplicaInfo(String node,
Collection<String> keys) |
Map<String,Object> |
getReplicaMetricsValues(String node,
Collection<String> tags)
Simulate getting replica metrics values.
|
void |
simAddNodeValue(String node,
String key,
Object value)
Add a node value, creating a list of values if necessary.
|
Map<String,Map<String,Object>> |
simGetAllNodeValues()
Get all node values.
|
Set<String> |
simGetDeadNodes()
Return a set of nodes that are not live but their values are still present.
|
Object |
simGetNodeValue(String node,
String key)
Get a node value
|
void |
simRemoveDeadNodes()
Remove values that correspond to dead nodes.
|
void |
simRemoveNodeValues(String node)
Remove node values.
|
void |
simSetNodeValue(String node,
String key,
Object value)
Set a node value, replacing any previous value.
|
void |
simSetNodeValues(String node,
Map<String,Object> values)
Set node values.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isClosed
public SimNodeStateProvider(LiveNodesSet liveNodesSet, SimDistribStateManager stateManager, SimClusterStateProvider clusterStateProvider, Map<String,Map<String,Object>> nodeValues)
public Object simGetNodeValue(String node, String key)
node
- node idkey
- property namepublic void simSetNodeValues(String node, Map<String,Object> values) throws InterruptedException
node
- node idvalues
- values.InterruptedException
public void simSetNodeValue(String node, String key, Object value) throws InterruptedException
node
- node idkey
- property namevalue
- property valueInterruptedException
public void simAddNodeValue(String node, String key, Object value) throws InterruptedException
node
- node idkey
- property namevalue
- property value.InterruptedException
public void simRemoveNodeValues(String node) throws InterruptedException
node
- node idInterruptedException
public void simRemoveDeadNodes() throws InterruptedException
InterruptedException
public Set<String> simGetDeadNodes()
public Map<String,Map<String,Object>> simGetAllNodeValues()
public Map<String,Object> getReplicaMetricsValues(String node, Collection<String> tags)
SimClusterStateProvider.simSetCollectionValue(String, String, Object, boolean, boolean)
and
similar methods.node
- node idtags
- metrics namespublic Map<String,Object> getNodeValues(String node, Collection<String> tags)
getNodeValues
in interface NodeStateProvider
public Map<String,Map<String,List<ReplicaInfo>>> getReplicaInfo(String node, Collection<String> keys)
getReplicaInfo
in interface NodeStateProvider
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.