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	StoreClientFactory.getFailureDetector() Returns the FailureDetector specific to the cluster against which this client factory is based.
FailureDetector	MockStoreClientFactory.getFailureDetector()
FailureDetector	CachingStoreClientFactory.getFailureDetector()
FailureDetector	AbstractStoreClientFactory.getFailureDetector()
protected FailureDetector	SocketStoreClientFactory.initFailureDetector(ClientConfig config, java.util.Collection<Node> nodes)
protected FailureDetector	HttpStoreClientFactory.initFailureDetector(ClientConfig config, java.util.Collection<Node> nodes)
protected abstract FailureDetector	AbstractStoreClientFactory.initFailureDetector(ClientConfig config, java.util.Collection<Node> nodes)

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 BannagePeriodFailureDetector relies on external callers to notify it of failed attempts to access a node's store via recordException.
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, java.util.concurrent.Semaphore repairPermits)

StreamingSlopPusherJob(StoreRepository storeRepo, MetadataStore metadataStore, FailureDetector failureDetector, VoldemortConfig voldemortConfig, java.util.concurrent.Semaphore 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)

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, boolean repairReads, FailureDetector failureDetector)

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, boolean repairReads, int clientZoneId, FailureDetector failureDetector)

Constructors in voldemort.store.routed with parameters of type FailureDetector

PipelineRoutedStore(java.lang.String name, 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, boolean repairReads, int clientZoneId, long timeoutMs, FailureDetector failureDetector)
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, long timeoutMs, 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, long timeoutMs, FailureDetector failureDetector, Time time)
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, long timeoutMs, FailureDetector failureDetector)
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)

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)

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)

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