Package com.linkedin.davinci.repository

Class VeniceMetadataRepositoryBuilder

java.lang.Object

com.linkedin.davinci.repository.VeniceMetadataRepositoryBuilder

public class VeniceMetadataRepositoryBuilder
extends java.lang.Object

VeniceMetadataRepositoryBuilder is a centralized builder class for constructing a variety of metadata components including store repository, schema repository, ZK-shared schema repository, ZK client and cluster info provider for Da Vinci, Venice Service and Isolated Ingestion Service.

Constructor Summary

Constructors

Constructor	Description
VeniceMetadataRepositoryBuilder(VeniceConfigLoader configLoader, ClientConfig clientConfig, io.tehuti.metrics.MetricsRepository metricsRepository, ICProvider icProvider, boolean isIngestionIsolation)

Method Summary

Modifier and Type	Method	Description
ClusterInfoProvider	getClusterInfoProvider()
ReadOnlyLiveClusterConfigRepository	getLiveClusterConfigRepo()
java.util.Optional<HelixReadOnlyZKSharedSchemaRepository>	getReadOnlyZKSharedSchemaRepository()
ReadOnlySchemaRepository	getSchemaRepo()
HelixReadOnlyStoreConfigRepository	getStoreConfigRepo()
ReadOnlyStoreRepository	getStoreRepo()
org.apache.helix.zookeeper.impl.client.ZkClient	getZkClient()
boolean	isDaVinciClient()

Methods inherited from class java.lang.Object

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

Constructor Detail

VeniceMetadataRepositoryBuilder

public VeniceMetadataRepositoryBuilder(VeniceConfigLoader configLoader,
                                       ClientConfig clientConfig,
                                       io.tehuti.metrics.MetricsRepository metricsRepository,
                                       ICProvider icProvider,
                                       boolean isIngestionIsolation)

Method Detail

getZkClient

public org.apache.helix.zookeeper.impl.client.ZkClient getZkClient()

getClusterInfoProvider

public ClusterInfoProvider getClusterInfoProvider()

getStoreRepo

public ReadOnlyStoreRepository getStoreRepo()

getStoreConfigRepo

public HelixReadOnlyStoreConfigRepository getStoreConfigRepo()

getSchemaRepo

public ReadOnlySchemaRepository getSchemaRepo()

getLiveClusterConfigRepo

public ReadOnlyLiveClusterConfigRepository getLiveClusterConfigRepo()

getReadOnlyZKSharedSchemaRepository

public java.util.Optional<HelixReadOnlyZKSharedSchemaRepository> getReadOnlyZKSharedSchemaRepository()

isDaVinciClient

public final boolean isDaVinciClient()