|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
RequestHandlerStoreClientFactory implementationsPipeline receiving an
Pipeline.Event.Cluster object.
AdminClientRequestHandlerClientRequest logic.StoreClientFactory which caches requests
to getStoreClientClientRequestExecutorPool to execute
requests for the client.ClientRequestExecutor keyed off the
SocketDestination.ClientRequestExecutor once all the processing
(normal or abnormal) has occurred on the ClientRequest object.
MetadataStoreSocketDestination.
Object.equals(Object), or "deeply equal" if both are arrays.
StoreClient implementation
you get back from a StoreClientFactoryClassLoader.getResource(String) internally to find the class
file and then dump the bytes[]
VoldemortConfig).
ClientConfig).
RequestFormat instance's
writeXxx method.
getAll, except
that the transforms are applied on the value associated with each key
before returning the results
VoldemortConfig.getFailureDetectorBannagePeriod() instead
ClientConfig.getFailureDetectorBannagePeriod() instead
state from
a remote node.
AdminClient.getROMaxVersion(int, List)
where-in we find the max versions on each machine and then return the max
of all of them
ReadOnlyStorageFormat for
a list of stores
StoreClient for the given store.
StoreClient for the given store.
Versioned as determined by
PerformSerialPutRequests.
Gossiper object, which implements Runnable allowing it to be
run as a thread or be submitted to an Executor.
RoutingStrategy for hints.HintedHandoffStrategy for a given
HintedHandoffStrategyType.StoreClientFactory that creates
a remote client that connects and bootstraps itself via HTTP.InvalidMetadataException if a client requests
a partition which is not or should not be available at this node.InvalidMetadataException if the partition for key
requested should not lie with this node.
true if ClientRequest.complete() was called.
ClientRequestExecutor's received thus far is inclusive of the
entire response.
JsonReaderStoreClient with lazy initialization.ChunkEncoder to compress individual chunks and combines resulting
chunks into contiguous output byte array.AsyncRecoveryFailureDetector class.
Store interface but instead of blocking
for the request to complete, it simply submits it for later processing and
returns immediately.NonblockingStore API.NonblockingStore API.Pair.create(Object, Object) instead of
this where possible.
Action is run.Pipeline as it moves from action to action.#put(Object, Object), except
that the given transforms are applied on the value before writing it to
the store
RebalanceController.rebalance(voldemort.cluster.Cluster, voldemort.cluster.Cluster)
RebalanceController.rebalance(voldemort.cluster.Cluster, voldemort.cluster.Cluster, java.util.List)
RebalancePartitionsInfo ( which in turn indicates the list of
movements from a particular donor node )DefaultStoreClient for server side routingDelegatingStoreRebootstrappingStore.
Store.
RequestFormatTypeRequestFormatType.resolveConflict([null, null]) == null
if t != null, then
resolveConflict([null, t]) == resolveConflict([t, null]) == t
RoutingStrategy for a given
RoutingStrategyType.MetadataStore.GOSSIP_KEYS
with that peer and then sleep for a specified interval.
HintedHandoff.sendHintSerial(voldemort.cluster.Node, voldemort.versioning.Version, Slop),
but doesn't block the pipeline.
HintedHandoffStrategy
implementation passed in the constructor
VoldemortConfig.setFailureDetectorBannagePeriod(long) instead
Node as determined by
PerformSerialPutRequests.
ClientConfig.setFailureDetectorBannagePeriod(long) instead
Versioned instance that was incremented before
attempting to put on the remote Voldemort node.
RequestFormatType.SocketStore instances.Gossiper.run() is invoked.
StoreClient instances to
interact with individual stores.Store API.StreamRequestHandler.StreamRequestHandlerState.COMPLETE.NonblockingStore.
MetadataStore.CLUSTER_KEY on a
remote node.
MetadataStore.VoldemortState) on a
remote node.
MetadataStore.VoldemortState MetadataStore.VoldemortState.NORMAL_SERVER).
AdminClientRequestFormat for a low-overhead custom
binary protocolHashMap as a Write through cache
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||