Package com.linkedin.venice.fastclient

Class ClientConfig<K,V,T extends org.apache.avro.specific.SpecificRecord>

java.lang.Object
com.linkedin.venice.fastclient.ClientConfig<K,V,T>
public class ClientConfig<K,V,T extends org.apache.avro.specific.SpecificRecord> extends Object

  • Field Details

    • LONG_TAIL_RANGE_BASED_RETRY_THRESHOLD_FOR_BATCH_GET_IN_MILLI_SECONDS

      public static final String LONG_TAIL_RANGE_BASED_RETRY_THRESHOLD_FOR_BATCH_GET_IN_MILLI_SECONDS
      See Also:

    • LONG_TAIL_RANGE_BASED_RETRY_THRESHOLD_FOR_COMPUTE_IN_MILLI_SECONDS

      public static final String LONG_TAIL_RANGE_BASED_RETRY_THRESHOLD_FOR_COMPUTE_IN_MILLI_SECONDS
      See Also:

  • Method Details

    • getStoreName

      public String getStoreName()

    • getR2Client

      public com.linkedin.r2.transport.common.Client getR2Client()

    • getMetricsRepository

      public io.tehuti.metrics.MetricsRepository getMetricsRepository()

    • getStats

      public FastClientStats getStats(RequestType requestType)

    • getSpecificValueClass

      public Class<T> getSpecificValueClass()

    • getDeserializationExecutor

      public Executor getDeserializationExecutor()

    • getMetadataRefreshExecutor

      public ScheduledExecutorService getMetadataRefreshExecutor()

    • isDualReadEnabled

      public boolean isDualReadEnabled()

    • getGenericThinClient

      public AvroGenericStoreClient<K,V> getGenericThinClient()

    • getSpecificThinClient

      public AvroSpecificStoreClient<K,T> getSpecificThinClient()

    • getDaVinciClientForMetaStore

      public DaVinciClient<StoreMetaKey,StoreMetaValue> getDaVinciClientForMetaStore()

    • isMetadataConnWarmupEnabled

      public boolean isMetadataConnWarmupEnabled()

    • getMetadataRefreshIntervalInSeconds

      public long getMetadataRefreshIntervalInSeconds()

    • getMetadataConnWarmupTimeoutInSeconds

      public long getMetadataConnWarmupTimeoutInSeconds()

    • isLongTailRetryEnabledForSingleGet

      public boolean isLongTailRetryEnabledForSingleGet()

    • getLongTailRetryThresholdForSingleGetInMicroSeconds

      public int getLongTailRetryThresholdForSingleGetInMicroSeconds()

    • isLongTailRetryEnabledForBatchGet

      public boolean isLongTailRetryEnabledForBatchGet()

    • getLongTailRetryThresholdForBatchGetInMicroSeconds

      public int getLongTailRetryThresholdForBatchGetInMicroSeconds()

    • isLongTailRetryEnabledForCompute

      public boolean isLongTailRetryEnabledForCompute()

    • isVsonStore

      @Deprecated public boolean isVsonStore()
      Deprecated.

    • getClientRoutingStrategyType

      public ClientRoutingStrategyType getClientRoutingStrategyType()

    • getClusterStats

      public ClusterStats getClusterStats()

    • getStoreMetadataFetchMode

      public StoreMetadataFetchMode getStoreMetadataFetchMode()

    • getD2Client

      public com.linkedin.d2.balancer.D2Client getD2Client()

    • getClusterDiscoveryD2Service

      public String getClusterDiscoveryD2Service()

    • useGrpc

      public boolean useGrpc()

    • getGrpcClientConfig

      public GrpcClientConfig getGrpcClientConfig()

    • isProjectionFieldValidationEnabled

      public boolean isProjectionFieldValidationEnabled()

    • getLongTailRetryBudgetEnforcementWindowInMs

      public long getLongTailRetryBudgetEnforcementWindowInMs()

    • getHarClusters

      public Set<String> getHarClusters()

    • setProjectionFieldValidationEnabled

      public ClientConfig setProjectionFieldValidationEnabled(boolean projectionFieldValidation)

    • getInstanceHealthMonitor

      public InstanceHealthMonitor getInstanceHealthMonitor()

    • isRetryBudgetEnabled

      public boolean isRetryBudgetEnabled()

    • getRetryBudgetPercentage

      public double getRetryBudgetPercentage()

    • isEnableLeastLoadedRoutingStrategyForHelixGroupRouting

      public boolean isEnableLeastLoadedRoutingStrategyForHelixGroupRouting()

    • isStoreLoadControllerEnabled

      public boolean isStoreLoadControllerEnabled()

    • getStoreLoadControllerWindowSizeInSec

      public int getStoreLoadControllerWindowSizeInSec()

    • getStoreLoadControllerRejectionRatioUpdateIntervalInSec

      public int getStoreLoadControllerRejectionRatioUpdateIntervalInSec()

    • getStoreLoadControllerMaxRejectionRatio

      public double getStoreLoadControllerMaxRejectionRatio()

    • getStoreLoadControllerAcceptMultiplier

      public double getStoreLoadControllerAcceptMultiplier()

    • getLongTailRangeBasedRetryThresholdForBatchGetInMilliSeconds

      public String getLongTailRangeBasedRetryThresholdForBatchGetInMilliSeconds()

    • getLongTailRangeBasedRetryThresholdForComputeInMilliSeconds

      public String getLongTailRangeBasedRetryThresholdForComputeInMilliSeconds()

    • getKeySerializerFactory

      public Optional<SerializerFactory<K>> getKeySerializerFactory()

    • getValueDeserializerFactory

      public Optional<DeserializerFactory<V>> getValueDeserializerFactory()