voldemort.cluster.failuredetector
Class BasicStoreVerifier<K,V,T>

java.lang.Object
  voldemort.cluster.failuredetector.BasicStoreVerifier<K,V,T>

All Implemented Interfaces:

StoreVerifier

public class BasicStoreVerifier<K,V,T>
extends java.lang.Object
implements StoreVerifier

BasicStoreVerifier is used to test Node->Store mappings when the mappings are already present at the time of FailureDetector implementation creation. This is usually (always) in the case of tests rather than running "live."

Field Summary

protected java.util.Map<java.lang.Integer,Store<K,V,T>>

stores

Fields inherited from interface voldemort.cluster.failuredetector.StoreVerifier

KEY

Constructor Summary

BasicStoreVerifier(java.util.Map<java.lang.Integer,Store<K,V,T>> stores, K key)

Method Summary

void	flushCachedStores() Flushes the cached stores if any
void	verifyStore(Node node) Verifies the ability to connect to a Store for this node.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

stores

protected final java.util.Map<java.lang.Integer,Store<K,V,T>> stores

Constructor Detail

BasicStoreVerifier

public BasicStoreVerifier(java.util.Map<java.lang.Integer,Store<K,V,T>> stores,
                          K key)

Method Detail

verifyStore

public void verifyStore(Node node)
                 throws UnreachableStoreException,
                        VoldemortException

Description copied from interface: StoreVerifier

Verifies the ability to connect to a Store for this node.

Specified by:

verifyStore in interface StoreVerifier

Parameters:

node - Node to test

Throws:

UnreachableStoreException

VoldemortException

flushCachedStores

public void flushCachedStores()

Description copied from interface: StoreVerifier

Flushes the cached stores if any

Specified by:

flushCachedStores in interface StoreVerifier