Uses of Interface
voldemort.cluster.failuredetector.FailureDetector

Packages that use FailureDetector
voldemort.client The user facing interface to Voldemort. 
voldemort.cluster.failuredetector Classes associated with client side failure detectors. 
voldemort.server.scheduler.slop The background jobs associated with the slop store. 
voldemort.store.rebalancing Server side wrapper stores used for redirection during rebalancing. 
voldemort.store.routed A store implmentation that handles routing to nodes, and repairing obsolete values detected on those nodes. 
voldemort.store.routed.action Classes representing various states for the state based routing stores. 
voldemort.store.slop A store implementation that falls back on storing values in additional nodes not in the preference list when nodes are unavailable. 
 

Uses of FailureDetector in voldemort.client
 

Fields in voldemort.client declared as FailureDetector
protected  FailureDetector AbstractStoreClientFactory.failureDetector
           
 

Methods in voldemort.client that return FailureDetector
 FailureDetector AbstractStoreClientFactory.getFailureDetector()
           
 FailureDetector MockStoreClientFactory.getFailureDetector()
           
 FailureDetector StoreClientFactory.getFailureDetector()
          Returns the FailureDetector specific to the cluster against which this client factory is based.
 FailureDetector CachingStoreClientFactory.getFailureDetector()
           
protected abstract  FailureDetector AbstractStoreClientFactory.initFailureDetector(ClientConfig config, Cluster cluster)
           
protected  FailureDetector SocketStoreClientFactory.initFailureDetector(ClientConfig config, Cluster cluster)
           
protected  FailureDetector HttpStoreClientFactory.initFailureDetector(ClientConfig config, Cluster cluster)
           
 

Methods in voldemort.client with parameters of type FailureDetector
 SystemStoreClient<K,V> SystemStoreClientFactory.createSystemStore(java.lang.String storeName, java.lang.String clusterXml, FailureDetector fd)
           
 void SystemStoreRepository.createSystemStores(ClientConfig config, java.lang.String clusterXml, FailureDetector fd)
           
<K,V,T> Store<K,V,T>
AbstractStoreClientFactory.getRawStore(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver, java.lang.String customStoresXml, java.lang.String clusterXmlString, FailureDetector fd)
           
<K,V,T> Store<K,V,T>
SocketStoreClientFactory.getSystemStore(java.lang.String storeName, java.lang.String clusterXml, FailureDetector fd)
           
 

Uses of FailureDetector in voldemort.cluster.failuredetector
 

Classes in voldemort.cluster.failuredetector that implement FailureDetector
 class AbstractFailureDetector
          AbstractFailureDetector serves as a building block for FailureDetector implementations.
 class AsyncRecoveryFailureDetector
          AsyncRecoveryFailureDetector detects failures and then attempts to contact the failing node's Store to determine availability.
 class BannagePeriodFailureDetector
          Deprecated. 
 class NoopFailureDetector
          NoopFailureDetector is used for testing classes which don't actually need a working FailureDetector ;)
 class ThresholdFailureDetector
          ThresholdFailureDetector builds upon the AsyncRecoveryFailureDetector and provides a more lenient for marking nodes as unavailable.
 

Methods in voldemort.cluster.failuredetector that return FailureDetector
static FailureDetector FailureDetectorUtils.create(FailureDetectorConfig failureDetectorConfig, boolean registerMbean, FailureDetectorListener... failureDetectorListeners)
           
 

Uses of FailureDetector in voldemort.server.scheduler.slop
 

Constructors in voldemort.server.scheduler.slop with parameters of type FailureDetector
BlockingSlopPusherJob(StoreRepository storeRepo, MetadataStore metadataStore, FailureDetector failureDetector, VoldemortConfig voldemortConfig, ScanPermitWrapper repairPermits)
           
StreamingSlopPusherJob(StoreRepository storeRepo, MetadataStore metadataStore, FailureDetector failureDetector, VoldemortConfig voldemortConfig, ScanPermitWrapper repairPermits)
           
 

Uses of FailureDetector in voldemort.store.rebalancing
 

Constructors in voldemort.store.rebalancing with parameters of type FailureDetector
RedirectingStore(Store<ByteArray,byte[],byte[]> innerStore, MetadataStore metadata, StoreRepository storeRepository, FailureDetector detector, SocketStoreFactory storeFactory, java.util.concurrent.ExecutorService proxyPutWorkerPool, ProxyPutStats proxyPutStats)
           
 

Uses of FailureDetector in voldemort.store.routed
 

Fields in voldemort.store.routed declared as FailureDetector
protected  FailureDetector RoutedStore.failureDetector
           
 

