Uses of Class
voldemort.cluster.Node

Packages that use Node
voldemort.client The user facing interface to Voldemort. 
voldemort.client.protocol.admin Classes that abstract admin based Voldemort requests. 
voldemort.cluster Classes that model a voldemort cluster. 
voldemort.cluster.failuredetector Classes associated with client side failure detectors. 
voldemort.routing Routing strategies for mapping requests into the Voldemort cluster. 
voldemort.server The Voldemort server. 
voldemort.server.gossip Classes associated with the Gossip feature. 
voldemort.store The Store interface is the primary interface for Voldemort. 
voldemort.store.nonblockingstore Non-blocking store which deals with async requests. 
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. 
voldemort.store.slop.strategy Bunch of different ways in which we would store failed requests for the Hinted handoff feature. 
voldemort.tools Tools used for administrating a cluster. 
voldemort.utils Basic helper functions. 
voldemort.xml Classes related to parsing our metadata ( cluster + store definition ) 
 

Uses of Node in voldemort.client
 

Methods in voldemort.client that return types with arguments of type Node
 java.util.List<Node> DefaultStoreClient.getResponsibleNodes(K key)
           
 java.util.List<Node> LazyStoreClient.getResponsibleNodes(K key)
           
 java.util.List<Node> StoreClient.getResponsibleNodes(K key)
          Returns the list of nodes which should have this key.
 

Methods in voldemort.client with parameters of type Node
protected abstract  int AbstractStoreClientFactory.getPort(Node node)
           
protected  int SocketStoreClientFactory.getPort(Node node)
           
protected  int HttpStoreClientFactory.getPort(Node node)
           
 

Uses of Node in voldemort.client.protocol.admin
 

Fields in voldemort.client.protocol.admin with type parameters of type Node
protected  java.util.List<Node> BaseStreamingClient.nodesToStream
           
 

Uses of Node in voldemort.cluster
 

Methods in voldemort.cluster that return Node
 Node Cluster.getNodeById(int id)
           
 Node Cluster.getNodeForPartitionId(int partitionId)
           
 Node[] Cluster.getPartitionIdToNodeArray()
           
 

Methods in voldemort.cluster that return types with arguments of type Node
 java.util.Collection<Node> Cluster.getNodes()
           
 

Methods in voldemort.cluster with parameters of type Node
 int Node.compareTo(Node other)
           
 boolean Node.isEqualState(Node other)
           
 

Constructor parameters in voldemort.cluster with type arguments of type Node
Cluster(java.lang.String name, java.util.List<Node> nodes)
           
Cluster(java.lang.String name, java.util.List<Node> nodes, java.util.List<Zone> zones)
           
 

Uses of Node in voldemort.cluster.failuredetector
 

Fields in voldemort.cluster.failuredetector with type parameters of type Node
protected  java.util.Collection<Node> FailureDetectorConfig.nodes
           
 

Methods in voldemort.cluster.failuredetector that return types with arguments of type Node
 java.util.Collection<Node> FailureDetectorConfig.getNodes()
          Deprecated. 
 

Methods in voldemort.cluster.failuredetector with parameters of type Node
 void FailureDetectorConfig.addNode(Node node)
           
protected  void AbstractFailureDetector.checkArgs(Node node, long requestTime)
           
protected  void AbstractFailureDetector.checkNodeArg(Node node)
           
 long NoopFailureDetector.getLastChecked(Node node)
           
 long FailureDetector.getLastChecked(Node node)
          Returns the number of milliseconds since the node was last checked for availability.
 long AbstractFailureDetector.getLastChecked(Node node)
           
protected  voldemort.cluster.failuredetector.NodeStatus AbstractFailureDetector.getNodeStatus(Node node)
           
protected abstract  Store<ByteArray,byte[],byte[]> ClientStoreVerifier.getStoreInternal(Node node)
           
 boolean BannagePeriodFailureDetector.isAvailable(Node node)
          Deprecated.  
 boolean NoopFailureDetector.isAvailable(Node node)
           
 boolean FailureDetector.isAvailable(Node node)
          Determines if the node is available or offline.
 boolean AsyncRecoveryFailureDetector.isAvailable(Node node)
           
 void FailureDetectorListener.nodeAvailable(Node node)
           
protected  void ThresholdFailureDetector.nodeRecovered(Node node)
          We delegate node recovery detection to the AsyncRecoveryFailureDetector class.
