Class TopicManagerContext
- java.lang.Object
-
- com.linkedin.venice.pubsub.manager.TopicManagerContext
-
public class TopicManagerContext extends java.lang.Object
A context object that contains all the dependencies needed byTopicManager
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TopicManagerContext.Builder
static interface
TopicManagerContext.PubSubPropertiesSupplier
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.tehuti.metrics.MetricsRepository
getMetricsRepository()
PubSubAdminAdapterFactory<PubSubAdminAdapter>
getPubSubAdminAdapterFactory()
PubSubConsumerAdapterFactory<PubSubConsumerAdapter>
getPubSubConsumerAdapterFactory()
long
getPubSubOperationTimeoutMs()
VeniceProperties
getPubSubProperties(java.lang.String pubSubBootstrapServers)
TopicManagerContext.PubSubPropertiesSupplier
getPubSubPropertiesSupplier()
PubSubTopicRepository
getPubSubTopicRepository()
long
getTopicDeletionStatusPollIntervalMs()
int
getTopicMetadataFetcherConsumerPoolSize()
int
getTopicMetadataFetcherThreadPoolSize()
long
getTopicMinLogCompactionLagMs()
long
getTopicOffsetCheckIntervalMs()
java.lang.String
toString()
-
-
-
Method Detail
-
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(java.lang.String pubSubBootstrapServers)
-
getTopicOffsetCheckIntervalMs
public long getTopicOffsetCheckIntervalMs()
-
getTopicMetadataFetcherConsumerPoolSize
public int getTopicMetadataFetcherConsumerPoolSize()
-
getTopicMetadataFetcherThreadPoolSize
public int getTopicMetadataFetcherThreadPoolSize()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-