Class TopologyView

    • Constructor Detail

      • TopologyView

        public TopologyView()
      • TopologyView

        public TopologyView​(Set<State> newStates)
    • 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
      • 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
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object