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>	StoreClient.getResponsibleNodes(K key) Returns the list of nodes which should have this key.
java.util.List<Node>	LazyStoreClient.getResponsibleNodes(K key)
java.util.List<Node>	DefaultStoreClient.getResponsibleNodes(K 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) Deprecated.

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	AbstractFailureDetector.getLastChecked(Node node)
long	FailureDetector.getLastChecked(Node node) Returns the number of milliseconds since the node was last checked for availability.
protected voldemort.cluster.failuredetector.NodeStatus	AbstractFailureDetector.getNodeStatus(Node node)
protected abstract Store<ByteArray,byte[],byte[]>	ClientStoreVerifier.getStoreInternal(Node node)
boolean	NoopFailureDetector.isAvailable(Node node)
boolean	BannagePeriodFailureDetector.isAvailable(Node node) Deprecated.
boolean	AsyncRecoveryFailureDetector.isAvailable(Node node)
boolean	FailureDetector.isAvailable(Node node) Determines if the node is available or offline.
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	NoopFailureDetector.recordException(Node node, long requestTime, UnreachableStoreException e)
void	BannagePeriodFailureDetector.recordException(Node node, long requestTime, UnreachableStoreException e) Deprecated.
void	ThresholdFailureDetector.recordException(Node node, long requestTime, UnreachableStoreException e)
void	AsyncRecoveryFailureDetector.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	NoopFailureDetector.recordSuccess(Node node, long requestTime)
void	BannagePeriodFailureDetector.recordSuccess(Node node, long requestTime) Deprecated.
void	ThresholdFailureDetector.recordSuccess(Node node, long requestTime)
void	AsyncRecoveryFailureDetector.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	FailureDetectorConfig.removeNode(Node node)
protected void	AbstractFailureDetector.setAvailable(Node node)
protected void	AbstractFailureDetector.setUnavailable(Node node, UnreachableStoreException e)
protected void	ThresholdFailureDetector.update(Node node, boolean isSuccess, UnreachableStoreException e)
void	StoreVerifier.verifyStore(Node node) Verifies the ability to connect to a Store for this node.
void	ClientStoreVerifier.verifyStore(Node node)
void	BasicStoreVerifier.verifyStore(Node node)
void	ServerStoreVerifier.verifyStore(Node node)
void	NoopFailureDetector.waitForAvailability(Node node)
void	AbstractFailureDetector.waitForAvailability(Node node)
void	FailureDetector.waitForAvailability(Node node) waitForAvailability causes the calling thread to block until the given Node is available.

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>	RouteToAllStrategy.getNodes()
java.util.Set<Node>	ConsistentRoutingStrategy.getNodes()
java.util.Set<Node>	RoutingStrategy.getNodes() Get the collection of nodes that are candidates for routing.
java.util.List<Node>	RouteToAllStrategy.routeRequest(byte[] key)
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.

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.Map<Node,Slop>

AbstractHintedHandoffAction.slopsToBeSent

Methods in voldemort.store.routed.action that return types with arguments of type Node

static java.util.Map<java.lang.Integer,java.util.List<Node>>	AbstractConfigureNodes.convertToZoneNodeMap(java.util.List<Node> nodes)
java.util.Set<Node>	AsyncPutSynchronizer.getDelegatedSlopDestinations() Get list of nodes to register slop for
protected java.util.List<Node>	AbstractConfigureNodes.getNodes(ByteArray key)
protected java.util.List<Node>	ConfigureNodesLocalZoneOnly.getNodes(ByteArray key)
java.util.List<Node>	ConfigureNodesDefault.getNodes(ByteArray key)
java.util.List<Node>	ConfigureNodesLocalHost.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)
protected void	AbstractHintedHandoffAction.rememberSlopForLaterEvent(Node node, Slop slop)
boolean	AsyncPutSynchronizer.tryDelegateSlop(Node node) Try to delegate the responsibility of sending slops to master

Method parameters in voldemort.store.routed.action with type arguments of type Node

static java.util.Map<java.lang.Integer,java.util.List<Node>>

AbstractConfigureNodes.convertToZoneNodeMap(java.util.List<Node> nodes)

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>	HandoffToAnyStrategy.routeHint(Node origin)
java.util.List<Node>	ProximityHandoffStrategy.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>	HandoffToAnyStrategy.routeHint(Node origin)
java.util.List<Node>	ProximityHandoffStrategy.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.

Method parameters in voldemort.tools with type arguments of type Node

protected static boolean	ZoneShrinkageCLI.verifyMetadataConsistency(AdminClient adminClient, java.util.Collection<Node> nodes, java.lang.String clusterXml, java.lang.String storesXml)
protected static boolean	ZoneShrinkageCLI.verifyRebalanceState(AdminClient adminClient, java.util.Collection<Node> nodes)

Constructors in voldemort.tools with parameters of type Node

KeySamplerCLI.SampleNodeTask(Node node, StoreDefinition storeDefinition, java.io.Writer writer)

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)

Uses of Node in voldemort.xml

Methods in voldemort.xml that return Node

Node	ClusterMapper.readServer(org.jdom.Element server)