Package com.linkedin.venice.router
Class VeniceRouterConfig
- java.lang.Object
-
- com.linkedin.venice.router.VeniceRouterConfig
-
public class VeniceRouterConfig extends java.lang.Object
Configuration for Venice Router.
-
-
Constructor Summary
Constructors Constructor Description VeniceRouterConfig(VeniceProperties props)
-
Method Summary
-
-
-
Constructor Detail
-
VeniceRouterConfig
public VeniceRouterConfig(VeniceProperties props)
-
-
Method Detail
-
getPerStoreRouterQuotaBuffer
public double getPerStoreRouterQuotaBuffer()
-
getClusterName
public java.lang.String getClusterName()
-
getZkConnection
public java.lang.String getZkConnection()
-
getPort
public int getPort()
-
getHostname
public java.lang.String getHostname()
-
getSslPort
public int getSslPort()
-
getHeartbeatTimeoutMs
public double getHeartbeatTimeoutMs()
-
getHeartbeatCycleMs
public long getHeartbeatCycleMs()
-
isSslToStorageNodes
public boolean isSslToStorageNodes()
-
getMaxReadCapacityCu
public long getMaxReadCapacityCu()
-
getLongTailRetryForSingleGetThresholdMs
public int getLongTailRetryForSingleGetThresholdMs()
-
getMaxKeyCountInMultiGetReq
public int getMaxKeyCountInMultiGetReq()
-
getClusterToD2Map
public java.util.Map<java.lang.String,java.lang.String> getClusterToD2Map()
-
getClusterToServerD2Map
public java.util.Map<java.lang.String,java.lang.String> getClusterToServerD2Map()
-
getConnectionLimit
public int getConnectionLimit()
-
getHttpClientPoolSize
public int getHttpClientPoolSize()
-
getMaxOutgoingConnPerRoute
public int getMaxOutgoingConnPerRoute()
-
getMaxOutgoingConn
public int getMaxOutgoingConn()
-
getRefreshIntervalForZkReconnectInMs
public long getRefreshIntervalForZkReconnectInMs()
-
getRefreshAttemptsForZkReconnect
public int getRefreshAttemptsForZkReconnect()
-
getRouterNettyGracefulShutdownPeriodSeconds
public int getRouterNettyGracefulShutdownPeriodSeconds()
-
isEnforcingSecureOnly
public boolean isEnforcingSecureOnly()
-
getLongTailRetryForBatchGetThresholdMs
public java.util.TreeMap<java.lang.Integer,java.lang.Integer> getLongTailRetryForBatchGetThresholdMs()
-
isDnsCacheEnabled
public boolean isDnsCacheEnabled()
-
getHostPatternForDnsCache
public java.lang.String getHostPatternForDnsCache()
-
getDnsCacheRefreshIntervalInMs
public long getDnsCacheRefreshIntervalInMs()
-
getSingleGetTardyLatencyThresholdMs
public long getSingleGetTardyLatencyThresholdMs()
-
getMultiGetTardyLatencyThresholdMs
public long getMultiGetTardyLatencyThresholdMs()
-
getComputeTardyLatencyThresholdMs
public long getComputeTardyLatencyThresholdMs()
-
isReadThrottlingEnabled
public boolean isReadThrottlingEnabled()
-
setReadThrottlingEnabled
public void setReadThrottlingEnabled(boolean readThrottlingEnabled)
-
getMaxPendingRequest
public long getMaxPendingRequest()
-
isSmartLongTailRetryEnabled
public boolean isSmartLongTailRetryEnabled()
-
getSmartLongTailRetryAbortThresholdMs
public int getSmartLongTailRetryAbortThresholdMs()
-
getLongTailRetryMaxRouteForMultiKeyReq
public int getLongTailRetryMaxRouteForMultiKeyReq()
-
getStorageNodeClientType
public StorageNodeClientType getStorageNodeClientType()
-
isDecompressOnClient
public boolean isDecompressOnClient()
-
getSocketTimeout
public int getSocketTimeout()
-
getConnectionTimeout
public int getConnectionTimeout()
-
isStatefulRouterHealthCheckEnabled
public boolean isStatefulRouterHealthCheckEnabled()
-
getRouterUnhealthyPendingConnThresholdPerRoute
public int getRouterUnhealthyPendingConnThresholdPerRoute()
-
getRouterPendingConnResumeThresholdPerRoute
public int getRouterPendingConnResumeThresholdPerRoute()
-
isPerNodeClientAllocationEnabled
public boolean isPerNodeClientAllocationEnabled()
-
getPerNodeClientThreadCount
public int getPerNodeClientThreadCount()
-
isKeyValueProfilingEnabled
public boolean isKeyValueProfilingEnabled()
-
getLeakedFutureCleanupPollIntervalMs
public long getLeakedFutureCleanupPollIntervalMs()
-
getLeakedFutureCleanupThresholdMs
public long getLeakedFutureCleanupThresholdMs()
-
getKafkaBootstrapServers
public java.lang.String getKafkaBootstrapServers()
-
isSslToKafka
public boolean isSslToKafka()
-
isIdleConnectionToServerCleanupEnabled
public boolean isIdleConnectionToServerCleanupEnabled()
-
getIdleConnectionToServerCleanupThresholdMins
public long getIdleConnectionToServerCleanupThresholdMins()
-
getFullPendingQueueServerOORMs
public long getFullPendingQueueServerOORMs()
-
isHttpasyncclientConnectionWarmingEnabled
public boolean isHttpasyncclientConnectionWarmingEnabled()
-
getHttpasyncclientConnectionWarmingSleepIntervalMs
public long getHttpasyncclientConnectionWarmingSleepIntervalMs()
-
getDictionaryRetrievalTimeMs
public int getDictionaryRetrievalTimeMs()
-
getRouterDictionaryProcessingThreads
public int getRouterDictionaryProcessingThreads()
-
getHttpasyncclientConnectionWarmingLowWaterMark
public int getHttpasyncclientConnectionWarmingLowWaterMark()
-
getHttpasyncclientConnectionWarmingExecutorThreadNum
public int getHttpasyncclientConnectionWarmingExecutorThreadNum()
-
getHttpasyncclientConnectionWarmingNewInstanceDelayJoinMs
public long getHttpasyncclientConnectionWarmingNewInstanceDelayJoinMs()
-
getHttpasyncclientConnectionWarmingSocketTimeoutMs
public int getHttpasyncclientConnectionWarmingSocketTimeoutMs()
-
isAsyncStartEnabled
public boolean isAsyncStartEnabled()
-
getMaxRouterReadCapacityCu
public long getMaxRouterReadCapacityCu()
-
getRouterQuotaCheckWindow
public long getRouterQuotaCheckWindow()
-
isEarlyThrottleEnabled
public boolean isEarlyThrottleEnabled()
-
setEarlyThrottleEnabled
public void setEarlyThrottleEnabled(boolean earlyThrottleEnabled)
-
isHelixHybridStoreQuotaEnabled
public boolean isHelixHybridStoreQuotaEnabled()
-
getIoThreadCountInPoolMode
public int getIoThreadCountInPoolMode()
-
isUseGroupFieldInHelixDomain
public boolean isUseGroupFieldInHelixDomain()
-
getMultiKeyRoutingStrategy
public VeniceMultiKeyRoutingStrategy getMultiKeyRoutingStrategy()
-
getHelixGroupSelectionStrategy
public HelixGroupSelectionStrategyEnum getHelixGroupSelectionStrategy()
-
getSystemSchemaClusterName
public java.lang.String getSystemSchemaClusterName()
-
parseRetryThresholdForBatchGet
public static java.util.TreeMap<java.lang.Integer,java.lang.Integer> parseRetryThresholdForBatchGet(java.lang.String retryThresholdStr)
The expected config format is like the following: "1-10:20,11-50:50,51-200:80,201-:1000"
-
getClientSslHandshakeThreads
public int getClientSslHandshakeThreads()
-
isResolveBeforeSSL
public boolean isResolveBeforeSSL()
-
getMaxConcurrentResolutions
public int getMaxConcurrentResolutions()
-
getClientResolutionRetryAttempts
public int getClientResolutionRetryAttempts()
-
getClientResolutionRetryBackoffMs
public long getClientResolutionRetryBackoffMs()
-
getClientSslHandshakeQueueCapacity
public int getClientSslHandshakeQueueCapacity()
-
getReadQuotaThrottlingLeaseTimeoutMs
public long getReadQuotaThrottlingLeaseTimeoutMs()
-
isRouterHeartBeatEnabled
public boolean isRouterHeartBeatEnabled()
-
getHttpClient5PoolSize
public int getHttpClient5PoolSize()
-
getHttpClient5TotalIOThreadCount
public int getHttpClient5TotalIOThreadCount()
-
isHttpClient5SkipCipherCheck
public boolean isHttpClient5SkipCipherCheck()
-
isHttp2InboundEnabled
public boolean isHttp2InboundEnabled()
-
getHttp2MaxConcurrentStreams
public int getHttp2MaxConcurrentStreams()
-
getHttp2MaxFrameSize
public int getHttp2MaxFrameSize()
-
getHttp2InitialWindowSize
public int getHttp2InitialWindowSize()
-
getHttp2HeaderTableSize
public int getHttp2HeaderTableSize()
-
getHttp2MaxHeaderListSize
public int getHttp2MaxHeaderListSize()
-
isMetaStoreShadowReadEnabled
public boolean isMetaStoreShadowReadEnabled()
-
isUnregisterMetricForDeletedStoreEnabled
public boolean isUnregisterMetricForDeletedStoreEnabled()
-
getRouterIOWorkerCount
public int getRouterIOWorkerCount()
-
isHttpClientOpensslEnabled
public boolean isHttpClientOpensslEnabled()
-
getIdentityParserClassName
public java.lang.String getIdentityParserClassName()
-
getSingleKeyLongTailRetryBudgetPercentDecimal
public double getSingleKeyLongTailRetryBudgetPercentDecimal()
-
getMultiKeyLongTailRetryBudgetPercentDecimal
public double getMultiKeyLongTailRetryBudgetPercentDecimal()
-
getLongTailRetryBudgetEnforcementWindowInMs
public long getLongTailRetryBudgetEnforcementWindowInMs()
-
getRetryManagerCorePoolSize
public int getRetryManagerCorePoolSize()
-
-