Package com.linkedin.venice.router
Class VeniceRouterConfig
java.lang.Object
com.linkedin.venice.router.VeniceRouterConfig
Configuration for Venice Router.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionint
long
int
int
long
int
int
int
long
long
long
double
int
int
int
int
int
int
int
long
long
int
int
int
int
long
int
long
long
long
int
int
int
int
int
int
long
long
long
long
double
int
double
int
getPort()
long
int
long
int
int
int
int
int
long
int
long
double
int
int
int
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
parseRetryThresholdForBatchGet
(String retryThresholdStr) The expected config format is like the following: "1-10:20,11-50:50,51-200:80,201-:1000"void
setEarlyThrottleEnabled
(boolean earlyThrottleEnabled) void
setReadThrottlingEnabled
(boolean readThrottlingEnabled)
-
Constructor Details
-
VeniceRouterConfig
-
-
Method Details
-
getPerStoreRouterQuotaBuffer
public double getPerStoreRouterQuotaBuffer() -
getClusterName
-
getZkConnection
-
getPort
public int getPort() -
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
-
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
-
isDnsCacheEnabled
public boolean isDnsCacheEnabled() -
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
-
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
-
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
-
getHelixGroupSelectionStrategy
-
getSystemSchemaClusterName
-
parseRetryThresholdForBatchGet
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
-
getSingleKeyLongTailRetryBudgetPercentDecimal
public double getSingleKeyLongTailRetryBudgetPercentDecimal() -
getMultiKeyLongTailRetryBudgetPercentDecimal
public double getMultiKeyLongTailRetryBudgetPercentDecimal() -
getLongTailRetryBudgetEnforcementWindowInMs
public long getLongTailRetryBudgetEnforcementWindowInMs() -
getRetryManagerCorePoolSize
public int getRetryManagerCorePoolSize()
-