Package com.linkedin.venice.pubsub.manager

Class TopicManagerRepository

java.lang.Object

com.linkedin.venice.pubsub.manager.TopicManagerRepository

All Implemented Interfaces:

Closeable, AutoCloseable

public class TopicManagerRepository
extends Object
implements Closeable

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 Summary

Constructors

Constructor	Description
TopicManagerRepository(TopicManagerContext topicManagerContext, String localPubSubAddress)

Method Summary

Modifier and Type	Method	Description
void	close()
TopicManager	getLocalTopicManager()	By default, return TopicManager for local PubSub cluster.
TopicManager	getTopicManager(String pubSubAddress)
void	invalidateTopicManagerCaches(PubSubTopic pubSubTopic)	Invalidates the cache for the given PubSub topic across all TopicManagers in the repository.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TopicManagerRepository

public TopicManagerRepository(TopicManagerContext topicManagerContext,
 String localPubSubAddress)

Method Details

getLocalTopicManager

public TopicManager getLocalTopicManager()

By default, return TopicManager for local PubSub cluster.

getTopicManager

public TopicManager getTopicManager(String pubSubAddress)

invalidateTopicManagerCaches

public void invalidateTopicManagerCaches(PubSubTopic pubSubTopic)

Invalidates the cache for the given PubSub topic across all TopicManagers in the repository.

Parameters:

pubSubTopic - the PubSub topic to invalidate

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable