Package com.linkedin.venice.router

Class VeniceRouterConfig

java.lang.Object
com.linkedin.venice.router.VeniceRouterConfig
All Implemented Interfaces:
RouterRetryConfig
public class VeniceRouterConfig extends Object implements RouterRetryConfig
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()
      Specified by:
      getLongTailRetryForSingleGetThresholdMs in interface RouterRetryConfig

    • 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()
      Specified by:
      getLongTailRetryForBatchGetThresholdMs in interface RouterRetryConfig

    • 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()
      Specified by:
      isSmartLongTailRetryEnabled in interface RouterRetryConfig

    • getSmartLongTailRetryAbortThresholdMs

      public int getSmartLongTailRetryAbortThresholdMs()
      Specified by:
      getSmartLongTailRetryAbortThresholdMs in interface RouterRetryConfig

    • getLongTailRetryMaxRouteForMultiKeyReq

      public int getLongTailRetryMaxRouteForMultiKeyReq()
      Specified by:
      getLongTailRetryMaxRouteForMultiKeyReq in interface RouterRetryConfig

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

    • getNameRepoMaxEntryCount

      public int getNameRepoMaxEntryCount()