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 boolean
equals(Object o)
Map<String,Long>
getMinOffsetByPubAgentName()
Return the map of min offset per publisher agentState
getState(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.int
hashCode()
Stream<Long>
offsets()
Return a stream of the offsets from all states in the view.String
toString()
-
-
-
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
-
-