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
io.tehuti.metrics.MetricsRepository	getMetricsRepository()
PubSubAdminAdapterFactory<PubSubAdminAdapter>	getPubSubAdminAdapterFactory()
PubSubConsumerAdapterFactory<PubSubConsumerAdapter>	getPubSubConsumerAdapterFactory()
long	getPubSubOperationTimeoutMs()
VeniceProperties	getPubSubProperties(String pubSubBootstrapServers)
TopicManagerContext.PubSubPropertiesSupplier	getPubSubPropertiesSupplier()
PubSubTopicRepository	getPubSubTopicRepository()
long	getTopicDeletionStatusPollIntervalMs()
int	getTopicMetadataFetcherConsumerPoolSize()
int	getTopicMetadataFetcherThreadPoolSize()
long	getTopicMinLogCompactionLagMs()
long	getTopicOffsetCheckIntervalMs()
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()

toString

public String toString()

Overrides:

toString in class Object