ds.funnel.peer

Class PeerManagerImpl

java.lang.Object

ds.funnel.node.compnt.NodeComponentImpl

ds.funnel.peer.PeerManagerImpl

All Implemented Interfaces:

NodeComponent, PeerManager

public class PeerManagerImpl
extends NodeComponentImpl
implements PeerManager

Field Summary

Fields

Modifier and Type	Field and Description
static int	ADVERT_SECONDS
static boolean	disableFunnelStartup
static int	JOIN_TIMEOUT_SECONDS
static java.lang.String	MASTER_TOPIC
static int	NEIGHBOR_HOPS
static int	OVERLAY_ACTIVATE_MILLIS
static int	OVERLAY_TIMEOUT_SECONDS

Constructor Summary

Constructors

Constructor and Description
PeerManagerImpl()

Method Summary

Modifier and Type	Method and Description
java.util.List<Topic>	getAvailableTopics()
java.util.List<Topic>	getCoordinatedTopics()
GraphBuilder	getDefaultGraphBuilder() Obtain a new instance of the default topology graph builder.
GraphBuilder	getDefaultTreeBuilder() Obtain a new instance of the default routing tree builder.
PeerGroup	getKnownGroup(Topic inTopic) Returns the peer group if it is known to exist.
PeerGroup	getMasterGroup() Obtain the master group used from lookups and adverts
PeerGroup	getPeerGroup(Topic inTopic) Obtain the peer group for a topic, performing a lookup if it is not known.
java.util.List<Topic>	getPublishingTopics()
java.util.List<Topic>	getSubscribingTopics()
Topic	getTopic(java.lang.String inTopicName) Obtain the topic object for a given string
void	onOpenTopicLink(ds.funnel.overlay.event.MsgTLinkOpen inEvent)
void	setBootstrapNodes(java.util.List<NodeDetails> inBootNodes) Provide a list of nodes that should be connected to upon startup.

Methods inherited from class ds.funnel.node.compnt.NodeComponentImpl

getComponentKey, getComponentLink, hashCode, setComponentKey, startComponent, stopComponent

Methods inherited from class java.lang.Object

equals, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

MASTER_TOPIC

public static final java.lang.String MASTER_TOPIC

See Also:

Constant Field Values

JOIN_TIMEOUT_SECONDS

public static final int JOIN_TIMEOUT_SECONDS

See Also:

Constant Field Values

OVERLAY_ACTIVATE_MILLIS

public static final int OVERLAY_ACTIVATE_MILLIS

See Also:

Constant Field Values

OVERLAY_TIMEOUT_SECONDS

public static final int OVERLAY_TIMEOUT_SECONDS

See Also:

Constant Field Values

ADVERT_SECONDS

public static final int ADVERT_SECONDS

See Also:

Constant Field Values

NEIGHBOR_HOPS

public static final int NEIGHBOR_HOPS

See Also:

Constant Field Values

disableFunnelStartup

public static boolean disableFunnelStartup

Constructor Detail

PeerManagerImpl

public PeerManagerImpl()

Method Detail

getAvailableTopics

public java.util.List<Topic> getAvailableTopics()

Specified by:

getAvailableTopics in interface PeerManager

Returns:

a list of all discovered topics. Other topics may exist.

getPublishingTopics

public java.util.List<Topic> getPublishingTopics()

Specified by:

getPublishingTopics in interface PeerManager

Returns:

A list of all topics that this node is publishing to.

getSubscribingTopics

public java.util.List<Topic> getSubscribingTopics()

Specified by:

getSubscribingTopics in interface PeerManager

Returns:

A list of all topics that this node is subscribed to.

getCoordinatedTopics

public java.util.List<Topic> getCoordinatedTopics()

Specified by:

getCoordinatedTopics in interface PeerManager

Returns:

A list of all topics that this node is a coordinator of.

getTopic

public Topic getTopic(java.lang.String inTopicName)

Description copied from interface: PeerManager

Obtain the topic object for a given string

Specified by:

getTopic in interface PeerManager

Parameters:

inTopicName - - The name of the topic to get the obtain.

Returns:

The requested topic.

getMasterGroup

public PeerGroup getMasterGroup()

Description copied from interface: PeerManager

Obtain the master group used from lookups and adverts

Specified by:

getMasterGroup in interface PeerManager

Returns:

The master peer group

getKnownGroup

public PeerGroup getKnownGroup(Topic inTopic)

Description copied from interface: PeerManager

Returns the peer group if it is known to exist.

Specified by:

getKnownGroup in interface PeerManager

Parameters:

inTopic - - The topic for the peer group.

Returns:

The associated peer group if it is known, null otherwise.

getPeerGroup

public PeerGroup getPeerGroup(Topic inTopic)
                       throws TopicException

Description copied from interface: PeerManager

Obtain the peer group for a topic, performing a lookup if it is not known.

Specified by:

getPeerGroup in interface PeerManager

Parameters:

inTopic - - The topic for the peer group.

Returns:

The associated peer group.

Throws:

TopicException

getDefaultGraphBuilder

public GraphBuilder getDefaultGraphBuilder()

Description copied from interface: PeerManager

Obtain a new instance of the default topology graph builder.

Specified by:

getDefaultGraphBuilder in interface PeerManager

Returns:

A graph builder for building the topology.

getDefaultTreeBuilder

public GraphBuilder getDefaultTreeBuilder()

Description copied from interface: PeerManager

Obtain a new instance of the default routing tree builder.

Specified by:

getDefaultTreeBuilder in interface PeerManager

Returns:

A graph builder for building the routing tree.

setBootstrapNodes

public void setBootstrapNodes(java.util.List<NodeDetails> inBootNodes)

Description copied from interface: PeerManager

Provide a list of nodes that should be connected to upon startup.

Specified by:

setBootstrapNodes in interface PeerManager

Parameters:

inBootNodes - - The list of nodes to connect to.

onOpenTopicLink

public void onOpenTopicLink(ds.funnel.overlay.event.MsgTLinkOpen inEvent)