Package com.linkedin.davinci.client.factory

Class CachingDaVinciClientFactory

java.lang.Object

com.linkedin.davinci.client.factory.CachingDaVinciClientFactory

All Implemented Interfaces:

DaVinciClientFactory, Closeable, AutoCloseable

public class CachingDaVinciClientFactory
extends Object
implements DaVinciClientFactory, Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	CachingDaVinciClientFactory.DaVinciClientConstructor

Field Summary

Fields

Modifier and Type	Field	Description
protected final VeniceProperties	backendConfig
protected boolean	closed
protected final Map<String,DaVinciConfig>	configs
protected final com.linkedin.d2.balancer.D2Client	d2Client
protected final ICProvider	icProvider
protected final List<DaVinciClient>	isolatedClients
protected final Optional<Set<String>>	managedClients
protected final io.tehuti.metrics.MetricsRepository	metricsRepository
protected final Map<String,DaVinciClient>	sharedClients

Constructor Summary

Constructors

Constructor	Description
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig)	Deprecated.
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig, Optional<Set<String>> managedClients)	Deprecated.
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig, Optional<Set<String>> managedClients, ICProvider icProvider)	Deprecated.
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, String clusterDiscoveryD2ServiceName, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig)
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, String clusterDiscoveryD2ServiceName, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig, Optional<Set<String>> managedClients)
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, String clusterDiscoveryD2ServiceName, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig, Optional<Set<String>> managedClients, ICProvider icProvider)
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, String clusterDiscoveryD2ServiceName, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig, Optional<Set<String>> managedClients, ICProvider icProvider, Executor readChunkExecutorForLargeRequest)

Method Summary

Modifier and Type	Method	Description
void	close()
<K, V> DaVinciClient<K,V>	getAndStartGenericAvroClient(String storeName, DaVinciConfig config)
<K, V> DaVinciClient<K,V>	getAndStartGenericAvroClient(String storeName, DaVinciConfig config, Class<V> valueClass)
<K, V extends org.apache.avro.specific.SpecificRecord> DaVinciClient<K,V>	getAndStartSpecificAvroClient(String storeName, DaVinciConfig config, Class<V> valueClass)
VeniceProperties	getBackendConfig()
protected DaVinciClient	getClient(String storeName, DaVinciConfig config, Class valueClass, CachingDaVinciClientFactory.DaVinciClientConstructor clientConstructor, Class clientClass, boolean startClient)
<K, V> DaVinciClient<K,V>	getGenericAvroClient(String storeName, DaVinciConfig config)
<K, V> DaVinciClient<K,V>	getGenericAvroClient(String storeName, DaVinciConfig config, Class<V> valueClass)
<K, V extends org.apache.avro.specific.SpecificRecord> DaVinciClient<K,V>	getSpecificAvroClient(String storeName, DaVinciConfig config, Class<V> valueClass)

Methods inherited from class java.lang.Object

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

Field Details

closed

protected boolean closed

d2Client

protected final com.linkedin.d2.balancer.D2Client d2Client

metricsRepository

protected final io.tehuti.metrics.MetricsRepository metricsRepository

backendConfig

protected final VeniceProperties backendConfig

managedClients

protected final Optional<Set<String>> managedClients

icProvider

protected final ICProvider icProvider

sharedClients

protected final Map<String,DaVinciClient> sharedClients

isolatedClients

protected final List<DaVinciClient> isolatedClients

configs

protected final Map<String,DaVinciConfig> configs

Constructor Details

CachingDaVinciClientFactory

@Deprecated
public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig)

Deprecated.

CachingDaVinciClientFactory

@Deprecated
public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig,
 Optional<Set<String>> managedClients)

Deprecated.

CachingDaVinciClientFactory

@Deprecated
public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig,
 Optional<Set<String>> managedClients,
 ICProvider icProvider)

Deprecated.

CachingDaVinciClientFactory

public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 String clusterDiscoveryD2ServiceName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig)

CachingDaVinciClientFactory

public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 String clusterDiscoveryD2ServiceName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig,
 Optional<Set<String>> managedClients)

CachingDaVinciClientFactory

public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 String clusterDiscoveryD2ServiceName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig,
 Optional<Set<String>> managedClients,
 ICProvider icProvider)

CachingDaVinciClientFactory

public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 String clusterDiscoveryD2ServiceName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig,
 Optional<Set<String>> managedClients,
 ICProvider icProvider,
 Executor readChunkExecutorForLargeRequest)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getGenericAvroClient

public <K,
V> DaVinciClient<K,V> getGenericAvroClient(String storeName,
 DaVinciConfig config)

Specified by:

getGenericAvroClient in interface DaVinciClientFactory

getGenericAvroClient

public <K,
V> DaVinciClient<K,V> getGenericAvroClient(String storeName,
 DaVinciConfig config,
 Class<V> valueClass)

getAndStartGenericAvroClient

public <K,
V> DaVinciClient<K,V> getAndStartGenericAvroClient(String storeName,
 DaVinciConfig config)

Specified by:

getAndStartGenericAvroClient in interface DaVinciClientFactory

getAndStartGenericAvroClient

public <K,
V> DaVinciClient<K,V> getAndStartGenericAvroClient(String storeName,
 DaVinciConfig config,
 Class<V> valueClass)

getSpecificAvroClient

public <K,
V extends org.apache.avro.specific.SpecificRecord>
DaVinciClient<K,V> getSpecificAvroClient(String storeName,
 DaVinciConfig config,
 Class<V> valueClass)

Specified by:

getSpecificAvroClient in interface DaVinciClientFactory

getAndStartSpecificAvroClient

public <K,
V extends org.apache.avro.specific.SpecificRecord>
DaVinciClient<K,V> getAndStartSpecificAvroClient(String storeName,
 DaVinciConfig config,
 Class<V> valueClass)

Specified by:

getAndStartSpecificAvroClient in interface DaVinciClientFactory

getBackendConfig

public VeniceProperties getBackendConfig()

getClient

protected DaVinciClient getClient(String storeName,
 DaVinciConfig config,
 Class valueClass,
 CachingDaVinciClientFactory.DaVinciClientConstructor clientConstructor,
 Class clientClass,
 boolean startClient)