Package com.linkedin.venice.pubsub

Class PubSubContext

java.lang.Object

com.linkedin.venice.pubsub.PubSubContext

public class PubSubContext
extends Object

PubSubContext is a container class that holds all the core components required for managing PubSub infrastructure, including topic managers, position registry, position deserializer, and topic repository.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PubSubContext.Builder

Method Summary

Modifier and Type	Method	Description
PubSubPositionDeserializer	getPubSubPositionDeserializer()
PubSubPositionTypeRegistry	getPubSubPositionTypeRegistry()
PubSubTopicRepository	getPubSubTopicRepository()
TopicManager	getTopicManager(String topicName)
TopicManagerRepository	getTopicManagerRepository()

Methods inherited from class java.lang.Object

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

Method Details

getTopicManager

public TopicManager getTopicManager(String topicName)

getTopicManagerRepository

public TopicManagerRepository getTopicManagerRepository()

getPubSubPositionTypeRegistry

public PubSubPositionTypeRegistry getPubSubPositionTypeRegistry()

getPubSubPositionDeserializer

public PubSubPositionDeserializer getPubSubPositionDeserializer()

getPubSubTopicRepository

public PubSubTopicRepository getPubSubTopicRepository()