Package com.linkedin.venice.router.api

Class VeniceVersionFinder

java.lang.Object

com.linkedin.venice.router.api.VeniceVersionFinder

public class VeniceVersionFinder
extends Object

VeniceVersionFinder provides methods to find the version for a given store.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,RouterCurrentVersionStats>	storeStats

Constructor Summary

Constructors

Constructor	Description
VeniceVersionFinder(ReadOnlyStoreRepository metadataRepository, HelixBaseRoutingRepository routingDataRepository, StaleVersionStats stats, ReadOnlyStoreConfigRepository storeConfigRepo, Map<String,String> clusterToD2Map, String clusterName, CompressorFactory compressorFactory, io.tehuti.metrics.MetricsRepository metricsRepository)

Method Summary

Modifier and Type	Method	Description
int	getVersion(String storeName, BasicFullHttpRequest request)
protected boolean	isDecompressorReady(Version version, String kafkaTopicName)
protected boolean	isPartitionResourcesReady(String kafkaTopic)

Methods inherited from class java.lang.Object

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

Field Details

storeStats

protected final Map<String,RouterCurrentVersionStats> storeStats

Constructor Details

VeniceVersionFinder

public VeniceVersionFinder(ReadOnlyStoreRepository metadataRepository,
 HelixBaseRoutingRepository routingDataRepository,
 StaleVersionStats stats,
 ReadOnlyStoreConfigRepository storeConfigRepo,
 Map<String,String> clusterToD2Map,
 String clusterName,
 CompressorFactory compressorFactory,
 io.tehuti.metrics.MetricsRepository metricsRepository)

Method Details

getVersion

public int getVersion(String storeName,
 BasicFullHttpRequest request)
               throws VeniceException

Throws:

VeniceException

isPartitionResourcesReady

protected boolean isPartitionResourcesReady(String kafkaTopic)

isDecompressorReady

protected boolean isDecompressorReady(Version version,
 String kafkaTopicName)