Class TopologyView
- java.lang.Object
-
- org.apache.sling.distribution.journal.impl.discovery.TopologyView
-
@Immutable @ParametersAreNonnullByDefault public class TopologyView extends Object
-
-
Constructor Summary
Constructors Constructor Description TopologyView()TopologyView(Set<State> newStates)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)Map<String,Long>getMinOffsetByPubAgentName()Return the map of min offset per publisher agentStategetState(String subAgentId, String pubAgentName)Set<String>getSubscribedAgentIds()Return the identifiers of subscriber agentsSet<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.inthashCode()Stream<Long>offsets()Return a stream of the offsets from all states in the view.StringtoString()
-
-
-
Method Detail
-
getSubscribedAgentIds
public Set<String> getSubscribedAgentIds()
Return the identifiers of subscriber agents- Returns:
- a set of subscriber agent identifiers (subAgentId)
-
getSubscribedAgentIds
public Set<String> getSubscribedAgentIds(String pubAgentName)
Return the identifiers of subscriber agents subscribed to the given publisher agent.- Parameters:
pubAgentName- the name of the publisher agent- Returns:
- a set of subscriber agent identifiers (subAgentId)
-
getSubscribedAgents
public Set<State> getSubscribedAgents(String pubAgentName)
Return the identifiers of subscriber agents subscribed to the given publisher agent.- Parameters:
pubAgentName- the name of the publisher agent- Returns:
- a set of subscriber agent identifiers (subAgentId)
-
getSubscriberAgentStates
public Set<State> getSubscriberAgentStates(String subAgentId)
Return the states for the given subscriber agent.- Parameters:
subAgentId- the name of the subscriber agent to get the states for- Returns:
- states of that subscriber agent
-
getState
@CheckForNull public State getState(String subAgentId, String pubAgentName)
-
getMinOffsetByPubAgentName
public Map<String,Long> getMinOffsetByPubAgentName()
Return the map of min offset per publisher agent- Returns:
- a map (pubAgentName x offset)
-
offsets
public Stream<Long> offsets()
Return a stream of the offsets from all states in the view.- Returns:
- a stream of offsets
-
-