Class VeniceRouterConfig

java.lang.Object
com.linkedin.venice.router.VeniceRouterConfig

public class VeniceRouterConfig extends Object
Configuration for Venice Router.
  • Constructor Details

  • Method Details

    • getPerStoreRouterQuotaBuffer

      public double getPerStoreRouterQuotaBuffer()
    • getClusterName

      public String getClusterName()
    • getZkConnection

      public String getZkConnection()
    • getPort

      public int getPort()
    • getHostname

      public 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 Map<String,String> getClusterToD2Map()
    • getClusterToServerD2Map

      public Map<String,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 TreeMap<Integer,Integer> getLongTailRetryForBatchGetThresholdMs()
    • isDnsCacheEnabled

      public boolean isDnsCacheEnabled()
    • getHostPatternForDnsCache

      public 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 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 String getSystemSchemaClusterName()
    • parseRetryThresholdForBatchGet

      public static TreeMap<Integer,Integer> parseRetryThresholdForBatchGet(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 String getIdentityParserClassName()
    • getSingleKeyLongTailRetryBudgetPercentDecimal

      public double getSingleKeyLongTailRetryBudgetPercentDecimal()
    • getMultiKeyLongTailRetryBudgetPercentDecimal

      public double getMultiKeyLongTailRetryBudgetPercentDecimal()
    • getLongTailRetryBudgetEnforcementWindowInMs

      public long getLongTailRetryBudgetEnforcementWindowInMs()
    • getRetryManagerCorePoolSize

      public int getRetryManagerCorePoolSize()