Package org.infinispan.distribution.topologyaware

Class TopologyInfo

java.lang.Object

org.infinispan.distribution.topologyaware.TopologyInfo

public class TopologyInfo
extends Object

This class holds the topology hierarchy of a cache's members and estimates for owned segments.

Since:

5.2

Author:

Dan Berindei

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TopologyInfo.Cluster
static class	TopologyInfo.Location	Base class for locations.
static class	TopologyInfo.Machine
static class	TopologyInfo.Node
static class	TopologyInfo.Rack
static class	TopologyInfo.Site

Constructor Summary

Constructors

Constructor	Description
TopologyInfo(int numSegments, int numOwners, Collection<Address> members, Map<Address,Float> capacityFactors)

Method Summary

Modifier and Type	Method	Description
float	computeTotalCapacity(Collection<Address> nodes, Map<Address,Float> capacityFactors)
boolean	duplicateLocation(TopologyLevel level, Collection<Address> addresses, Address candidate, boolean excludeCandidate)
String	formatLocation(DecimalFormat df, TopologyInfo.Location location, String prefix)
Collection<String>	getAllSites()
int	getDistinctLocationsCount(TopologyLevel level)
int	getDistinctLocationsCount(TopologyLevel level, Collection<Address> addresses)
float	getExpectedOwnedSegments(Address address)
float	getExpectedPrimarySegments(Address address)
Object	getLocationId(TopologyLevel level, Address address)
int	getMachineIndex(Address address)
Collection<Address>	getMachineNodes(String site, String rack, String machine)
int	getRackIndex(Address address)
Collection<String>	getRackMachines(String site, String rack)
Collection<Address>	getRackNodes(String site, String rack)
int	getSiteIndex(Address address)
Collection<Address>	getSiteNodes(String site)
Collection<String>	getSiteRacks(String site)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TopologyInfo

public TopologyInfo(int numSegments,
                    int numOwners,
                    Collection<Address> members,
                    Map<Address,Float> capacityFactors)

Method Detail

getDistinctLocationsCount

public int getDistinctLocationsCount(TopologyLevel level)

getDistinctLocationsCount

public int getDistinctLocationsCount(TopologyLevel level,
                                     Collection<Address> addresses)

duplicateLocation

public boolean duplicateLocation(TopologyLevel level,
                                 Collection<Address> addresses,
                                 Address candidate,
                                 boolean excludeCandidate)

getLocationId

public Object getLocationId(TopologyLevel level,
                            Address address)

getSiteNodes

public Collection<Address> getSiteNodes(String site)

getRackNodes

public Collection<Address> getRackNodes(String site,
                                        String rack)

getMachineNodes

public Collection<Address> getMachineNodes(String site,
                                           String rack,
                                           String machine)

getAllSites

public Collection<String> getAllSites()

getSiteRacks

public Collection<String> getSiteRacks(String site)

getRackMachines

public Collection<String> getRackMachines(String site,
                                          String rack)

toString

public String toString()

Overrides:

toString in class Object

formatLocation

public String formatLocation(DecimalFormat df,
                             TopologyInfo.Location location,
                             String prefix)

computeTotalCapacity

public float computeTotalCapacity(Collection<Address> nodes,
                                  Map<Address,Float> capacityFactors)

getExpectedPrimarySegments

public float getExpectedPrimarySegments(Address address)

getExpectedOwnedSegments

public float getExpectedOwnedSegments(Address address)

getSiteIndex

public int getSiteIndex(Address address)

getRackIndex

public int getRackIndex(Address address)

getMachineIndex

public int getMachineIndex(Address address)