@Immutable @ParametersAreNonnullByDefault public class TopologyView extends Object
Constructor and Description |
---|
TopologyView() |
TopologyView(Set<State> newStates) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
Map<String,Long> |
getMinOffsetByPubAgentName()
Return the map of min offset per publisher agent
|
State |
getState(String subAgentId,
String pubAgentName) |
Set<String> |
getSubscribedAgentIds()
Return the identifiers of subscriber agents
|
Set<String> |
getSubscribedAgentIds(String pubAgentName)
Return the identifiers of subscriber agents subscribed to the given publisher agent.
|
Set<State> |
getSubscribedAgents(String pubAgentName)
Return the identifiers of subscriber agents subscribed to the given publisher agent.
|
Set<State> |
getSubscriberAgentStates(String subAgentId)
Return the states for the given subscriber agent.
|
int |
hashCode() |
String |
toString() |
public Set<String> getSubscribedAgentIds()
public Set<String> getSubscribedAgentIds(String pubAgentName)
pubAgentName
- the name of the publisher agentpublic Set<State> getSubscribedAgents(String pubAgentName)
pubAgentName
- the name of the publisher agentpublic Set<State> getSubscriberAgentStates(String subAgentId)
subAgentId
- the name of the subscriber agent to get the states for@CheckForNull public State getState(String subAgentId, String pubAgentName)
public Map<String,Long> getMinOffsetByPubAgentName()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.