protected  void AsyncRecoveryFailureDetector.nodeRecovered(Node node)
           
 void FailureDetectorListener.nodeUnavailable(Node node)
           
 void BannagePeriodFailureDetector.recordException(Node node, long requestTime, UnreachableStoreException e)
          Deprecated.  
 void NoopFailureDetector.recordException(Node node, long requestTime, UnreachableStoreException e)
           
 void FailureDetector.recordException(Node node, long requestTime, UnreachableStoreException e)
          Allows external callers to provide input to the FailureDetector that an error occurred when trying to access the node.
 void ThresholdFailureDetector.recordException(Node node, long requestTime, UnreachableStoreException e)
           
 void AsyncRecoveryFailureDetector.recordException(Node node, long requestTime, UnreachableStoreException e)
           
 void BannagePeriodFailureDetector.recordSuccess(Node node, long requestTime)
          Deprecated.  
 void NoopFailureDetector.recordSuccess(Node node, long requestTime)
           
 void FailureDetector.recordSuccess(Node node, long requestTime)
          Allows external callers to provide input to the FailureDetector that an access to the node succeeded.
 void ThresholdFailureDetector.recordSuccess(Node node, long requestTime)
           
 void AsyncRecoveryFailureDetector.recordSuccess(Node node, long requestTime)
           
 void FailureDetectorConfig.removeNode(Node node)
           
protected  void AbstractFailureDetector.setAvailable(Node node)
           
protected  void AbstractFailureDetector.setUnavailable(Node node, UnreachableStoreException e)
           
protected  void ThresholdFailureDetector.update(Node node, int successDelta, UnreachableStoreException e)
           
 void BasicStoreVerifier.verifyStore(Node node)
           
 void ServerStoreVerifier.verifyStore(Node node)
           
 void ClientStoreVerifier.verifyStore(Node node)
           
 void StoreVerifier.verifyStore(Node node)
          Verifies the ability to connect to a Store for this node.
 void NoopFailureDetector.waitForAvailability(Node node)
           
 void FailureDetector.waitForAvailability(Node node)
          waitForAvailability causes the calling thread to block until the given Node is available.
 void AbstractFailureDetector.waitForAvailability(Node node)
           
 

Method parameters in voldemort.cluster.failuredetector with type arguments of type Node
 FailureDetectorConfig FailureDetectorConfig.setNodes(java.util.Collection<Node> nodes)
          Deprecated. 
 

Uses of Node in voldemort.routing
 

Methods in voldemort.routing that return Node
 Node[] ConsistentRoutingStrategy.getPartitionToNode()
           
 

Methods in voldemort.routing that return types with arguments of type Node
 java.util.Set<Node> ConsistentRoutingStrategy.getNodes()
           
 java.util.Set<Node> RoutingStrategy.getNodes()
          Get the collection of nodes that are candidates for routing.
 java.util.Set<Node> RouteToAllStrategy.getNodes()
           
 java.util.List<Node> ConsistentRoutingStrategy.routeRequest(byte[] key)
           
 java.util.List<Node> RoutingStrategy.routeRequest(byte[] key)
          Get the node preference list for the given key.
 java.util.List<Node> RouteToAllStrategy.routeRequest(byte[] key)
           
 

Constructor parameters in voldemort.routing with type arguments of type Node
ConsistentRoutingStrategy(HashFunction hash, java.util.Collection<Node> nodes, int numReplicas)
           
RouteToAllLocalPrefStrategy(java.util.Collection<Node> nodes)
           
RouteToAllStrategy(java.util.Collection<Node> nodes)
           
 

Uses of Node in voldemort.server
 

Methods in voldemort.server that return Node
 Node VoldemortServer.getIdentityNode()
           
 

Uses of Node in voldemort.server.gossip
 

Methods in voldemort.server.gossip that return Node
protected  Node Gossiper.selectPeer()
          Randomly select a distinct peer.
 

Methods in voldemort.server.gossip with parameters of type Node
protected  void Gossiper.gossipKey(Node node, java.lang.String key)
          Perform Gossip on a specified metadata key with a remote node.
 

Uses of Node in voldemort.store
 

Methods in voldemort.store with parameters of type Node
static void StoreUtils.assertValidMetadata(ByteArray key, RoutingStrategy routingStrategy, Node currentNode)
          Check if the current node is part of routing request based on cluster.xml or throw an exception.
 

Constructor parameters in voldemort.store with type arguments of type Node
InsufficientOperationalNodesException(java.lang.String message, java.util.List<Node> replicationSet, java.util.List<Node> preferenceList, java.util.List<Node> failedList, java.util.Collection<? extends java.lang.Throwable> failures)
           
InsufficientOperationalNodesException(java.lang.String message, java.util.List<Node> replicationSet, java.util.List<Node> preferenceList, java.util.List<Node> failedList, java.util.Collection<? extends java.lang.Throwable> failures)
           
