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 java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClientConfig.ClientConfigBuilder<K,V,T extends org.apache.avro.specific.SpecificRecord>

Method Summary

Modifier and Type	Method	Description
ClientRoutingStrategyType	getClientRoutingStrategyType()
java.lang.String	getClusterDiscoveryD2Service()
ClusterStats	getClusterStats()
com.linkedin.d2.balancer.D2Client	getD2Client()
DaVinciClient<StoreMetaKey,StoreMetaValue>	getDaVinciClientForMetaStore()
java.util.concurrent.Executor	getDeserializationExecutor()
AvroGenericStoreClient<K,V>	getGenericThinClient()
GrpcClientConfig	getGrpcClientConfig()
java.util.Set<java.lang.String>	getHarClusters()
long	getLongTailRetryBudgetEnforcementWindowInMs()
int	getLongTailRetryThresholdForBatchGetInMicroSeconds()
int	getLongTailRetryThresholdForComputeInMicroSeconds()
int	getLongTailRetryThresholdForSingleGetInMicroSeconds()
long	getMetadataConnWarmupTimeoutInSeconds()
long	getMetadataRefreshIntervalInSeconds()
io.tehuti.metrics.MetricsRepository	getMetricsRepository()
com.linkedin.r2.transport.common.Client	getR2Client()
long	getRoutingErrorRequestCounterResetDelayMS()
long	getRoutingLeakedRequestCleanupThresholdMS()
int	getRoutingPendingRequestCounterInstanceBlockThreshold()
long	getRoutingQuotaExceededRequestCounterResetDelayMS()
long	getRoutingUnavailableRequestCounterResetDelayMS()
AvroSpecificStoreClient<K,T>	getSpecificThinClient()
java.lang.Class<T>	getSpecificValueClass()
FastClientStats	getStats(RequestType requestType)
StoreMetadataFetchMode	getStoreMetadataFetchMode()
java.lang.String	getStoreName()
boolean	isDualReadEnabled()
boolean	isLongTailRetryEnabledForBatchGet()
boolean	isLongTailRetryEnabledForCompute()
boolean	isLongTailRetryEnabledForSingleGet()
boolean	isMetadataConnWarmupEnabled()
boolean	isProjectionFieldValidationEnabled()
boolean	isSpeculativeQueryEnabled()
boolean	isVsonStore()	Deprecated.
ClientConfig	setProjectionFieldValidationEnabled(boolean projectionFieldValidation)
boolean	useGrpc()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getStoreName

public java.lang.String getStoreName()

getR2Client

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

getMetricsRepository

public io.tehuti.metrics.MetricsRepository getMetricsRepository()

getStats

public FastClientStats getStats(RequestType requestType)

isSpeculativeQueryEnabled

public boolean isSpeculativeQueryEnabled()

getSpecificValueClass

public java.lang.Class<T> getSpecificValueClass()

getDeserializationExecutor

public java.util.concurrent.Executor getDeserializationExecutor()

isDualReadEnabled

public boolean isDualReadEnabled()

getGenericThinClient

public AvroGenericStoreClient<K,V> getGenericThinClient()

getSpecificThinClient

public AvroSpecificStoreClient<K,T> getSpecificThinClient()

getRoutingLeakedRequestCleanupThresholdMS

public long getRoutingLeakedRequestCleanupThresholdMS()

getRoutingQuotaExceededRequestCounterResetDelayMS

public long getRoutingQuotaExceededRequestCounterResetDelayMS()

getRoutingErrorRequestCounterResetDelayMS

public long getRoutingErrorRequestCounterResetDelayMS()

getRoutingUnavailableRequestCounterResetDelayMS

public long getRoutingUnavailableRequestCounterResetDelayMS()

getRoutingPendingRequestCounterInstanceBlockThreshold

public int getRoutingPendingRequestCounterInstanceBlockThreshold()

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

getLongTailRetryThresholdForComputeInMicroSeconds

public int getLongTailRetryThresholdForComputeInMicroSeconds()

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 java.lang.String getClusterDiscoveryD2Service()

useGrpc

public boolean useGrpc()

getGrpcClientConfig

public GrpcClientConfig getGrpcClientConfig()

isProjectionFieldValidationEnabled

public boolean isProjectionFieldValidationEnabled()

getLongTailRetryBudgetEnforcementWindowInMs

public long getLongTailRetryBudgetEnforcementWindowInMs()

getHarClusters

public java.util.Set<java.lang.String> getHarClusters()

setProjectionFieldValidationEnabled

public ClientConfig setProjectionFieldValidationEnabled(boolean projectionFieldValidation)