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	StoreClientFactory.getFailureDetector() Returns the FailureDetector specific to the cluster against which this client factory is based.
FailureDetector	MockStoreClientFactory.getFailureDetector()
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) Deprecated.

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

Fields in voldemort.server.scheduler.slop declared as FailureDetector

protected FailureDetector

SlopPusherJob.failureDetector

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, java.lang.String identifierString, 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, PerformDeleteHintedHandoff hintedHandoffAction, 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