Package com.linkedin.venice.pubsub.manager

Class TopicManagerContext.Builder

java.lang.Object

com.linkedin.venice.pubsub.manager.TopicManagerContext.Builder

Enclosing class:

TopicManagerContext

public static class TopicManagerContext.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
TopicManagerContext	build()
TopicManagerContext.Builder	setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository)
TopicManagerContext.Builder	setPubSubAdminAdapterFactory(PubSubAdminAdapterFactory<PubSubAdminAdapter> pubSubAdminAdapterFactory)
TopicManagerContext.Builder	setPubSubConsumerAdapterFactory(PubSubConsumerAdapterFactory<PubSubConsumerAdapter> pubSubConsumerAdapterFactory)
TopicManagerContext.Builder	setPubSubOperationTimeoutMs(long pubSubOperationTimeoutMs)
TopicManagerContext.Builder	setPubSubPropertiesSupplier(TopicManagerContext.PubSubPropertiesSupplier pubSubPropertiesSupplier)
TopicManagerContext.Builder	setPubSubTopicRepository(PubSubTopicRepository pubSubTopicRepository)
TopicManagerContext.Builder	setTopicDeletionStatusPollIntervalMs(long topicDeletionStatusPollIntervalMs)
TopicManagerContext.Builder	setTopicMetadataFetcherConsumerPoolSize(int topicMetadataFetcherConsumerPoolSize)
TopicManagerContext.Builder	setTopicMetadataFetcherThreadPoolSize(int topicMetadataFetcherThreadPoolSize)
TopicManagerContext.Builder	setTopicMinLogCompactionLagMs(long topicMinLogCompactionLagMs)
TopicManagerContext.Builder	setTopicOffsetCheckIntervalMs(long topicOffsetCheckIntervalMs)
void	verify()

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setPubSubOperationTimeoutMs

public TopicManagerContext.Builder setPubSubOperationTimeoutMs(long pubSubOperationTimeoutMs)

setTopicDeletionStatusPollIntervalMs

public TopicManagerContext.Builder setTopicDeletionStatusPollIntervalMs(long topicDeletionStatusPollIntervalMs)

setTopicMinLogCompactionLagMs

public TopicManagerContext.Builder setTopicMinLogCompactionLagMs(long topicMinLogCompactionLagMs)

setPubSubAdminAdapterFactory

public TopicManagerContext.Builder setPubSubAdminAdapterFactory(PubSubAdminAdapterFactory<PubSubAdminAdapter> pubSubAdminAdapterFactory)

setPubSubConsumerAdapterFactory

public TopicManagerContext.Builder setPubSubConsumerAdapterFactory(PubSubConsumerAdapterFactory<PubSubConsumerAdapter> pubSubConsumerAdapterFactory)

setPubSubTopicRepository

public TopicManagerContext.Builder setPubSubTopicRepository(PubSubTopicRepository pubSubTopicRepository)

setMetricsRepository

public TopicManagerContext.Builder setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository)

setPubSubPropertiesSupplier

public TopicManagerContext.Builder setPubSubPropertiesSupplier(TopicManagerContext.PubSubPropertiesSupplier pubSubPropertiesSupplier)

setTopicOffsetCheckIntervalMs

public TopicManagerContext.Builder setTopicOffsetCheckIntervalMs(long topicOffsetCheckIntervalMs)

setTopicMetadataFetcherConsumerPoolSize

public TopicManagerContext.Builder setTopicMetadataFetcherConsumerPoolSize(int topicMetadataFetcherConsumerPoolSize)

setTopicMetadataFetcherThreadPoolSize

public TopicManagerContext.Builder setTopicMetadataFetcherThreadPoolSize(int topicMetadataFetcherThreadPoolSize)

verify

public void verify()

build

public TopicManagerContext build()