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)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Deprecated.
|
Map<String,Object> |
getNodeValues(String node,
Collection<String> tags)
Deprecated.
|
Map<String,Map<String,List<ReplicaInfo>>> |
getReplicaInfo(String node,
Collection<String> keys)
Deprecated.
|
Map<String,Object> |
getReplicaMetricsValues(String node,
Collection<String> tags)
Deprecated.
Simulate getting replica metrics values.
|
void |
simAddNodeValue(String node,
String key,
Object value)
Deprecated.
Add a node value, creating a list of values if necessary.
|
Map<String,Map<String,Object>> |
simGetAllNodeValues()
Deprecated.
Get all node values.
|
Set<String> |
simGetDeadNodes()
Deprecated.
Return a set of nodes that are not live but their values are still present.
|
Object |
simGetNodeValue(String node,
String key)
Deprecated.
Get a node value
|
Map<String,Object> |
simGetNodeValues(String node)
Deprecated.
Get all values for a selected node.
|
void |
simRemoveDeadNodes()
Deprecated.
Remove values that correspond to dead nodes.
|
void |
simRemoveNodeValues(String node)
Deprecated.
Remove node values.
|
void |
simSetNodeValue(String node,
String key,
Object value)
Deprecated.
Set a node value, replacing any previous value.
|
void |
simSetNodeValues(String node,
Map<String,Object> values)
Deprecated.
Set node values.
|
Object |
simUpdateNodeValue(String node,
String key,
Function<Object,Object> updater)
Deprecated.
Atomically update a node value.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitisClosedpublic 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 Object simUpdateNodeValue(String node, String key, Function<Object,Object> updater) throws InterruptedException
node - node idkey - property nameupdater - updater functionInterruptedExceptionpublic void simSetNodeValues(String node, Map<String,Object> values) throws InterruptedException
node - node idvalues - values.InterruptedExceptionpublic void simSetNodeValue(String node, String key, Object value) throws InterruptedException
node - node idkey - property namevalue - property valueInterruptedExceptionpublic void simAddNodeValue(String node, String key, Object value) throws InterruptedException
node - node idkey - property namevalue - property value.InterruptedExceptionpublic void simRemoveNodeValues(String node) throws InterruptedException
node - node idInterruptedExceptionpublic void simRemoveDeadNodes()
throws InterruptedException
InterruptedExceptionpublic Set<String> simGetDeadNodes()
public Map<String,Map<String,Object>> simGetAllNodeValues()
public Map<String,Object> simGetNodeValues(String node)
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 NodeStateProviderpublic Map<String,Map<String,List<ReplicaInfo>>> getReplicaInfo(String node, Collection<String> keys)
getReplicaInfo in interface NodeStateProviderpublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableIOExceptionCopyright © 2000-2021 Apache Software Foundation. All Rights Reserved.