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	setLogContext(LogContext logContext)
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	setPubSubPositionTypeRegistry(PubSubPositionTypeRegistry pubSubPositionTypeRegistry)
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)
TopicManagerContext.Builder	setVeniceComponent(VeniceComponent veniceComponent)
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)

setPubSubPositionTypeRegistry

public TopicManagerContext.Builder setPubSubPositionTypeRegistry(PubSubPositionTypeRegistry pubSubPositionTypeRegistry)

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)

setVeniceComponent

public TopicManagerContext.Builder setVeniceComponent(VeniceComponent veniceComponent)

setLogContext

public TopicManagerContext.Builder setLogContext(LogContext logContext)

verify

public void verify()

build

public TopicManagerContext build()