InsufficientOperationalNodesException(java.lang.String message, java.util.List<Node> replicationSet, java.util.List<Node> preferenceList, java.util.List<Node> failedList, java.util.Collection<? extends java.lang.Throwable> failures)
           
 

Uses of Node in voldemort.store.nonblockingstore
 

Methods in voldemort.store.nonblockingstore with parameters of type Node
 void NonblockingStoreRequest.submit(Node node, NonblockingStore store, NonblockingStoreCallback callback)
          Submits the request to the given NonblockingStore.
 

Uses of Node in voldemort.store.rebalancing
 

Methods in voldemort.store.rebalancing with parameters of type Node
protected  void RedirectingStore.checkNodeAvailable(Node proxyNode)
           
protected  void RedirectingStore.recordException(Node node, long startNs, UnreachableStoreException e)
           
protected  void RedirectingStore.recordSuccess(Node node, long startNs)
           
 

Uses of Node in voldemort.store.routed
 

Fields in voldemort.store.routed with type parameters of type Node
protected  java.util.List<Node> PipelineData.failedNodes
           
protected  java.util.List<Node> PipelineData.replicationSet
           
 

Methods in voldemort.store.routed that return Node
 Node PutPipelineData.getMaster()
          Returns the previously determined "master" node.
 Node Response.getNode()
           
 

Methods in voldemort.store.routed that return types with arguments of type Node
 java.util.List<Node> PipelineData.getFailedNodes()
           
 java.util.Map<ByteArray,java.util.List<Node>> GetAllPipelineData.getKeyToExtraNodesMap()
           
 java.util.List<Node> BasicPipelineData.getNodes()
           
 java.util.Map<Node,java.util.List<ByteArray>> GetAllPipelineData.getNodeToKeysMap()
           
 java.util.List<Node> PipelineData.getReplicationSet()
           
 

Methods in voldemort.store.routed with parameters of type Node
 void PipelineData.addFailedNode(Node node)
           
 void PutPipelineData.setMaster(Node master)
          Assigns the "master" Node as determined by PerformSerialPutRequests.
 

Method parameters in voldemort.store.routed with type arguments of type Node
 void GetAllPipelineData.setKeyToExtraNodesMap(java.util.Map<ByteArray,java.util.List<Node>> keyToExtraNodesMap)
           
 void BasicPipelineData.setNodes(java.util.List<Node> nodes)
           
 void GetAllPipelineData.setNodeToKeysMap(java.util.Map<Node,java.util.List<ByteArray>> nodeToKeysMap)
           
 void PipelineData.setReplicationSet(java.util.List<Node> replicationSet)
           
 

Constructors in voldemort.store.routed with parameters of type Node
Response(Node node, K key, V value, long requestTime)
           
 

Uses of Node in voldemort.store.routed.action
 

Fields in voldemort.store.routed.action with type parameters of type Node
protected  java.util.List<Node> AbstractHintedHandoffAction.failedNodes
           
 

Methods in voldemort.store.routed.action that return types with arguments of type Node
 java.util.Set<Node> AsyncPutSynchronizer.getDelegatedSlopDestinations()
          Get list of nodes to register slop for
protected  java.util.List<Node> ConfigureNodesLocalZoneOnly.getNodes(ByteArray key)
           
 java.util.List<Node> ConfigureNodesLocalHost.getNodes(ByteArray key)
           
 java.util.List<Node> ConfigureNodesDefault.getNodes(ByteArray key)
           
protected  java.util.List<Node> AbstractConfigureNodes.getNodes(ByteArray key)
           
 java.util.List<Node> ConfigureNodesLocalHostByZone.getNodes(ByteArray key, Pipeline.Operation op)
           
 java.util.List<Node> ConfigureNodesByZone.getNodes(ByteArray key, Pipeline.Operation op)
           
 

Methods in voldemort.store.routed.action with parameters of type Node
protected  boolean AbstractAction.handleResponseError(java.lang.Exception e, Node node, long requestTime, Pipeline pipeline, FailureDetector failureDetector)
           
protected  void AbstractReadRepair.insertNodeValue(Node node, ByteArray key, java.util.List<Versioned<byte[]>> value)
           
 boolean AsyncPutSynchronizer.tryDelegateSlop(Node node)
          Try to delegate the responsibility of sending slops to master
 

Uses of Node in voldemort.store.slop
 

Methods in voldemort.store.slop with parameters of type Node
 void HintedHandoff.sendHintParallel(Node failedNode, Version version, Slop slop)
          Like HintedHandoff.sendHintSerial(voldemort.cluster.Node, voldemort.versioning.Version, Slop) , but doesn't block the pipeline.
 boolean HintedHandoff.sendHintSerial(Node failedNode, Version version, Slop slop)
          Deprecated. 
 

