| Package | Description |
|---|---|
| ds.funnel.overlay | |
| ds.funnel.overlay.routing | |
| ds.funnel.peer | |
| ds.funnel.samples | |
| ds.funnel.topic | |
| ds.funnel.traffic.analysis | |
| ds.granules.samples.uppercase |
This package contains a simple example which flips an input string from lowercase to uppercase.
|
| Modifier and Type | Method and Description |
|---|---|
OverlayVersion |
OverlayManagerImpl.createOverlay(long inVersion) |
OverlayVersion |
OverlayManager.createOverlay(long inVersion)
Create a specific version of the overlay.
|
OverlayVersion |
OverlayManagerImpl.getCurrentOverlay() |
OverlayVersion |
OverlayManager.getCurrentOverlay()
Get the current version of the overlay used for routing new events.
|
OverlayPath |
OverlayManagerImpl.getCurrentPath(NodeDetails inNode) |
OverlayPath |
OverlayManager.getCurrentPath(NodeDetails inNode)
Get the most recent known path to the node, up to the current version.
|
OverlayLink |
OverlayVersion.getLink(NodeDetails inNode)
Get a link to a specific remote node, if one exists.
|
OverlayLink |
OverlayVersionImpl.getLink(NodeDetails inNode) |
java.util.List<OverlayLink> |
OverlayVersion.getLinks() |
java.util.List<OverlayLink> |
OverlayVersionImpl.getLinks() |
OverlayVersion |
OverlayManagerImpl.getOverlay(long inVersion) |
OverlayVersion |
OverlayManager.getOverlay(long inVersion)
Get a specific version of the overlay, creating it if needed.
|
java.util.List<OverlayVersion> |
OverlayManagerImpl.getOverlays() |
java.util.List<OverlayVersion> |
OverlayManager.getOverlays() |
OverlayPath |
OverlayManagerImpl.getPath(NodeDetails inNode,
long inVersion) |
OverlayPath |
OverlayManager.getPath(NodeDetails inNode,
long inVersion)
Get the known path to a given node for a specific overlay version.
|
java.util.List<OverlayPath> |
OverlayManagerImpl.getPaths(NodeDetails inNode) |
java.util.List<OverlayPath> |
OverlayManager.getPaths(NodeDetails inNode)
Get the known paths to a given node.
|
java.util.List<OverlayLink> |
OverlayVersion.getPrimaryLinks() |
java.util.List<OverlayLink> |
OverlayVersionImpl.getPrimaryLinks() |
boolean |
OverlayVersion.isLinked(NodeDetails inNode)
Check if a link to another node exists.
|
boolean |
OverlayVersionImpl.isLinked(NodeDetails inNode) |
OverlayLink |
OverlayVersion.openLink(NodeDetails inNode,
boolean inPrimary)
Open a link to a specific remote node, if one does not exist.
|
OverlayLink |
OverlayVersionImpl.openLink(NodeDetails inNode,
boolean inPrimary) |
boolean |
OverlayManagerImpl.removeOverlay(long inVersion) |
boolean |
OverlayManager.removeOverlay(long inVersion)
Remove a specific version of the overlay from the set of active overlays.
|
boolean |
OverlayManagerImpl.removePath(NodeDetails inNode,
long inVersion) |
boolean |
OverlayManager.removePath(NodeDetails inNode,
long inVersion)
Remove the known path to a node over a specific version of the overlay.
|
boolean |
OverlayManagerImpl.setCurrentOverlay(long inVersion) |
boolean |
OverlayManager.setCurrentOverlay(long inVersion)
Set a specific version of the overlay as the current version.
|
boolean |
OverlayLinkImpl.setPrimary(boolean inPrimary) |
boolean |
OverlayLink.setPrimary(boolean inPrimary)
Set the primary status of this link.
|
boolean |
OverlayVersion.unlink(NodeDetails inNode)
Close a link.
|
boolean |
OverlayVersionImpl.unlink(NodeDetails inNode) |
boolean |
OverlayVersion.updateLocation(int[] inLocation)
Update the known location of this node in this version of the overlay.
|
boolean |
OverlayVersionImpl.updateLocation(int[] inLoc) |
boolean |
OverlayManagerImpl.updatePath(NodeDetails inNode,
OverlayPath inPath) |
boolean |
OverlayManager.updatePath(NodeDetails inNode,
OverlayPath inPath)
Update the known path to a node for a given version of the overlay.
|
| Constructor and Description |
|---|
OverlayVersionImpl(OverlayManagerImpl inManager,
long inVersion) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<OverlayLink,java.util.List<OverlayPath>> |
RoutePolicyImpl.getRoutingLinks(MessageEvent inEvent) |
java.util.Map<OverlayLink,java.util.List<OverlayPath>> |
RoutePolicy.getRoutingLinks(MessageEvent inEvent)
Determine the links that should be used to route a message.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PeerGroup.addUtilizer(PeerGroupUtilizer inUtilizer)
Register a utilizer with this group.
|
void |
PeerGroupImpl.addUtilizer(PeerGroupUtilizer inUtilizer) |
void |
PeerGroupOverlay.appendOverlay(NodeDetails inDetails) |
void |
PeerGroupOverlay.generateOverlay(GraphBuilder inTopoGen,
GraphBuilder inRouteGen) |
java.util.List<PeerDetails> |
PeerGroup.getKnownPeers()
Get the overlay information for any known nodes.
|
java.util.List<PeerDetails> |
PeerGroupImpl.getKnownPeers() |
OverlayLink |
PeerDetails.getOverlayLink() |
OverlayLink |
PeerDetailsImpl.getOverlayLink() |
OverlayVersion |
PeerGroup.getOverlayLinks() |
OverlayVersion |
PeerGroupImpl.getOverlayLinks() |
OverlayManager |
PeerGroup.getOverlayManager() |
OverlayManager |
PeerGroupImpl.getOverlayManager() |
OverlayPath |
PeerDetails.getOverlayPath() |
OverlayPath |
PeerDetailsImpl.getOverlayPath() |
void |
PeerGroupOverlay.joinOverlay(java.util.List<PeerDetails> inConnectList) |
Task<PeerDetails> |
PeerGroupLookup.lookupPeer() |
PeerDetails |
PeerGroupLookup.lookupPeer(int inMaxTries) |
void |
PeerGroup.setGraphBuilder(GraphBuilder inBuilder)
Set the desired topology type.
|
void |
PeerGroupImpl.setGraphBuilder(GraphBuilder inBuilder) |
void |
PeerGroup.setTreeBuilder(GraphBuilder inBuilder)
Set the desired routing tree type.
|
void |
PeerGroupImpl.setTreeBuilder(GraphBuilder inBuilder) |
PeerDetails |
PeerGroup.updatePeerDetails(NodeDetails inDetails,
OverlayPath inPath,
int inCoordOrder)
Update overlay information for a given node.
|
PeerDetails |
PeerGroupImpl.updatePeerDetails(NodeDetails inDetails,
OverlayPath inPath,
int inCoordOrder) |
| Constructor and Description |
|---|
PeerDetailsImpl(PeerGroupImpl inGroup,
NodeDetails inDetails,
OverlayPath inPath,
int inCoordOrder) |
| Modifier and Type | Method and Description |
|---|---|
static void |
NanoTimeSample.main(java.lang.String[] args) |
static void |
PublishSubscribeSample.main(java.lang.String[] args) |
| Modifier and Type | Method and Description |
|---|---|
TopicPublisher |
Topic.publish() |
TopicPublisher |
TopicBase.publish() |
TopicSubscription |
Topic.subscribe(TopicSubscriptionHandler inHandler) |
TopicSubscription |
TopicBase.subscribe(TopicSubscriptionHandler inHandler) |
| Modifier and Type | Method and Description |
|---|---|
static void |
TrafficReflector.main(java.lang.String[] args) |
static void |
TrafficPublisher.main(java.lang.String[] args) |
static void |
TrafficReflector.onEvent(TopicDataEvent inEvent,
long receiveTime)
If the inEvent was not published by this traffic reflector, republishes
the event to the traffic generation topic.
|
| Modifier and Type | Method and Description |
|---|---|
void |
UpperCaseProducer.initialize() |