Package com.linkedin.venice.router

Class VeniceRouterConfig

  • public class VeniceRouterConfig
extends java.lang.Object
    Configuration for Venice Router.

    • Constructor Detail

    • 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()

      • isDecompressOnClient

        public boolean isDecompressOnClient()

      • isComputeFastAvroEnabled

        public boolean isComputeFastAvroEnabled()

      • 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()

      • 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()