Methods in voldemort.store.routed with parameters of type FailureDetector
 RoutedStore RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, FailureDetector failureDetector, RoutedStoreConfig routedStoreConfig)
           
 RoutedStore RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, FailureDetector failureDetector, RoutedStoreConfig routedStoreConfig)
           
 

Constructors in voldemort.store.routed with parameters of type FailureDetector
PipelineRoutedStore(java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, Cluster cluster, StoreDefinition storeDef, FailureDetector failureDetector, boolean repairReads, TimeoutConfig timeoutConfig, int clientZoneId, boolean isJmxEnabled, int jmxId, ZoneAffinity zoneAffinity)
          Create a PipelineRoutedStore
RoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, Cluster cluster, StoreDefinition storeDef, boolean repairReads, TimeoutConfig timeoutConfig, FailureDetector failureDetector, Time time)
           
ThreadPoolRoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, Cluster cluster, StoreDefinition storeDef, boolean repairReads, java.util.concurrent.ExecutorService threadPool, TimeoutConfig timeoutConfig, FailureDetector failureDetector, Time time)
          Deprecated. Create a RoutedStoreClient
ThreadPoolRoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, Cluster cluster, StoreDefinition storeDef, int numberOfThreads, boolean repairReads, TimeoutConfig timeoutConfig, FailureDetector failureDetector)
          Deprecated. Create a RoutedStoreClient
 

Uses of FailureDetector in voldemort.store.routed.action
 

Fields in voldemort.store.routed.action declared as FailureDetector
protected  FailureDetector AbstractConfigureNodes.failureDetector
           
 

Methods in voldemort.store.routed.action with parameters of type FailureDetector
protected  boolean AbstractAction.handleResponseError(java.lang.Exception e, Node node, long requestTime, Pipeline pipeline, FailureDetector failureDetector)
           
protected  boolean AbstractAction.handleResponseError(Response<?,?> response, Pipeline pipeline, FailureDetector failureDetector)
           
 

Constructors in voldemort.store.routed.action with parameters of type FailureDetector
AbstractConfigureNodes(PD pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int required, RoutingStrategy routingStrategy)
           
ConfigureNodes(PD pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int required, RoutingStrategy routingStrategy, ByteArray key, Zone clientZone)
           
ConfigureNodesByZone(PD pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int required, RoutingStrategy routingStrategy, ByteArray key, Zone clientZone)
           
ConfigureNodesDefault(PD pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int required, RoutingStrategy routingStrategy, ByteArray key)
           
ConfigureNodesLocalHost(PD pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int required, RoutingStrategy routingStrategy, ByteArray key)
           
ConfigureNodesLocalHostByZone(PD pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int required, RoutingStrategy routingStrategy, ByteArray key, Zone clientZone)
           
ConfigureNodesLocalZoneOnly(PD pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int required, RoutingStrategy routingStrategy, ByteArray key, Zone clientZone)
           
GetAllConfigureNodes(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int preferred, int required, RoutingStrategy routingStrategy, java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, Zone clientZone, ZoneAffinity zoneAffinity)
           
PerformParallelDeleteRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, FailureDetector failureDetector, int preferred, int required, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, HintedHandoff hintedHandoff, Version version)
           
PerformParallelGetAllRequests(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores)
           
PerformParallelPutRequests(PutPipelineData pipelineData, Pipeline.Event completeEvent, ByteArray key, byte[] transforms, FailureDetector failureDetector, int preferred, int required, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, HintedHandoff hintedHandoff)
           
PerformParallelRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, byte[] transforms, FailureDetector failureDetector, int preferred, int required, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, Pipeline.Event insufficientSuccessesEvent, Pipeline.Event insufficientZonesEvent)
           
PerformSerialGetAllRequests(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, java.lang.Iterable<ByteArray> keys, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, int preferred, int required, boolean allowPartial)
           
PerformSerialPutRequests(PutPipelineData pipelineData, Pipeline.Event completeEvent, ByteArray key, byte[] transforms, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, int required, Versioned<byte[]> versioned, Time time, Pipeline.Event masterDeterminedEvent)
           
PerformSerialRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, int preferred, int required, StoreRequest<V> storeRequest, Pipeline.Event insufficientSuccessesEvent)
           
PerformZoneSerialRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, StoreRequest<V> storeRequest)
           
 

Uses of FailureDetector in voldemort.store.slop
 

Constructors in voldemort.store.slop with parameters of type FailureDetector
HintedHandoff(FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, HintedHandoffStrategy handoffStrategy, java.util.List<Node> failedNodes, long timeoutMs)
          Create a Hinted Handoff object
 



Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu