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
PubSubClientsFactory	getPubSubClientsFactory()
Function<String,String>	getPubSubEncryptionKeyUrnLookup()	Returns the optional local store-name to raw encryption-key URN lookup, or null if not configured.
PubSubMessageDeserializer	getPubSubMessageDeserializer()
PubSubPositionDeserializer	getPubSubPositionDeserializer()
PubSubPositionTypeRegistry	getPubSubPositionTypeRegistry()
PubSubTopicRepository	getPubSubTopicRepository()
AsyncStoreChangeNotifier	getStoreChangeNotifier()
TopicManager	getTopicManager(String topicName)
TopicManagerRepository	getTopicManagerRepository()
boolean	isUseCheckpointedPubSubPositionWithFallbackEnabled()

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()

getStoreChangeNotifier

public AsyncStoreChangeNotifier getStoreChangeNotifier()

getPubSubEncryptionKeyUrnLookup

public Function<String,String> getPubSubEncryptionKeyUrnLookup()

Returns the optional local store-name to raw encryption-key URN lookup, or null if not configured. The lookup returns null for a missing store; an unassigned key may be null or empty. Metadata may be unavailable during adapter construction; resolve keys when needed after initialization. A missing result must not be cached or interpreted as disabling encryption. It must not refresh metadata or perform remote requests.

getPubSubMessageDeserializer

public PubSubMessageDeserializer getPubSubMessageDeserializer()

getPubSubClientsFactory

public PubSubClientsFactory getPubSubClientsFactory()

isUseCheckpointedPubSubPositionWithFallbackEnabled

public boolean isUseCheckpointedPubSubPositionWithFallbackEnabled()