Package com.linkedin.venice.pubsub.manager

Class TopicManagerContext

java.lang.Object

com.linkedin.venice.pubsub.manager.TopicManagerContext

public class TopicManagerContext
extends Object

A context object that contains all the dependencies needed by TopicManager.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TopicManagerContext.Builder
static interface	TopicManagerContext.PubSubPropertiesSupplier

Method Summary

Modifier and Type	Method	Description
LogContext	getLogContext()
io.tehuti.metrics.MetricsRepository	getMetricsRepository()
PubSubAdminAdapterFactory<PubSubAdminAdapter>	getPubSubAdminAdapterFactory()
PubSubConsumerAdapterFactory<PubSubConsumerAdapter>	getPubSubConsumerAdapterFactory()
Function<String,String>	getPubSubEncryptionKeyUrnLookup()
long	getPubSubOperationTimeoutMs()
PubSubPositionTypeRegistry	getPubSubPositionTypeRegistry()
VeniceProperties	getPubSubProperties(String pubSubBootstrapServers)
TopicManagerContext.PubSubPropertiesSupplier	getPubSubPropertiesSupplier()
PubSubTopicRepository	getPubSubTopicRepository()
AsyncStoreChangeNotifier	getStoreChangeNotifier()
long	getTopicDeletionStatusPollIntervalMs()
int	getTopicMetadataFetcherConsumerPoolSize()
int	getTopicMetadataFetcherThreadPoolSize()
long	getTopicMinLogCompactionLagMs()
long	getTopicOffsetCheckIntervalMs()
VeniceComponent	getVeniceComponent()
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

getPubSubOperationTimeoutMs

public long getPubSubOperationTimeoutMs()

getTopicDeletionStatusPollIntervalMs

public long getTopicDeletionStatusPollIntervalMs()

getTopicMinLogCompactionLagMs

public long getTopicMinLogCompactionLagMs()

getPubSubAdminAdapterFactory

public PubSubAdminAdapterFactory<PubSubAdminAdapter> getPubSubAdminAdapterFactory()

getPubSubConsumerAdapterFactory

public PubSubConsumerAdapterFactory<PubSubConsumerAdapter> getPubSubConsumerAdapterFactory()

getPubSubTopicRepository

public PubSubTopicRepository getPubSubTopicRepository()

getMetricsRepository

public io.tehuti.metrics.MetricsRepository getMetricsRepository()

getPubSubPropertiesSupplier

public TopicManagerContext.PubSubPropertiesSupplier getPubSubPropertiesSupplier()

getPubSubProperties

public VeniceProperties getPubSubProperties(String pubSubBootstrapServers)

getTopicOffsetCheckIntervalMs

public long getTopicOffsetCheckIntervalMs()

getTopicMetadataFetcherConsumerPoolSize

public int getTopicMetadataFetcherConsumerPoolSize()

getTopicMetadataFetcherThreadPoolSize

public int getTopicMetadataFetcherThreadPoolSize()

getVeniceComponent

public VeniceComponent getVeniceComponent()

getLogContext

public LogContext getLogContext()

getPubSubPositionTypeRegistry

public PubSubPositionTypeRegistry getPubSubPositionTypeRegistry()

getStoreChangeNotifier

public AsyncStoreChangeNotifier getStoreChangeNotifier()

getPubSubEncryptionKeyUrnLookup

public Function<String,String> getPubSubEncryptionKeyUrnLookup()

See Also:

• PubSubContext.getPubSubEncryptionKeyUrnLookup()

toString

public String toString()

Overrides:

toString in class Object