Package com.linkedin.venice.fastclient.meta

Class AbstractStoreMetadata

java.lang.Object

com.linkedin.venice.fastclient.meta.AbstractStoreMetadata

All Implemented Interfaces:

StoreMetadata, SchemaReader, Closeable, AutoCloseable

Direct Known Subclasses:

RequestBasedMetadata

public abstract class AbstractStoreMetadata
extends Object
implements StoreMetadata

Field Summary

Fields

Modifier and Type	Field	Description
protected AbstractClientRoutingStrategy	routingStrategy
protected final String	storeName

Constructor Summary

Constructors

Constructor	Description
AbstractStoreMetadata(ClientConfig clientConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getBatchGetLimit()
VeniceCompressor	getCompressor(CompressionStrategy compressionStrategy, int version, CompressorFactory compressorFactory, Map<Integer,ByteBuffer> versionZstdDictionaryMap)
InstanceHealthMonitor	getInstanceHealthMonitor()
int	getPartitionId(int version, byte[] key)
String	getReplica(long requestId, int groupId, int version, int partitionId, Set<String> excludedInstances)	This function is expected to return fully qualified URI, such as: "https://fake.host:8888".
String	getStoreName()
<K> void	routeRequest(RequestContext requestContext, RecordSerializer<K> keySerializer)
void	setRoutingStrategy(AbstractClientRoutingStrategy routingStrategy)	For testing only.
void	setRoutingStrategy(ClientRoutingStrategyType strategyType)
ChainedCompletableFuture<Integer,Integer>	trackHealthBasedOnRequestToInstance(String instance, int version, int partitionId, CompletableFuture<TransportClientResponse> transportFuture)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.schema.SchemaReader

getKeySchema, getLatestUpdateSchema, getLatestValueSchema, getLatestValueSchemaId, getLatestValueSchemaId, getUpdateSchema, getValueSchema, getValueSchemaId

Methods inherited from interface com.linkedin.venice.fastclient.meta.StoreMetadata

getClusterName, getCompressor, getCurrentStoreVersion, getPartitionId, getReplicas, isReady, start

Field Details

routingStrategy

protected volatile AbstractClientRoutingStrategy routingStrategy

storeName

protected final String storeName

Constructor Details

AbstractStoreMetadata

public AbstractStoreMetadata(ClientConfig clientConfig)

Method Details

setRoutingStrategy

public void setRoutingStrategy(ClientRoutingStrategyType strategyType)

setRoutingStrategy

public void setRoutingStrategy(AbstractClientRoutingStrategy routingStrategy)

For testing only.

getStoreName

public String getStoreName()

Specified by:

getStoreName in interface StoreMetadata

getPartitionId

public int getPartitionId(int version,
 byte[] key)

Specified by:

getPartitionId in interface StoreMetadata

getReplica

public String getReplica(long requestId,
 int groupId,
 int version,
 int partitionId,
 Set<String> excludedInstances)

Description copied from interface: StoreMetadata

This function is expected to return fully qualified URI, such as: "https://fake.host:8888".

Specified by:

getReplica in interface StoreMetadata

trackHealthBasedOnRequestToInstance

public ChainedCompletableFuture<Integer,Integer> trackHealthBasedOnRequestToInstance(String instance,
 int version,
 int partitionId,
 CompletableFuture<TransportClientResponse> transportFuture)

Specified by:

trackHealthBasedOnRequestToInstance in interface StoreMetadata

getInstanceHealthMonitor

public InstanceHealthMonitor getInstanceHealthMonitor()

Specified by:

getInstanceHealthMonitor in interface StoreMetadata

getBatchGetLimit

public int getBatchGetLimit()

Specified by:

getBatchGetLimit in interface StoreMetadata

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getCompressor

public VeniceCompressor getCompressor(CompressionStrategy compressionStrategy,
 int version,
 CompressorFactory compressorFactory,
 Map<Integer,ByteBuffer> versionZstdDictionaryMap)

routeRequest

public <K> void routeRequest(RequestContext requestContext,
 RecordSerializer<K> keySerializer)

Specified by:

routeRequest in interface StoreMetadata