Package com.linkedin.venice.fastclient

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

java.lang.Object

com.linkedin.venice.fastclient.ClientConfig.ClientConfigBuilder<K,V,T>

Enclosing class:

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

public static class ClientConfig.ClientConfigBuilder<K,V,T extends org.apache.avro.specific.SpecificRecord>
extends Object

Constructor Summary

Constructors

Constructor	Description
ClientConfigBuilder()

Method Summary

Modifier and Type	Method	Description
ClientConfig<K,V,T>	build()
ClientConfig.ClientConfigBuilder<K,V,T>	clone()
ClientConfig.ClientConfigBuilder<K,V,T>	setClientRoutingStrategyType(ClientRoutingStrategyType clientRoutingStrategyType)
ClientConfig.ClientConfigBuilder<K,V,T>	setClusterDiscoveryD2Service(String clusterDiscoveryD2Service)
ClientConfig.ClientConfigBuilder<K,V,T>	setD2Client(com.linkedin.d2.balancer.D2Client d2Client)
ClientConfig.ClientConfigBuilder<K,V,T>	setDaVinciClientForMetaStore(DaVinciClient<StoreMetaKey,StoreMetaValue> daVinciClientForMetaStore)
ClientConfig.ClientConfigBuilder<K,V,T>	setDeserializationExecutor(Executor deserializationExecutor)
ClientConfig.ClientConfigBuilder<K,V,T>	setDualReadEnabled(boolean dualReadEnabled)
ClientConfig.ClientConfigBuilder<K,V,T>	setGenericThinClient(AvroGenericStoreClient<K,V> genericThinClient)
ClientConfig.ClientConfigBuilder<K,V,T>	setGrpcClientConfig(GrpcClientConfig grpcClientConfig)
ClientConfig.ClientConfigBuilder<K,V,T>	setHARClusters(Set<String> clusters)
ClientConfig.ClientConfigBuilder<K,V,T>	setIsMetadataConnWarmupEnabled(boolean isMetadataConnWarmupEnabled)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryBudgetEnforcementWindowInMs(long longTailRetryBudgetEnforcementWindowInMs)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryEnabledForBatchGet(boolean longTailRetryEnabledForBatchGet)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryEnabledForCompute(boolean longTailRetryEnabledForCompute)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryEnabledForSingleGet(boolean longTailRetryEnabledForSingleGet)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryThresholdForBatchGetInMicroSeconds(int longTailRetryThresholdForBatchGetInMicroSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryThresholdForComputeInMicroSeconds(int longTailRetryThresholdForComputeInMicroSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryThresholdForSingleGetInMicroSeconds(int longTailRetryThresholdForSingleGetInMicroSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setMetadataConnWarmupTimeoutInSeconds(long metadataConnWarmupTimeoutInSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setMetadataRefreshIntervalInSeconds(long metadataRefreshIntervalInSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository)
ClientConfig.ClientConfigBuilder<K,V,T>	setProjectionFieldValidationEnabled(boolean projectionFieldValidation)
ClientConfig.ClientConfigBuilder<K,V,T>	setR2Client(com.linkedin.r2.transport.common.Client r2Client)
ClientConfig.ClientConfigBuilder<K,V,T>	setRoutingErrorRequestCounterResetDelayMS(long routingErrorRequestCounterResetDelayMS)
ClientConfig.ClientConfigBuilder<K,V,T>	setRoutingLeakedRequestCleanupThresholdMS(long routingLeakedRequestCleanupThresholdMS)
ClientConfig.ClientConfigBuilder<K,V,T>	setRoutingPendingRequestCounterInstanceBlockThreshold(int routingPendingRequestCounterInstanceBlockThreshold)
ClientConfig.ClientConfigBuilder<K,V,T>	setRoutingQuotaExceededRequestCounterResetDelayMS(long routingQuotaExceededRequestCounterResetDelayMS)
ClientConfig.ClientConfigBuilder<K,V,T>	setRoutingUnavailableRequestCounterResetDelayMS(long routingUnavailableRequestCounterResetDelayMS)
ClientConfig.ClientConfigBuilder<K,V,T>	setSpecificThinClient(AvroSpecificStoreClient<K,T> specificThinClient)
ClientConfig.ClientConfigBuilder<K,V,T>	setSpecificValueClass(Class<T> specificValueClass)
ClientConfig.ClientConfigBuilder<K,V,T>	setSpeculativeQueryEnabled(boolean speculativeQueryEnabled)
ClientConfig.ClientConfigBuilder<K,V,T>	setStatsPrefix(String statsPrefix)
ClientConfig.ClientConfigBuilder<K,V,T>	setStoreMetadataFetchMode(StoreMetadataFetchMode storeMetadataFetchMode)
ClientConfig.ClientConfigBuilder<K,V,T>	setStoreName(String storeName)
ClientConfig.ClientConfigBuilder<K,V,T>	setThinClientForMetaStore(AvroSpecificStoreClient<StoreMetaKey,StoreMetaValue> thinClientForMetaStore)
ClientConfig.ClientConfigBuilder<K,V,T>	setUseGrpc(boolean useGrpc)
ClientConfig.ClientConfigBuilder<K,V,T>	setVsonStore(boolean vsonStore)	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Details

ClientConfigBuilder

public ClientConfigBuilder()

Method Details

setStoreName

public ClientConfig.ClientConfigBuilder<K,V,T> setStoreName(String storeName)

setMetricsRepository

public ClientConfig.ClientConfigBuilder<K,V,T> setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository)

setStatsPrefix

public ClientConfig.ClientConfigBuilder<K,V,T> setStatsPrefix(String statsPrefix)

setSpeculativeQueryEnabled

public ClientConfig.ClientConfigBuilder<K,V,T> setSpeculativeQueryEnabled(boolean speculativeQueryEnabled)

setSpecificValueClass

public ClientConfig.ClientConfigBuilder<K,V,T> setSpecificValueClass(Class<T> specificValueClass)

setDeserializationExecutor

public ClientConfig.ClientConfigBuilder<K,V,T> setDeserializationExecutor(Executor deserializationExecutor)

setClientRoutingStrategyType

public ClientConfig.ClientConfigBuilder<K,V,T> setClientRoutingStrategyType(ClientRoutingStrategyType clientRoutingStrategyType)

setR2Client

public ClientConfig.ClientConfigBuilder<K,V,T> setR2Client(com.linkedin.r2.transport.common.Client r2Client)

setDualReadEnabled

public ClientConfig.ClientConfigBuilder<K,V,T> setDualReadEnabled(boolean dualReadEnabled)

setGenericThinClient

public ClientConfig.ClientConfigBuilder<K,V,T> setGenericThinClient(AvroGenericStoreClient<K,V> genericThinClient)

setSpecificThinClient

public ClientConfig.ClientConfigBuilder<K,V,T> setSpecificThinClient(AvroSpecificStoreClient<K,T> specificThinClient)

setRoutingLeakedRequestCleanupThresholdMS

public ClientConfig.ClientConfigBuilder<K,V,T> setRoutingLeakedRequestCleanupThresholdMS(long routingLeakedRequestCleanupThresholdMS)

setRoutingQuotaExceededRequestCounterResetDelayMS

public ClientConfig.ClientConfigBuilder<K,V,T> setRoutingQuotaExceededRequestCounterResetDelayMS(long routingQuotaExceededRequestCounterResetDelayMS)

setRoutingErrorRequestCounterResetDelayMS

public ClientConfig.ClientConfigBuilder<K,V,T> setRoutingErrorRequestCounterResetDelayMS(long routingErrorRequestCounterResetDelayMS)

setRoutingUnavailableRequestCounterResetDelayMS

public ClientConfig.ClientConfigBuilder<K,V,T> setRoutingUnavailableRequestCounterResetDelayMS(long routingUnavailableRequestCounterResetDelayMS)

setRoutingPendingRequestCounterInstanceBlockThreshold

public ClientConfig.ClientConfigBuilder<K,V,T> setRoutingPendingRequestCounterInstanceBlockThreshold(int routingPendingRequestCounterInstanceBlockThreshold)

setDaVinciClientForMetaStore

public ClientConfig.ClientConfigBuilder<K,V,T> setDaVinciClientForMetaStore(DaVinciClient<StoreMetaKey,StoreMetaValue> daVinciClientForMetaStore)

setThinClientForMetaStore

public ClientConfig.ClientConfigBuilder<K,V,T> setThinClientForMetaStore(AvroSpecificStoreClient<StoreMetaKey,StoreMetaValue> thinClientForMetaStore)

setIsMetadataConnWarmupEnabled

public ClientConfig.ClientConfigBuilder<K,V,T> setIsMetadataConnWarmupEnabled(boolean isMetadataConnWarmupEnabled)

setMetadataRefreshIntervalInSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setMetadataRefreshIntervalInSeconds(long metadataRefreshIntervalInSeconds)

setMetadataConnWarmupTimeoutInSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setMetadataConnWarmupTimeoutInSeconds(long metadataConnWarmupTimeoutInSeconds)

setLongTailRetryEnabledForSingleGet

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryEnabledForSingleGet(boolean longTailRetryEnabledForSingleGet)

setLongTailRetryThresholdForSingleGetInMicroSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryThresholdForSingleGetInMicroSeconds(int longTailRetryThresholdForSingleGetInMicroSeconds)

setLongTailRetryEnabledForBatchGet

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryEnabledForBatchGet(boolean longTailRetryEnabledForBatchGet)

setLongTailRetryThresholdForBatchGetInMicroSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryThresholdForBatchGetInMicroSeconds(int longTailRetryThresholdForBatchGetInMicroSeconds)

setLongTailRetryEnabledForCompute

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryEnabledForCompute(boolean longTailRetryEnabledForCompute)

setLongTailRetryThresholdForComputeInMicroSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryThresholdForComputeInMicroSeconds(int longTailRetryThresholdForComputeInMicroSeconds)

setVsonStore

@Deprecated
public ClientConfig.ClientConfigBuilder<K,V,T> setVsonStore(boolean vsonStore)

Deprecated.

setStoreMetadataFetchMode

public ClientConfig.ClientConfigBuilder<K,V,T> setStoreMetadataFetchMode(StoreMetadataFetchMode storeMetadataFetchMode)

setD2Client

public ClientConfig.ClientConfigBuilder<K,V,T> setD2Client(com.linkedin.d2.balancer.D2Client d2Client)

setClusterDiscoveryD2Service

public ClientConfig.ClientConfigBuilder<K,V,T> setClusterDiscoveryD2Service(String clusterDiscoveryD2Service)

setUseGrpc

public ClientConfig.ClientConfigBuilder<K,V,T> setUseGrpc(boolean useGrpc)

setGrpcClientConfig

public ClientConfig.ClientConfigBuilder<K,V,T> setGrpcClientConfig(GrpcClientConfig grpcClientConfig)

setProjectionFieldValidationEnabled

public ClientConfig.ClientConfigBuilder<K,V,T> setProjectionFieldValidationEnabled(boolean projectionFieldValidation)

setLongTailRetryBudgetEnforcementWindowInMs

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryBudgetEnforcementWindowInMs(long longTailRetryBudgetEnforcementWindowInMs)

setHARClusters

public ClientConfig.ClientConfigBuilder<K,V,T> setHARClusters(Set<String> clusters)

clone

public ClientConfig.ClientConfigBuilder<K,V,T> clone()

Overrides:

clone in class Object

build

public ClientConfig<K,V,T> build()