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

Constructor Summary

Constructors

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

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, org.infinispan.distribution.topologyaware.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)
Collection<Address>	getMachineNodes(String site, String rack, String machine)
Collection<String>	getRackMachines(String site, String rack)
Collection<Address>	getRackNodes(String site, String rack)
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(ConsistentHash ch)

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,
                             org.infinispan.distribution.topologyaware.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)