Constructor parameters in voldemort.store.slop with type arguments of type Node
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
 

Uses of Node in voldemort.store.slop.strategy
 

Methods in voldemort.store.slop.strategy that return types with arguments of type Node
 java.util.List<Node> ProximityHandoffStrategy.routeHint(Node origin)
           
 java.util.List<Node> HandoffToAnyStrategy.routeHint(Node origin)
           
 java.util.List<Node> ConsistentHandoffStrategy.routeHint(Node origin)
           
 java.util.List<Node> HintedHandoffStrategy.routeHint(Node origin)
          Get an ordered "preference list" of nodes eligible to receive hints for a given node in case of that node's failure
 

Methods in voldemort.store.slop.strategy with parameters of type Node
 java.util.List<Node> ProximityHandoffStrategy.routeHint(Node origin)
           
 java.util.List<Node> HandoffToAnyStrategy.routeHint(Node origin)
           
 java.util.List<Node> ConsistentHandoffStrategy.routeHint(Node origin)
           
 java.util.List<Node> HintedHandoffStrategy.routeHint(Node origin)
          Get an ordered "preference list" of nodes eligible to receive hints for a given node in case of that node's failure
 

Uses of Node in voldemort.tools
 

Methods in voldemort.tools that return types with arguments of type Node
static Pair<java.util.HashMap<Node,java.lang.Integer>,java.util.HashMap<Node,java.lang.Integer>> Repartitioner.getDonorsAndStealersForBalance(Cluster nextCandidateCluster, java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> numPartitionsPerNodePerZone)
          Assign target number of partitions per node to specific node IDs.
static Pair<java.util.HashMap<Node,java.lang.Integer>,java.util.HashMap<Node,java.lang.Integer>> Repartitioner.getDonorsAndStealersForBalance(Cluster nextCandidateCluster, java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> numPartitionsPerNodePerZone)
          Assign target number of partitions per node to specific node IDs.
 

Uses of Node in voldemort.utils
 

Methods in voldemort.utils that return Node
static Node UpdateClusterUtils.addPartitionsToNode(Node node, java.util.Set<java.lang.Integer> donatedPartitions)
          Add the set of partitions to the node provided
static Node UpdateClusterUtils.addPartitionToNode(Node node, java.lang.Integer donatedPartition)
          Add a partition to the node provided
 Node ConsistencyCheck.ClusterNode.getNode()
           
static Node UpdateClusterUtils.removePartitionFromNode(Node node, java.lang.Integer donatedPartition)
          Remove a partition from the node provided
static Node UpdateClusterUtils.removePartitionsFromNode(Node node, java.util.Set<java.lang.Integer> donatedPartitions)
          Remove the set of partitions from the node provided
static Node UpdateClusterUtils.updateNode(Node node, java.util.List<java.lang.Integer> partitionsList)
          Creates a replica of the node with the new partitions list
 

Methods in voldemort.utils with parameters of type Node
static Node UpdateClusterUtils.addPartitionsToNode(Node node, java.util.Set<java.lang.Integer> donatedPartitions)
          Add the set of partitions to the node provided
static Node UpdateClusterUtils.addPartitionToNode(Node node, java.lang.Integer donatedPartition)
          Add a partition to the node provided
static Node UpdateClusterUtils.removePartitionFromNode(Node node, java.lang.Integer donatedPartition)
          Remove a partition from the node provided
static Node UpdateClusterUtils.removePartitionsFromNode(Node node, java.util.Set<java.lang.Integer> donatedPartitions)
          Remove the set of partitions from the node provided
static Node UpdateClusterUtils.updateNode(Node node, java.util.List<java.lang.Integer> partitionsList)
          Creates a replica of the node with the new partitions list
 

Method parameters in voldemort.utils with type arguments of type Node
static java.util.List<java.lang.Integer> Utils.nodeListToNodeIdList(java.util.List<Node> nodes)
          Given a list of nodes, retrieves the list of node ids
static Cluster UpdateClusterUtils.updateCluster(Cluster currentCluster, java.util.List<Node> updatedNodeList)
          Concatenates the list of current nodes in the given cluster with the new nodes provided and returns an updated cluster metadata.
 

Constructors in voldemort.utils with parameters of type Node
ConsistencyCheck.ClusterNode(java.lang.Integer clusterId, Node node)
           
KeySamplerCLI.SampleNodeTask(Node node, StoreDefinition storeDefinition, java.io.Writer writer)
           
 

Uses of Node in voldemort.xml
 

Methods in voldemort.xml that return Node
 Node ClusterMapper.readServer(org.jdom.Element server)
           
 



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