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