ds.funnel.peer

Interface PeerManager

All Known Implementing Classes:

PeerManagerImpl

public interface PeerManager

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	setBootstrapNodes(java.util.List<NodeDetails> inBootNodes) Provide a list of nodes that should be connected to upon startup.

Method Detail

getAvailableTopics

java.util.List<Topic> getAvailableTopics()

Returns:

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

getPublishingTopics

java.util.List<Topic> getPublishingTopics()

Returns:

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

getSubscribingTopics

java.util.List<Topic> getSubscribingTopics()

Returns:

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

getCoordinatedTopics

java.util.List<Topic> getCoordinatedTopics()

Returns:

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

getTopic

Topic getTopic(java.lang.String inTopicName)

Obtain the topic object for a given string

Parameters:

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

Returns:

The requested topic.

getMasterGroup

PeerGroup getMasterGroup()

Obtain the master group used from lookups and adverts

Returns:

The master peer group

getKnownGroup

PeerGroup getKnownGroup(Topic inTopic)

Returns the peer group if it is known to exist.

Parameters:

inTopic - - The topic for the peer group.

Returns:

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

getPeerGroup

PeerGroup getPeerGroup(Topic inTopic)
                throws TopicException

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

Parameters:

inTopic - - The topic for the peer group.

Returns:

The associated peer group.

Throws:

TopicException

getDefaultGraphBuilder

GraphBuilder getDefaultGraphBuilder()

Obtain a new instance of the default topology graph builder.

Returns:

A graph builder for building the topology.

getDefaultTreeBuilder

GraphBuilder getDefaultTreeBuilder()

Obtain a new instance of the default routing tree builder.

Returns:

A graph builder for building the routing tree.

setBootstrapNodes

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

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

Parameters:

inBootNodes - - The list of nodes to connect to.