Package com.linkedin.venice.fastclient.meta

Interface StoreMetadata

All Superinterfaces:

AutoCloseable, Closeable, SchemaReader

All Known Implementing Classes:

AbstractStoreMetadata, RequestBasedMetadata

public interface StoreMetadata
extends SchemaReader

This interface defines the APIs to retrieve store metadata and routing data, and it also includes the feedback APIs: trackHealthBasedOnRequestToInstance(java.lang.String, int, int, java.util.concurrent.CompletableFuture<com.linkedin.venice.client.store.transport.TransportClientResponse>) to decide the healthiness of each replica.

Method Summary

Modifier and Type	Method	Description
int	getBatchGetLimit()
String	getClusterName()
VeniceCompressor	getCompressor(CompressionStrategy compressionStrategy, int version)
int	getCurrentStoreVersion()
InstanceHealthMonitor	getInstanceHealthMonitor()
int	getPartitionId(int version, byte[] key)
int	getPartitionId(int version, ByteBuffer 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".
List<String>	getReplicas(int version, int partitionId)
String	getStoreName()
default boolean	isReady()
<K> void	routeRequest(RequestContext requestContext, RecordSerializer<K> keySerializer)
void	start()
ChainedCompletableFuture<Integer,Integer>	trackHealthBasedOnRequestToInstance(String instance, int version, int partitionId, CompletableFuture<TransportClientResponse> transportFuture)

Methods inherited from interface java.io.Closeable

close

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

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

Method Details

getClusterName

String getClusterName()

getStoreName

String getStoreName()

getCurrentStoreVersion

int getCurrentStoreVersion()

getPartitionId

int getPartitionId(int version,
 ByteBuffer key)

getPartitionId

int getPartitionId(int version,
 byte[] key)

getReplicas

List<String> getReplicas(int version,
 int partitionId)

getReplica

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".

trackHealthBasedOnRequestToInstance

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

getInstanceHealthMonitor

InstanceHealthMonitor getInstanceHealthMonitor()

getCompressor

VeniceCompressor getCompressor(CompressionStrategy compressionStrategy,
 int version)

getBatchGetLimit

int getBatchGetLimit()

start

void start()

isReady

default boolean isReady()

routeRequest

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