Class TopicManagerRepository

  • All Implemented Interfaces:, java.lang.AutoCloseable

    public class TopicManagerRepository
    extends java.lang.Object
    A repository of TopicManager instances, each associated with a specific PubSub region and cluster. This repository maintains one TopicManager for each unique PubSub bootstrap server address. While not mandatory, it is expected that each Venice component will have one and only one instance of this class.
    • Constructor Detail

      • TopicManagerRepository

        public TopicManagerRepository​(TopicManagerContext topicManagerContext,
                                      java.lang.String localPubSubAddress)
    • Method Detail

      • getLocalTopicManager

        public TopicManager getLocalTopicManager()
        By default, return TopicManager for local PubSub cluster.
      • getTopicManager

        public TopicManager getTopicManager​(java.lang.String pubSubAddress)
      • invalidateTopicManagerCaches

        public void invalidateTopicManagerCaches​(PubSubTopic pubSubTopic)
        Invalidates the cache for the given PubSub topic across all TopicManagers in the repository.
        pubSubTopic - the PubSub topic to invalidate
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface