Uses of Class
voldemort.store.routed.Pipeline.Event

Packages that use Pipeline.Event

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.

Uses of Pipeline.Event in voldemort.store.routed

Methods in voldemort.store.routed that return Pipeline.Event

static Pipeline.Event	Pipeline.Event.valueOf(java.lang.String name) Returns the enum constant of this type with the specified name.
static Pipeline.Event[]	Pipeline.Event.values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods in voldemort.store.routed with parameters of type Pipeline.Event

void	Pipeline.addEvent(Pipeline.Event event) Add an event to the queue.
void	Pipeline.addEventAction(Pipeline.Event event, Action action) Assigns the event to be handled by the given action.

Uses of Pipeline.Event in voldemort.store.routed.action

Fields in voldemort.store.routed.action declared as Pipeline.Event

protected Pipeline.Event

AbstractAction.completeEvent

Constructors in voldemort.store.routed.action with parameters of type Pipeline.Event

AbstractAction(PD pipelineData, Pipeline.Event completeEvent)

AbstractConfigureNodes(PD pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int required, RoutingStrategy routingStrategy)

AbstractHintedHandoffAction(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, HintedHandoff hintedHandoff)

AbstractKeyBasedAction(PD pipelineData, Pipeline.Event completeEvent, K key)

AbstractReadRepair(PD pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)

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)

GetAllReadRepair(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)

IncrementClock(PutPipelineData pipelineData, Pipeline.Event completeEvent, Versioned<byte[]> versioned, Time time)

PerformDeleteHintedHandoff(BasicPipelineData<java.lang.Boolean> pipelineData, Pipeline.Event completeEvent, ByteArray key, Version version, HintedHandoff hintedHandoff)

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)

PerformPutHintedHandoff(PutPipelineData pipelineData, Pipeline.Event completeEvent, ByteArray key, Versioned<byte[]> versioned, byte[] transforms, HintedHandoff hintedHandoff, Time time)

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)

ReadRepair(PD pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)