public class PeerManagerImpl extends NodeComponentImpl implements PeerManager
| 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 and Description |
|---|
PeerManagerImpl() |
| 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.
|
getComponentKey, getComponentLink, hashCode, setComponentKey, startComponent, stopComponentpublic static final java.lang.String MASTER_TOPIC
public static final int JOIN_TIMEOUT_SECONDS
public static final int OVERLAY_ACTIVATE_MILLIS
public static final int OVERLAY_TIMEOUT_SECONDS
public static final int ADVERT_SECONDS
public static final int NEIGHBOR_HOPS
public static boolean disableFunnelStartup
public java.util.List<Topic> getAvailableTopics()
getAvailableTopics in interface PeerManagerpublic java.util.List<Topic> getPublishingTopics()
getPublishingTopics in interface PeerManagerpublic java.util.List<Topic> getSubscribingTopics()
getSubscribingTopics in interface PeerManagerpublic java.util.List<Topic> getCoordinatedTopics()
getCoordinatedTopics in interface PeerManagerpublic Topic getTopic(java.lang.String inTopicName)
PeerManagergetTopic in interface PeerManagerinTopicName - - The name of the topic to get the obtain.public PeerGroup getMasterGroup()
PeerManagergetMasterGroup in interface PeerManagerpublic PeerGroup getKnownGroup(Topic inTopic)
PeerManagergetKnownGroup in interface PeerManagerinTopic - - The topic for the peer group.public PeerGroup getPeerGroup(Topic inTopic) throws TopicException
PeerManagergetPeerGroup in interface PeerManagerinTopic - - The topic for the peer group.TopicExceptionpublic GraphBuilder getDefaultGraphBuilder()
PeerManagergetDefaultGraphBuilder in interface PeerManagerpublic GraphBuilder getDefaultTreeBuilder()
PeerManagergetDefaultTreeBuilder in interface PeerManagerpublic void setBootstrapNodes(java.util.List<NodeDetails> inBootNodes)
PeerManagersetBootstrapNodes in interface PeerManagerinBootNodes - - The list of nodes to connect to.public void onOpenTopicLink(ds.funnel.overlay.event.MsgTLinkOpen inEvent)