Package com.linkedin.venice.client.factory

Interface VeniceStoreClientFactory

All Known Implementing Classes:

CachingVeniceStoreClientFactory

public interface VeniceStoreClientFactory

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	VeniceStoreClientFactory.ClientConfigUpdater

Method Summary

Modifier and Type	Method	Description
void	close()
<K,V> AvroGenericStoreClient<K,V>	getAndStartAvroGenericStoreClient(java.lang.String storeName)
default <K,V> AvroGenericStoreClient<K,V>	getAndStartAvroGenericStoreClient(java.lang.String storeName, VeniceStoreClientFactory.ClientConfigUpdater configUpdater)	create a generic client along with customized client configs.
<K,V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V>	getAndStartAvroSpecificStoreClient(java.lang.String storeName, java.lang.Class<V> specificRecordClass)
default <K,V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V>	getAndStartAvroSpecificStoreClient(java.lang.String storeName, java.lang.Class<V> specificRecordClass, VeniceStoreClientFactory.ClientConfigUpdater configUpdater)

Method Detail

getAndStartAvroGenericStoreClient

<K,V> AvroGenericStoreClient<K,V> getAndStartAvroGenericStoreClient(java.lang.String storeName)

getAndStartAvroGenericStoreClient

default <K,V> AvroGenericStoreClient<K,V> getAndStartAvroGenericStoreClient(java.lang.String storeName,
                                                                                        VeniceStoreClientFactory.ClientConfigUpdater configUpdater)

create a generic client along with customized client configs. This is only for sophisticated use cases. Do not use it if you are not familiar with these configs. e.g. client = veniceStoreClientFactory.getAndStartAvroGenericStoreClient(storeName, (config) -> config.setVsonClient(true));

Returns:

getAndStartAvroSpecificStoreClient

<K,V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V> getAndStartAvroSpecificStoreClient(java.lang.String storeName,
                                                                                                                                  java.lang.Class<V> specificRecordClass)

getAndStartAvroSpecificStoreClient

default <K,V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V> getAndStartAvroSpecificStoreClient(java.lang.String storeName,
                                                                                                                                          java.lang.Class<V> specificRecordClass,
                                                                                                                                          VeniceStoreClientFactory.ClientConfigUpdater configUpdater)

close

void close()